ActiveMQ 线程机制

1、understanding the threads allocated in activemq attachments:6 added by hiram chirino, last edited by rich petersen on dec 18, 2007 (view change) one of the easiest ways to tune an activemq deployment to increase scaleability is reduce the number of threads used to get the work done. the default acti

2、vemq configuration makes use of several threads to isolate producers from consumers. this prevents a producer from blocking when a consumer is misbehaving. the following diagram shows the threads involved in the typical process of sending a message from a producer application to a consumer applicati

3、on.activemq has several options that change the way threads are used and allocated. understanding these options and knowing how they can impact the system will help you know if they are safe to enable on your system to reduce the number of threads used and thereby increase scaleability.for example,

4、the default configuration of the vm transport allocates a transport thread which polls for messages from the transport and delivers them to the connection. the vm transport considers this async delivery of messages. since the vm transport connects to its transport peer within the same jvm, its possi

5、ble to use the calling transports thread to deliver the message to connection instead of using the polling thread. when the aysnc=false option is used, the threads in the system look like the following diagram.the broker uses a dispatch thread when sending messages to another connection. this isolat

6、es the producers application thread from any problems that may occur with the consumers connection. the dispatching of a message over transport can be a blocking operation if there are problems with the network connection or if the client is misbehaving. the broker avoids blocking the producers thre

7、ad even when the consumers connection is blocked by using this dispatch thread.the broker supports an option to avoid using the dispatch thread and instead have the producers transport thread directly send the message over the consumers transport. this option should only be used when either you dont

8、 mind blocking the producer when a consumer problem occurs or you know you wont have consumer problems. this option can be enabled per consumer by setting dispatchasync=false. the thread usage diagram for this option is shown below:if you look at the consumer jvm, you see at least 2 threads when you

9、 create a consumer that uses a messagelistener. the first thread is the transport thread which polls and delivers messages from the underlying network. the second thread is the session thread which delivers the message to the messagelistener and processed the message. by using a session thread, acti

10、vemq frees up the transport thread to continue to receive more messages from the network.activemq has an option that can disable the creation and use of the session thread. when the optimizeddispatch=true option is enabled, the transport thread deliver the message directly to the messagelistener for

11、 processing. i would only recommend that this be used for simple messagelisteners that do not send messages back into the jms system and which execute quickly. please note that if you have multiple sessions, the consumers in each session will be serviced by a single transport thread, which makes the system less concurrent. the thread usage diagram for this option is shown below: