网站搭建费用明细,二手房网站制作教程,怎么做网站充值网站,上海网站营销推广原文地址#xff1a;http://blog.csdn.net/zhangxs_3/article/details/4034801 我们都知道Queue 即我们经常说的点对点或者生产者/消费者 模型。 生产者将消息发送到队列#xff0c; 消费者从队列中消费消息#xff0c;一个消息指能被消费一次。下面例子中启动了两个消费者一…原文地址http://blog.csdn.net/zhangxs_3/article/details/4034801 我们都知道Queue 即我们经常说的点对点或者生产者/消费者 模型。 生产者将消息发送到队列 消费者从队列中消费消息一个消息指能被消费一次。下面例子中启动了两个消费者一个生产者。 public class TestQueue { private static String brokerURL tcp://192.168.2.240:61616; private static ConnectionFactory connectionFactory; private static Connection connection; private static Session session; private static Destination queue; static{ connectionFactory new ActiveMQConnectionFactory(brokerURL); try { connection connectionFactory.createConnection(); connection.start(); session connection.createSession(false, Session.AUTO_ACKNOWLEDGE); queue session.createQueue(testqueue); } catch (JMSException e) { e.printStackTrace(); } } public static void main(String[] args) throws Exception { MessageProducer producer session.createProducer(queue); MessageConsumer consumer1 session.createConsumer(queue); MessageConsumer consumer2 session.createConsumer(queue); consumer1.setMessageListener(new MessageListener() { Override public void onMessage(Message message) { try { String content message.getStringProperty(content); System.out.println(consumer1:content); } catch (JMSException e) { e.printStackTrace(); } } }); consumer2.setMessageListener(new MessageListener() { Override public void onMessage(Message message) { try { String content message.getStringProperty(content); System.out.println(consumer2:content); } catch (JMSException e) { e.printStackTrace(); } } }); for(int i0;i10;i){ Message message session.createMessage(); message.setStringProperty(content, i); producer.send(message); } }} 运行结果 consumer1:0consumer2:1consumer1:2consumer2:3consumer1:4consumer2:5consumer1:6consumer2:7consumer1:8consumer2:9 从结果中我们可以看出每条消息只能被一个消费者消费但我们并不能确定到底有哪个消费者消费。转载于:https://www.cnblogs.com/gaohuiqian/p/5215949.html
