我想知道我对消息总线和消息队列工作原理的理解是否正确。
首先，我需要明确命名，服务巴士可以与以下互换使用消息总线？这是一种发布者-订阅者类型的系统，其中消息被添加到任意数量的发布者的消息集合中，并且任意数量的订阅者可以从中读取消息，到目前为止我是对的吗？
P1 --- /``````S1
\________ Service Bus Middleware ------+------ S2
/ MESSAGE-COLLECTION \______S3
P2 ---
我不明白的是
订阅者如何知道它感兴趣的消息，我的意思是它显然订阅了它，但是它如何知道它应该订阅哪条消息？，它在哪里看到消息列表，它如何使用它？通过 API 或如何？
订阅者如何接收消息？
何时从 MESSAGE-COLLECTION 中删除消息？我可以想象的是，为每条消息保留一些计数器，该计数器代表订阅者的总数，一旦一个订阅者成功处理该消息，该计数器就会递减。
A 消息队列也称为消息代理是一种推拉式系统。有任意数量的生产者和任意数量的消费者。每个生产者为每个消费者创建一个队列，并向其提供消息。
--- Message Queue 1 ---- C1
/
P1 ------ +
\
--- Message Queue 2 ---- C2
P2 ------ + --- Message Queue 1 ---- C1
在这种情况下，一旦消费者成功处理该消息，该消息就会被删除。是我的消息队列对其工作原理的理解正确吗？
我不确定到底是什么的另一个概念是活动中心.
我想知道我对消息总线和消息队列工作原理的理解是否正确。
一些评论/答案。这并不全面，因为许多方面都是特定于所使用的队列的。
服务总线与消息总线可以互换使用吗？
正确的。服务总线是面向服务的解决方案中使用的消息总线基础设施，提供服务之间的后端数据传输机制。
它是一种发布者-订阅者类型的系统，其中消息被添加到任意数量的发布者的消息集合中，并且任意数量的订阅者都可以从中读取消息
一般有两种型号：
-
发布/订阅，发布者将数据发送到总线，而无需考虑特定目标。然后，一个或多个订阅者可以使用该消息（或不使用，请参见下文）。
-
请求/响应，发送方将数据发送到总线，但期望特定的接收方处理消息并返回响应。
订阅者如何知道他对什么消息感兴趣......？
大多数服务总线实现都使用路由键的概念。发送到总线的每个数据实体都附有一个密钥，订阅者可以根据该密钥进行过滤。
当然，订阅者也可以选择获取发布到特定队列的所有消息。
订阅者如何接收消息？
这因服务队列产品而异。例如，在 RabbitMQ 中，消息通过 API 传递给订阅者，而在 Kafka 中，客户端必须定期轮询服务器以获取消息。
何时从 MESSAGE-COLLECTION 中删除消息？
有时根本不是。这在产品和配置之间也有所不同。有时，消息仅传递给一个接收者，并在确认传递后被删除，但有时消息会留在总线上，直到根据时间戳过期为止。许多场景都是可能的。
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)
