In ActiveMQ standard package, there are two example programs, we can use the
following two scripts to reproduce the issue:
==============================================================================
#!/bin/sh
for id in $(seq 1 50)
do
ant consumer -Durl=tcp://SERVER1:61616 -Dsubject=queue-$id
-Dmax=20000 > consumer-$id.out &
done
==============================================================================
==============================================================================
#!/bin/sh
for id in $(seq 1 50)
do
ant producer -Durl=tcp://SERVER2:61616 -Dsubject=queue-$id
-Dmax=20000 > producer-$id.out &
done
==============================================================================
(server1 and server2 are connected as a broker cluster)
ActiveMQ get stalled and can not keep sending messages. Both senders and
receivers are disconnected by server.
Chen-hsiu Huang wrote:
>
> Hi,
>
> We're using ActiveMQ 5.3 as our message service. However, we found that
> messages stall easily through our test.
>
> 1. We have two servers, each with two Intel Xeon E5420 CPUs, total 8
> cores, 32 GB memory for each. Both servers run on Linux CentOS 5.3.
> 2. JDK 1.6.0_13 is used
> 3. The two servers use static network connector to form a cluster.
> 4. 50 consumers listen to 50 channels on Server1, and 50 producers send
> messages to those consumers on the said 50 channels via Server2. (one
> consumer/producer means a standalone java process)
> 5. 50 producers connect and send messages to Server2 simultaneously. Each
> producer sends 20,000 messages.
> 6. If all 50 consumers receives 20,000 messages for each (total 1,000,000
> messages), then we say “the round” is completed.
> 7. However, not every round finishes successfully. Messages get pending or
> stalled easily.
> 8. We have both Java and C++ client implemented, both have the same
> problem.
>
> We design this test scenario in order to simulate our production
> environment. But actually we get stalled messages frequently when we test
> our applications.
>
> Does anyone have any clue to this issue?
> How should I configurate our server to provide stable services?
>
> Thanks in advance.
>
> PS: attached with one of our server configuration file.
>
> BR,
> Chen-hsiu Huang
> http://www.nabble.com/file/p24913211/activemq_01.xml activemq_01.xml
>
--
View this message in context:
http://www.nabble.com/ActiveMQ-5.3-pending-message-issue-tp24913211p24934545.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
