`
- 浏览:
112043 次
-
发送端:
-
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 message service
Java Message Service 基础教程
JMS ,java message service 消息中间件开源项目幻灯片
JSR-000343 Java Message Service 2.0 javadocs for Evaluation.官网下载的,放在这里共享
java message service 第二版 非常不错的 JMS 资料
一篇深入的讲解了java message service技术的文档 ,希望对大家有所帮助
《Java Message Service》 PDF英文版本下载
关于JMS的消息服务的代码,包括PTP和Pub/Sub,简单通俗 易懂。
JMS(Java Message Service)是访问企业消息系统的标准API,它便于消息系统中的Java应用程序进行消息交换,并且通过提供标准的产生、发送、接收消息的接口简化企业应用的开发。
JSR-000343 Java Message Service 2.0 Specification for Evaluation.从官网下载的,在这里共享
Java Message Service 原文翻译的中文版,描述了JMS消息传递的规范
Java Message Service 2nd Edition 的源代码
JMS (Java Message Service): Queue, Topic两种模式
JMS : Java Message Service (Java消息服务)1 引言 1.1 编写目的 1.2 名词解释
Java 语言的客户端和Java 语言的中间层服务必须能够使用这些消息系统。JMS 为Java 语言程序提供了一个通用的方式来获取这些系统。 JMS 是一个接口和相关语义的集合,那些语义定义了JMS 客户端如何获取企业消息产品 ...