`
maosheng
  • 浏览: 566255 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

Apache ActiveMQ 介绍

阅读更多
一、下载部署

1、下载

http://activemq.apache.org/

2、安装

直接解压至任意目录

3、启动ActiveMQ服务器

直接运行bin\activemq.bat

4、ActiveMQ消息管理后台系统:
http://localhost:8161/admin
user/password:  admin/admin

二、运行附带的示例程序

1、Queue消息示例:

* 启动Queue消息消费者

cd example

ant consumer

* 启动Queue消息生产者

cd example

ant producer

简要说明:生产者(producer)发消息,消费者(consumer)接消息,发送/接收2000个消息后自动关闭

2、Topic消息示例:

* 启动Topic消息消费者

cd example

ant topic-listener

* 启动Topic消息生产者

cd example

ant topic-publisher

简要说明:重复10轮,publisher每轮发送2000个消息,并等待获取listener的处理结果报告,然后进入下一轮发送,最后统计全局发送时间。


三、Point-to-Point (点对点)消息模式开发流程

1、生产者(producer)开发流程(ProducerTool.java):

1.1 创建Connection:

根据url,user和password创建一个jms Connection。

1.2 创建Session:

在connection的基础上创建一个session,同时设置是否支持事务和ACKNOWLEDGE标识。

1.3 创建Destination对象:

需指定其对应的主题(subject)名称,producer和consumer将根据subject来发送/接收对应的消息。

1.4 创建MessageProducer:

根据Destination创建MessageProducer对象,同时设置其持久模式。

1.5 发送消息到队列(Queue):

封装TextMessage消息,使用MessageProducer的send方法将消息发送出去。


2、消费者(consumer)开发流程(ConsumerTool.java):

2.1 实现MessageListener接口:

消费者类必须实现MessageListener接口,然后在onMessage()方法中监听消息的到达并处理。

2.2 创建Connection:

根据url,user和password创建一个jms Connection,如果是durable模式,还需要给connection设置一个clientId。

2.3 创建Session和Destination:

与ProducerTool.java中的流程类似,不再赘述。

2.4创建replyProducer【可选】:

可以用来将消息处理结果发送给producer。

2.5 创建MessageConsumer:

根据Destination创建MessageConsumer对象。

2.6 消费message:

在onMessage()方法中接收producer发送过来的消息进行处理,并可以通过replyProducer反馈信息给producer

四、Publisher/Subscriber(发布/订阅者)消息模式开发流程

1、订阅者(Subscriber)开发流程(TopicListener.java):

1.1 实现MessageListener接口:

在onMessage()方法中监听发布者发出的消息队列,并做相应处理。

1.2 创建Connection:

根据url,user和password创建一个jms Connection。

1.3 创建Session:

在connection的基础上创建一个session,同时设置是否支持事务和ACKNOWLEDGE标识。

1.4 创建Topic:

创建2个Topic, topictest.messages用于接收发布者发出的消息,topictest.control用于向发布者发送消息,实现双方的交互。

1.5 创建consumer和producer对象:

根据topictest.messages创建consumer,根据topictest.control创建producer。

1.6 接收处理消息:

在onMessage()方法中,对收到的消息进行处理,可直接简单在本地显示消息,或者根据消息内容不同处理对应的业务逻辑(比如:数据库更新、文件操作等等),并且可以使用producer对象将处理结果返回给发布者。


2、发布者(Publisher)开发流程(TopicPublisher.java):

2.1 实现MessageListener接口:

在onMessage()方法中接收订阅者的反馈消息。

2.2 创建Connection:

根据url,user和password创建一个jms Connection。

2.3 创建Session:

在connection的基础上创建一个session,同时设置是否支持事务和ACKNOWLEDGE标识。

2.4 创建Topic:

创建2个Topic,topictest.messages用于向订阅者发布消息,topictest.control用于接收订阅者反馈的消息。这2个topic与订阅者开发流程中的topic是一一对应的。

2.5 创建consumer和producer对象:

根据topictest.messages创建publisher;

根据topictest.control创建consumer,同时监听订阅者反馈的消息。

2.6 给所有订阅者发送消息,并接收反馈消息:

示例代码中,一共重复10轮操作。

每轮先向所有订阅者发送2000个消息;

然后堵塞线程,开始等待;

最后通过onMessage()方法,接收到订阅者反馈的“REPORT”类信息后,才print反馈信息并解除线程堵塞,进入下一轮。

注:可同时运行多个订阅者测试查看此模式效果







分享到:
评论

相关推荐

    apache-activemq Linux版本

    Apache ActiveMQ是业界广泛使用的开源消息中间件,尤其在Linux环境下表现出色。它基于Java语言开发,遵循Apache软件基金会的许可证,并且实现了多种消息传递协议,包括OpenWire、STOMP、AMQP和XMPP等。在Linux系统上...

    apache-activemq-5.16.5

    Apache ActiveMQ是业界广泛使用的开源消息中间件,它基于Java消息服务(JMS)标准,提供了高度可扩展、可靠的异步通信能力。标题"apache-activemq-5.16.5"指的是该软件的一个特定版本,即5.16.5版本,通常每个新版本...

    apache-activemq-5.10.0.zip

    **一、Apache ActiveMQ介绍** ActiveMQ作为Apache软件基金会的一部分,它是一个开源的消息中间件,能够处理各种类型的消息模式,如点对点、发布/订阅和请求/响应。它支持多种协议,包括开放标准的JMS、STOMP、AMQP...

    apache-activemq-5.15.9.rar

    Apache ActiveMQ是Apache软件基金会开发的一个开源消息中间件,它基于Java Message Service (JMS) 规范,提供高效、可靠的消息传递服务。在本文中,我们将深入探讨Apache ActiveMQ,特别是针对“apache-activemq-...

    Apache+ActiveMQ教程

    Apache ActiveMQ 是一款高度可扩展且功能强大的消息中间件,它是Apache软件基金会的一部分,完全开源且免费。Apache ActiveMQ 在Java消息服务(JMS)领域扮演着重要角色,为分布式系统提供可靠的消息传递机制。本...

    apache-activemq-5.9.0-bin

    Apache ActiveMQ是世界上最流行的开源消息代理和队列服务器,它基于Java Message Service(JMS)规范,为分布式系统提供高效、可靠和可扩展的消息传递功能。这个“apache-activemq-5.9.0-bin”压缩包包含了Apache ...

    apache-activemq-5.12.0.zip

    1. **Apache ActiveMQ介绍**:ActiveMQ是一个完全支持JMS 1.1和1.0.2B规范的消息中间件,提供可靠的消息传递和高效的数据通信。它支持多种协议,包括OpenWire、STOMP、AMQP、XMPP、MQTT等,使得不同的应用程序和平台...

    JMS Apache ActiveMQ 安装包

    Apache ActiveMQ JMS实现

    Apache ActiveMQ 入门最简单例子

    Apache ActiveMQ 是一款开源的消息中间件,它是Apache软件基金会下的顶级项目,被广泛应用于构建分布式系统中的消息传递。在本文中,我们将深入探讨如何通过Apache ActiveMQ 5.8版本进行入门,以及如何构建一个简单...

    apache-activemq-5.17.3

    Apache ActiveMQ是开源的、基于Java消息服务(JMS)的应用服务器,它是Apache软件基金会的一部分。这个名为"apache-activemq-5.17.3"的压缩包包含了ActiveMQ的5.17.3版本,这是一个稳定且功能丰富的发布版本。在深入...

    apache-activemq-5.10到apache-activemq6.1大版本合集

    apache-activemq-5.10.2-bin.tar.gz apache-activemq-5.11.4-bin.zip apache-activemq-5.12.3-bin.zip apache-activemq-5.13.5-bin.zip apache-activemq-5.14.5-bin.zip apache-activemq-5.15.9-bin.zip apache-...

    linux 下apache-activemq.zip

    Apache ActiveMQ是开源的、基于Java消息服务(JMS)的应用服务器,它是Apache软件基金会的一部分。在Linux环境下配置和使用Apache ActiveMQ对于许多企业和开发者来说是至关重要的,因为Linux提供了稳定且安全的基础...

    Instant Apache ActiveMQ Messaging Application Development How-to源码

    Apache ActiveMQ是Apache软件基金会开发的一个开源消息中间件,它基于Java消息服务(JMS)规范,用于在分布式系统中实现可靠的消息传递。本指南主要关注如何使用ActiveMQ开发消息应用,通过`Instant Apache ActiveMQ...

    apache-activemq-5.8.0-bin.zip

    Apache ActiveMQ是Apache软件基金会开发的一个开源消息中间件,它基于Java Message Service(JMS)规范,用于在分布式系统中高效地传输数据。这个压缩包"apache-activemq-5.8.0-bin.zip"包含了ActiveMQ 5.8.0版本的...

    ( apache-activemq-5.13.0-bin.zip )

    Apache ActiveMQ是Apache软件基金会开发的一个开源消息中间件,它基于Java Message Service(JMS)规范,用于在分布式系统中高效地处理、路由和传递消息。这个`( apache-activemq-5.13.0-bin.zip )`压缩包包含了...

    apache-activemq-5.15.3-bin.tar.gz

    Apache ActiveMQ是开源的、基于Java消息服务(JMS)的Message Broker,它允许应用程序之间进行异步通信。这个压缩包“apache-activemq-5.15.3-bin.tar.gz”包含了Apache ActiveMQ 5.15.3版本的源代码和可执行文件,...

    apache-activemq-5.13.0-bin.tar.gz

    Apache ActiveMQ是世界上最流行的开源消息代理和集成模式服务器,它基于Java Message Service (JMS)规范,提供了一种高效、灵活、可靠的消息传递解决方案。在"apache-activemq-5.13.0-bin.tar.gz"这个压缩包中,包含...

    apache-activemq-5.0.0.rar

    1. **Apache ActiveMQ介绍**: - Apache ActiveMQ 是一个高性能、可伸缩、可靠的消息传递平台,支持多种协议,包括OpenWire、STOMP、XMPP、AMQP以及MQTT。 - 它遵循JMS 1.1规范,提供了消息持久化、事务处理、网络...

    apache-activemq-5.11.2 附全解教程

    Apache ActiveMQ是Apache软件基金会的一款开源消息中间件,它遵循开放消息传递协议(Open Message Broker,JMS)标准,提供高效、可靠的消息传递服务。在本教程中,我们将深入探讨Apache ActiveMQ 5.11.2版本的核心...

    基于Java的Apache ActiveMQ高性能消息中间件设计源码

    该项目为Apache ActiveMQ高性能消息中间件设计源码,采用Java语言编写,总计包含5357个文件,其中Java源文件4383个,XML配置文件340个,属性文件82个,HTML文件77个,JavaScript文件35个,Markdown文件31个,PNG图片...

Global site tag (gtag.js) - Google Analytics