`
berdy
  • 浏览: 513260 次
  • 性别: Icon_minigender_1
  • 来自: 广州
社区版块
存档分类
最新评论

一个基于OpenMQ的JMS的简短DEMO

    博客分类:
  • JMS
阅读更多
下载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中几个主要步骤。
具体涉及到一些细节后面将再写文章具体描述。

分享到:
评论
1 楼 ryanshaw 2012-08-23  
你好,请问您这样创建的MQ的jndiname是什么
还有destjnid是什么?

相关推荐

    openmq 编译依赖包

    OpenMQ,全称为Java Message Service (JMS) 提供者,是Oracle公司开发的一个开源消息中间件。它允许应用程序在分布式环境中发送、接收和存储消息,以实现异步通信和解耦。OpenMQ的编译过程涉及到多个依赖包,这些...

    openMq基本命令使用

    OpenMQ,全称为Java消息服务(Java Message Service)的一个实现,是Oracle公司提供的一款开源消息中间件。本文将详细介绍OpenMQ的基本管理命令,包括安装、集群配置、管理命令以及查看和操作队列与主题。 首先,让...

    habari-openmq-20190131-src.zip

    标题中的"habari-openmq-20190131-src.zip"表明这是一个源代码压缩包,发布日期为2019年1月31日,名为“habari”的项目,它与OpenMQ相关。OpenMQ是Oracle的开源消息中间件,用于处理应用程序之间的消息传递,提供...

    openmq-4.4.2

    OpenMQ 4.4.2是该软件的一个特定版本,它提供了稳定且高性能的消息传递服务。在这个版本中,用户可以获取到源代码,这对于开发者来说是一个宝贵的资源,因为可以通过深入研究源代码来理解其工作原理,进行自定义配置...

    OpenMQ_install_FCS

    除了平台特定的要求之外,OpenMQ 4.3 还依赖于一系列必需和可选的软件组件,包括 Java 运行时环境 (JRE) 和 Java 软件开发工具包 (JDK)。这些依赖关系详细记录在《Sun Java System Message Queue 4.3 发布说明》中的...

    大型系统中使用JMS优化技巧–Sun OpenMQ

    在传送过程中,系统处理JMS消息分为以下两类: ■ 有效负荷消息,由生成方发送给使用方的消息。 ■ 控制消息,代理与客户端运行时环境之间传送的私有消息,用于确保有效负荷消息成功传送和控制跨连接的消息流。 ...

    openmq:OpenMQ

    OpenMQ,全称为Oracle GlassFish Message Queue,是一个开源的消息中间件,它实现了Java消息服务(JMS)标准。OpenMQ是Oracle公司的一部分,主要用于在分布式系统中传递消息,确保数据的可靠传输和解耦应用程序。它...

    habari-openmq-6.1-installer.exe

    habari-openmq-6.1-installer.exe

    将Sun的Open Message Queue与Spring集成

    OpenMQ是Sun Java System Message Queue的一个开源版本,拥有企业级、可扩展性以及成熟稳定的特点。它提供了一套完整的JMS实现,并且具备Java System Message Queue的所有特性和性能。本文将详细介绍如何将Sun的Open...

    QBrowser for GlassFish JMS / WebLogic MQ-开源

    为 OpenMQ (GlassFish JMS) / Oracle WebLogic MQ 开发基于队列消息管理 gui 的工具。 工具名称为 QBrowserV2。 它旨在实现新消息创建/发送、删除消息、转发消息、订阅主题等功能。

    各种消息队列对比

    首先,社区活跃度是衡量一个开源项目成熟度和受关注程度的重要指标。ActiveMQ、RabbitMQ、RocketMQ均有着较高社区活跃度,拥有大量开源项目使用案例,且在相关社区文档和资源方面也较为丰富。 在成熟度方面,...

    java8集合源码分析-notes:读书笔记

    java8 集合源码分析 项目地址 #目录 自己做过的消息组件 [自己实现simple RPC](#自己实现simple RPC) [JDK NIO/BIO](#JDK NIOBIO) [JVM SandBox](#JVM ...OpenMQ ...JMS。...ZeroMQ(简称ZMQ)是一个基于消

    rabbitMQ文档

    6. **OpenMQ**:OpenMQ 是一个开源的消息中间件,提供多种消息传递模型,支持JMS API。 #### RabbitMQ详解 **RabbitMQ**是一款基于AMQP协议的消息中间件,提供了丰富的API接口以及强大的插件机制,能够满足各种...

    十种MQ的技术选型详细对比.docx

    - **RocketMQ**的前身是MetaQ,最初可以看作是LinkedIn的Kafka(Scala版)的一个Java版本,并在此基础上增加了事务支持。 - **RocketMQ**相对于原生Kafka的特点在于除了基本的日志收集功能外,还支持高可用(HA)、...

    ActiveMQ.zip

    ActiveMQ是Apache软件基金会开发的一款开源消息中间件,它是基于Java的,并且遵循开放消息传递协议(Open Message Broker Protocol,简称OpenMQ),广泛应用于分布式系统中的异步通信和解耦。ActiveMQ作为消息代理,...

    OOP_ISS_2term_tasks

    使用SOAP协议,创建一个Web服务,该服务使用RSA协议对给定消息进行加密(首先在数据库中找到接收者的公共密钥),然后将其发送给接收者的适当地址,而发送消息的客户端可以发送回复。 使用Web浏览器作为客户端应用...

    mq产品对比

    本文档基于一份关于消息队列(MQ)中间件的调研报告,对比分析了市场上流行的MQ产品。这些产品包括:ActiveMQ、RabbitMQ、RocketMQ、Joram、HornetQ、OpenMQ、MuleMQ、SonicMQ以及ZeroMQ。我们将从多个维度对这些产品...

    activeMq Api 文档

    队列遵循“一对一”模型,每个消息仅由一个消费者接收;主题遵循“一对多”模型,多个订阅者可以接收同一消息。 7. **持久化(Persistence)**:ActiveMQ支持消息的持久化,即使在服务器重启后,未被消费的消息也能...

    chef-glassfish:管理GlassFish的食谱

    项目中提供了一个带有Vagrantfile的示例项目,该文件可启动glassfish实例。 要求 平台: ubuntu Debian的 视窗 食谱: Java 授权 档案 刀具 运行 属性 node['glassfish']['user'] -GlassFish用户:GlassFish执行...

    rocket 以及客户端相关资源

    - **发布/订阅(Pub/Sub)模型**:一个消息可以有多个消费者,消息广播给所有订阅者。 4. **特性**: - **高吞吐量**:RocketMQ设计目标是每秒处理上百万条消息。 - **低延迟**:优化的网络通信和批量发送策略...

Global site tag (gtag.js) - Google Analytics