我正在测试Spring-AMQP中的publisher confirm是如何工作的，试图找出如何使用Spring AMQP控制最大的未确认发布？基本上，当未确认的消息计数大于某个限制时，我希望暂停发布程序。rabbitTemplate.getUnconfirmed(age)似乎给出了未确认消息
浏览 14提问于2016-08-05得票数 1
回答已采纳
2回答
我一直在尝试Spring AMQP。我有几个问题：
我想知道什么是出版商退货，它与出版商确认有什么不同。据我所知，我们有一个发布者确认回调来检查ack的状态。现在，我查看了Spring AMQP和Rabbit MQ中的文档。在这方面并没有真正找到或理解太多。还有，为什么如果尝试将消息发送到不存在的队列，我既得不到任何类型的确认(ack/nack )，也得不到任何错误。对于非确认，有没有setTimeouts的方法？
浏览 0提问于2018-05-22得票数 4
这是我的代码，channel.addConfirmListener() ackCallback --一些回调将丢失，消息确实被发送到rabbitmq服务器，并且可以正常使用，但是我在发送消息后睡眠2ms17:04:29.607 [AMQP Connection 27.11.210.232:7005] INFO me.demo.me.rabbitmq.consumer.发布确认.异步确认发布 - ackCallback17:05:18.037 [AMQP Connecti
浏览 3提问于2022-04-12得票数 0
回答已采纳
是否有方法在使用amqp发布消息后继续使用spring集成流:出站-通道-适配器？-使用确认- ack -通道，我只能在amqp ack之后才能继续该流程，这需要太长时间。
浏览 1提问于2016-11-15得票数 1
回答已采纳
1回答
在使用Spring AQMP时，是否可以确认发布者已将发布的消息传递给侦听器？我在许多队列中设置了x-message-ttl = 0，这意味着如果消息不能立即传递，它们将被丢弃，但由于我在请求/应答场景中使用它，我希望能够中止请求并立即处理错误。
浏览 2提问于2015-04-22得票数 3
我想知道在rabbitmq中预取计数和无ack的区别是什么？如果我将预取计数设置为10，是否会创建10个消费者线程？或者--以上哪一项更有效
浏览 9提问于2016-09-26得票数 3
回答已采纳
环境 Spring Boot：2.1.11.RELEASE Spring Cloud：Greenwich.SR4 Spring Cloud Stream：Fishtown.SR4 spring-cloud-stream-binder-rabbit：2.1.4.RELEASE Yaml配置 spring: stream: input:
binder: rabbitgroup: ${spring.a
浏览 11提问于2020-01-17得票数 0
回答已采纳
1回答
我正在测试AMQP的Spring实现，我想使用publisher确认。我在文档和代码中缺少的是如何处理某个年龄的未确认消息。裸RabbitMQ客户端java库提供了一个工作良好的方法，但这将迫使我在Spring抽象下更深入，为什么我不想继续发布和重新尝试未确认的消息？我确实找到了，但是我遇到的问题是它似乎不是线程安全，因为当我的发布者连续发送消息时，我试图重新发送超过5秒的
浏览 3提问于2015-06-26得票数 1
回答已采纳
我是RabbitMQ的新手，目前正在从事RabbitMQ发布，在我的web应用程序中确认确认。在每个新请求中，向RabbitMQ服务器发送消息以异步处理它，并启用确认从RMQ服务器获得确认。经过一些研究后，如果我在设置确认回调之前添加了一个检查(template.isConfirmListener())，而不是得到错误。但是，如果需要的话，我们如何覆盖不同请求的确认回调呢？环境：
浏览 0提问于2019-09-05得票数 0
回答已采纳
1回答
我们有一个使用Spring来使用来自RabbitMQ代理的消息的项目。我们希望增加消费端的并发性，以便多个工作线程可以并行地处理消息。我首先阅读了本机RabbitMQ客户机的文档，然后介绍了使用单个使用者和预取计数>1来控制并行性的设计。直接使用RabbitMQ客户机，这似乎是很自然的。handleDelivery方法的DefaultConsumer可以生成一个新的Runnable来完成工作，并在工作结束时确认消息。预取计数有效地控制</
浏览 8提问于2016-05-03得票数 1
回答已采纳
2回答
以下属性之间的主要区别是什么：
1)spring.rabbitmq.listener.direct.prefetch= #单次请求处理的消息数。它应该大于或等于事务大小(如果使用)。2)spring.rabbitmq.listener.simple.prefetch= #单次请求处理的消息数。它应该大于或等于事务大小(如果使用)。
浏览 2提问于2018-09-21得票数 1
我正在使用spring amqp通过出站网关将我的消息发布到RabbitMQ。我已经在连接工厂上设置了发布者确认，并添加了我的自定义回调侦听器。对于出站网关，publisher确认还能工作吗？
编辑我的配置如下。我查看了SI代码，是的，出版商确认，是启用的。问题是当我收到一个NACK时我该怎么做？使用带有出站网关的publisher确认到底有什么意义？如果没有响应，或者我的Rabbit节点宕机，我会遇到异常。是否存在
浏览 1提问于2014-12-16得票数 1
我正在做一个Spring Boot项目，通过Spring AMQP使用RabbitMQ。为了清楚起见，我们测试的是发布者的确认，而不是消费者的确认。我们知道可以使用RabbitTemplate的execute方法访问通道，但是我们的RabbitMQ是自动确认的，所以在执行通道回调时消息已经消失了。我们认为我们可以在运行时禁用自动确认(这样就不会中断测试套件)，或者在测试中简单地阻止通道并在其上手动接收消息，但我们不知
浏览 2提问于2016-02-09得票数 8
我有一个使用spring库的spring引导应用程序。pom.xml： <groupId>org.springframework.boot</groupId></dependency>
我如何让它处理和确认一个单一的消息，然后优雅地
浏览 0提问于2017-11-08得票数 0
回答已采纳
我有一个连接JMS侦听器(侦听mq系列本地队列)的spring集成代码。<int-jms:message-driven-channel-adapter> <int-amqp:outbound-channel-adapter>
我试图保持这个事务性://${amqp.user}@${amqp.host}:${amqp.port}/${amqp.vhost}'"
浏览 1提问于2019-08-07得票数 0
我有一个发布者正在发布关于主题的消息，我有2个订阅者S1 & S2正在接收这些消息。当我的发布者发送一条消息，并且两个订阅者都在运行时，他们都会收到该消息。但是，当我的订阅服务器没有启动，而我的发布者发送消息时，当订阅服务器出现时，它们就不会收到消息。我的订阅服务器如何接收未运行的消息？spring.qpidjm
浏览 0提问于2019-01-20得票数 0
回答已采纳
1回答
我的侦听器(我使用的是Java的org.springframework.amqp.core.MessageListener) )失败了，比如："java.lang.RuntimeException:损坏的消息例如，是否有可能向我的侦听器放置一个通用的尝试-捕捉，并使用异常信息增强标题？
浏览 3提问于2015-11-19得票数 5
回答已采纳
2回答
当我尝试使用以下方法编译amqp_client.hrl时，它会产生“无法找到”错误以下是我所采取的步骤。创建模块amqp_example.erl
谁能让我知道我错过了什么。顺便说一句，我对二
浏览 7提问于2013-04-23得票数 0
回答已采纳
我正在尝试发布一条从PostgreSQL到RabbitMQ的消息(都运行在Docker上)
正确定义了amqp.brok
浏览 0提问于2019-02-14得票数 0
channel.assertQueue(config.amqp.queue{ queue: 'tasks', messageCount: 0, consumerCount: 1 }我通过以下方式发送
浏览 0提问于2019-11-19得票数 2
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
