一个生产者被两个消费者平均的消费了生产的消息
创建AppProducer.java类,并创建访问地址url、队列名queueName;
创建目录
演示的两种模式:
队列模式;
主题模式
创建Maven项目;
添加activemq-all依赖;
如果你使用的activeMQ是目前最新版本5.15.3的话,老师讲的连接地址URL不管用,正确的地址是:tcp://localhost:61616?jms.useAsyncSend=true
更加详细的配置可以查看官方文档:http://activemq.apache.org/connection-configuration-uri.html
创建一个监听器接受消息
JMS队列模式:
生产者先向目标队列里发送消息,消费者创建监听器从目标队列里取出消息。
ps:监听的过程是个异步的过程,所以消费者连接不应该关闭。
如果你使用的activeMQ是目前最新版本5.15.3的话,老师讲的连接地址URL不管用,正确的地址是:tcp://localhost:61616?jms.useAsyncSend=true
更加详细的配置可以查看官方文档:http://activemq.apache.org/connection-configuration-uri.html
队列模式,如果两个消费者,一个生产者,那么两个消费者接收的消息之和是生产者生产的消息
怪不得消费者不用关闭连接,原来消费者监听停止后连接自动关闭了,666
jms编码接口之间的关系
生产者消费者模式 多个消费者接收的消息为部分消息 不能接收所有消息