我必须用“春兔”代替“Spring-Cloud-Stream”吗
我正在做一个尝试采用消息驱动框架的项目。（不同的独立组件与消息代理路由的消息通信）
RabbitMQ最终被选为经纪人。
对于框架，起初我们尝试使用Spring Cloud Stream，但当我们尝试利用Rabbit特性时，例如：Exchange、路由密钥、备用交换......我们发现很难在Spring Cloud Stream中使用它们。
所以我的问题是：
- 我必须使用SpringRabbit（或者SpringIntegration）而不是SpringCloud流吗
- 你对他们有什么建议/最佳做法吗
共有1个答案
Spring Cloud Stream对队列、交换、路由密钥非常固执己见；我们正在考虑在未来的版本中增加更多的灵活性，但现在，您可以直接使用Spring AMQP，并且没有太大的不同，例如，RabbitListener代替StreamListener。是否添加Spring集成实际上取决于您的应用程序需要什么。
-
我已经配置了一个基于Spring启动的应用程序与Spring云流。我试图在KStream上工作，但我不断得到错误"java.lang.IllegalArgumentExc的：方法必须是声明性的"。有人能帮我了解如何配置这个吗？我查找了StreamListener留档，但我无法让它工作。 https://docs.spring.io/spring-cloud-stream/docs/Elmhurst
-
本节将详细介绍如何使用Spring Cloud Stream。它涵盖了创建和运行流应用程序等主题。
-
我有一个接受@Payload字符串的@StreamListener。为了测试这个侦听器类，我使用嵌入式Kafka编写了一个Junit类。运行我的测试类时，我得到以下错误 错误O.S.I.Handler.LoggingHandler-org.SpringFramework.Messaging.Converter.MessageConversionException：无法将GenericMessage
-
我不确定我的理解是否正确。我们启动了一个Spring云流应用程序并订阅了一个主题。该应用程序将运行并暂停该主题以获取新消息，除了我们发送终止信号退出。我在想我们是否可以明确退出Spring云应用程序，比如等待5分钟但没有新消息进来？或者处理了1000条记录并退出？
-
我在尝试将Reactor的Mono与Spring Cloud Stream一起使用时遇到了一个问题，无法真正弄清楚发生了什么。 想象一下，我有一个这样的听众： 因此，它基本上是将一个格式如下的url扩展成这样 < code > http://www . example . com/page/1 它按预期工作，但是当我尝试这样做时： 其中pageNumber是
-
Spring Cloud Stream是构建消息驱动的微服务应用程序的框架。Spring Cloud Stream基于Spring Boot建立独立的生产级Spring应用程序，并使用Spring Integration提供与消息代理的连接。它提供了来自几家供应商的中间件的意见配置，介绍了持久发布订阅语义，消费者组和分区的概念。 您可以将@EnableBinding注释添加到应用程序，以便立即连接