spring-amqp 相关问题

在 Spring Cloud 配置服务器中转义登录

我有spring cloud配置服务器，它为rabbit提供密码。密码包含“@”。当我使用 static appliation.yaml 运行应用程序时，我必须用 '' 包围值 春天： 兔子MQ：

spring-boot-starter-amqp 依赖导致 CglibAopProxy 在调用 CachingConnectionFactory.createConnection() 时抛出 AmqpException

我正在尝试将rabbitmq嵌入到Spring Boot应用程序中。我遵循了互联网上的各种教程。 使用的spring boot版本是V2.7.14。我的 POM 中有 spring-boot-starter-amqp

如何配置Spring AMQP在监听器抛出AmqpRejectAndDontRequeueException时不重新排队？

我目前有一个 Spring Boot 应用程序配置为使用 spring-boot-starter-amqp 2.1.5.RELEASE。我已在 yaml 中将其配置为重试： 兔子MQ： 听众： 简单的： 重新...

RabbitMQ 消息在抛出 AmqpRejectAndDontRequeueException 后仍然重试

我有一个简单的 Spring Boot 应用程序，其中有以下 RabbitMQ 设置（spring-boot-starter-amqp 版本是 2.7.0）： 春天： 兔子MQ： 主机：本地主机 端口：5672 虚拟...

Spring amqp 死信交换与多个队列绑定

在我的应用程序中，使用两个队列，它们与一个带有密钥的交换器绑定.. 与此键正则表达式匹配的任何消息都将进入两个队列。 案例 2：我正在尝试实施...

如何在 Spring Boot 中将当前的 SecurityContext 传播到我的 @RabbitListener？

用例：我想要一个 REST API，它将使用 RabbitMQ/AMQP 在系统中触发一个事件，并且我想要将当前登录用户的 SecurityContext 传播到该事件，或者...

使用 springboot 的 Rabbitmq RPC（请求-回复）

我想使用 RabbitMQ 实现微服务通信的请求-回复模式。然而，问题是每个内部调用都会创建一个新队列，并且默认情况下，队列大小在

单个队列，多个@RabbitListener但服务不同

是否可以有一个@RabbitListener，例如： @RabbitListener（队列= STORAGE_REQUEST_QUEUE_NAME） 公共 FindApplicationByIdResponse findApplicationById（FindApplicationByIdRequest 请求...

如何拦截RabbitMQ中的身份验证错误

我们公司有一项政策，当我们连续验证失败超过3次时，帐户将被锁定。在 Spring Boot 服务中，我们使用 RabbitMQ 进行设置，登录机制...

在 Spring Boot 中无法解锁 Rabbit Listener 中的 Redisson 锁

我在 Spring Boot 的 rbbit 监听器中有以下代码块。我尝试使用 redisson 获取锁： @RabbitListener（队列= Const.Rabbit.QUEUE_NAME，并发=“1”） 公共空间

RabbitMQ：多个消费者的循环

项目主要由三部分组成： 生产者（设备）通过 MQTT 协议向 Broker 发送数据 RabbitMQ 代理 用于应用程序和代理之间通信的消费者（spring AMQP）。 （设备 MQTT

possibleFatalAuthenticationFailure 标志 - 被 AsyncMessageProcessingConsumer 忽略

Spring-AMQP 通过 AMQP-750 添加了 possibleFailureAuthentication 标志。但是，至少在一种情况下，容器可以接收 AuthenticationFailureException 并抛出

带有 AMQP 库或 RabbitMQ 库的 Spring Boot RabbitMQ

我开始使用 RabbitMQ 处理消息队列，我很喜欢使用 AMQP，下面是代码，所以我发现当使用 RabbitTemplate 和 amqp.connectionFactory 时，我们不能有 h...

spring-amqp：通道关闭并显示 NACKS RECEIVED 消息

在 RabbitMQ 总线上使用负载较重的 spring-amqp，我们有时会从 org.springframework.amqp.rabbit.connection.CachingConnectionFactory 获取日志： 通道关闭：干净通道关闭；

如何使用SimpleRetryPolicy从Spring AMQP重试策略中排除特定异常？

我的 Spring AMQP 应用程序中有一个 RabbitListener，并且我正在使用自定义 RabbitListenerFactory 和配置用于消息重试的 SimpleRetryPolicy。但是，我想排除某些例外...

Spring amqp - 未找到兼容的身份验证机制 - 服务器提供[]

我正在尝试通过外部身份验证机制（https://github.com/rabbitmq/rabbitmq-auth-mechanism-ssl）将spring boot应用程序连接到rabbit mq。 我收到以下错误： org.springframework.amqp.

Spring Rabbit 在新线程上哪里消费消息

我正在跟踪rabbitmq，我发现springrabbit在新线程上消费消息。我想知道它在哪里创建新线程

无法连接Spring AMQP / Rabbit MQ：org.springframework.amqp.AmqpConnectException：java.net.ConnectException：连接被拒绝：connect

我是 Spring AMQP / Rabbit MQ 的新手。 我在我的项目中使用 Spring AMQP / Rabbit MQ。运行tomcat后遇到以下错误： org.springframework.amqp.rabbit.listener.

在 TestSuite 中模拟 AMQPTemplate

我正在将 JUnits 作为 TestSuite 运行。 JUnit 类之一用于测试将消息发布到 RabbitMQ 的代码。我应该模拟代码以将消息发布到 MQ。怎么会...

Spring amqp RetryCache 抛出 AmqpRejectAndDontRequeueException 时未清除

我有一个简单的 Rabbit 侦听器，它总是抛出 AmqpRejectAndDontRequeueException （以测试侦听器是否可以处理多个无效消息）。 配置是： @RabbitListener( id = 测试配置。