В настоящее время я использую Glassfish v2.1, и я настроил очередь для отправки и получения сообщений с бобами Sesion и MDB соответственно. Тем не менее, я заметил, что я могу отправить только 1000 сообщений в очередь. Есть ли причина, по которой я не могу отправить более 1000 сообщений в очередь? У меня есть настройка профиля "developer" для домена glassfish. Может ли это быть причиной? Или есть какой-то параметр конфигурации ресурса, который мне нужно изменить?
Я настроил свойства конфигурации sun-resources.xml следующим образом:
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE resources PUBLIC "-//Sun Microsystems, Inc.//DTD Application Server 9.0 Resource Definitions //EN" "http://www.sun.com/software/appserver/dtds/sun-resources_1_3.dtd">
<resources>
<admin-object-resource
enabled="true"
jndi-name="jms/UpdateQueue"
object-type="user"
res-adapter="jmsra"
res-type="javax.jms.Queue">
<description/>
<property name="Name" value="UpdatePhysicalQueue"/>
</admin-object-resource>
<connector-resource
enabled="true" jndi-name="jms/UpdateQueueFactory"
object-type="user"
pool-name="jms/UpdateQueueFactoryPool">
<description/>
</connector-resource>
<connector-connection-pool
associate-with-thread="false"
connection-creation-retry-attempts="0"
connection-creation-retry-interval-in-seconds="10"
connection-definition-name="javax.jms.QueueConnectionFactory"
connection-leak-reclaim="false"
connection-leak-timeout-in-seconds="0"
fail-all-connections="false"
idle-timeout-in-seconds="300"
is-connection-validation-required="false"
lazy-connection-association="false"
lazy-connection-enlistment="false"
match-connections="true"
max-connection-usage-count="0"
max-pool-size="32"
max-wait-time-in-millis="60000"
name="jms/UpdateFactoryPool"
pool-resize-quantity="2"
resource-adapter-name="jmsra"
steady-pool-size="8"
validate-atmost-once-period-in-seconds="0"/>
</resources>
Хм .. дальнейшее расследование показало следующее в журналах imq:
[17/Nov/2009:10:27:57 CST] ERROR sendMessage: Sending message failed. Connection ID: 427038234214377984:
com.sun.messaging.jmq.jmsserver.util.BrokerException: transaction failed: [B4303]: The maximum number of messages [1,000] that the producer can process in a single transaction (TID=427038234364096768) has been exceeded. Please either limit the # of messages per transaction or increase the imq.transaction.producer.maxNumMsgs property.
Что бы я сделал, если бы мне нужно было отправлять более 5000 сообщений одновременно?
То, что я пытаюсь сделать, - это прочитать все записи в таблице и обновить определенное поле каждой записи на основе соответствующего значения этой записи в прежней таблице, к которой у меня есть доступ только для чтения. В этой таблице более 10 тысяч записей. На данный момент я последовательно просматриваю каждую запись в цикле for, получая соответствующую запись из прежней таблицы, сравнивая значения полей, обновляя запись при необходимости и добавляя соответствующие новые записи в другие таблицы.
Однако я надеялся улучшить производительность, обрабатывая все записи асинхронно. Для этого я думал об отправке каждой записи в виде отдельного сообщения и, следовательно, требовал столько сообщений.