当前页面: 开发资料首页 → J2EE 专题 → 600分！JMS选型，请教ActiveMQ的问题!

600分！JMS选型，请教ActiveMQ的问题!

摘要: 600分！JMS选型，请教ActiveMQ的问题!

各位高手:

我在测试ActiveMQ自带的example时,当我发送100条1k的消息时一切正常:

生产者:ant producer -Ddurable=true -Dmax=100 -DmessageSize=1000
消费者:ant consumer -Ddurable=true -Dmax=100 -DmessageSize=1000

但当我发送1000条100k的消息时却出错:

生产者:ant producer -Ddurable=true -Dmax=1000 -DmessageSize=100000
消费者:ant consumer -Ddurable=true -Dmax=1000 -DmessageSize=100000

我用的是ActiveMQ 4.0,数据库用的是mysql,另外,我是先发送消息,发送完毕后,再去接收消息的.

发送1000条100k的消息时出现的异常是:
[java] javax.jms.JMSException: java.io.IOException: Failed to broker message: ID:www-1138-1150610392343-0:0:1:1:1 in con
tainer: java.io.EOFException
[java] at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:45)
[java] at org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1137)
[java] at org.apache.activemq.ActiveMQSession.syncSendPacket(ActiveMQSession.java:1667)
[java] at org.apache.activemq.ActiveMQMessageConsumer.(ActiveMQMessageConsumer.java:196)
[java] at org.apache.activemq.ActiveMQSession.createConsumer(ActiveMQSession.java:840)
[java] at org.apache.activemq.ActiveMQSession.createConsumer(ActiveMQSession.java:800)
[java] at ConsumerTool.run(Unknown Source)
[java] at ConsumerTool.main(Unknown Source)

---

另外,我查看了mysql的表,里面确实有1000条消息,但就是消费不了.

mysql> select count(*) from activemq_msgs;
+----------+
| count(*) |
+----------+
| 1000 |
+----------+

---

我在网上看到有人评价ActiveMQ目前还是不稳定，特别是在网络状态不好的环境下，基本上网络一出现异常，它就死掉。

各位高手,ActiveMQ真是这样的吗?

---

关注...

---

关注

---

学习

---

学习

---

csdn 的高手帮帮忙吧：

早段时间我做jsf + spring + hibernate的集群及性能测试，csdn也没有多少人回应，但幸好我搞定了。

现在这个ActiveMQ的问题实在不知道怎么解决，在它的jira上也没有找到解决方法，各位高手给条明路吧！

---

关注

---

汗～老大，我也是刚和你做同样的事．正在找解决的方法，如果有的话希望可以指点一下．当然，我解决了也会和大家分享

---

MQ还是用商业化的产品比较好

---

楼上说的是,我现在改用sun message queue了,反正也是免费的,不过Juwen_zhong()找到了解决办法的话,请分享一下,开源还是要支持的!

---

我想可能是最大内存数的限制,也只是估计.还要继续测试

---

楼上的兄弟,有结果告诉我啊!

开源还是要支持的!

---

昨天在activemq.org看到一段出现上述情况的解释.
The messages can be loaded directly from the journal (in case the message was removed swapped out of memory). But the journal cannot be used to to recover a durable subscription (he does not keep an ordered index of messages per durable sub). So when a durable sub is activated, then the journal checkpoints to flush any messaqges in the journal to the long term store and then the long term store is used to recover the durable subscription.
不知道对不对.贴上来大家看看.

---