代码之家 › 专栏 › 技术社区 › Dominik Heim

RabbitMQ-如何将2条异步消息作为消费微服务来处理?[已关闭]

microservices message-queue rabbitmq c# java

-1

Dominik Heim · 技术社区 · 7 年前

我有一个问题,就是寻找解决问题的最佳方法。我们目前正致力于用微服务架构取代我们的软件整体。

我们希望使用消息队列作为不同微服务之间的通信。

我们的一个微服务(邮件服务)需要在收到来自两个或多个微服务的两条消息后做出反应。第一条消息提供有关已下订单的信息。它提供有关电子邮件内容和收件人的信息,第二条消息提供指向附件的链接,电子邮件应包括。

邮件服务应该等到收到这两条消息。目前,我计划将所有消息存储到数据库中(每条消息一个表),并每5秒钟检查一次是否存在这两个信息以及是否可以发送电子邮件。

但我觉得RabbitMQ可能也提供了一种方法,所以我不需要自己开发来避免这两条消息之间的竞争条件。

你会用什么方法来解决这个问题?

1 回复 | 直到 7 年前

user9244629 user9244629 7 年前

我会更改消息模式,以便您有三条消息;

这样,您就不必每隔x秒检查一次数据库,并且可以非常便宜地扩展消息工作流。

希望有帮助:)

推荐文章

junsung kang · Cassandra突然挂起,返回WindowsFileSystemException:“该进程不可访问,因为该文件正被另一个进程使用”

1 年前

vaibhav nalamalpu · Intellij 2023.1无法打开(即使在重新安装后)[关闭]

1 年前

Katlock · 如何在Spring中将Restpage转换为特定的对象类型?

1 年前

Edward Khazzoum · 为什么在H2数据库中创建表时出现错误4201-214?

1 年前

Yellow Blood · If语句在应为[重复]时未返回True

1 年前

user21749640 · List.contents(A)返回false,但List.contens(B)和B.equals(A)是否返回true?

1 年前

MysticSticker · 如何在savedPreferences中保存按钮[]文本

1 年前

Pektra Mom · 如何将数组中的所有字符串替换为特定的特殊字符

1 年前

Nitin Kshirsagar · 在谷歌云上将java8迁移到java11/17是强制性的吗

1 年前

changhoon seong · 为什么这个代码没有按照我想的方式输出?(关于班次)

1 年前