4

我想知道我对消息总线和消息队列工作的理解是否正确。

首先，我需要清除命名，服务总线与消息总线可以互换使用？它是一种发布者-订阅者类型的系统，其中消息被添加到任意数量的发布者的消息集合中，并且任意数量的订阅者都可以从中读取，到目前为止我是对的吗？

P1 ---                                         /``````S1
       \________ Service Bus Middleware ------+------ S2
       /           MESSAGE-COLLECTION          \______S3
P2 ---

我不明白的是

  1. 订阅者如何知道它感兴趣的消息，我的意思是它显然订阅了它，但是它如何知道它应该订阅哪些消息？，它在哪里看到消息列表，它如何获得它? 通过 API 或如何？

  2. 订阅者如何接收消息？

  3. 何时从 MESSAGE-COLLECTION 中删除消息？我可以想象的是，为每条消息保留了一些计数器，该计数器表示订阅者的总数，一旦一个订阅者成功处理了该消息，它就会减少。

消息队列也称为消息代理，是一种推拉式系统。有任意数量的生产者和任意数量的消费者。每个生产者为每个消费者创建一个队列，向其提供消息。

             --- Message Queue 1 ---- C1
           /  
P1 ------ +
           \ 
             --- Message Queue 2 ---- C2


P2 ------ + --- Message Queue 1 ---- C1

由于是这种情况，一旦消费者成功处理该消息，该消息就会被删除。我的消息队列对其工作原理的理解是否正确？

我不确定的另一个概念是event hub。

4

1 回答 1

2

我想知道我对消息总线和消息队列工作的理解是否正确。

一些评论/答案。这不会是全面的，因为许多方面都特定于正在使用的队列。

服务总线与消息总线可互换使用？

正确的。服务总线是用于面向服务的解决方案中的消息总线基础设施，提供服务之间的后端数据传输机制。

它是一种发布者-订阅者类型的系统，其中消息被添加到任意数量的发布者的消息集合中，并且任意数量的订阅者都可以从中读取

一般有两种型号：

1) 发布/订阅，发布者在没有特定目标的情况下将数据发送到总线。然后一个或多个订阅者可以使用该消息（或不使用，见下文）。

2) 请求/响应，发送者将数据发送到总线，但希望接收到特定的数据来处理消息并返回响应。

订阅者如何知道它对什么消息感兴趣...？

大多数服务总线实现都使用路由键的概念。发送到总线的每个数据实体都附有一个密钥，然后订阅者可以通过该密钥进行过滤。

当然，订阅者也可以选择将所有消息发布到特定队列。

订阅者如何接收消息？

这因服务队列产品而异。例如，在 RabbitMQ 中，消息通过 API 传递给订阅者，而在 Kafka 中，客户端必须定期轮询服务器以获取消息。

何时从 MESSAGE-COLLECTION 中删除消息？

有时根本没有。这也因产品和配置而异。有时，一条消息仅传递给一个接收者，并在确认传递后被删除，但有时消息会留在总线上，直到它们根据时间戳过期。许多情况都是可能的。

于 2019-08-05T07:22:38.000 回答