电子商务网站项目预算,网站站点是什么,方城企业网站制作哪家好,南宁网站建设nnxun原文地址#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
