当前位置: 首页 > 知识库问答 >
问题:

具有微服务的RabbitMQ-如何处理扩展的服务?

仲孙鸣
2023-03-14

示例:
                              >>>服务B(获取消息
服务A>推送消息>>>服务B(不应接收消息,已复制)
                        >>>服务C(获取消息)

我认为它是“路由”和“工作队列”的组合,我需要什么?
但我怎样才能正确地做到这一点呢?我使用node.js或C#(如果您有示例的话)。

共有1个答案

蒲功
2023-03-14

我有我的微服务和DDD信息在这里。看一看

如果您想要将事件发布到一个特殊的服务,那么您应该使用一个服务总线。我使用nServiceBus。它是.NET中最好的工具。RabbitMQ只是一个队列。在NServiceBus内部,您可以使用许多不同的队列,如RabbitMQ、SqlServer等

现在对于您的示例,服务A发布一个事件,比方说UserCreated。服务B有一个EventHandler作为UserCreateDeventHandler。则服务B可以获得UserCreated的任何已发布事件。NServiceBus具有自动订阅和消息路由,以了解在什么事件上订阅了什么服务。他们的文件完全是完整的。看看他们

 类似资料:
  • 问题内容: 我还很陌生,因此无法找到任何文档或示例。我要做的是扩展基本服务,以便可以使用其他服务在基本服务下定义的方法。例如,说我有如下基本服务。 现在,我想定义一个从上述扩展的扩展服务,以便可以使用扩展服务中BasicService下定义的方法。也许像这样: 问题答案: 您应该注入以便能够访问它。旁边是对象文字,因此您实际上不能将其称为函数()。

  • 我有一堆在唯一端口中运行的Spring启动微服务。我们如何在生产中处理这些微服务? 在生产中,我们只需要DNS,如何处理DNS映射。 例如:示例微服务-1(端口:8001) 示例微服务-2(端口:8002) 示例微服务-3(端口:8003) 示例微服务-4(端口:8004) 示例微服务-5(端口:8005) 我想要下面的东西, myprod。com/example-microservice-1 m

  • 本文向大家介绍微服务中的反应性扩展是什么?相关面试题,主要包含被问及微服务中的反应性扩展是什么?时的应答技巧和注意事项,需要的朋友参考一下 Reactive Extensions 也称为Rx。这是一种设计方法,我们通过调用多个服务来收集结果,然后编译组合响应。这些调用可以是同步或异步,阻塞或非阻塞。 Rx 是分布式系统中非常流行的工具,与传统流程相反。  

  • 问题:假设有两个服务 A 和 B,服务 A 对服务 B 进行 API 调用。一段时间后,服务A因网络错误而掉落或丢失。 另一个服务将如何猜测来自服务A的出站呼叫丢失/从未发生?我需要另一个并发应用程序,如果服务A出站呼叫丢失,它将自动响应(运行紧急代码)。 存在哪些尖端解决方案? 例如,我的想法: 服务 A 在某些中间件中注册调用事件(事件信息、“正在运行”状态、时间戳等)。 如果此调用在 N 秒

  • 最近在做微服务的开发,突然发现一个问题,就是微服务好像是每个服务对应一个数据库,那么,微服务之间如果存在关联查询的话,那怎么做跨库查询呢?

  • 我读了一些文章,看了一些视频,但在为这些微服务提供服务方面,没有找到具体的建议。我的理解是,他们应该使用自己的应用程序服务器。 我的问题是它们应该部署在不同的服务器上,还是没关系。 当它们在同一台服务器(计算机)上提供服务时,不会有端口冲突吗?