开发学院软件开发Java JMS - 异步消息的使者 阅读

JMS - 异步消息的使者

 2009-09-23 00:00:00 来源:WEB开发网   
核心提示:Java消息服务(JMS)实现了异步消息的传递,在企业级的应用中,JMS - 异步消息的使者,极大的简化了异步通信系统的实现,使用消息传递的优点在于保持了系统的松散耦合,或者一个任意的对象,当前JMS支持五种类型的消息:TextMessage、MapMessage、ByteMessage、 StreamMessage、

Java消息服务(JMS)实现了异步消息的传递,在企业级的应用中,极大的简化了异步通信系统的实现,使用消息传递的优点在于保持了系统的松散耦合。

JMS支持点到点(P2P)模式和发布-订阅(pub/sub)模式。点到点消息模式依赖于消息队列概念,它将消息发送到称为队列(Queue)的特定目的地,接受者从队列中获取消息,对其进行处理。发布-订阅模式则是将消息发送到成为主题(Topic)的目的地,使用者通过订阅消息来获取。因此,我们可以简单的将Queue和Topic理解为消息的存储器,或者接受器,通过它将消息转发给消息最终的接收者。对于消息,可以是一个简单的字符串,一段二进制流,或者一个任意的对象,当前JMS支持五种类型的消息:TextMessage、MapMessage、ByteMessage、 StreamMessage、ObjectMessage。

下面来看一段P2P的完整实现,

sender: 

       Context context = new InitialContext();
       QueueConnectionFactory queueConnectionFactory = (QueueConnectionFactory) context.lookup("QueueConnectionFactoryTest");
       QueueConnection queueConnection = queueConnectionFactory.createQueueConnection();
       QueueSession queueSession = queueConnection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
       Queue queue = (Queue) context.lookup("QueueTest");
       QueueSender queueSender = queueSession.createSender(queue);
       TextMessage message = queueSession.createTextMessage();
       message.setText("Hello JMS!");
       queueSender.send(message);
       queueConnection.close();

1 2 3  下一页

Tags:JMS 异步 消息

编辑录入:爽爽 [复制链接] [打 印]
[]
  • 好
  • 好的评价 如果觉得好,就请您
      0%(0)
  • 差
  • 差的评价 如果觉得差,就请您
      0%(0)
赞助商链接