标签：订阅 消费者 生产者 activeMQ 消息 activemq

 

 

 

官网：http://activemq.apache.org/

 

 

1 activeMQ是什么？作用域范围？

2 jms说明

JMS的全称是Java Message Service，即Java消息服务。用于在两个应用程序之间，或分布式系统中发送消息，进行异步通信；

它主要用于在生产者和消费者之间进行消息传递，生产者负责产生消息，而消费者负责接收消息。把它应用到实际的业务需求中的话我们可以在特定的时候利用生产者生成一消息，并进行发送，对应的消费者在接收到对应的消息后去完成对应的业务逻辑。

 

3 activeMQ的两种消息形式

 

1）、对于消息的传递有两种类型。
　　　　a）、一种是点对点的，即一个生产者和一个消费者一一对应。
　　　　b）、另一种是发布/订阅模式，即一个生产者产生消息并进行发送后，可以由多个消费者进行接收。

 

2）、JMS定义了五种不同的消息正文格式，以及调用的消息类型，允许你发送并接收以一些不同形式的数据，提供现有消息格式的一些级别的兼容性。
　　　　a)、 StreamMessage -- Java原始值的数据流。
　　　　b)、 MapMessage--一套名称-值对。
　　　　c)、 TextMessage--一个字符串对象。
　　　　d)、 ObjectMessage--一个序列化的 Java对象。
　　　　e)、 BytesMessage--一个字节的数据流。

 

4 activeMQ安装

官网：http://activemq.apache.org/

注：需安装jdk1.7以上版本；



tar xvf apache-activemq-5.15.13-bin.tar.gz 
# ./bin/activemq start
# ./activemq status
# ./activemq stop

　　

Home是当前的欢迎页，Queues是点到点形式，Topics是发布订阅模式，Subscribers话题消息的发布与订阅，Connections客户端链接，Network当前网络的链接状态，Scheduled计划任务，Send可以测试发送消息。

 

 

 

5 activeMQ的使用方法，jms消息发送模式

 

注：
   1）在点对点或队列模型下，一个生产者向一个特定的队列发布消息，一个消费者从该队列中读取消息。这里，生产者知道消费者的队列，并直接将消息发送到消费者的队列。这种模式被概括为：只有一个消费者将获得消息。生产者不需要在接收者消费该消息期间处于运行状态，接收者也同样不需要在消息发送时处于运行状态。每一个成功处理的消息都由接收者签收。
  2）发布者/订阅者模型支持向一个特定的消息主题发布消息。0或多个订阅者可能对接收来自特定消息主题的消息感兴趣。在这种模型下，发布者和订阅者彼此不知道对方。这种模式好比是匿名公告板。这种模式被概括为：多个消费者可以获得消息，在发布者和订阅者之间存在时间依赖性。发布者需要建立一个订阅（subscription），以便客户能够购订阅。订阅者必须保持持续的活动状态以接收消息，除非订阅者建立了持久的订阅。在那种情况下，在订阅者未连接时发布的消息将在订阅者重新连接时重新发布。

 

 

6 jms应用程序接口

7 如何使用java操作activeMQ呢，把ActiveMQ依赖的jar包添加到工程中

8 ActiveMQ点对点模式（point-to-point）

 

标签：订阅,消费者,生产者,activeMQ,消息,activemq
来源： https://www.cnblogs.com/Alexr/p/13253951.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。