JMS消息队列入门
2017-05-22 23:38
176 查看
参考:http://blog.csdn.net/wl_ldy/article/category/1216997
Message:被发送的消息,它包括数据流、map和普通text等类型。
Session:信息生成者与消息服务JMS建立的会话,只能通过session创建Message。
Connection:信息生产者与消息服务JMS建立的连接,通过它创建Session。
ConnectionFactory:连接工厂。
Producer:消息生产者。
MessageConsumer:消息的消费者。
基本概念
JMS(Java Message Service)即java消息服务。它提供了标准的生产、发送和接收信息的借口,简化了企业开发的流程。它提供了两种方式的消息通信模型:点对点的模型、发布/点阅模型。重要的几个概念:
Destination:消息发送的目的地Message:被发送的消息,它包括数据流、map和普通text等类型。
Session:信息生成者与消息服务JMS建立的会话,只能通过session创建Message。
Connection:信息生产者与消息服务JMS建立的连接,通过它创建Session。
ConnectionFactory:连接工厂。
Producer:消息生产者。
MessageConsumer:消息的消费者。
下面是一个基于ActiveMQ消息服务器的例子
/** * @author Administrator * @desctiption 结合一个例子,深入理解JMS的基本概念 * 消息的消费者接收消息可以采用两种方式: * 1、consumer.receive() 或 consumer.receive(int timeout); * 2、注册一个MessageListener。 * 采用第一种方式,消息的接收者会一直等待下去,直到有消息到达,或者超时。 * 后一种方式会注册一个监听器,当有消息到达的时候,会回调它的onMessage()方法。 */ package com.wl.jms; import javax.jms.Connection; import javax.jms.ConnectionFactory; 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; public class MessageSendAndReceive { /** * @param args * @throws JMSException */ public static void main(String[] args) throws JMSException { // TODO Auto-generated method stub ConnectionFactory factory = new ActiveMQConnectionFactory("vm://localhost"); Connection connection = factory.createConnection(); connection.start(); //创建消息的Destination Queue queue = new ActiveMQQueue("testQueue"); final Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); //创建将要发送的消息 Message message = session.createTextMessage("Hello JMS!"); //创建消息生产者发送消息 MessageProducer producer = session.createProducer(queue); producer.send(message); System.out.println("Send Message Completed!"); //创建消息的接收者 MessageConsumer comsumer = session.createConsumer(queue); //消息的消费者接收消息的第一种方式:consumer.receive() 或 consumer.receive(int timeout); //Message recvMessage = comsumer.receive(); //System.out.println(((TextMessage)recvMessage).getText()); //消息的消费者接收消息的第二种方式:注册一个MessageListener comsumer.setMessageListener(new MessageListener(){ public void onMessage(Message msg) { // TODO Auto-generated method stub TextMessage textMsg=(TextMessage)msg; try { System.out.println(textMsg.getText()); } catch (JMSException e) { e.printStackTrace(); } } }); } }
相关文章推荐
- [jms那点事儿] JMS ( java message service )入门 + activemq消息持久化
- 消息队列RABBITMQ入门介绍
- 消息队列RabbitMQ入门介绍
- linux 消息队列简单入门
- JMS学习4 - 初试在队列上发布/接收消息
- JMS入门消息发布和定购
- 消息队列技术终结者(一)—通俗深刻地认识JMS(即Java Message Service)
- Python 学习入门(29)—— 消息队列
- Activemq+spring的第一个程序(入门程序--内嵌Broker--消息队列)
- 可嵌入式JMS消息队列FFMQ
- 使用WLST脚本列出JMS队列中的消息
- Activemq+spring的第一个程序(入门程序--内嵌Broker--消息队列)
- 消息队列入门
- 消息队列之JMS和AMQP对比
- JBoss 系列六:JBoss 7/WildFly中配置使用JMS消息队列
- spring jsm tomcat 异步消息传递入门实例(消息队列)
- Activemq+spring的第一个程序(入门程序--内嵌Broker--消息队列)
- 消息队列RabbitMQ入门介绍
- 消息队列之JMS和AMQP对比
- 消息队列技术—获取JMS中文版和英文版API