使用消息代理（如apache kafka）时
在本公司的最后一个项目中：客户提出身份验证等请求，应用程序第一层得到客户请求并在Kafka上生成消息，核心服务消费该消息后向银行服务提出rest请求，得到响应后在Kafka上生成响应消息，应用程序第一层将消息传递给客户。是真的Kafka用例，还是去掉第一层和Kafka，在客户端和核心之间使用rest服务更好。谢谢
共有1个答案
在第一步使用Kafaka进行验证不是一个好主意。理想情况下，消息队列应该用于应用程序的非关键部分。
这个问题将帮助您理解REST调用和消息队列之间的功能差异。您可以根据您的用例做出决定。
-
我已经创建了要将它们连接在一起的kstream。两个流的输出如下所示： 流1： 流2： 我想创建这两个Stream的连接流（内连接），所以我创建了以下KStream： 在这个KStream中，我只使用了一个连接，我正在更改输出消息的格式，仅此而已。 通过一个例子，我将解释我想做什么： 在窗口内发布以下消息： 流1 流2 加入流 出版的是什么 我想出版什么 总之，我只想在窗口中发布最新消息，而不是所
-
我已经用C语言编写了kafka消费者和生产者，使用的库是Library dkafka库。kafka代理版本是kafka_2.12-2.3.0。生产者正在成功生成消息，dr_msg_cb函数确认成功传递。但是，消费者没有收到来自代理的消息。有人能帮助进一步调试吗？ 我可以看到，从消费者到代理的TCP连接已经建立。但TCPdump显示代理并没有向消费者发送任何数据。我在消费者代码上启用了调试，下面是消
-
我想使用Spring消息为我的webapp的登录用户创建一个实时通知系统。 我定义了一个如下： 根据文件规定： 应用程序可以发送针对特定用户的消息。Spring的STOMP支持识别前缀为“/user/”的目的地。例如，客户机可能订阅目标“/用户/队列/位置更新”。此目的地将由UserDestinationMessageHandler处理，并转换为用户会话特有的目的地，例如“/queue/posit
-
每当我试图将消息从esb发布到消息代理的主题时，我都会收到此错误 我的代理代码是 我的jndi配置和axis 2配置配置正确。我的MB在端口9444上运行，Publisher_esb在端口9443上运行，subscriber esb在端口9446上运行。当我使我的订阅者保持活动状态时，如果我从我的发布者发布一条消息，该消息会反映到订阅者。 从订户获取消息的代码是 当我第一次运行订阅者时，它给了我结
-
我们有一个应用程序，它使用来自Kafka主题（3个分区）的消息，丰富数据，并将记录保存在DB（Spring JPA）中，然后将消息发布到另一个Kafka主题（在同一个代理上），所有这些都通过使用Camel 2.4.1和Spring Boot 2.1.7进行编排。释放 我们想为 kafka 消费者-生产者组合实现“exactly-once”语义。 消费者设置： 生产者设置： 豆接线： 骆驼路线： 但
-
它提供的Swagger UI和rest API规范给了我灵感。 最近，我开始使用消息代理（特别是RabbitMQ），我希望有一些工具来开始开发具有消息和队列规范的面向微服务的系统。 是否有任何工具允许制作这些规范？从代码生成文档还是从模型生成代码？ 提前感谢！ 更新: 如本文所述。队列，交换，填充，用户和权限可以用RabbitMQ配置文件来描述。 AsyncAPI 看起来是一个很好的解决方案