转自:http://www.cnblogs.com/chenpi/p/5566983.html
阅读目录
前言
基于上篇文章"基于Tomcat + JNDI + ActiveMQ实现JMS的点对点消息传送"很容易就可以编写一个发布/订阅消息传送例子,相关环境准备与该篇文章基本类似,主要的区别如下。
在Tomcat中配置JNDI
配置连接工厂和话题
<Resource name="topic/connectionFactory" auth="Container" type="org.apache.activemq.ActiveMQConnectionFactory" description="JMS Connection Factory" factory="org.apache.activemq.jndi.JNDIReferenceFactory" brokerURL="failover:(tcp://localhost:61616)?initialReconnectDelay=100&maxReconnectAttempts=5" brokerName="LocalActiveMQBroker" useEmbeddedBroker="false" /> <Resource name="topic/topic0" auth="Container" type="org.apache.activemq.command.ActiveMQTopic" description="My Topic" factory="org.apache.activemq.jndi.JNDIReferenceFactory" physicalName="TestTopic" />
在Web工厂中编写代码
新建一个发布者Servlet
package pubSub; import java.io.IOException; import java.io.PrintWriter; import javax.naming.InitialContext; import javax.servlet.ServletException; import javax.servlet.annotation.WebServlet; import javax.servlet.http.HttpServlet; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import javax.jms.Topic; import javax.jms.Session; import javax.jms.TextMessage; import javax.jms.TopicPublisher; import javax.jms.DeliveryMode; import javax.jms.TopicSession; import javax.jms.TopicConnection; import javax.jms.TopicConnectionFactory; /** * Servlet implementation class JMSTest */ @WebServlet("/Publish") public class Publisher extends HttpServlet { private static final long serialVersionUID = 1L; /** * @see HttpServlet#HttpServlet() */ public Publisher() { super(); // TODO Auto-generated constructor stub } /** * @see HttpServlet#doGet(HttpServletRequest request, HttpServletResponse * response) */ protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { PrintWriter out = response.getWriter(); try { // get the initial context InitialContext ctx = new InitialContext(); // lookup the topic object Topic topic = (Topic) ctx.lookup("java:comp/env/topic/topic0"); // lookup the topic connection factory TopicConnectionFactory connFactory = (TopicConnectionFactory) ctx .lookup("java:comp/env/topic/connectionFactory"); // create a topic connection TopicConnection topicConn = connFactory.createTopicConnection(); // create a topic session TopicSession topicSession = topicConn.createTopicSession(false, Session.AUTO_ACKNOWLEDGE); // create a topic publisher TopicPublisher topicPublisher = topicSession.createPublisher(topic); topicPublisher.setDeliveryMode(DeliveryMode.NON_PERSISTENT); // create the "Hello World" message TextMessage message = topicSession.createTextMessage(); message.setText("Hello World"); // publish the messages topicPublisher.publish(message); // print what we did out.write("Message published: " + message.getText()); // close the topic connection topicConn.close(); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } } /** * @see HttpServlet#doPost(HttpServletRequest request, HttpServletResponse * response) */ protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { // TODO Auto-generated method stub } }
新建一个订阅者Servlet
package pubSub; import java.io.IOException; import java.io.PrintWriter; import javax.jms.Session; import javax.jms.TextMessage; import javax.jms.Topic; import javax.jms.TopicConnection; import javax.jms.TopicConnectionFactory; import javax.jms.TopicSession; import javax.jms.TopicSubscriber; import javax.naming.InitialContext; import javax.servlet.ServletException; import javax.servlet.annotation.WebServlet; import javax.servlet.http.HttpServlet; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; /** * Servlet implementation class Receive */ @WebServlet("/Subscribe") public class Subscriber extends HttpServlet { private static final long serialVersionUID = 1L; /** * @see HttpServlet#HttpServlet() */ public Subscriber() { super(); // TODO Auto-generated constructor stub } /** * @see HttpServlet#doGet(HttpServletRequest request, HttpServletResponse * response) */ protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { PrintWriter out = response.getWriter(); try { // get the initial context InitialContext ctx = new InitialContext(); // lookup the topic object Topic topic = (Topic) ctx.lookup("java:comp/env/topic/topic0"); // lookup the topic connection factory TopicConnectionFactory connFactory = (TopicConnectionFactory) ctx .lookup("java:comp/env/topic/connectionFactory"); // create a topic connection TopicConnection topicConn = connFactory.createTopicConnection(); // create a topic session TopicSession topicSession = topicConn.createTopicSession(false, Session.AUTO_ACKNOWLEDGE); // create a topic subscriber TopicSubscriber topicSubscriber = topicSession .createSubscriber(topic); // start the connection topicConn.start(); // receive the message TextMessage message = (TextMessage) topicSubscriber.receive(); // print the message out.write("Message received: " + message.getText()); // close the topic connection topicConn.close(); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } } /** * @see HttpServlet#doPost(HttpServletRequest request, HttpServletResponse * response) */ protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { // TODO Auto-generated method stub } }
运行Web工程,分别打开多个标签访问订阅servlet,然后访问发布servlet,结果如下:
在订阅者订阅消息的时候,一开始没接收到消息,一旦发布者发布消息后,订阅者马上收到消息。
参考资料
http://howtodoinjava.com/jms/jms-publish-subscribe-message-example/
相关推荐
在这里,生产者发布消息到一个主题,多个消费者可以订阅这个主题以接收消息。与点对点模型不同,发布/订阅模型支持一对多的消息传递,即一条消息可以被多个订阅者接收。 - **主题**:消息发布的中心,类似于广播...
为了解决这一问题,SUN公司发布了Java消息服务(Java Message Service,简称JMS)规范,虽然一定程度上解决了不同厂商产品之间的互操作问题,但在实时性和灵活性方面仍然存在不足。为此,对象管理组织(Object ...
生产者(发布者)发布消息到一个主题,多个消费者(订阅者)可以订阅这个主题并接收到消息。相比于点对点模式,发布/订阅模式支持一对多的广播式通信。在ActiveMQ中,我们可以通过创建一个Topic,然后使用`...
在这个模型中,生产者(publisher)发布消息到一个主题(topic),而消费者(subscriber)则订阅这个主题,从而接收到发布的消息。 1. **JMS基本概念** - **消息**:消息是数据的载体,包含实际要传递的信息。 - ...
对于消息订阅,我们需要创建`MessageConsumer`来监听特定的消息源。如果是队列,消费者是独占的;如果是主题,可以有多个订阅者。 ```java MessageConsumer consumer = session.createConsumer(destination); ...
1. **消息模型**:JMS支持两种主要的消息传递模型——点对点(Queue)和发布/订阅(Topic)。点对点模式中,消息从一个生产者发送到一个队列,然后由一个消费者接收。发布/订阅模式下,消息由发布者发送到主题,多个...
3. **发布/订阅模式**:在发布/订阅模式中,消息生产者(发布者)将消息发送到一个中心节点(消息代理或消息总线),而消息消费者(订阅者)则注册对特定主题的兴趣。当有新消息发布时,消息总线会将消息推送给所有...
1. 广播消息:生产者发布消息到一个主题,所有订阅了该主题的消费者都能接收到消息。 2. 多对多交付:一个消息可以被多个消费者同时接收,实现了广播效果。 3. 动态订阅:消费者可以随时订阅或取消订阅主题,不影响...
2. **发布消息**:生产者连接到主题,创建Message对象,然后调用`publish`方法发布消息到主题。 3. **订阅消息**:消费者作为订阅者,可以订阅一个或多个主题。订阅后,每当有新的消息发布到主题,消费者都会接收到...
3. **发布消息**: 创建一个`MessageProducer`实例,并通过`createTextMessage()`或`createObjectMessage()`方法创建消息。然后,调用`send()`方法将消息发送到指定的主题。 ```java MessageProducer producer = ...
3. **创建生产者**: 生产者是发送消息的组件,它需要连接到JMS提供者,并创建一个TopicProducer对象,用来发布消息到已定义的Topic。 4. **创建消费者**: 消费者是接收消息的组件,它们需要订阅特定的Topic。每个...
### Apache ActiveMQ 学习笔记 ...点对点模型适用于一对一的消息传递场景,而发布/订阅模型则适用于一对多的消息分发场景。此外,通过示例代码,我们也了解了如何使用 Java 和 Spring 框架与 ActiveMQ 集成来发送消息。
5. **主题(Topic)与队列(Queue)**:JMS支持两种消息模式——发布/订阅(Publish/Subscribe)和点对点(Point-to-Point)。主题适用于广播式通信,多个消费者可以订阅同一个主题并接收消息。队列则遵循一对一的...
这个"activemq和spring整合发布消息和订阅消息demo"是用于演示如何在Spring环境中配置和使用ActiveMQ来实现实时的数据通信。现在,我们将深入探讨相关的知识点。 首先,ActiveMQ是Apache软件基金会开发的一个开源...
在JMS中,发布/订阅模式是一种通信方式,其中生产者(发布者)发布消息到一个主题,而消费者(订阅者)可以订阅这个主题来接收消息。与点对点模型不同,发布/订阅模型中,一个消息可以被多个消费者接收,增强了消息...
通过理解并熟练掌握上述内容,你将在WebLogic环境中成功地利用JMS进行消息传递,无论是简单的点对点通信还是复杂的发布/订阅模式,都能游刃有余。请务必根据具体需求进行配置,并确保测试环节充分,以确保JMS服务的...
【MQ JMS 发布订阅配置】是分布式消息传递系统中的一种模式,允许消息生产者(发布者)发送消息,而消息消费者(订阅者)可以选择性地接收这些消息。IBM 的 WebSphere MQ(简称 MQ)提供了Java消息服务(JMS)接口来...
在这个"spring-jms使用queue发送消息简单例子"中,我们将深入探讨如何使用Spring JMS与ActiveMQ结合,通过队列(Queue)来发送和接收消息。 首先,`pom.xml`文件是Maven项目的配置文件,它包含了项目所依赖的库。...
- **订阅**:消息订阅者可以根据自己的需求订阅感兴趣的通道或主题。 4. **集群和客户端** - **集群**:多台服务器协同工作,提高系统的整体性能和稳定性。 - **客户端**:支持多种客户端接入,如Web、移动设备...
3. **jms规范教程.pdf** - 这是一个关于JMS规范的教程,可能详细讲解了JMS接口、消息类型(如点对点和发布/订阅模型)、消息队列和主题等核心概念,为理解JMS和ActiveMQ的工作原理提供了基础。 综上所述,这个主题...