下载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,全称为Java Message Service (JMS) 提供者,是Oracle公司开发的一个开源消息中间件。它允许应用程序在分布式环境中发送、接收和存储消息,以实现异步通信和解耦。OpenMQ的编译过程涉及到多个依赖包,这些...
OpenMQ,全称为Java消息服务(Java Message Service)的一个实现,是Oracle公司提供的一款开源消息中间件。本文将详细介绍OpenMQ的基本管理命令,包括安装、集群配置、管理命令以及查看和操作队列与主题。 首先,让...
标题中的"habari-openmq-20190131-src.zip"表明这是一个源代码压缩包,发布日期为2019年1月31日,名为“habari”的项目,它与OpenMQ相关。OpenMQ是Oracle的开源消息中间件,用于处理应用程序之间的消息传递,提供...
OpenMQ 4.4.2是该软件的一个特定版本,它提供了稳定且高性能的消息传递服务。在这个版本中,用户可以获取到源代码,这对于开发者来说是一个宝贵的资源,因为可以通过深入研究源代码来理解其工作原理,进行自定义配置...
除了平台特定的要求之外,OpenMQ 4.3 还依赖于一系列必需和可选的软件组件,包括 Java 运行时环境 (JRE) 和 Java 软件开发工具包 (JDK)。这些依赖关系详细记录在《Sun Java System Message Queue 4.3 发布说明》中的...
在传送过程中,系统处理JMS消息分为以下两类: ■ 有效负荷消息,由生成方发送给使用方的消息。 ■ 控制消息,代理与客户端运行时环境之间传送的私有消息,用于确保有效负荷消息成功传送和控制跨连接的消息流。 ...
OpenMQ,全称为Oracle GlassFish Message Queue,是一个开源的消息中间件,它实现了Java消息服务(JMS)标准。OpenMQ是Oracle公司的一部分,主要用于在分布式系统中传递消息,确保数据的可靠传输和解耦应用程序。它...
habari-openmq-6.1-installer.exe
OpenMQ是Sun Java System Message Queue的一个开源版本,拥有企业级、可扩展性以及成熟稳定的特点。它提供了一套完整的JMS实现,并且具备Java System Message Queue的所有特性和性能。本文将详细介绍如何将Sun的Open...
为 OpenMQ (GlassFish JMS) / Oracle WebLogic MQ 开发基于队列消息管理 gui 的工具。 工具名称为 QBrowserV2。 它旨在实现新消息创建/发送、删除消息、转发消息、订阅主题等功能。
首先,社区活跃度是衡量一个开源项目成熟度和受关注程度的重要指标。ActiveMQ、RabbitMQ、RocketMQ均有着较高社区活跃度,拥有大量开源项目使用案例,且在相关社区文档和资源方面也较为丰富。 在成熟度方面,...
java8 集合源码分析 项目地址 #目录 自己做过的消息组件 [自己实现simple RPC](#自己实现simple RPC) [JDK NIO/BIO](#JDK NIOBIO) [JVM SandBox](#JVM ...OpenMQ ...JMS。...ZeroMQ(简称ZMQ)是一个基于消
6. **OpenMQ**:OpenMQ 是一个开源的消息中间件,提供多种消息传递模型,支持JMS API。 #### RabbitMQ详解 **RabbitMQ**是一款基于AMQP协议的消息中间件,提供了丰富的API接口以及强大的插件机制,能够满足各种...
- **RocketMQ**的前身是MetaQ,最初可以看作是LinkedIn的Kafka(Scala版)的一个Java版本,并在此基础上增加了事务支持。 - **RocketMQ**相对于原生Kafka的特点在于除了基本的日志收集功能外,还支持高可用(HA)、...
ActiveMQ是Apache软件基金会开发的一款开源消息中间件,它是基于Java的,并且遵循开放消息传递协议(Open Message Broker Protocol,简称OpenMQ),广泛应用于分布式系统中的异步通信和解耦。ActiveMQ作为消息代理,...
使用SOAP协议,创建一个Web服务,该服务使用RSA协议对给定消息进行加密(首先在数据库中找到接收者的公共密钥),然后将其发送给接收者的适当地址,而发送消息的客户端可以发送回复。 使用Web浏览器作为客户端应用...
本文档基于一份关于消息队列(MQ)中间件的调研报告,对比分析了市场上流行的MQ产品。这些产品包括:ActiveMQ、RabbitMQ、RocketMQ、Joram、HornetQ、OpenMQ、MuleMQ、SonicMQ以及ZeroMQ。我们将从多个维度对这些产品...
队列遵循“一对一”模型,每个消息仅由一个消费者接收;主题遵循“一对多”模型,多个订阅者可以接收同一消息。 7. **持久化(Persistence)**:ActiveMQ支持消息的持久化,即使在服务器重启后,未被消费的消息也能...
项目中提供了一个带有Vagrantfile的示例项目,该文件可启动glassfish实例。 要求 平台: ubuntu Debian的 视窗 食谱: Java 授权 档案 刀具 运行 属性 node['glassfish']['user'] -GlassFish用户:GlassFish执行...
- **发布/订阅(Pub/Sub)模型**:一个消息可以有多个消费者,消息广播给所有订阅者。 4. **特性**: - **高吞吐量**:RocketMQ设计目标是每秒处理上百万条消息。 - **低延迟**:优化的网络通信和批量发送策略...