Spring JMS和ActiveMQ的同步问题

Question

我正在通过JNDI//Tomcat使用SpringJMS和ActiveMQ实现一个简单的演示。整个目的是有一个发送者和多个接收者，但是队列中的消息必须同步操作，这意味着不管有多少接收者，所有消息都应该按照原始发送顺序处理。

这就是我所做的

>

创建一个spring应用程序，该应用程序可以通过队列通过activemq/tomcat/jndi发送和接收JMS消息。我将@transaction放入onmessage()方法（应该在JPA中工作，但在本示例中可能不工作）。sender方法用@Scheule注释，每5秒运行一次，并向队列发送10条消息。有一个全局计数器来计算正在发送的消息总数。

部署这个应用程序的三个实例，一个同时打开发送者和接收者，另外两个只激活接收者。因此，所有三个接收者将把消息写入相同的文本文件（作为一个小型数据库工作），这样每个接收者都将在写入后关闭该文件。

Mon Nov 24 13:57:00 EST 2014    Receiver 1  {from Sender agent..message_aj9gg95q1kmb77i8506bcn3dpp(0)=messageBody1}
Mon Nov 24 13:57:00 EST 2014    Receiver 0  {from Sender agent..message_aj9gg95q1kmb77i8506bcn3dpp(1)=messageBody2}
Mon Nov 24 13:57:00 EST 2014    Receiver 1  {from Sender agent..message_aj9gg95q1kmb77i8506bcn3dpp(2)=messageBody3}
Mon Nov 24 13:57:00 EST 2014    Receiver 1  {from Sender agent..message_aj9gg95q1kmb77i8506bcn3dpp(3)=messageBody4}
Mon Nov 24 13:57:00 EST 2014    Receiver 0  {from Sender agent..message_aj9gg95q1kmb77i8506bcn3dpp(4)=messageBody5}
Mon Nov 24 13:57:00 EST 2014    Receiver 1  {from Sender agent..message_aj9gg95q1kmb77i8506bcn3dpp(5)=messageBody6}
Mon Nov 24 13:57:00 EST 2014    Receiver 0  {from Sender agent..message_aj9gg95q1kmb77i8506bcn3dpp(6)=messageBody7}
Mon Nov 24 13:57:00 EST 2014    Receiver 1  {from Sender agent..message_aj9gg95q1kmb77i8506bcn3dpp(7)=messageBody8}
Mon Nov 24 13:57:00 EST 2014    Receiver 0  {from Sender agent..message_aj9gg95q1kmb77i8506bcn3dpp(8)=messageBody9}
Mon Nov 24 13:57:00 EST 2014    Receiver 1  {from Sender agent..message_aj9gg95q1kmb77i8506bcn3dpp(9)=messageBody10}
Mon Nov 24 13:57:05 EST 2014    Receiver 1  {from Sender agent..message_n7ofp65ioqcfhdl63cjg76e4fb(0)=messageBody11}
Mon Nov 24 13:57:05 EST 2014    Receiver 0  {from Sender agent..message_n7ofp65ioqcfhdl63cjg76e4fb(1)=messageBody12}
Mon Nov 24 13:57:05 EST 2014    Receiver 0  {from Sender agent..message_n7ofp65ioqcfhdl63cjg76e4fb(2)=messageBody13}
Mon Nov 24 13:57:05 EST 2014    Receiver 1  {from Sender agent..message_n7ofp65ioqcfhdl63cjg76e4fb(3)=messageBody14}
Mon Nov 24 13:57:05 EST 2014    Receiver 0  {from Sender agent..message_n7ofp65ioqcfhdl63cjg76e4fb(4)=messageBody15}
Mon Nov 24 13:57:05 EST 2014    Receiver 1  {from Sender agent..message_n7ofp65ioqcfhdl63cjg76e4fb(5)=messageBody16}
Mon Nov 24 13:57:05 EST 2014    Receiver 1  {from Sender agent..message_n7ofp65ioqcfhdl63cjg76e4fb(6)=messageBody17}
Mon Nov 24 13:57:05 EST 2014    Receiver 1  {from Sender agent..message_n7ofp65ioqcfhdl63cjg76e4fb(8)=messageBody19} ----- oops    
Mon Nov 24 13:57:05 EST 2014    Receiver 2  {from Sender agent..message_n7ofp65ioqcfhdl63cjg76e4fb(7)=messageBody18} ----- oops   
Mon Nov 24 13:57:05 EST 2014    Receiver 0  {from Sender agent..message_n7ofp65ioqcfhdl63cjg76e4fb(9)=messageBody20}




Answer 1

不可能在多个接收者中保持严格的排序（或者在单个接收者上并发>1)。

消费者正在为消息而竞争，这只是一场谁先处理下一个得到的消息的竞赛。操作系统可能会在收到消息后但在写入文件之前将线程从CPU中踢开，而“下一个”使用者可能会端到端地处理整个事情。即使使用多核CPU也可能发生这种情况。