Java消息服务~JMSReplyTo示例

在下面的例子中，首先创建两个Queue，发送者给一个Queue发送，接收者接收到消息之后给另一个Queue回复一个Message，然后再创建一个消费者来接受所回复的消息

import javax.jms.Connection;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageListener;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.command.ActiveMQQueue;
/*** TODO 在此写上类的相关说明.<br>* @author gqltt<br>* @version 1.0.0 2021年10月21日<br>* @see * @since JDK 1.5.0*/
public class JMSReplyToDemo {public static void main(String[] args) throws Exception {ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("vm://localhost");  Connection connection = factory.createConnection();  connection.start();  //消息发送到这个Queue  Queue queue = new ActiveMQQueue("testQueue");  //消息回复到这个Queue  Queue replyQueue = new ActiveMQQueue("replyQueue");  final Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);  //创建一个消息，并设置它的JMSReplyTo为replyQueue。  Message message = session.createTextMessage("Andy");  message.setJMSReplyTo(replyQueue);  MessageProducer producer = session.createProducer(queue);  producer.send(message);  //消息的接收者  MessageConsumer comsumer = session.createConsumer(queue);  comsumer.setMessageListener(new MessageListener(){  public void onMessage(Message m) {  try {  //创建一个新的MessageProducer来发送一个回复消息。  MessageProducer producer = session.createProducer(m.getJMSReplyTo());  producer.send(session.createTextMessage("Hello " + ((TextMessage) m).getText()));  } catch (JMSException e1) {  e1.printStackTrace();  }  }  });  //这个接收者用来接收回复的消息  MessageConsumer comsumer2 = session.createConsumer(replyQueue);  comsumer2.setMessageListener(new MessageListener(){  public void onMessage(Message m) {  try {  System.out.println(((TextMessage) m).getText());  } catch (JMSException e) {  e.printStackTrace();  }  }  });  }
}

首先消息生产者发送一个消息，内容为“Andy”，然后消费者收到这个消息之后根据消息的JMSReplyTo，回复一个消息，内容为“Hello Andy‘。最后在回复的Queue上创建一个接收回复消息的消费者，它输出所回复的内容。

运行上面的程序，可以得到下面的输出结果：

Hello Andy

Java消息服务~JMSReplyTo示例相关推荐

JMS(Java消息服务)入门教程
什么是Java消息服务 Java消息服务指的是两个应用程序之间进行异步通信的API,它为标准消息协议和消息服务提供了一组通用接口,包括创建.发送.读取消息等,用于支持JAVA应用程序开发.在J2EE中 ...
JMS (Java消息服务) 入门教程
转载自:https://www.cnblogs.com/chenpi/p/5559349.html 什么是Java消息服务 Java消息服务指的是两个应用程序之间进行异步通信的API,它为标准消息协议 ...
JMS : Java Message Service （Java消息服务）之一 [转]
为什么80%的码农都做不了架构师?>>> 1 引言 1.1 编写目的本文作为B2bi项目中开源产品JORAM的使用指导文档,旨在帮助项目组人员方便明了的进行JMS模块的详细设 ...
Java 消息服务（Java Message Service
Java 消息服务( Java Message Service ,简称 JMS )是企业级消息传递系统,紧密集成于 Jboss Server 平台之中.企业消息传递系统使得应用程序能够通过消息的交换与 ...
Java消息服务【必看】
什么是Java消息服务 # Java消息服务指的是两个应用程序之间进行异步通信的API,它为标准消息协议和消息服务提供了一组通用接口,包括创建.发送.读取消息等,用于支持JAVA应用程序开发.在J2E ...
java 消息服务框架_Java消息服务在 Spring Boot 中的使用
原标题:Java消息服务在 Spring Boot 中的使用当前环境 Mac OS 10.11.x docker 1.12.1 JDK 1.8 SpringBoot 1.5 前言基于之前一篇&q ...
Java消息服务JMS详解
2019独角兽企业重金招聘Python工程师标准>>> JMS: Java消息服务(Java Message Service) JMS是用于访问企业消息系统的开发商中立的API.企业 ...
01_Weblogic课程之概念篇：代理服务器，web服务器，应用程序服务器，JNDI概念，JTA概念，Java消息服务，Java验证和授权（JAAS）,Java管理扩展，Web客户机，客户机应用程序
1 什么是服务器 Weblogic中服务器分为两种,一种是受管服务器,另外一种是管理服务器. Weblogic课程(Weblogic是Oracle公司的,最开始的是BEA公司的) 一系统管理 ...
JAVA消息服务JMS规范及原理详解
一.简介 JMS即Java消息服务(Java Message Service)应用程序接口,是一个Java平台中关于面向消息中间件(MOM)的API,用于在两个应用程序之间,或分布式系统中发送消息,进 ...

Java消息服务~JMSReplyTo示例

Java消息服务~JMSReplyTo示例相关推荐

最新文章

热门文章