JMS教程(四)

╰半橙微兮° 2022-08-19 11:13 187阅读 0赞

Queue模型中消息只能被消费一次，下面就这一点我们来测试一下:

//注册第一个消费者
            MessageConsumer comsumer1 = session.createConsumer(queue); 
            comsumer1.setMessageListener(   new MessageListener(){
    			@Override
    			public void onMessage(Message message) {
    				TextMessage text=(TextMessage)message;
    				try {
    					System.out.println(   "消费者一号:"+ text.getText()  );
    				} catch (JMSException e) {
    					e.printStackTrace();
    				}
    			}
            });
            //注册第二个消费者
            MessageConsumer comsumer2 = session.createConsumer(queue); 
            comsumer2.setMessageListener(   new MessageListener(){
    			@Override
    			public void onMessage(Message message) {
    				TextMessage text=(TextMessage)message;
    				try {
    					System.out.println(  "消费者二号:"+text.getText()  );
    				} catch (JMSException e) {
    					e.printStackTrace();
    				}
    			}
            });

下面创建一个生产者，生产多个消息:

//创建一个生产者
            MessageProducer producer = session.createProducer(queue); 
            for(  int i=0;i<10;i++){
    	        //通过会话来创建一个消息
    	        Message message = session.createTextMessage("消息编号:"+ i );  
    	        //生产者将消息发给服务器
    	        producer.send(message);  
            }

![Center][]

[Center]: /images/20220731/cc5f1aabc1224c24a446898eb4216777.png

发表评论取消回复

表情：

评论列表（有 0 条评论，187人围观）

还没有评论，来说两句吧...

相关阅读

相关 JMS入门教程

转载：[http://www.cnblogs.com/jjj250/archive/2012/08/08/2628552.html][http_www.cnblogs.com_

红太狼/ 2022年08月27日 03:24/ 0 赞/ 169 阅读

相关 JMS教程(六)

本次测试一下如何接收消费者回复的消息: 接收回复消息的关键是生产者这边也要注册一个临听器。生产端: ConnectionFact

客官°小女子只卖身不卖艺/ 2022年08月19日 11:14/ 0 赞/ 148 阅读

相关 JMS教程(五)

下面来测试一下消息的类型: Persistent和nonpersistent的消息 / 测试消息的类型 : DeliveryMode.PERSISTE

Love The Way You Lie/ 2022年08月19日 11:14/ 0 赞/ 132 阅读

相关 JMS教程(四)

Queue模型中消息只能被消费一次，下面就这一点我们来测试一下: //注册第一个消费者 Message

╰半橙微兮°/ 2022年08月19日 11:13/ 0 赞/ 188 阅读

相关 JMS教程(三)

JMS消息的消费者接收消息可以采用两种方式： 1、consumer.receive() 或 consumer.receive(int timeout):

男娘i/ 2022年08月19日 11:13/ 0 赞/ 180 阅读

相关 JMS教程(二)

下面我们来写一个Hello World程序，让大家对activeMQ及JMS有一个初步的了解. 1. 首先请下载activeMQ. 官网: http://act

r囧r小猫/ 2022年08月19日 11:12/ 0 赞/ 144 阅读

相关 JMS教程(一)

官网: http://activemq.apache.org/ JMS即Java消息服务（Java Message Service）

约定不等于承诺〃/ 2022年08月19日 11:12/ 0 赞/ 145 阅读

相关 Spring整合JMS（四）——事务管理

Spring提供了一个JmsTransactionManager用于对JMS ConnectionFactory做事务管理。这将允许JMS应用利用Spring的事务管理特

小灰灰/ 2022年06月15日 03:45/ 0 赞/ 211 阅读

相关 Spring整合JMS（四）——事务管理

Spring整合JMS（四）——事务管理 Spring提供了一个JmsTransactionManager用于对JMS ConnectionFactory做事务管

- 日理万妓/ 2022年04月23日 15:14/ 0 赞/ 227 阅读

相关 ActiveMQ入门教程（四）-------java消息服务之JMS简介

java消息服务之JMS简介回顾JavaEE是什么 JavaEE是一套使用java进行企业级应用开发的大家一致遵循的13个核心规范工业标准。JavaEE平台提供了

水深无声/ 2021年09月01日 05:25/ 0 赞/ 389 阅读