TopicConnectionFactory是从 JNDI 中检索的受管理对象,它创建了到提供者的链接。它包含 createTopicConnection() 方法,该方法返回了一个 TopicConnection 对象。
TopicConnection 封装了到提供者的一个活动连接。它的一些方法包括:
createTopicSession(boolean, int):返回 TopicSession 对象。boolean 参数指出 TopicSession 是否被处理,int 指出确认模式。
start() (从 Connection 继承):激活提供者发送的消息。
stop() (从 Connection 继承):临时停止发送消息,可以用 start() 重新开始发送。
close() (从 Connection 继承):关闭到提供者的连接,并释放它所占有的所有资源。
TopicSession是发送和接收 pub/sub 消息的单线程上下文。它的一些方法包括:
createPublisher(Topic):返回 TopicPublisher 对象来向指定的 Topic 发送消息。
createSubscriber(Topic):返回 TopicSubscriber 对象来接收指定 Topic 中的消息。这个订阅者是 非持久的,也就是说,订阅只持续到对象的生存周期,只在它对象处于活动状态时才接收消息。
createDurableSubscriber(Topic, String):返回 TopicSubscriber 对象来接收指定 Topic 中的消息,String 给出订阅者的名字。如果对象没有处于活动状态,则通过 JMS 保留 持久的 订阅者的消息,并将它发送给以后用相同名称创建的订阅者对象。
unsubscribe(String):结束名为 String 的订阅者的订阅。
commit() (从 Session 继承):提交当前事务的所有已使用或者已产生的消息。
rollback() (从 Session 继承):回滚当前事务的所有已使用或者已产生的消息。
create<MessageType>Message(...) (从 Session 继承):各种返回 <MessageType>Message 的方法,如 MapMessage、TextMessage 等。
Topic 封装了一个 pub/sub 目的地。它是从 JNDI 中检索的受管理对象。
TopicPublisher 被用来发送 pub/sub 消息。它的一些方法包括:
publish(Message):发布指示的 Message。
setDeliveryMode(int) (从 MessageProducer 继承):设置后续消息发送的发送模式,有效值为 DeliveryMode.PERSISTENT 和 DeliveryMode.NON_PERSISTENT。
setPriority(int) (从 MessageProducer 继承):设置后续消息发送的优先级,有效值为 0 到 9。
setTimeToLive(long) (从 MessageProducer 继承):设置后续发送消息失效前的持续时间,以毫秒为单位。
TopicSubscriber 被用来接收点对点消息。它的一些方法包括:
receive() (从 MessageConsumer 继承):返回到达的下一个消息,这个方法会阻塞,直到一个消息可用为止。
receive(long) (从 MessageConsumer 继承):接收在 long 毫秒内到达的下一个消息,如果在时间期限内没有消息到达,则返回 null 。
receiveNoWait (从 MessageConsumer 继承):返回立即可用的下一个消息,如果没有消息可用,则返回 null。
setMessageListener(MessageListener) (inherited from MessageConsumer):设置 MessageListener,MessageListener 在消息到达时接收消息,即异步接收消息。
TPublisher.java 的代码清单
import java.io.*;
import javax.jms.*;
import javax.naming.*;
public class TPublisher {
public static void main(String[] args) {
new TPublisher().publish();
}
public void publish() {
BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
try {
//Prompt for JNDI names
System.out.println("Enter TopicConnectionFactory name:");
String factoryName = reader.readLine();
System.out.println("Enter Topic name:");
String topicName = reader.readLine();
//Look up administered objects
InitialContext initContext = new InitialContext();
TopicConnectionFactory factory =
(TopicConnectionFactory) initContext.lookup(factoryName);
Topic topic = (Topic) initContext.lookup(topicName);
initContext.close();
//Create JMS objects
TopicConnection connection = factory.createTopicConnection();
TopicSession session =
connection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);
TopicPublisher publisher = session.createPublisher(topic);
//Send messages
String messageText = null;
while (true) {
System.out.println("Enter message to send or 'quit':");
messageText = reader.readLine();
if ("quit".equals(messageText))
break;
TextMessage message = session.createTextMessage(messageText);
publisher.publish(message);
}
//Exit
System.out.println("Exiting...");
reader.close();
connection.close();
System.out.println("Goodbye!");
} catch (Exception e) {
e.printStackTrace();
System.exit(1);
}
}
}
TSubscriber.java 的代码清单
import java.io.*;
import javax.jms.*;
import javax.naming.*;
public class TSubscriber implements MessageListener {
private boolean stop = false;
public static void main(String[] args) {
new TSubscriber().subscribe();
}
public void subscribe() {
BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
try {
//Prompt for JNDI names
System.out.println("Enter TopicConnectionFactory name:");
String factoryName = reader.readLine();
System.out.println("Enter Topic name:");
String topicName = reader.readLine();
reader.close();
//Look up administered objects
InitialContext initContext = new InitialContext();
TopicConnectionFactory factory =
(TopicConnectionFactory) initContext.lookup(factoryName);
Topic topic = (Topic) initContext.lookup(topicName);
initContext.close();
//Create JMS objects
TopicConnection connection = factory.createTopicConnection();
TopicSession session =
connection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);
TopicSubscriber subscriber = session.createSubscriber(topic);
subscriber.setMessageListener(this);
connection.start();
//Wait for stop
while (!stop) {
Thread.sleep(1000);
}
//Exit
System.out.println("Exiting...");
connection.close();
System.out.println("Goodbye!");
} catch (Exception e) {
e.printStackTrace();
System.exit(1);
}
}
public void onMessage(Message message) {
try {
String msgText = ((TextMessage) message).getText();
System.out.println(msgText);
if ("stop".equals(msgText))
stop = true;
} catch (JMSException e) {
e.printStackTrace();
stop = true;
}
}
}
分享到:
相关推荐
JMS实现sub/pub,聊天系统 创建消息的消费者和生产者
消费形式的不同造成JMS有两组平行的API,这就是JMS的PTP(point to point)模型和PUB/SUB(publisher和subscriber、出版和订阅)模型。PTP的消息应用中一个消息只有一个消费者,消费后该消息即不再有效。而PUB/SUB...
Java消息服务支持两种消息模型:Point-to-Point消息(P2P)和发布订阅消息(Publish Subscribe messaging,简称Pub/Sub)。JMS规范并不要求供应商同时支持这两种消息模型,但开发者应该熟悉这两种消息模型的优势与缺点...
四、JMS Pub/Sub编程 五、二阶段提交的事务 ━━━━━━━━━━━━━━━━━━━━━━━━━━ EJB 2.0和J2EE 1.3规范开始提供对Java消息服务(JMS)的支持。在J2EE 1.3加入JMS之前,J2EE环境中的组件...
关于JMS的消息服务的代码,包括PTP和Pub/Sub,简单通俗 易懂。
它既支持点到点(point-to-point)(PTP)模型和发布/订阅(Pub/Sub)模型。 *. 支持同步与异步消息发送 *. JDBC持久性管理使用数据库表来存储消息 *. 可视化管理界面。 *. Applet支持。 *. 能够与Jakarta ...
Java Message Service(JMS)是SUN提出的旨在统一各种MOM(Message-Oriented Middleware )系统接口的规范,它包含点对点(Point to Point,PTP)和发布/订阅(Publish/Subscribe,pub/sub)两种消息模型,提供可靠...
发布/订阅(publish/subscribe,简称 pub/sub)。 这两种消息传递模型非常相似,但有以下区别: PTP 消息传递模型规定了一条消息只能传递给一个接收方。 采用javax.jms.Queue 表示。Spring配置类型destination-type=...
activemq集成spring,和原生的active测试active的p2p和pub/sub方式
基于Spring+JMS+ActiveMQ+Tomcat,做一个Spring4.1.0和ActiveMQ5.11.1整合实例,实现了Point-To-Point的异步队列消息和PUB/SUB(发布/订阅)模型,简单实例,不包含任何业务。
Java消息服务支持两种消息模型:Point-to-Point消息(P2P)和发布订阅消息(Publish Subscribe messaging,简称Pub/Sub)。JMS规范并不要求供应商同时支持这两种消息模型,但开发者应该熟悉这两种消息模型的优势与缺点...
简单的JMS的代码,里面有p2p,pub/sub方式的通信,有异步和同步消费消息,具体的内容大家可以下载看看
支持发布/订阅(Pub/Sub)和点对点(P2P)消息模型 在一个队列中可靠的先进先出(FIFO)和严格的顺序传递 支持拉(pull)和推(push)两种消息模式 单一队列百万消息的堆积能力 支持多种消息协议,如 JMS、MQTT ...
支持发布/订阅(Pub/Sub)和点对点(P2P)消息模型 在一个队列中可靠的先进先出(FIFO)和严格的顺序传递 支持拉(pull)和推(push)两种消息模式 单一队列百万消息的堆积能力 支持多种消息协议,如 JMS、MQTT 等 ...
SpringBoot集成ActiveMQ,ActiveMQ支持队列和主题两种消息发送方式,选择发送方式可以在SpringBoot的配置文件中通过参数spring.jms.pub-sub-domain来控制,值为false表示是队列,值为true表示是主题。
Messaging Patterns Point-To-Point Queue/TemporaryQueue QueueBrower Pub/Sub Topic/TemporaryTopic DurableSubscriber
JMS是Java的消息服务,JMS的客户端之间可以通过JMS服务进行异步的消息传输。JMS支持两种消息模型:Point-to-Point(P2P)和Publish/Subscribe(Pub/Sub),即点对点和发布订阅模型。
JavaMessageService(JMS)是SUN提出的旨在统一各种MOM(Message-OrientedMiddleware)系统接口的规范,它包含点对点(PointtoPoint,PTP)和发布/订阅(Publish/Subscribe,pub/sub)两种消息模型,提供可靠消息...