在Spring AMQP中正确使用Spring WebClient
我有一个使用Rabbitmq- 消息的Spring AMQP应用程序的技术堆栈 Spring boot 2.2.6.RELEASE Reactor Netty 0.9.12.RELEASE Reactor Core 3.3.10.RELEASE 应用程序部署在四核RHEL上。 下面是Rabbitmq使用的一些配置 @Bean public CachingConnectionFa
..
spring-amqp相关内容
如何监听动态创建的队列？
我有一个rabbitListener，它可以持续地异步监听队列“user-Messages”的用户消息。除非队列中加载了批量消息，否则一切正常。当消息批量发布到队列时，同一用户的消息会先处理，其他用户的消息则会等待处理。 我无法使用优先级队列，因为所有用户的优先级都相等。因此，我希望创建新队列并在运行时监听它们。一旦消息被使用，所有队列都将是短暂的。(该队列将被删除) 浏览时，我发现可
..
Spring Batch-AmqpWriter和AmqpReader示例
需要一个解决方案，使用AmqpWriter在RabbitMQ上写入数据，使用AmqpReader使用RabbitMQ读取数据。我们不是在寻找Apache Kafka，我们只想发送Say Program详细信息并使用它。 编写器代码 JobConfig.java @Configuration public class JobConfig { @Autowired
..
使 Spring RabbitMQ 在缺少交换时失败
有很好的属性 spring.rabbitmq.listener.simple.missing-queues-fatal=true当我将它设置为不存在的队列时，它会使 SimpleMessageListenerContainer 和整个应用程序失败 - 这就是我想要的.我不想让应用程序在无效状态下运行. 我找不到类似的交流解决方案，如 spring.rabbitmq.listener.s
..
Spring AMQP 单消费者并行与预取
我们有一个项目正在使用 Spring-AMQP 来使用来自我们的 RabbitMQ 代理的消息.我们希望增加消费端的并发性，以便多个工作线程可以并行处理消息.我从阅读原生 RabbitMQ 客户端的文档开始，这让我想到了使用单个消费者的设计，并且预取计数 > 1 来控制并行性.直接使用 RabbitMQ 客户端，这看起来很自然.DefaultConsumer 的 handleDelivery 方法
..
添加多个侦听器将侦听不同的 RabbitMQ 队列不起作用
我有以下 spring xml 配置 现在在我的 Java 代码中，我有 2 个监听器类:com.vzw.es.cosumer.SpringMessageListener 和 com.vzw.es.cosumer.SpringMessageListener1.现在，当我运行我的主类时，只有 1 个侦听器的 onMessage 方法被调用，即 SpringMessageListener1，我确
..
未使用 Spring AMQP StatefulRetryOperationsInterceptor
我正在尝试将 spring amqp 配置为仅重试消息定义的次数.当前一条消息失败，例如因为 DataIntegrityViolationException 被无限期重新交付. 根据文档 这里我想出了以下配置 @Bean公共 StatefulRetryOperationsInterceptor statefulRetryOperationsInterceptor() {返回 RetryIn
..
在 RabbitMQ 中分组接收消息，最好使用 Spring AMQP?
我从服务 (S) 接收消息，该服务将每个单独的属性更改作为单独的消息发布到实体.一个人为的例子是这样的实体: 人{编号:123名称:“某事"，地址: {...}} 如果姓名和地址在同一事务中更新，则 (S) 将发布两条消息，PersonNameCorrected 和 PersonMoved.问题出在接收端，我在其中存储此 Person 实体的投影，并且每个属性更改都会导致写入数据库.所以在这个
..
spring amqp rabbitmq MessageListener 不工作
我正在尝试使用 spring amqp 使用rabbitmq，下面是我的配置. 这是一个简单的消息监听类， import org.springframework.amqp.core.Message;导入 org.springframework.amqp.core.MessageListener；公共类 ImportMessageListener 实现 MessageListener {@覆
..
Spring AMQP Java 客户端中的队列大小
我使用 Spring amqp 1.1 版本作为我的 java 客户端.我有一个大约有 2000 条消息的队列.我想要一个检查这个队列大小的服务，如果它是空的，它会发送一条消息说“所有项目已处理". 我不知道如何获取当前队列大小?请帮忙 我在谷歌上搜索并找到了早期版本 1.0 中存在的一个类“RabbitBrokerAdmin".我认为它现在不存在于 1.1 中. 获取当前队列大
..
spring rabbit amqp @RabbitListener 配置最小和最大消费者数量
我正在使用spring amqp rabbit @RabbitListener 注解来自:神器 spring-rabbit-1.7.1.RELEASE我想知道是否有办法为每个队列配置消费者数量?我一直在挖掘文档，但一无所获，有没有办法在相关容器中为每个队列配置消费者数量?提前致谢. 解决方案 通过文档中显示的容器工厂bean. @Bean公共 SimpleRabbitListenerCo
..
Spring boot 中的 Rabbitmq 并发消费者
我正在使用@RabbitListener 注释和 SimpleRabbitListenerContainerFactory bean 来并行执行 rabbitmq 消息并通过以下方式设置最小和最大并发消费者: @Bean公共 SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory() {SimpleRabbitLis
..
从 Java/Spring 中检索 RabbitMQ 队列中未确认消息的数量
有没有办法返回未确认的消息数量? 我正在使用此代码来获取队列中的消息数: DeclareOk declareOk = amqpAdmin.getRabbitTemplate().execute(新的 ChannelCallback() {public DeclareOk doInRabbit(频道频道)抛出异常 {返回 channel.queueDeclarePass
..
多个带有 Spring Boot 的 Rabbitmq 队列
来自 Spring Boot 教程:https://spring.io/guides/gs/messaging-rabbitmq/p> 他们给出了一个仅创建 1 个队列和 1 个队列的示例，但是，如果我希望能够创建多于 1 个队列怎么办?怎么可能? 显然，我不能两次创建同一个 bean: @Bean队列队列(){返回新队列(queueNameAAA，false)；}@豆角，扁豆队列队列(
..
RabbitMQ/AMQP - 微服务架构中的最佳实践队列/主题设计
我们正在考虑为我们的微服务基础架构(编排)引入基于 AMQP 的方法.我们确实有几个服务，比如说客户服务、用户服务、文章服务等.我们计划引入 RabbitMQ 作为我们的中央消息传递系统. 我正在寻找有关主题/队列等系统设计的最佳实践.一种选择是为我们系统中可能发生的每个事件创建一个消息队列，例如: user-service.user.deleted用户服务.user.updateduse
..
rabbitmq 和 spring-rabbitmq 中的 DLX - 拒绝消息的一些注意事项
我确实阅读了此参考:https://www.rabbitmq.com/dlx.html，但它并没有解决我的疑问，即: 如果接受消息没有问题 - spring-rabbitmq 发送确认并且一切都很好，DLX 不知道确认的消息. 问题是如果拒绝回答，即抛出 MessageConverterException 怎么办?此消息已删除或移至 DLX? 如果有其他异常怎么办?例如 Except
..
使用 Spring AMQP 接收和发送 Java 对象
我想实现 Spring AMQP 示例，以使用侦听器发送和接收 Java 对象.我试过这个: 发送 Java 对象 ConnectionFactory connectionFactory = new CachingConnectionFactory("localhost");AmqpAdmin admin = new RabbitAdmin(connectionFactory);admin
..
如何在 Spring Boot 中从 AMQP 的 Json 字节数组转换?
按照这个，我有这个代码 @Bean打开有趣的 messageConverter(om: ObjectMapper): MessageConverter {返回 Jackson2JsonMessageConverter(om)}@豆角，扁豆打开有趣的rabbitListenerContainerFactory(cf:ConnectionFactory，mc:MessageConverter):Si
..
如何通过 MQTT 传输并使用 RabbitMQ 和 Spring-AMQP 在 AMQP 上接收
所以我已经让 MQTT -> MQTT 和 AMQP -> AMQP 工作了；MQTT -> AMQP 的翻译似乎并没有在某处工作.这是我的测试，如果我的“监听器"也在使用 paho 的 MQTT 中，则它通过了，但是这个 rabbitmq 实现没有. @SpringBootTest@SpringJUnitConfig内部开放类 ProvisioningTest @Autowired 构造函数(
..
仅使用 RabbitMQ 和 SpringAMQP 使用具有某些标头的消息
我正在尝试将消息发布到队列，然后只有当它包含某个标头时才让某些消费者使用它，如果它包含另一个标头，另一个消费者会使用它. 到目前为止，我所做的是设置一个标头交换，仅当消息包含该标头时才将消息路由到某个队列. 这是我用来设置交换、队列和监听器的配置:
..