这里的主要目标是消息传递，因此有消息(kafka/rabbit)生产者和消费者声明： spring: stream:
default-binder: kafka话虽如此，但问题是，使用此配置程序会在所有4个streamListener消费者端点上接收具有特定路由关键字的消息。反过来。因此，当第一个参数的消息类型与声明的有效负载不匹配时，第一个receiveLoanContractWait
浏览 38提问于2021-09-28得票数 0
回答已采纳
我正在尝试做一个简单的spring-cloud-stream单元测试来验证流之间的连接；基本上，处理程序可以从一个流中读取并写入到另一个流中。这部分运行得很好。问题是，应用程序的其他部分也在启动；即rabbitMQ侦听器。在另一个类中有一个方法(除了我正在测试的那个)，它有一个@RabbitListener。这就是被调用的方法。我在本地机器上运行了rabbit，用
浏览 46提问于2019-01-11得票数 0
回答已采纳
我们运行多个并发的RabbitMQ使用者，每个使用者在一个循环中执行“basicGet”。我们看到，单个消费者获得了大部分消息。有没有办法在所有消费者之间更均匀地传播信息？基本上，我们可以以某种方式中断为第一个客户提供服务的RabbitMQ，并切换到下一个客户。注意:必须拉取消息(basicGet)，不能切换为推流(basicConsume)，谢谢。
浏览 1提问于2016-05-31得票数 1
1回答
我们使用spring云数据流应用程序和RabbitMQ作为消息代理。使用者？？即接收器模块，从链接到exchange的队列中接收有效负载并打印。为了在使用者程序日志中获得“通道关闭:连接错误”，我访问了rabbitMQ UI页面，并连续删除了RabbitMQ UI页面中可用的连接。我们能捕获或检测Spring流应用程序中的“
浏览 0提问于2019-02-18得票数 0
2回答
我希望创建一个公共项目(使用spring云流)，根据消息内容动态地将消息路由到不同的(使用者)项目。(rabbitmq作为消息代理)
春云流支持它吗？如果没有，是否有建议的方法来实现这一点？thx
浏览 0提问于2016-11-08得票数 1
回答已采纳
它们的描述和默认值如下：
有人能解释一下这两者是如何相互作用的吗，特别是从性能的角度？每个并发使用者是否得到与threadPoolSize中指定的线程相同的线程，还是在
浏览 2提问于2016-02-11得票数 11
我们在两台不同的机器上创建了RabbitMQ集群，消息生产者向RabbitMQ负载均衡器发送消息。消息使用者也连接到RabbitMQ负载均衡器。
现在，我们希望特定队列的侦听器暂停一段时间。我看到ListenerContainer的stop()方法在这种情况下会很有帮助。但我想知道这是否会停止两个RabbitMQ实例上的容器。请
浏览 8提问于2016-08-19得票数 1
据我所知，rabbitmq是一个HA消息队列。是可以将其用作任务队列的。一些要求：
你能给出一些例子或想法吗？
浏览 4提问于2012-07-07得票数 2
实际上，我有一个使用@RabbitListener消费rabbitMQ消息的on引导应用程序，并且我已经将相同的应用程序迁移到azure，后者使用@JMSListener来消耗AzureServiceBus消息。因此，由于这两个侦听器，我计划在两个具有相同内容的不同类中复制相同的使用者代码，并使用两个不同的侦听器
消费者与JMS
浏览 1提问于2020-09-11得票数 1
回答已采纳
我从RabbitMq服务器上得到了这个错误
之所以会发生这种情况，是因为连接在使用者任务期间丢失，而在最后，当消息被加/捕获时，我会得到这个错误，因为我无法在与我所得到的消息不同的信道上插入一个消息。下面是RabbitMq连接的</
浏览 14提问于2021-07-01得票数 0
回答已采纳
2回答
我们有一个.Net Core 3.1应用程序，它使用EF Core与SQL Server数据库连接。我们面临的一个问题是，当由于某种原因在我们的方法中发生exception时，例如，在DB和SaveChanges中，字段是强制性的，就会引发Exception，因为该字段的值被传递为null，然后下次当使用不同的参数调用相同的方法时(即使是所有正确的/强制的字段)，仍然在EF Core中执行旧的</e
浏览 2提问于2022-04-28得票数 0
1回答
我正在维护一个Spring应用程序，它将Spring用于各种异步流。我已经实现了允许我动态暂停并恢复我所选择的任何Kafka侦听器/使用者的功能。但是，我希望能够恢复侦听器/使用者，使其只能临时轮询指定数量的Kafka消息(例如1条或5条)，以便在完全打开/恢复侦听器之前安全地测试侦听器的业务逻辑。这样做的自然方式是
浏览 3提问于2021-12-06得票数 0
目前，我正在Spring项目的基础上构建一个自定义库。我已经到了想要实现消息侦听器以便能够接收消息异步的地步。在深入阅读了项目指定的文档之后，我管理发现实现您自己的消息侦听器应该非常容易。只需实现MessageListener类并将其配置为触发传入消息。因此，我没有使用任何上下文(注释或xml)。我不确定这是否是必须的，因为我可以自己创建类的实例。
当运行一
浏览 3提问于2015-04-09得票数 3
回答已采纳
我必须向第三方服务提出请求它也没有web挂钩或任何回调机制。产品生成的所有消息目前都放在一个队列中。调用第三方服务的相同队列。
目前有3个使用者，每个工作线程运行4
浏览 0提问于2015-07-24得票数 2
1回答
如果我使用发布者确认，我可以(合理地)确定发送到RabbitMQ服务器上的exchange的消息以及从RabbitMQ服务器接收确认的消息不会丢失，即使RabbitMQ服务器崩溃(例如断电)。但是，当消息在使用者手动拒绝后到达死信交换时会发生什么？(channel.basicReject，我使用Spring AMQP。)如果原始消息</e
浏览 6提问于2019-06-25得票数 1
我们需要向客户端提供实时消息，但它们的服务器位于代理之后，我们无法初始化连接；web钩子变体无法工作。考虑到这一点，什么是传递实时信息的最佳方式：
WebSocket - client打开一个websocket连接，我们发送存储在DB中的消息，同时消息
浏览 3提问于2013-09-24得票数 0
我正在尝试理解中的概念。“点击”和“命名目的地”这两个概念让我很困惑。我试图创建一个具有一个名为“某些源”的点击的流：但是，在我保存了流之后，它变成了一个“命名目的地”：我的问题是：
“destination"?Why”和“”之间的区别是什么？
浏览 2提问于2020-08-17得票数 0
回答已采纳
我正在为我的项目使用C#，并且我已经使用发布到队列的windows服务成功地设置了RabbitMQ消息队列。我还在与RabbitMQ消息队列相同的机器上为使用者创建了另一个windows服务。有没有办法让使用者在不同于消息队列的机器上运行？现在一切都在本地运行得很好，但我设想有单独的机器用于生
浏览 20提问于2021-10-21得票数 0
回答已采纳
3回答
如何将任务排队到C#的芹菜中？
、、、、
正如我所理解的，像RabbitMQ这样的消息代理为用不同语言/平台编写的不同应用程序相互通信提供了便利。因此，由于芹菜可以使用RabbitMQ作为消息代理，所以我相信我们可以将任务从任何应用程序排队到芹菜，即使生产者不是用Python编写的。现在，我试图弄清楚如何通过C#通过RabbitMQ编写应用程序，将任务排队到芹菜。但我还找不到这样的例子。我发现的唯一接近这个<em
浏览 3提问于2016-10-13得票数 13
回答已采纳
我们正在启动一个新项目，在该项目中，我们将评估用于微服务之间异步通信的技术堆栈？我们正在考虑RabbitMQ和卡夫卡的这一点。谢谢
浏览 1提问于2019-11-05得票数 0
云服务器
ICP备案
对象存储
实时音视频
云直播
腾讯云开发者
