我正在尝试使用php-amqplib进行消息的发送和接收。在终端上,它可以正常地发送/接收消息。但是,在Web浏览器中,无法从队列中接收消息,它会不断等待消息。我在receive.php中使用了以下代码: require_once(__DIR__ . '/lib/php-amqplib/am...
有没有可能使用联邦或铲子将一个服务器上的交换机和队列的创建镜像到另一个服务器上? 所有我看过的使用铲子和联邦的例子都是使用已经存在于服务器上的交换机和队列。我的要求是在服务器A上创建一个交换机,并通过联邦或铲子重新在服务器B上创建它,然后开始向其发送消息。 如果不能使用联邦或铲子来实现此操...
在主题交换和由消费者动态创建的队列的上下文中,当没有消费者消费消息时如何重新传递消息/通知生产者? 我有以下组件: - 一个主要服务,生成文件。每个文件都有一个特定的类别(例如pictures.profile、pictures.gallery)。 - 一组工作人员,消耗文件并从中产生文本...
我有一个场景,我想使用特定的路由键(例如abc)将一些消息发布到rabbitmq-exchange。问题在于可能已经存在任何队列已绑定到路由键“abc”,也可能不存在。这种情况下的行为似乎要么是丢弃该消息,要么是如果配置了死信交换,则将其路由到死信交换。我希望在没有为该路由键存在任何队列的情况...
在我的项目中,我发现存在确认相同传送标签的机会。当出现这种情况时,消费者将从队列中解除绑定,并且不会再有任何消息传递给消费者(使用RabbitMQ管理仪表板观察)。如何检查某个传递标签已经被确认?是否有一种推荐的方法来使用RabbitMQ API处理这种情况?我尝试在代码中避免重复确认,但由于...
我正在使用RabbitMQ 3.0.3版本。服务在过去的4-5年中一直正常运行。最近服务器安装了一些更新补丁,服务停止响应。以下是发生的情况: RabbitMQ服务(Windows服务)正在运行但没有响应。 在日志文件中,我看到错误信息access to vhost 'XXX' refus...
我正在使用spring-boot-starter-amqp 1.4.2。生产者和消费者工作正常,但有时传入的JSON消息语法不正确。这会导致以下(正确的)异常: org.springframework.amqp.rabbit.listener.ListenerExecutionFailedE...