`
- 浏览:
114845 次
-
发送端:
-
package com.ccl.app;
-
-
import javax.jms.Destination;
-
import javax.jms.MessageProducer;
-
import javax.jms.Session;
-
import javax.jms.TextMessage;
-
import javax.jms.TopicConnection;
-
import javax.jms.TopicConnectionFactory;
-
import javax.jms.TopicSession;
-
import javax.naming.InitialContext;
-
-
public class SendQueue {
-
-
/**
-
* @param args
-
*/
-
public static void main(String[] args) {
-
-
try {
-
-
InitialContext ctx
=
new
InitialContext();
-
-
TopicConnectionFactory factory
= (TopicConnectionFactory) ctx
-
.lookup("TopicConnectionFactory");
-
-
TopicConnection conn
=
factory
.createTopicConnection();
-
-
Session session
=
conn
.createSession(false,
-
TopicSession.AUTO_ACKNOWLEDGE);/* 建立不需要事务的并且能够自动确认已接收的会话 */
-
-
Destination destination
= (Destination) ctx
-
.lookup("queue/jboossTopic");
-
-
MessageProducer producer
=
session
.createProducer(destination);
-
-
TextMessage msg
=
session
-
.createTextMessage("hello java Message service of topic.");
-
-
producer.send(msg);
-
-
System.out.println(msg);
-
-
} catch (Exception e) {
-
e.printStackTrace();
-
}
-
-
}
-
-
}
接收端:
-
package com.ccl.app.client;
-
-
import javax.ejb.ActivationConfigProperty;
-
import javax.ejb.MessageDriven;
-
import javax.jms.JMSException;
-
import javax.jms.Message;
-
import javax.jms.MessageListener;
-
import javax.jms.TextMessage;
-
-
@MessageDriven(activationConfig
= {
-
@ActivationConfigProperty(propertyName
=
"destinationType"
,
propertyValue
=
"javax.jms.Topic"
),
-
@ActivationConfigProperty(propertyName
=
"destination"
,
propertyValue
=
"queue/jboossTopic"
)
-
-
})
-
public class MessageDrivenBean implements MessageListener {
-
-
@Override
-
public void onMessage(Message mess) {
-
-
TextMessage msg
= (TextMessage)mess;
-
-
try {
-
-
System.out.println(msg.getText());
-
-
} catch (JMSException e) {
-
e.printStackTrace();
-
}
-
-
}
-
-
}
分享到:
Global site tag (gtag.js) - Google Analytics
相关推荐
Java消息服务(JMS,Java Message Service)是Java平台中用于在分布式系统中进行可靠的消息传递的标准API。它提供了一种解耦应用程序的方式,使得不同的组件可以异步通信,即使它们可能在不同的时间运行,或者在不同...
Java Message Service(JMS)是Java平台中用于创建和管理消息传递系统的一种API。它提供了一种标准的方式来发送和接收消息,使得不同的应用程序之间能够进行异步通信。JMS允许开发者在分布式环境中创建可靠的、基于...
Java Message Service(JMS)是Java平台上的一个标准接口,用于在分布式环境中交换消息。JSR-000343则是对这个标准的第2.0版本的规范定义,它详细描述了如何在Java应用程序之间可靠地发送和接收消息。Javadoc是一种...
Java Message Service(JMS)是Java平台中用于创建、发送、接收和读取消息的应用程序接口。它提供了一种标准的方式来解耦应用程序之间的通信,使得它们可以异步地交换信息,提高了系统的可扩展性和可靠性。在JMS中,...
根据提供的文件内容,以下是关于“JSR-000343 Java Message Service 2.0 Specification for Evaluation”的详细知识点: ### 标题知识点 - **JSR-000343**: Java Message Service (JMS) 2.0 规范的代号,JSR(Java...
Java消息服务(Java Message Service, JMS)是Java平台中的消息中间件接口标准,它为应用程序之间的通信提供了一种高效、可靠的机制。通过定义一系列的接口规范,JMS允许开发者在不同的消息传递系统之间进行互操作,...
【Java Message Service (JMS) 简介】 Java Message Service (JMS) 是Java平台上的一个标准API,专门设计用于在企业级消息系统中进行消息交换。它为Java应用程序提供了一种统一的方式,以便与各种不同的消息中间件...
### 深入掌握 JMS(Java Message Service) #### JMS 基础概念 - **JMS**(Java Message Service)是一种Java平台中的消息中间件技术标准,它定义了一套标准API,用于应用程序之间的消息传递。JMS的出现极大地简化...
### Java Message Service (JMS) 规范中文完整版解读 #### 一、概述 Java Message Service(简称JMS)是一种消息中间件的标准接口,它为应用程序提供了与消息中间件进行交互的方式。JMS规范定义了一组接口和方法,...
《Java Message Service》 PDF英文版本下载
Java Message Service(JMS)是Java平台上的一个标准接口,用于在分布式环境中交换异步消息。它是企业级应用集成中的重要组成部分,特别是在处理大量数据、高并发和系统间解耦时。这个“Java Message Service 2nd ...
为了满足这一需求,Java消息服务(Java Message Service,简称JMS)应运而生,成为了一种标准的消息传递协议,用于应用程序之间进行异步通信。本文将对JMS进行全面解析,包括其架构、点对点(Point-to-Point)与发布...