`
mixer_b
  • 浏览: 115039 次
社区版块
存档分类
最新评论

Java Message Service

    博客分类:
  • java
阅读更多

发送端:

[html]   view plain copy
  1. package com.ccl.app;  
  2.   
  3. import javax.jms.Destination;  
  4. import javax.jms.MessageProducer;  
  5. import javax.jms.Session;  
  6. import javax.jms.TextMessage;  
  7. import javax.jms.TopicConnection;  
  8. import javax.jms.TopicConnectionFactory;  
  9. import javax.jms.TopicSession;  
  10. import javax.naming.InitialContext;  
  11.   
  12. public class SendQueue {  
  13.   
  14.     /**  
  15.      * @param args  
  16.      */  
  17.     public static void main(String[] args) {  
  18.   
  19.         try {  
  20.   
  21.             InitialContext ctx  =  new  InitialContext();  
  22.   
  23.             TopicConnectionFactory factory  = (TopicConnectionFactory) ctx  
  24.                     .lookup("TopicConnectionFactory");  
  25.   
  26.             TopicConnection conn  =  factory .createTopicConnection();  
  27.   
  28.             Session session  =  conn .createSession(false,  
  29.                     TopicSession.AUTO_ACKNOWLEDGE);/* 建立不需要事务的并且能够自动确认已接收的会话 */  
  30.   
  31.             Destination destination  = (Destination) ctx  
  32.                     .lookup("queue/jboossTopic");  
  33.   
  34.             MessageProducer producer  =  session .createProducer(destination);  
  35.   
  36.             TextMessage msg  =  session   
  37.                     .createTextMessage("hello java Message service of topic.");  
  38.   
  39.             producer.send(msg);  
  40.               
  41.             System.out.println(msg);  
  42.   
  43.         } catch (Exception e) {  
  44.             e.printStackTrace();  
  45.         }  
  46.   
  47.     }  
  48.   
  49. }  


接收端:

[html]   view plain copy
  1. package com.ccl.app.client;  
  2.   
  3. import javax.ejb.ActivationConfigProperty;  
  4. import javax.ejb.MessageDriven;  
  5. import javax.jms.JMSException;  
  6. import javax.jms.Message;  
  7. import javax.jms.MessageListener;  
  8. import javax.jms.TextMessage;  
  9.   
  10. @MessageDriven(activationConfig  = {  
  11.         @ActivationConfigProperty(propertyName  =  "destinationType" propertyValue  =  "javax.jms.Topic" ),  
  12.         @ActivationConfigProperty(propertyName  =  "destination" propertyValue  =  "queue/jboossTopic" )  
  13.   
  14. })  
  15. public class MessageDrivenBean implements MessageListener {  
  16.   
  17.     @Override  
  18.     public void onMessage(Message mess) {  
  19.           
  20.         TextMessage msg  = (TextMessage)mess;  
  21.           
  22.         try {  
  23.               
  24.             System.out.println(msg.getText());  
  25.               
  26.         } catch (JMSException e) {  
  27.             e.printStackTrace();  
  28.         }  
  29.   
  30.     }  
  31.   
  32. }  


分享到:
评论

相关推荐

    JMS教程 java message service

    Java消息服务(JMS,Java Message Service)是Java平台中用于在分布式系统中进行可靠的消息传递的标准API。它提供了一种解耦应用程序的方式,使得不同的组件可以异步通信,即使它们可能在不同的时间运行,或者在不同...

    Java Message Service 基础教程

    Java Message Service(JMS)是Java平台中用于创建和管理消息传递系统的一种API。它提供了一种标准的方式来发送和接收消息,使得不同的应用程序之间能够进行异步通信。JMS允许开发者在分布式环境中创建可靠的、基于...

    JSR-000343 Java Message Service 2.0 javadocs for Evaluation

    Java Message Service(JMS)是Java平台上的一个标准接口,用于在分布式环境中交换消息。JSR-000343则是对这个标准的第2.0版本的规范定义,它详细描述了如何在Java应用程序之间可靠地发送和接收消息。Javadoc是一种...

    JMS消息服务代码(java message service)

    Java Message Service(JMS)是Java平台中用于创建、发送、接收和读取消息的应用程序接口。它提供了一种标准的方式来解耦应用程序之间的通信,使得它们可以异步地交换信息,提高了系统的可扩展性和可靠性。在JMS中,...

    JSR-000343 Java Message Service 2.0 Specification for Evaluation

    根据提供的文件内容,以下是关于“JSR-000343 Java Message Service 2.0 Specification for Evaluation”的详细知识点: ### 标题知识点 - **JSR-000343**: Java Message Service (JMS) 2.0 规范的代号,JSR(Java...

    java message service 第二版

    Java消息服务(Java Message Service, JMS)是Java平台中的消息中间件接口标准,它为应用程序之间的通信提供了一种高效、可靠的机制。通过定义一系列的接口规范,JMS允许开发者在不同的消息传递系统之间进行互操作,...

    JMS简介 Java Message Service

    【Java Message Service (JMS) 简介】 Java Message Service (JMS) 是Java平台上的一个标准API,专门设计用于在企业级消息系统中进行消息交换。它为Java应用程序提供了一种统一的方式,以便与各种不同的消息中间件...

    深入掌握 JMS(java message service)

    ### 深入掌握 JMS(Java Message Service) #### JMS 基础概念 - **JMS**(Java Message Service)是一种Java平台中的消息中间件技术标准,它定义了一套标准API,用于应用程序之间的消息传递。JMS的出现极大地简化...

    Java Message Service中文完整版

    ### Java Message Service (JMS) 规范中文完整版解读 #### 一、概述 Java Message Service(简称JMS)是一种消息中间件的标准接口,它为应用程序提供了与消息中间件进行交互的方式。JMS规范定义了一组接口和方法,...

    《Java Message Service》 PDF英文版本下载.txt

    《Java Message Service》 PDF英文版本下载

    Java Message Service 2nd Edition源代码

    Java Message Service(JMS)是Java平台上的一个标准接口,用于在分布式环境中交换异步消息。它是企业级应用集成中的重要组成部分,特别是在处理大量数据、高并发和系统间解耦时。这个“Java Message Service 2nd ...

    Introducing the Java Message Service

    为了满足这一需求,Java消息服务(Java Message Service,简称JMS)应运而生,成为了一种标准的消息传递协议,用于应用程序之间进行异步通信。本文将对JMS进行全面解析,包括其架构、点对点(Point-to-Point)与发布...

Global site tag (gtag.js) - Google Analytics