标签:inf 传递 就是 http 注册 发布订阅 src 没有 img
JMS是java的消息服务,JMS的客户端之间可以通过JMS服务进行异步的消息传输。
○ Point-to-Point(P2P) --- 点对点 ○ Publish/Subscribe(Pub/Sub)--- 发布订阅 |
即点对点和发布订阅模型
1、P2P
2、涉及到的概念
3、P2P的特点
如果你希望发送的每个消息都应该被成功处理的话,那么你需要P2P模式。
A用户与B用户发送消息
Pub/Sub模式图
涉及到的概念
主题(Topic)
发布者(Publisher)
订阅者(Subscriber)
客户端将消息发送到主题。多个发布者将消息发送到Topic,系统将这些消息传递给多个订阅者。
Pub/Sub的特点
每个消息可以有多个消费者
发布者和订阅者之间有时间上的依赖性。针对某个主题(Topic)的订阅者,它必须创建一个订阅者之后,才能消费发布者的消息,而且为了消费消息,订阅者必须保持运行的状态。
为了缓和这样严格的时间相关性,JMS允许订阅者创建一个可持久化的订阅。这样,即使订阅者没有被激活(运行),它也能接收到发布者的消息。
如果你希望发送的消息可以不被做任何处理、或者被一个消息者处理、或者可以被多个消费者处理的话,那么可以采用Pub/Sub模型
消息的消费
在JMS中,消息的产生和消息是异步的。对于消费来说,JMS的消息者可以通过两种方式来消费消息。
○ 同步
订阅者或接收者调用receive方法来接收消息,receive方法在能够接收到消息之前(或超时之前)将一直阻塞
○ 异步
订阅者或接收者可以注册为一个消息监听器。当消息到达之后,系统自动调用监听器的onMessage方法。
用户注册、订单修改库存、日志存储
画图演示
发布订阅模式:
消息容器 类似队列
队列里面存放多个消息,消息容器里面可以存放多个队列
原则: 先进先出原则
生产者 消费者 消息容器
消费者和消息容器建立长链接 一旦生产者发布消息后 推送退给 消费者(监听)
如果消费者宕机了,消息会丢失吗?
不会的。原因消息存在队列里面的。队列中存放消息,如果消费者没有及时消费的话,都会存放在消息队列中。
消息中间件可以解决高并发问题,流量削锋问题,如果生产者上产一万个消息,消费者每次只能一千个消息消费。
整个过程属于异步方式的。
1、生产者发送一条消息到queue,只有一个消费者能收到 (一对一模式)
2、客户端包括生产者和消费者 队列中的消息只能被一个消息消费者消费
消息消费者可以随时消费队列中的消息
1、发布者发送套tipic的消息,只有订阅了topic的订阅者才会收到消息
1 特性:
客户端暴扣发布者和订阅者
主题中的消息被所有订阅者消费
消费者不能消费订阅之前就发送到主题中的消息
发布订阅和点对点通讯方式的却别:
点对点 只能保证一个消费者进行消费
发布订阅 只要集群服务订阅该主题都会收到消息 一对多
下次队列指的是生产者与消费者传递数据
队列里存放消息集合
消息中间件包括 消息队列 和 发布订阅
标签:inf 传递 就是 http 注册 发布订阅 src 没有 img
原文地址:https://www.cnblogs.com/toov5/p/9936517.html