《rabbitmq》专题
-
RabbitMQ路由密钥
很好的一天。 有没有办法通过基于浏览器的UI检索现有交换（扇出或主题）的路由密钥？ 我无法访问客户端源代码（生产者）以查看正在将哪些路由密钥发送到模型。 非常感谢。 编辑：想法是尝试锁定现有的扇出交换（我无法重新配置）。我想创建一个新的exchange，将其绑定到此exchange，并只过滤掉某些消息。
-
无法连接到C#程序中由Docker启动的RabbitMQ（使用RabbitMQ.Client）
我开始了一个RabbitMQ容器下面的文章：https://docs.docker.com/samples/library/rabbitmq使用图像包括管理工具 我可以通过http://localhost:8080访问管理工具 然后，我创建了这篇文章之后最基本的C#项目，以与我的本地RabbitMQ实例通信： 但不幸的是，运行时出现以下错误： 不太清楚RabbitClient为什么不能通过 有什么
-
SpringBoot RabbitMQ-如何减少许多主题（事件）的样板？
我想知道在SpringBoot中初始化许多RabbitMQ队列/绑定时，是否有办法减少样板代码的数量？ 遵循事件驱动的方法，我的应用程序产生了大约50种类型的事件（它将在稍后被分成几个较小的应用程序，但仍然）。每个事件都以类型"主题"去交换。某些事件被其他应用程序消耗，某些事件被发送它们的同一应用程序额外消耗。 让我们考虑一下出版和自我消费的情况。 在SpringBoot中，我需要为每个事件声明：
-
使用Spring cloud函数对rabbitmq进行Spring cloud流dlq处理
我已经阅读了Spring Cloud stream binder参考文档，其中提到了使用@RabbitListener进行DLQ处理。https://docs.spring.io/spring-cloud-stream-binder-rabbit/docs/3.0.10.RELEASE/reference/html/spring-cloud-stream-binder-rabbit.html#ra
-
Spring批处理集成使用RabbitMq消息
当RabbitMq消息到达队列时，我目前正在使用IntegrationFlow来触发作业执行。IntegrationFlow的AmqpInFronChannelAdapter和作业的第一步的ItemReader都配置为从同一队列中读取消息。 我遇到的问题是IntegrationFlow的AmqpInboundChannelAdapter读取RabbitMQ消息，然后ItemReader再也找不到该
-
RabbitMQ：为什么重新连接后通道不重新打开？
在我的应用程序与RabbitMQ服务器失去连接后，我在日志中看到 然后，当我的应用程序重新连接到RabbitMQ服务器时，我在日志中看到 但是，当应用程序重新连接到RabbitMQ服务器时，通道不会重新打开，在RabbitMQ管理控制台中，我可以在“通道”选项卡中看到没有任何通道。 重新连接后，在RabbitMQ服务器日志中： 我使用的是Spring Boot 1.5.3和Spring Boot
-
如何在opentelemetry中通过rabbitmq通信的两个服务之间传播上下文？
我试图找到一种方法，在opentelemetry中通过rabbitmq通信的两个服务之间传播上下文。在Go article链接中有一篇类似的文章，但无法在节点中实现它。 我正在考虑两种方法 在通过代理发布的消息头中传递上下文。或 是否有任何代码参考可用于执行上述任何操作？
-
spring rabbitmq自动重试到代理的连接
我读过这段文档： RabbitMQ自动连接/拓扑恢复 自Spring AMQP的第一个版本以来，该框架在代理失败的情况下提供了自己的连接和通道恢复。此外，如第3.1.10节“配置代理”所述，RabbitAdmin将在重新建立连接时重新声明任何基础结构bean（队列等）。因此，它不依赖amqp客户端库现在提供的自动恢复。Spring AMQP现在使用4.0。amqp客户端的x版本，默认情况下已启用自
-
在spring-boot-1.1.3的rabbitmq服务器上拒绝访问\u，在1.0.1中可以
我在sping-boot 1.0.1下有一个工作的客户端应用程序，但当我将sping-boot版本更新到1.1.3时。RELEASE，我在客户端上得到一个周期性的连接重置堆栈跟踪，我可以在服务器上看到以下日志： =信息报告===2014年7月3日：：10:57:55===接受AMQP连接 =ERROR REPORT====3-Jul-2014::10:57:58 ===关闭AMQP连接 我认为设置
-
RabbitMQ CachingConnectionFactory和发布者返回配置
Make Spring RabbitMQ在缺少exchange时继续失败 我为多个队列注册MessageListenerContainer。 我应该在哪里以及如何配置通道返回侦听器？-我认为我这样做是错误的。我将CachingConnectionFactory配置插入createQueueBMessageListener（...）-负责创建多个MessageListeners之一的方法。 Cach
-
如何使用Spring Rabbitmq连接到多个Rabbitmq节点？
我正在用Spring编写一个服务，并使用Spring AMQP连接到Rabbitmq。 我有两个rabbitmq集群，一个仅用于发布消息（消息通过联合插件发送到另一个集群），另一个集群用于声明最终用户将从中使用的队列。 节点位于aws lb后面，每个集群有一个lb。 我在代码中使用CachingConnectionFactory和RabbitTemboard、RabbitAdmin，我希望与所有节
-
如何为RabbitMQ和Spring动态注册队列及其独占使用者/侦听器？
我有以下问题需要解决：我正在尝试使用RabbitMQ消息实现一个简单的延迟重试机制。我有一个基础设施，可以延迟传递消息。我可以让任何数量的感兴趣的参与者在运行时利用这种延迟重试机制。 参与者只想向我提供2个细节和信息：1。他们希望消息在延迟T秒后传递到的队列名称。2、队列的使用者（例如消息的使用者） 我已尝试执行以下操作： 请注意，队列已经创建并注册到rabbitadmin，并且对象使用者有一个名
-
在Spring AMQP中处理RabbitMQ DLQ消息的最佳方法是什么
我正在使用Spring AMQP侦听RabbitMQ队列。在侦听队列时，根据业务逻辑，我的服务可以引发RuntimeException，在这种情况下，消息将重试多次。在最大次数重试后，消息将保留在DLQ中。我想知道，在DLQ中处理这些消息的最佳方法是什么？我从博客上读到我可以使用停车场队列。但在这种情况下，如何监控队列并通知人们死信消息？P、 对不起，我的英语不好。希望我能够解释我的问题：）
-
Storm使用Spring AMQP从RabbitMq读取消息
我想使用rabbitMq队列中Storm喷口中的消息。 现在，我们使用Spring AMQP异步发送和接收来自RabbitMq的消息。 Spring AMQP提供了从队列读取消息的机制（创建监听器或使用注释@RabbitListner）。 问题是我可以让一个侦听器从队列中读取消息。但是，我如何将此消息发送到Storm群上运行的Storm喷口？ 拓扑将启动一个集群，但在我的spout的nextTup
-
如何使用Spring RabbitMQ MessageListener获取MessageProperties
我正在创建一个Spring MessageListenerAdapter，用于侦听XML消息队列。 这是我的amqp配置： 当前，消息的接收工作正常，但仅当我的侦听器的返回类型是字符串时。 通过以下侦听器，我可以接收XML消息，所以这很好。但我无法获取原始消息的消息属性： 如果我将receiveMessage（）的返回类型更改为字节[]或消息，则会收到以下错误消息： 我已经尝试过MessageCo