php rabbitmq使用者重新连接
PHP RabbitMQ使用者重新连接是指在使用RabbitMQ消息队列的PHP应用程序中，当消费者与消息队列的连接断开后，重新建立连接的过程。
RabbitMQ是一个开源的消息代理软件，它实现了高级消息队列协议（AMQP），用于在分布式系统中传递消息。PHP RabbitMQ是基于PHP语言的RabbitMQ客户端库，用于在PHP应用程序中与RabbitMQ进行交互。
当使用者与RabbitMQ的连接断开时，可能是由于网络故障、RabbitMQ服务器重启或者连接超时等原因导致的。为了保证消息的可靠传递，消费者需要重新建立与RabbitMQ的连接，并继续消费消息。
在PHP RabbitMQ中，可以通过以下步骤实现使用者重新连接：
- 建立初始连接：在应用程序启动时，使用PHP RabbitMQ库建立与RabbitMQ的初始连接。可以指定RabbitMQ服务器的主机名、端口号、虚拟主机、用户名和密码等连接参数。
- 监听连接断开事件：使用PHP RabbitMQ库提供的回调函数或事件监听器，监测与RabbitMQ的连接是否断开。当连接断开时，触发相应的事件或回调函数。
- 重新连接策略：根据实际需求，制定合适的重新连接策略。例如，可以设置重连间隔时间，每隔一段时间尝试重新连接，或者在连接断开后立即尝试重新连接。
- 重新建立连接：当连接断开后，根据重新连接策略，使用PHP RabbitMQ库重新建立与RabbitMQ的连接。可以使用之前建立连接时的参数，或者根据实际情况进行调整。
- 恢复消费状态：在重新连接成功后，消费者需要重新订阅之前的消息队列，并恢复消费状态。可以使用PHP RabbitMQ库提供的方法重新声明队列、绑定交换机、设置消费者回调函数等。
通过以上步骤，PHP RabbitMQ使用者可以实现在连接断开后的重新连接，并继续消费消息。这样可以提高应用程序的可靠性和稳定性。
推荐的腾讯云相关产品：腾讯云消息队列 CMQ（Cloud Message Queue），它是腾讯云提供的一种高可靠、可弹性扩展的分布式消息队列服务。CMQ支持多种协议和编程语言，包括PHP，可以与PHP RabbitMQ类似的功能。您可以通过腾讯云官网了解更多关于腾讯云消息队列 CMQ的信息：https://cloud.tencent.com/product/cmq
相关·内容
我实现了一个使用者，如果基础连接关闭，它将在一段时间后自动重新连接到代理。我的情况如下：
成功启动RabbitMQ服务器。
成功启动消费者。
发布了一条消息，并成功地接收到了它。
停止RabbitMQ服务器，使用者将显示异常：
com.rabbitmq.client.ShutdownSignalException:连接错误；原因：{#方法(回-代码=541，回-文本=内部_ERROR，类-id=0，方法-id=0)，null，“}。
然后消费者会在重新连接之前睡上60秒。
再次启动RabbitMQ服务器。
成功发布消息，命令'list_queues‘的结
浏览 2提问于2013-08-09得票数 4
回答已采纳
1回答
我应该如何构造RabbitMQ？
、、、、
我正在尝试将我们的单块PHP Symfony应用程序迁移到一个更可伸缩的Docker解决方案中。应用程序和RabbitMQ之间有一些通信，我使用docker-compose将所有容器都打开，在本例中是应用程序和RabbitMQ服务器。
围绕这个主题有很多讨论，即一个容器应该只生成一个进程，而在这一点上有点模糊：
虽然这个口头禅有良好的意图，但并不一定每个容器只有一个操作系统进程。除了容器现在可以通过init进程生成之外，一些程序可能自行生成额外的进程。
为每个RabbitMQ使用者创建一个单独的Docker容器有意义吗？不让rabbitmq服务器知道用于处理队列的语言/工具是“正确的”
浏览 2提问于2017-07-05得票数 5
回答已采纳
我正在创建一个简单的聊天应用程序
可以有多个用户和多个聊天室。
每个聊天室可以容纳多个用户。
服务器启动时将建立rabbitMQ连接。
当用户连接到服务器时，将在rabbitMQ通道中打开套接字连接。
在从客户端(用户)通过套接字发送消息时，rabbitmq通道使用特定的路由密钥将其推送到exchange。
在消费时，如果套接字是活动的，那么通过它发送&确认它。如果没有，请确认并重新排队。
{
//Creating a new connection
amqp.connect('amqp://localhost', (err, conn)
浏览 2提问于2019-02-21得票数 0
1回答
当我们有超过3000个连接/秒的峰值时，我们的rabbitmq服务器不能跟上连接，并且新的连接需要很长时间才能稳定(达到3s的失败限制)。我们需要出版商尽快返回，因为任何延迟传输到用户体验。 我们目前正在考虑将连接到第二个rabbitmq服务器的负载平衡编码为一个快速的临时解决方案。 我们只在需要发布时创建连接，并且按照最佳实践的建议，对相同的web请求/流程重用相同的连接和通道。PHP进程的本质是在web请求之后终止。 我是否可以重用该连接以在web请求之间发布？ 3000连接/秒的峰值是否足以使rabbitmq服务器遭受tpc连接过载？ 当我们将来有10倍的这种连接时，我们应该采取什么方
浏览 79提问于2021-11-12得票数 0
回答已采纳
我正在使用spring，如果它失败了，我想重试获得到RabbitMQ和MongoDB的连接。
我知道它适用于sql数据库：。
但是，我不知道应该为RabbitMQ和MongoDB包装哪些类。
我还试图包装ConnectionFactory for RabbitMQ，但是AbstractConnectionFactory有一些最后的方法，我不能重写它来将调用传递给委托工厂。
浏览 1提问于2018-05-15得票数 1
回答已采纳
我们观察了RabbitMQ的以下行为，并试图了解它是否正确以及如何解决它。
设想情况：
一个(持久)消息被传递到一个持久队列中。
(单)使用者(Spring)接收消息并开始处理=>消息，从就绪到UNACK。
现在代理被关闭了，=>客户端正确地报告了“通道关闭”
使用者完成处理，但由于代理仍处于关闭状态，因此无法确认消息。
代理再次启动=>客户端重新连接
因此，一条消息将永远被解压(或者直到客户端重新启动)。
附带注意:在兔子管理UI中，我可以看到现在存在两个通道。在代理重新启动之前创建的“死”消息，包含未加标记的消息和健康的新消息。
这种行为会是这
浏览 1提问于2018-02-21得票数 3
1回答
我是rabbitmq的新手。在python/php中的所有rabbitmq教程中，接收方表示
php receiver.php
或
python receiver.py
但我们如何在生产中做到这一点呢？如果我们必须在生产中运行以上命令，我们要么必须使用&最后，要么我们必须使用nohup。这不是个好主意吗？
如何在php/python的生产服务器中实现rabbitmq接收器？
浏览 2提问于2020-04-13得票数 1
回答已采纳
1回答
我有一个node.js应用程序，它使用amqlib与RabbitMQ连接。我试图在RabbitMQ中复制一个连接错误，通过重复相同的流程得到两个不同的错误。
我所做的是：
启动带有RabbitMQ管理的Docker容器。
启动连接在node.js上的RabbitMQ应用程序(对接者或npm)。
继续RabbitMQ管理，并使用rabbitmqctl执行stop_app
此流每次产生以下两个异常中的一个(不确定如何决定每个异常)：
OperationalError： ECONNREFUSED 172.24.0.3:5672
错误：心跳超时
这一切为什么要发生？
浏览 5提问于2020-03-24得票数 1
回答已采纳
1回答
我在Rabbitmq服务器中使用自签名证书，代理是通过SSL端口成功启动的。我现在正在尝试更新/使用新的SSL证书、SSL密钥和信任存储库，但我不希望重新启动正在运行的rabbitmq服务器，因为我的应用程序应该继续运行。我在网上查看了在运行时刷新/重新加载erlang/rabbitmq的解决方案，以读取/重新加载这些新的SSL证书，我偶然发现了它们建议使用- rabbitmqctl eval "ssl:stop(), ssl:start()." to reload certs的几个链接。
该命令运行良好，无需重新启动就刷新了新的SSL证书，但是使用者/连接被重新设置为，因为我
浏览 0提问于2018-07-04得票数 8
我在OpenShift上运行了一个MQTV3.6.10实例，并启用了RabbitMQ插件。我有多个Spring Boot应用程序，使用来自RabbitMQ队列的消息。所有消费者都使用MqttDefaultFilePersistence。将持久化数据写入到持久化卷上的目录/tmp/mqtt，配额为100M。这是我为连接到RabbitMQ队列而编写的代码：
MqttConnectOptions options = new MqttConnectOptions();
options.setUserName(username);
options.setPassword(pass
浏览 1提问于2017-11-24得票数 0
1回答
假设您创建了一个通道并开始使用其中的消息。
channel = get_channel()
channel.queue_declare(queue=QUEUE_NAME, durable=True)
channel.basic_qos(prefetch_count=1)
channel.basic_consume(callback, queue=QUEUE_NAME)
channel.start_consuming()
但不知何故，您就失去了与RabbitMQ服务器的连接。当连接下降时，您将得到一个ConnectionClosed异常，并且使用者停止。在消费模式下，如何处理皮卡的连接损耗？
浏览 3提问于2018-01-30得票数 1
回答已采纳
我在使用php-amqplib的rabbitmq中遇到了一个特别的问题，consumer.php不使用更新的代码库，而是使用旧的代码。
rabbitmq有没有类似于laravel listen命令的东西？php artisan队列:监听
如果没有，你能为我的用例推荐一些替代方案吗？
浏览 0提问于2020-11-04得票数 0
我使用RabbitMQ生产者向使用者发送长时间运行的任务(30 mins+)。问题是，当关闭到服务器的连接并请求未确认的任务时，使用者仍在处理一个任务。
通过研究，我了解到可以使用或来解决这个问题。这两种解决方案在尝试时都会引发错误。在阅读类似帖子的答案时，我还了解到，自从发布答案以来，RabbitMQ已经实现了许多更改(例如，默认心跳超时已从RabbitMQ 3.5.5之前的580次更改为60次)。
当指定心跳和阻塞连接超时时：
credentials = pika.PlainCredentials('user', 'password')
parameters
浏览 2提问于2016-03-21得票数 17
回答已采纳
我有一个php应用程序(laravel5.8)，它实现了一个rabbitmq使用者(bschmitt/laravel)。
当应用程序启动时，为了保持对使用者过程的控制，监督程序也会启动。
我的主管文件：
[program:message-consume]
process_name=%(program_name)s_%(process_num)02d
command=php artisan message:consume
directory=/var/www
autostart=true
autorestart=true
numprocs=1
redirect_stderr=true
stdo
浏览 6提问于2021-03-26得票数 2
回答已采纳
我在RabbitMQ和死连接方面有一些问题。我有一个RabbitMQ服务器和许多ec2实例，它们连接并包含来自该服务器的消息。问题是，有时当我需要终止ec2实例时，它与RabbitMQ服务器的连接不会关闭。
正因为如此，我们开始看到未加加的消息，它们永远不会回到就绪状态。我现在要做的是使用rabbitmqctl删除这个连接和/或使用我编写的python脚本来杀死任何空闲超过X天的连接。
我已经尝试使用1 RabbitMQ选项，但问题仍然存在。我想要做的是自动关闭任何“死”(空闲了很长时间)连接。
这是我在客户端而不是服务器端设置的东西吗？
RabbitMQ为3.3.4，我们在客户机上使用py-
浏览 0提问于2014-09-15得票数 4
第19页的"RabbitMQ in Action“一书给出了这些排他性和自动删除的描述：
排他性-当设置为true时，您的队列变得私有，只能由应用程序使用。当您需要将队列限制为一个使用者时，这是非常有用的。
自动删除-当最后一个使用者取消订阅时，队列将自动删除。如果只需要一个使用者使用的临时队列，请将自动删除与独占结合起来。当使用者断开连接时，队列将被移除。
但据我所见，当使用排他性时，自动删除是多余的。只需要排他性。RabbitMQ 似乎是这样说的。
...once，我们断开了消费者的连接，队列应该被删除。有一个独家的旗帜：
result = channel.queu
浏览 2提问于2014-01-21得票数 56
回答已采纳
我正在尝试使用RabbitMQ客户端API与RabbitMQ服务器交互。我从上读到
根据经验，在线程之间共享通道实例是必须避免的。应用程序应该更喜欢使用每个线程的通道，而不是在多个线程之间共享相同的通道。
我试图使用带有ThreadPoolExecutor 1的corePoolSize，并添加可运行的任务，以便将消息保存到RabbitMQ队列中。下面是我使用的代码：
package common;
import java.io.IOException;
import java.io.InputStream;
import java.security.KeyManagementExce
浏览 4提问于2017-06-15得票数 1
我开发了一个android应用程序，它可以订阅一个队列，也可以发布到其他队列。一次，它将相同的消息发布到两个不同的队列，其中一个是名为" queue“的队列，现在我需要从appfog实例订阅"Queue”，使用消息并将其插入到mysql数据库中。
为此，我用codeigniter创建了一个php独立应用程序。由于某种原因，worker应用程序失去了与rabbitmq的连接。我想知道做这件事的最佳方法。appfog上的工作应用程序如何支持应用程序重启。
我需要用什么样的东西来解决上面的问题。
我认为问题不在于rabbitmq连接。它是与mysql插入相关的代码。我检查了我的应用程
浏览 1提问于2013-04-22得票数 1
2回答
使用spring amqp (rabbitmq)：
我的消费者需要相当多的时间来处理消息，有时我的业务逻辑需要超过2个小时，但是在处理之后，当我尝试确认rabbitmq为"basic ack“时，它抛出连接超时异常。
我该怎么做？我应该让连接永远存在还是使用心跳？
浏览 0提问于2017-09-19得票数 0
1回答
我们的系统中有几个RabbitMQ队列，我们使用Spring Integration amqp:inbound-channel-adapter来使用消息。Spring应用程序在5个JBoss节点上运行(不在集群中)
RabbitMQ端是一个具有负载均衡器、持久队列的两个集群节点，在应用程序端的监听器定义相当简单，连接工厂定义如下：
<rabbit:connection-factory id="amqpConnectionFactory" username="${orts.rabbitmq.username}" password="${orts.ra
浏览 0提问于2016-08-30得票数 0
2回答
我计划使用RabbitMQ、Symfony2和RabbitMqBundle编写一个日志处理应用程序。我正在使用的工具必须是高度可用的，并且必须每天处理数百万条条目，因此重要的是，使用者始终处于启动和运行状态(短暂的休息时间是可以的)，否则我的队列可能会在一段时间后溢出。
在如何管理使用者(用PHP编写)、在发生错误时启动/重新启动消费者等方面有最佳实践吗？
谢谢
浏览 2提问于2013-11-05得票数 5
回答已采纳
1回答
我正在尝试建立一个消息传递系统，并在多个应用程序上运行。我有一个运行RabbitMQ的实例，这似乎很好。我可以将多个订阅者/发布服务器连接到RabbitMQ实例，它们看起来很好。然后，我可以从一个发布服务器发布一条消息，但只有一个订阅服务器正在接收该消息。
我相信这与我排队的方式有关。我看过关于兔子，的教程，但我不知道这是否能转化为Masstransit库。
为了我的生命，我很难弄清楚我做错了什么。
NuGets：
MassTransit.Extensions.DependencyInjection 5.3.2
MassTransit.RabbitMQ 5.3.2
有人能帮忙吗
浏览 0提问于2019-03-12得票数 2
回答已采纳
我从RabbitMq服务器上得到了这个错误
服务器关闭的通道: 406 (前提-失败)，带有消息"PRECONDITION_FAILED -未知传递标记80“
之所以会发生这种情况，是因为连接在使用者任务期间丢失，而在最后，当消息被加/捕获时，我会得到这个错误，因为我无法在与我所得到的消息不同的信道上插入一个消息。
下面是RabbitMq连接的代码
async connect({ prefetch = 1, queueName }) {
this.queueName = queueName;
console.log(`[AMQP][${this.queueNam
浏览 14提问于2021-07-01得票数 0
回答已采纳
在RabbitMQ中，是否可以将一个消费者(即Android )设置为主用户，但在第一个消费者不承认消息时将消息发送给sencond使用者(即服务器)？
浏览 2提问于2016-10-02得票数 0
回答已采纳
我是RabbitMQ的初学者，我从RabbitMQ的官方网站开始了我的冒险。
现在，我已经得到了在层中使用broker的以下模式：
Backend Server(Business logic) -> (push message) -> RabbitMQ -> Customer(receiver).
关于这个逻辑，我有一个简单的问题:如果将这些物理组件放置在不同的服务器上，那么客户和RabbitMQ代理之间以及Backend Server和RabbitMQ Broker之间存在什么样的绑定？它是套接字层还是无状态HTTP连接？
说明我想法的模式是：
Backend Serve
浏览 2提问于2017-10-06得票数 0
回答已采纳
如何为生产者和消费者在Masstransit使用rabbitmq传输时创建两个rabbitmq连接。为发布者和使用者分离连接，以实现高吞吐量。当发布服务器发送太多消息以供服务器处理时，RabbitMQ可以对TCP连接施加回压。如果您在同一个TCP连接上使用，服务器可能不会从客户端接收消息确认，从而影响使用性能。以较低的消耗速度，服务器将不堪重负。
浏览 3提问于2021-07-16得票数 0
回答已采纳
我有一个使用RabbitMQ绑定器的Spring Cloud Stream应用程序，构建在Spring Boot 1.5和Spring Cloud Edgware.SR4上。由于某种原因，Spring Cloud Bus无法从至少30秒的网络中断中恢复(持续时间可能取决于您的环境)。如果网络中断的时间足够长，以至于RabbitMQ删除了独占队列，则应用程序能够重新声明匿名队列。这似乎是一个重复发生的事件，与RabbitMQ服务器的系统修补/重新启动一致。
通过连接到远程服务器并断开笔记本电脑上的网络连接，我复制了此RabbitMQ中的错误。拥有来自测试的整个标准输出。
以下是事件的概要：
声明
浏览 291提问于2018-12-18得票数 3
2回答
我创建了一些连接到Rabbitmq中的队列的使用者，解压缩了一些消息，比如每次10,50,100条，以避免一个接一个地获取不必要的连接。有时，我们会遇到队列几乎是空的情况，只有一个用户收到所有消息。不幸的是，其中一条消息的处理速度很慢(例如，第三方web服务超时)，而所有其他消息都必须排队等待这条消息完成，即使它们更快。尽管如此，其他消费者都是空的，没有什么可做的，但是他们不能接收第一个用户还没有处理的消息。
如果我可以对Rabbitmq说，传递一种更完美的消息，如果它在一段时间后没有中断，那么按摩必须被传递到队列中，并被另一个消费者接受。有人知道附近有没有工作吗？
浏览 0提问于2018-04-05得票数 0
回答已采纳
2回答
我有一个生产者，我想通过一致的哈希，在消费者之间始终如一地分发作品。例如，对于使用者节点X和Y，任务A、B、C应该始终转到使用者X，而D、E、F应该转到使用者Y。但是，如果Z加入了消费者池，这可能会发生一些变化。
我不想编写自己的逻辑来连接到使用者节点，特别是不想管理连接和离开池的节点，所以我已经开始使用RabbitMQ和每个使用者节点的排他队列。
我遇到的一个问题是列出这些队列，因为在发布工作之前，生产者需要知道所有可用的队列。AMQP甚至不支持列表队列，这让我对我的整个方法感到不确定。RabbitMQ和Alice ()添加了这个功能：
这是对兔子的明智使用吗？我应该使用消息队列吗？是否有一
浏览 11提问于2010-09-01得票数 7
回答已采纳
我和我的同事讨论了RabbitMQ的设计，Server A和Server B之间，下面是流程图。
Server A通过exchange A和Queue B向Server B发送消息，并通过Queue A接收来自Server B的消息。反之亦然，对于Server B。
Server A中有两个用C++实现的类:一个是sender，另一个是receiver。对于用Server B实现的JavaScript，也有相同的代码结构。
sender和receiver在Server A。我同事的想法是：
发件人中的初始化：
创建与rabbitmq的连接
声明exchange A
声明
浏览 1提问于2015-07-21得票数 7
在我的应用程序(多个实例)中，我们偶尔会看到我的应用程序和rabbitmq之间的连接由于网络问题而丢失(我的应用程序和rabbitmq都是活着的)，然后在恢复连接(重新建立)之后，我们将接收未加标记的消息。
这给我们带来了一个问题，因为我的应用程序还没有死，它仍然在处理以前收到的消息，但是现在消息被重新处理了，它导致应用程序再次处理消息(这对我们来说可能是致命的)。
由于应用程序有多个实例，因此实例很难检查另一个实例是否同时处理相同的消息。我们不能简单地过滤掉重新传递的消息，因为我们需要这个特性来处理实例/应用程序崩溃/重新部署.
似乎没有api来告诉rabbitmq什么时候不重新传递未加标记
浏览 5提问于2019-12-18得票数 2
目前，我有以下情况：
publisher.js：
var queue_connection = new amqp.createConnection( { host: config.rabbitmq.host, port: config.rabbitmq.port } );
queue_connection.on( 'ready', function () {
var exchange = queue_connection.exchange( 'http_worker', { type: 'topic' } );
e
浏览 3提问于2015-04-23得票数 3
回答已采纳
嗨，我有一个rabbitMQ队列，只有one worker来处理排队的消息。我想知道是否有任何方法告诉rabbitMQ，如果消息未被确认，定期将其再次发送给工作人员。
非常感谢。
浏览 1提问于2018-07-23得票数 1
回答已采纳
如果我有一个RabbitMQ使用者批量检索100条消息，但在将这些消息标记为已处理之前就会崩溃，那么这些消息是否丢失了？我希望队列中的每条消息至少处理一次。在确认消息之前，有什么推荐的方法来处理那些崩溃的消费者？
RabbitMQ是否以某种方式将它们重新放到了队列中，或者我需要做些什么来实现它呢？
浏览 8提问于2017-02-21得票数 11
1回答
我正在实现一个日常作业，它从MongoDB (大约300 K文档)获取数据，并为每个文档在RabbitMQ队列上发布一条消息。另一方面，我在同一个队列中有一些消费者，理想情况下，这些用户应该并行工作。
一切都很正常，但没有我想的那么多，特别是关于消费者的表现。
我是这样声明队列的：
rabbitMQ.getChannel().queueDeclare(QUEUE_NAME, true, false, false, null);
以下是发布的方式：
rabbitMQ.getChannel().basicPublish("", QUEUE_NAME, null, body.getB
浏览 2提问于2018-04-16得票数 2
回答已采纳
1回答
我能够使用 RabbitMQ Java教程创建扇出交换，并且任何连接的消费者都将收到一份消息副本。我希望在连接任何使用者之前创建交换和绑定，而不是以动态/编程的方式声明交换和绑定。我已经通过RabbitMQ管理控制台完成了这项工作。然而，由于某些原因，我的消费者正在以循环方式接收消息，而不是所有接收消息的副本。我遗漏了什么？以下是一些代码片段：
出版商：
channel.basicPublish("public", "", null, rowId.getBytes("UTF-8"));
消费者：
QueueingConsumer consumer
浏览 1提问于2013-03-11得票数 8
回答已采纳
如何增加传递确认超时rabbitMQ版本为3.10.1
rabbitMQ配置
rabbitmq:
hostname: 'prod-rabbitmq'
image: "rabbitmq:3.10.1-management-alpine"
container_name: puppeteer-script-rabbitmq
restart: always
volumes:
- ./data/rabbitmq:/var/lib/rabbitmq
浏览 9提问于2022-05-18得票数 1
回答已采纳
第19页的"RabbitMQ in Action“一书给出了这些排他性和自动删除的描述：
自动删除-当最后一个使用者取消订阅时，队列将自动删除。如果只需要一个使用者使用的临时队列，请将自动删除与独占结合起来。当使用者断开连接时，队列将被移除。
然后，在中给出如下描述：
“过期”策略控制队列在自动删除之前可以使用多长时间。未使用意味着队列没有使用者，队列最近没有重新声明(重新声明续订租约)，并且至少在过期期间没有调用basic.get。
浏览 13提问于2019-09-30得票数 4
这是Symfony2命令行脚本的一部分。当脚本等待时，它会随着此异常而死亡。
[PhpAmqpLib\Exception\AMQPRuntimeException]
Error reading data. Received 0 instead of expected 1 bytes
我搜索过谷歌，发现提到了心跳和set_time_out，但是当我试图设置构造函数时，但是当我将其从缺省值中更改时，它就会死得更快。
这就是我的脚本的设置方式。因为它的Amqplib方面。
// Get the configuration options for RabbitMQ
$q
浏览 3提问于2015-08-10得票数 0
回答已采纳
我正在学习https://www.rabbitmq.com/tutorials/tutorial-one-python.html上的教程 我已经使用docker设置了RabbitMQ。在那里定义了交换，等等。 管理UI显示创建的exchange。当第一次执行发送者脚本时，队列也会显示在UI中。 我首先运行消费者&然后是发布者。但是，当消息被发布时(假设消息已经发布，因为send脚本没有抛出任何错误)，消费者不会收到任何消息。我可以看到AMQP连接被正确地建立和关闭(在发布者的情况下)。但是队列是空的。 管理UI还显示一个空队列。我尝试使用UI本身发布持久和非持久消息，但即使在那里，当
浏览 257提问于2021-10-24得票数 0
1回答
据我在rabbitmq文档上看到的，已排队的消息以循环方式发送给连接的消费者。然而，我想让我的一个消费者接受，让我们说，1%的信息进行试点测试。
是否有可能做到这一点？任何想法都会有帮助。
谢谢
浏览 1提问于2020-04-29得票数 4
我正在尝试写一个SpringBootTest来测试骆驼路线。我的路线如下：
restConfiguration().producerComponent("http4")
.host("http://127.0.0.1);
from("rabbitmq:foo")
.to(rest:post")
.log("Hello!: ${body}");
这是我的测试：
@RunWith(CamelSpringRunner.class)
@MockEndpoi
浏览 0提问于2019-08-18得票数 0
回答已采纳
1回答
和春天一起工作，我对狂犬病很陌生，我想知道我错在哪里。
我编写了一个rabbitmq连接工厂和一个包含侦听器的侦听器容器。我还为侦听器容器提供了一个错误处理程序，但它似乎不起作用。
我的春豆：
<rabbit:connection-factory id="RabbitMQConnectionFactory" virtual-host="${rabbitmq.vhost}" host="${rabbitmq.host}" port="${rabbitmq.port}" username="${rabbitmq.user
浏览 1提问于2017-04-04得票数 3
回答已采纳
在实现使用RabbitMQ(.NET)使用者使用EventingBasicConsumer时，控制最大工作线程数的最简单方法是什么？
根据我目前的理解，在默认情况下，会有大量消息传入线程。例如，如果使用操作打开数据库连接，则最大线程数应处于控制之下。
浏览 3提问于2015-09-15得票数 2
回答已采纳
在我的应用程序中，我想跟踪哪个用户/客户机/应用程序与RabbitMQ代理连接/断开连接。
对于客户端连接，如何设置唯一的ID，以便能够找到哪个客户端(两者都是生产者/使用者)被连接了。
顺便说一下，我正在使用来处理RabbitMQ/AMQP。
浏览 2提问于2017-02-10得票数 0
我们需要向客户端提供实时消息，但它们的服务器位于代理之后，我们无法初始化连接；web钩子变体无法工作。
考虑到这一点，什么是传递实时信息的最佳方式：
代理背后的客户端
客户端可以关闭很长一段时间，所有消息都必须传递。
协议/方式必须足够通用，这样即使是PHP开发人员也可以很容易地使用它
我想到了三个变体：
WebSocket - client打开一个websocket连接，我们发送存储在DB中的消息，同时消息实时启动。
RabbitMQ -所有消息都存储在一个持久的持久队列中。如果合作伙伴在一段时间内不会从队列中读取数据，该怎么办？
HTTP partner将按
浏览 3提问于2013-09-24得票数 0
1回答
我们使用RabbitMQ的event-exchange插件来接收有关打开/关闭连接的事件：https://www.rabbitmq.com/event-exchange.html 当从特定队列消费任何消息时，是否有任何插件或机制来接收事件？
浏览 18提问于2019-09-18得票数 1
1回答
需要帮助(如果可能的话)，我尝试在rabbitMQ中更改队列中的消息，但直到现在我还没有找到任何方法。
有什么办法可以做吗？比如插件或RabbitMQ Http接口？
示例:更改此消息的有效负载：
关于信息，我使用与Amqp启动器一起的spring引导来建立连接，有什么方法可以获得像这条消息那样的特定消息并进行更新吗？
预先通知，谢谢。
浏览 2提问于2018-03-20得票数 2
回答已采纳
1回答
我正在尝试向我的Django应用程序添加一些实时特性，因为我在django项目中使用了RabbitMQ和Celery，所以我想要做的是:我有一个外部Python脚本，它将数据从RabbitMQ >发送到RabbitMQ --应该从Django应用程序中检索。
我正在发送一些木偶数据，如：
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
channel.queue_declare(queue='Te
浏览 3提问于2020-03-31得票数 0
回答已采纳
1回答
我有两个关于狂犬病消费者(接受者)的问题：
我如何定义(静态地从队列中)注册到某个队列的使用者是什么，以便如果有一个使用者下线，消息仍然会在该使用者再次上升之后被传递，或者有其他方法来实现这一点？
消费者如何连接到一个仍未创建的队列，在rabbitmq教程中，我可以在生产者之前给消费者打电话，它仍然能工作，有人能解释一下这是如何工作的吗？
谢谢
浏览 1提问于2016-06-23得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
