ActiveMQ消息发送模式

作者: Xiangdong_She | 来源:发表于2017-05-17 10:52 被阅读59次
    1. 点对点方式(point-to-point)

    点对点的消息发送方式主要建立在Produce, Message Queue, Consumer上,Message Queue 存贮消息,Produce发送消息,Consumer接收消息。
    具体点就是Produce Client发送Message Queue ,而 Consumer Cliernt从Queue中接收消息并且"发送消息已接受"到Queue,确认消息接收。
    消息发送客户端与接收客户端没有时间上的依赖,发送客户端可以在任何时刻发送信息到Queue,而不需要知道接收客户端是不是在运行;

    2. 发布/订阅 方式(publish/subscriber Messaging)

    发布/订阅方式用于多接收客户端的方式,作为发布订阅的方式,可能存在多个接收客户端,并且接收端客户端与发送客户端存在时间上的依赖。一个接收端只能接收他创建以后发送客户端发送的信息。作为subscriber ,在接收消息时有两种方法,destination的receive方法,和实现message listener 接口的onMessage 方法。

    消息发送与接收

    发送消息的基本步骤:
    • 获取生产连接的连接工厂JMS ConnectionFactory
    • 使用管理对象JMS ConnectionFactory建立连接Connection,并启动
    • 使用连接Connection 建立会话Session
    • 使用会话Session和管理对象Destination创建消息生产者MessageProducer
    • 使用消息生产者MessageProducer发送消息
    接收消息的基本步骤:
    • 获取连接工厂JMS ConnectionFactory
    • 从连接工厂获取连接Connection
    • 使用Connection创建会话Session
    • 使用会话Session和管理对象Destination创建消息消费者MessageConsumer
    • 使用MessageConsumer接收消息

    相关文章

      网友评论

        本文标题:ActiveMQ消息发送模式

        本文链接:https://www.haomeiwen.com/subject/ebxdxxtx.html