下载j2ee SDK并安装。具体链接;
http://www.oracle.com/technetwork/java/javaee/downloads/index.html
下面指定些特定的环境变量:
J2EE_HOME :j2ee sdk的安装目,我本地安装在d:\j2ee
MQ_HOME :J2EE_HOME\mq
1、在eclipse的项目中导入下面两个jar包:
MQ_HOME\lib\jms.jar : SUN定义的一套JMS的标准接口
MQ_HOME\lib\imq.jar :OpenMQ对SUN接口的实现
2、创建一个类,并编写主函数;具体代码如下:
public static void main(String[] args) {
try {
// 当然也可通过jndi方式获取ConnectionFactory,后续将会详细讲解
ConnectionFactory factory = new com.sun.messaging.ConnectionFactory();
Connection conn = factory.createConnection();
Session session = conn.createSession(false,
Session.AUTO_ACKNOWLEDGE);
Queue queue = new com.sun.messaging.Queue("test");
MessageProducer producer = session.createProducer(queue);
TextMessage message = session.createTextMessage();
message.setText("hello world");
producer.send(message);
MessageConsumer consumer = session.createConsumer(queue);
conn.start();
Message rMessage = consumer.receive();
TextMessage textMessage = (TextMessage) rMessage;
System.out.println("receive message from : "
+ textMessage.getText());
session.close();
conn.close();
} catch (JMSException e) {
System.out.println(e.getStackTrace());
}
}
3、启动OpenMQ的本地服务
命令行运行输入如下命令:
cd /d %MQ_HOME%\bin
imqbrokered
4、运行程序,得到下面的输出就成功了。
receive message from : hello world
上面仅仅是个很小很小的DEMO,但是已经包括了在使用JMS中几个主要步骤。
具体涉及到一些细节后面将再写文章具体描述。
分享到:
相关推荐
openmq 编译依赖包
sun公司OpenMq的安装指南,比较详细,可以惨嚎
OpenMq 基本管理命令,安装、集群、管理命令、查看队列、链接等相关服务
在传送过程中,系统处理JMS消息分为以下两类: ■ 有效负荷消息,由生成方发送给使用方的消息。 ■ 控制消息,代理与客户端运行时环境之间传送的私有消息,用于确保有效负荷消息成功传送和控制跨连接的消息流。 ...
openmq 4.4.2源码
OpenMQ项目JMS SI(规范实施) 该项目包含以下模块:更多详细信息可在下一个文件夹中找到,
habari-openmq-20190131-src.zip
基于JMS标准的消息中间件实现的产品有很多,JBossMQ、ActiveMQ、OpenMQ、OpenJMS等等,最常用的还是apache的ActiveMQ。有时也使用Sun的OpenMQ。在官网http://mq.java.net/处可以下载。Open Message Queue是Sun Java ...
habari-openmq-6.1-installer.exe
为 OpenMQ (GlassFish JMS) / Oracle WebLogic MQ 开发基于队列消息管理 gui 的工具。 工具名称为 QBrowserV2。 它旨在实现新消息创建/发送、删除消息、转发消息、订阅主题等功能。
java8 集合源码分析 项目地址 #目录 自己做过的消息组件 [自己实现simple RPC](#自己实现simple RPC) [JDK NIO/BIO](#JDK NIOBIO) [JVM SandBox](#JVM ...OpenMQ ...JMS。...ZeroMQ(简称ZMQ)是一个基于消
使用SOAP协议,创建一个Web服务,该服务使用RSA协议对给定消息进行加密(首先在数据库中找到接收者的公共密钥),然后将其发送给接收者的适当地址,而发送消息的客户端可以发送回复。 使用Web浏览器作为客户端应用...
项目中提供了一个带有Vagrantfile的示例项目,该文件可启动glassfish实例。 要求 平台: ubuntu Debian的 视窗 食谱: Java 授权 档案 刀具 运行 属性 node['glassfish']['user'] -GlassFish用户:GlassFish执行...
消息队列中间件调研文档。ActiveMQ、RabbitMQ、RocketMq、Joram、HornetQ、OpenMQ等的对比。
ActiveMQ、RabbitMQ、RocketMq、Joram、HornetQ、OpenMQ、MuleMQ、SonicMQ、ZeroMQ、Kafka 从关注度,成熟度,社区活跃度、文档、特点、授权方式、语言、事务、集群、持久化、协议,部署方式、UI、评价等诸多维度
这使得用Rust编写的程序可以与消息队列服务进行交互,例如ActiveMQ,RabbitMQ,HornetQ和OpenMQ。 连接订阅发送确认(自动/客户端/客户端个人)交易收据断开心跳信号踩踏程序的API尚不稳定,并且可能在v1.0之前波动...