JMS学习

Posted 2020-11-03 hangzhi

转自：https://blog.csdn.net/jiuqiyuliang/article/details/46701559

1.基本概念

JMS是java的消息服务，JMS的客户端之间可以通过JMS服务进行异步的消息传输。

2.消息模型

P2P

Pub/Sub

3.P2P

　　模式：

1. 消息队列（Queue）
2. 发送者(Sender)
3. 接收者(Receiver)
4. 每个消息都被发送到一个特定的队列，接收者从队列中获取消息。队列保留着消息，直到他们被消费或超时。

 　　特点

1. 每个消息只有一个消费者（Consumer）(即一旦被消费，消息就不再在消息队列中)
2. 发送者和接收者之间在时间上没有依赖性，也就是说当发送者发送了消息之后，不管接收者有没有正在运行，它不会影响到消息被发送到队列
3. 接收者在成功接收消息之后需向队列应答成功

4.Pub/Sub

　模式图

1. 主题（Topic）
2. 发布者（Publisher）
3. 订阅者（Subscriber）
   客户端将消息发送到主题。多个发布者将消息发送到Topic,系统将这些消息传递给多个订阅者。

　　特点：

1. 每个消息可以有多个消费者
2. 发布者和订阅者之间有时间上的依赖性。针对某个主题（Topic）的订阅者，它必须创建一个订阅者之后，才能消费发布者的消息，而且为了消费消息，订阅者必须保持运行的状态。
3. 为了缓和这样严格的时间相关性，JMS允许订阅者创建一个可持久化的订阅。这样，即使订阅者没有被激活（运行），它也能接收到发布者的消息。

5.JMS编程模型

　　1.ConnectionFactory：创建connection的工厂，针对两种不同的消息模型，有QueueConnectionFactory和TopicConnectionFactory

　　2.Destination：对于生产者来说它的destination是某个queue或topic；对于消费者来说它的destination也是

　　3.Connection：表示在客户端和JMS系统之间建立的连接（对TCP/IP socket的包装）；connection可以产生多个session；connection有QueueConnection和TopicConnection两种

　　4.session：操作消息的接口，可通过session创建生产者/消费者/消息等；session 提供了事物的功能；当我们要使用session发送/接收多个消息时，可将这些动作放到一个事物中；有QueueSession和TopicQueue两种

　　5.消息的生产者：消息生产者由Session创建，并用于将消息发送到Destination。同样，消息生产者分两种类型：QueueSender和TopicPublisher。可以调用消息生产者的方法（send或publish方法）发送消息。

　　6.消息的消费者：消息消费者由Session创建，用于接收被发送到Destination的消息。两种类型：QueueReceiver和TopicSubscriber。可分别通过session的createReceiver(Queue)或createSubscriber(Topic)来创建。当然，也可以session的creatDurableSubscriber方法来创建持久化的订阅者。

　　7.MessageListener：消息监听器。如果注册了消息监听器，一旦消息到达，将自动调用监听器的onMessage方法

6.好处

　　1.提供消息灵活性

　　2.松散耦合

　　3.异步性