Spring-Cloud-Stream请求回复消息模式
是否有一个请求-回复模式应该与spring-cloud-stream一起使用？我在spring-cloud-stream上能找到的所有留档都面向MessageChannel.send即发即弃类型的生产者，我熟悉spring-集成中的@MessagingGateway，但我不确定这将如何与spring-cloud-stream一起使用。当您有一个REST POSTendpoint来保存具有分配标识符的实体并且您需要将分配的标识符返回给调用者时，这将很有用，但您仍然希望使用消息传递。
共有1个答案
目前，spring cloud stream中没有任何请求/应答的概念。
将其视为unix管道的一个类比，其中每个“应用程序”或微服务都会获取一些输入并将其转发到管道中的下一个元素。
考虑一个独立的Spring启动应用程序，将Spring集成用于请求/回复场景。当然，该应用程序可以使用s-c-s来完成其工作。
-
我开发了spring批处理应用程序，该应用程序生成由json对象列表组成的amqp（rabbitmq）消息。消息具有包含一些元数据的标头。Spring cloud stream应用程序正在消费消息，我使用了功能性方法。如何访问标题<将消息头用于除路由之外的任何内容，这是一种糟糕的方法吗？
-
在我们的spring boot应用程序中，我们注意到Kafka消费者偶尔会在prod env中随机消费两次消息。我们在PCF中部署了6个实例和6个分区。我们发现在同一主题中收到两次具有相同偏移量和分区的消息，这会导致重复，对我们来说是业务关键。我们在非生产环境中没有注意到这一点，在非生产环境中很难复制。我们最近转向Kafka，但我们无法找到根本问题。 我们使用的是spring cloud stre
-
我已经实现了如下所示的示例Spring Dynamic Destination 在rabbitmq中，它动态地创建一个交换，但没有提供绑定或路由密钥的选项。我的要求是用路由密钥向这个动态创建的exchange发送消息。我需要如何实现这一点来设置路由密钥？
-
有没有办法配置默认消息 或 在上面的示例中，
-
我正在使用Kafka活页夹的Spring Cloud Stream。它工作得很好，但客户端接收到重复的消息。已经尝试了所有Kafka消费属性，但没有结果。 在我的应用程序示例中检查2个类-Aggregate Application和EventFilterApplication。如果我运行EventFilterApplication-只有1条消息，如果是Aggregate Application-2
-
我正在使用IBM MQ构建应用程序。建议使用spring cloud stream来构建它。我在许多文章中读到，您可以将spring云消息传递系统移植到其他系统。这意味着，我可以稍后将IBM MQ更改为kafka，但在类路径上提供了绑定器实现。这是什么意思？ 我使用Rabbitmq构建了一个Spring Amqp应用程序，我在应用程序中使用的功能如下所示， 请求回复 Dlq 生产者和侦听器配置都具