JMS持久订阅(DurableSubscribe)模式示例
2017-07-16 21:16
155 查看
为了缓和严格的时间相关性,JMS允许订阅者创建一个可持久化的订阅。这样,即使订阅者没有被激活(运行),它也能接收到发布者的消息。
发布者:
创建一个DurableSubscriber的两个前提条件是:
connection.setClientID("ClientID");
session.createDurableSubscriber(topic,"SubscriberName");
订阅者:package com.zzj.durablesubscriber;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.MessageConsumer;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.jms.Topic;
import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;
/**
* 同步消费
* @author lenovo
*
*/
public class Customer {
private static final String DEST = "com.zzj.dest.03";
public static void main(String[] args) throws Exception {
ConnectionFactory factory = new ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_USER,
ActiveMQConnection.DEFAULT_PASSWORD, ActiveMQConnection.DEFAULT_BROKER_URL);
Connection connection = factory.createConnection();
connection.setClientID("zzj.client01");
connection.start();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Topic topic = session.createTopic(DEST);
MessageConsumer consumer = session.createDurableSubscriber(topic, "zzj.subscriber01");
TextMessage message = (TextMessage) consumer.receive(); // 阻塞方法,直到接收到消息
System.out.println(message.getText());
// 关闭资源
consumer.close();
session.close();
connection.close();
}
}
发布者:
package com.zzj.durablesubscriber; import javax.jms.Connection; import javax.jms.ConnectionFactory; import javax.jms.Message; import javax.jms.MessageProducer; import javax.jms.Session; import javax.jms.Topic; import org.apache.activemq.ActiveMQConnection; import org.apache.activemq.ActiveMQConnectionFactory; public class Producer { private static final String DEST = "com.zzj.dest.03"; public static void main(String[] args) throws Exception { ConnectionFactory factory = new ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_USER, ActiveMQConnection.DEFAULT_PASSWORD, ActiveMQConnection.DEFAULT_BROKER_URL); Connection connection = factory.createConnection(); connection.start(); Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); Topic topic = session.createTopic(DEST); MessageProducer producer = session.createProducer(topic); Message message = session.createTextMessage("Hello world!"); producer.send(message); System.out.println("发送成功!"); // 关闭资源 producer.close(); session.close(); connection.close(); } }
创建一个DurableSubscriber的两个前提条件是:
connection.setClientID("ClientID");
session.createDurableSubscriber(topic,"SubscriberName");
订阅者:package com.zzj.durablesubscriber;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.MessageConsumer;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.jms.Topic;
import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;
/**
* 同步消费
* @author lenovo
*
*/
public class Customer {
private static final String DEST = "com.zzj.dest.03";
public static void main(String[] args) throws Exception {
ConnectionFactory factory = new ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_USER,
ActiveMQConnection.DEFAULT_PASSWORD, ActiveMQConnection.DEFAULT_BROKER_URL);
Connection connection = factory.createConnection();
connection.setClientID("zzj.client01");
connection.start();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Topic topic = session.createTopic(DEST);
MessageConsumer consumer = session.createDurableSubscriber(topic, "zzj.subscriber01");
TextMessage message = (TextMessage) consumer.receive(); // 阻塞方法,直到接收到消息
System.out.println(message.getText());
// 关闭资源
consumer.close();
session.close();
connection.close();
}
}
相关文章推荐
- JMS发布订阅(Pub/Sub)模式示例
- JMS持久订阅
- JMS消息机制--发布-订阅模式
- JMS-activeMq发布订阅模式(非持久订阅)
- 关于 Jms Topic 持久订阅
- JMS点对点(P2P)模式示例
- 消息队列:快速上手ActiveMQ消息队列的JMS方式使用(两种模式:Topic和Queue的消息推送和订阅)
- 理解JMS规范中的持久订阅和非持久订阅
- 理解JMS规范中消息的传输模式和消息持久化
- Javascript设计模式-发布/订阅模式最小化的示例
- JMS(五):订阅/发布模式(SUB/PUB)
- 理解JMS规范中的持久订阅和非持久订阅
- 理解JMS规范中消息的传输模式和消息持久化
- jms消息机制,包括点对点、发布/订阅模式
- 理解JMS规范中消息的传输模式和消息持久化
- JMS消息队列ActiveMQ(发布/订阅模式)
- 理解JMS规范中消息的传输模式和消息持久化
- [置顶] 理解JMS规范中的持久订阅和非持久订阅
- ZeroMQ:订阅-发布模式的java程序示例
- JMS(二)之发布/订阅模式