PHP RabbitMQ使用者停止使用事件
是指在使用PHP编程语言开发的应用程序中，使用RabbitMQ消息队列服务的消费者停止使用的事件。
RabbitMQ是一个开源的消息代理和队列服务器，它实现了高级消息队列协议（AMQP），用于在分布式系统中进行消息传递。它提供了可靠的消息传递机制，使得不同的应用程序可以通过消息进行通信，实现解耦和异步处理。
当PHP RabbitMQ使用者停止使用时，可能会出现以下几种情况：
- 程序错误或异常：消费者程序可能由于代码错误、逻辑错误或异常情况而停止使用。这可能导致消息无法被消费和处理。
- 运行环境问题：消费者程序所运行的服务器或容器可能发生故障、崩溃或重启，导致消费者停止使用。这可能需要重新启动消费者程序或修复运行环境问题。
- 网络问题：消费者程序与RabbitMQ服务器之间的网络连接可能出现问题，例如网络中断、连接超时或连接错误，导致消费者停止使用。这可能需要检查网络连接并重新建立连接。
为了解决PHP RabbitMQ使用者停止使用的问题，可以采取以下措施：
- 监控和日志记录：使用监控工具和日志记录机制来实时监测消费者程序的运行状态和错误信息。这可以帮助及时发现问题并进行排查。
- 异常处理和重启机制：在消费者程序中实现适当的异常处理机制，以捕获和处理可能出现的错误和异常情况。同时，可以考虑实现自动重启机制，使消费者程序在停止使用后能够自动重新启动。
- 定期维护和更新：定期对消费者程序进行维护和更新，包括修复已知的问题、优化性能和安全性，并及时应用最新的补丁和更新。
腾讯云提供了一系列与消息队列相关的产品和服务，可以用于构建可靠的消息传递系统。其中，推荐的产品是腾讯云消息队列 CMQ（Cloud Message Queue），它是一种高可用、高可靠、高性能的分布式消息队列服务。CMQ支持多种协议和编程语言，包括PHP，可以方便地与PHP应用程序集成使用。
更多关于腾讯云消息队列 CMQ的信息和产品介绍，可以访问以下链接地址： https://cloud.tencent.com/product/cmq
相关·内容
2回答
我计划使用RabbitMQ、Symfony2和RabbitMqBundle编写一个日志处理应用程序。我正在使用的工具必须是高度可用的，并且必须每天处理数百万条条目，因此重要的是，使用者始终处于启动和运行状态(短暂的休息时间是可以的)，否则我的队列可能会在一段时间后溢出。
在如何管理使用者(用PHP编写)、在发生错误时启动/重新启动消费者等方面有最佳实践吗？
谢谢
浏览 2提问于2013-11-05得票数 5
回答已采纳
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
我有一个消息驱动的通道适配器，我将最大并发消费者定义为100，并发消费者定义为2。当我尝试负载测试时，我看到并发用户增加了，但是在负载测试之后，消费者的数量并没有减少到标准水平。我正在RabbitMQ管理门户网站上查看它。
当项目重新启动(无负载测试)时，GET (空)是650/s，但在负载测试之后它保持在2500/s左右。它没有返回到650/s。我认为并发-消费者属性被增加到一个数字，但没有降低到原始值。怎样才能使它再次降到正常水平呢？下面是我的消息驱动-通道适配器定义：
<int-jms:message-driven-channel-adapter id="inboundA
浏览 4提问于2022-08-25得票数 0
我正在尝试使用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
1回答
我应该如何构造RabbitMQ？
、、、、
我正在尝试将我们的单块PHP Symfony应用程序迁移到一个更可伸缩的Docker解决方案中。应用程序和RabbitMQ之间有一些通信，我使用docker-compose将所有容器都打开，在本例中是应用程序和RabbitMQ服务器。
围绕这个主题有很多讨论，即一个容器应该只生成一个进程，而在这一点上有点模糊：
虽然这个口头禅有良好的意图，但并不一定每个容器只有一个操作系统进程。除了容器现在可以通过init进程生成之外，一些程序可能自行生成额外的进程。
为每个RabbitMQ使用者创建一个单独的Docker容器有意义吗？不让rabbitmq服务器知道用于处理队列的语言/工具是“正确的”
浏览 2提问于2017-07-05得票数 5
回答已采纳
1回答
我使用MASSERSIT7.0.0与使用者一起处理来自RabbitMQ的消息。我已经观察到，当使用者处理消息的速度很慢时，或者当我将调试点放在visual studio中供使用者使用时，过了一段时间，我的使用者再次收到消息。我的假设是，Masstransit认为消费者崩溃了，并再次发送了信息。
在我的例子中，我的使用者在与外部端点交谈时处理消息的速度有时很慢，但是处理时间大约是30-40秒，而不是分钟。
请您解释一下，如何知道用户是如何通过崩溃(或任何其他方式)重新发送消息的？如果它等待一定时间等待ack，那么在任何地方设置这个时间是否只是为了增加队列/使用者的特定时间呢？
谢谢
浏览 2提问于2020-08-25得票数 1
回答已采纳
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
回答已采纳
2回答
如何扩大微型服务中的并行消费者
、、、、
对于一个新的项目，我们将考虑将Microservices与RabbitMQ或Kafka一起使用。对于这两种技术，我都有相同的问题，但答案可能有所不同。
考虑三项活动：
创建产品1
创建配置文件1
删除产品1
我们希望使用这些事件在服务之间“复制”数据。当使用一个使用者时，所有消息都将以正确的顺序执行，并且数据库将是一致的。
但是，当这个使用者在处理消息时放慢速度时，您可能希望并行地添加另一个使用者。此时，事件1是否在事件3之前执行是不确定的，这可能导致不一致的数据库(先删除，后创建)。
找到了一些关于这个主题的信息，但这两种解决方案似乎都很难实现。如何才能扩大这些消费者的规
浏览 5提问于2017-11-05得票数 1
回答已采纳
1回答
我是rabbitmq的新手。在python/php中的所有rabbitmq教程中，接收方表示
php receiver.php
或
python receiver.py
但我们如何在生产中做到这一点呢？如果我们必须在生产中运行以上命令，我们要么必须使用&最后，要么我们必须使用nohup。这不是个好主意吗？
如何在php/python的生产服务器中实现rabbitmq接收器？
浏览 2提问于2020-04-13得票数 1
回答已采纳
我正在尝试同步我拥有的三个微服务。
为了做到这一点，我实现了RabbitMQ。现在似乎一切正常，但我不确定我是否在遵循最佳实践，我找不到参考资料来查找它，也许有人能帮我做这件事？
简要介绍我要做的事情：我有一个服务应该更新另外两个，每个服务都应该接收发送的消息。我有两种类型的消息(保存和删除资源)。*在出现错误时，队列应恢复并重新发送消息。
我正在做的事情：，我已经设置了一个交换，我的每个使用者连接到两个不同的队列，每种类型的消息(保存/删除)一个。我已经使用了一个直接的交换来过滤以后的消息，即使目前我不需要过滤它们。
每个队列都是命名的，交换和消息都是持久的，我正在添加我使用过的消息。
问题
浏览 4提问于2016-07-11得票数 3
回答已采纳
我是RabbitMQ新手，我正在开发一个应用程序，它将从许多设备接收信息，并根据MQTT主题将所有消息路由到几个队列中。我能够轻松地完成所有这些工作，但现在我正在研究如何在客户端连接或断开与RabbitMQ的连接时将消息推送到队列中，以便更新数据库中客户端的当前状态。有办法这样做吗？
浏览 0提问于2018-03-17得票数 3
我希望在RabbitMQ中的队列中有这个约束：
队列中的下一条消息不能在前一条消息(正在处理的消息)被添加之前退出队列。
通过这个，我将实现事件的有序处理和跨多个队列的并行处理。如何为此配置RabbitMQ？
编辑(澄清)：将有许多消费者都试图从所有队列中获得工作，而且由于他们无法从一个队列中获得工作，而该队列中有一个事件正在被处理，而这个队列并没有被执行--有序处理是被维护的。
浏览 4提问于2015-09-07得票数 3
回答已采纳
正如您在下面的图中所看到的，有两个使用者，它们都读取相同的分区。
为什么使用者2要读取所有读取使用者1的消息？怎样才能在实践中有用呢？
如何知道分区的大小和位置开始/结束读取？
卡夫卡还记得每个消费者的抵消分区吗？它像RabbitMQ中的扇形吗？
浏览 6提问于2019-07-21得票数 0
回答已采纳
我在EventingBasicConsumer的RabbitMQ中添加了一个接收到的事件处理程序。我试图检查队列是否被消耗(已处理，现在为空)，它应该关闭使用者和连接。我无法找到能够判断队列是否已被处理的条件。
请帮帮忙
public void ProcessQueue(string queueName, Func<string, bool> ProcessMessage)
{
//lock (this.Model)
{
this.Model.BasicQos(0, 1, false);
浏览 7提问于2017-11-08得票数 3
回答已采纳
我有一个I任务，每个任务都有一些任务要做：
每个用户的每一项工作；
对于每个任务，用户数和作业数是不同的。
我希望将所有作业放入一个具有名称任务{id}的队列中，以便控制任务何时完成(通过空队列任务{id})，并使用rabbitMQ帮助自动删除它，并控制处理一个任务{id}的多个使用者。
我希望我的消费者一直像守护进程一样工作，并选择具有自动工作任务的队列。
这里的主要问题是如何在使用者内部获取任务的名称来将它们绑定到它？或者，在不知道队列名称的情况下，rabbitMQ还可以使用另一个技巧来做到这一点？
浏览 5提问于2019-11-24得票数 0
我看不出有什么可以说这是正常的行为，所以如果我是瞎子，请原谅。在使用带有请求响应的MassTransit时，我看到了一些奇怪的东西。
因此，我在一个服务上有多个使用者，它侦听不同的请求来执行简单的任务，比如从数据库抓取数据。
为了测试每个使用者，我创建了一个控制台应用程序，它为每个使用者执行一个请求并检查响应。
我注意到的是，第一个请求-响应工作正常，但是当代码运行时，下一个检查会收到响应，但是消息会被移动到跳过的队列中并删除。
这是第二次请求的杂凑日志。
发送
rabbitmq://192.168.0.25/Ksrs.Requests:ConceptByConceptNoRequest d9
浏览 3提问于2021-05-14得票数 0
回答已采纳
1回答
我正在尝试使用Moq包对我的RabbitMQ交换和队列进行单元测试。但是，无论我如何尝试和多少使用谷歌，我无法理解我应该如何嘲弄rabbitMQ对象。对于刚开始单元测试的人有什么指点吗？
我尝试过使用nuget包RabbitMQ.Fakes，如下所示：
[TestMethod]
public void testconnectionnotnull()
{
FakeConnectionFactory factory = new FakeConnectionFactory();
IConnection connection = factory.CreateConnection();
浏览 0提问于2018-12-10得票数 1
下面是在ASP.net Core6.0API中开发的一个示例POC，它使用MassTransit和RabbitMQ来模拟使用MassTransit使用者的简单发布/订阅。然而，当代码被执行时，它会在RabbitMQ中创建2个交换和1个队列。
Program.cs
builder.Services.AddMassTransit(msConfig =>
{
msConfig.AddConsumers(Assembly.GetEntryAssembly());
msConfig.UsingRabbitMq((hostcontext, cfg) =>
{
浏览 11提问于2022-09-15得票数 0
我正在使用以下代码测试RabbitMQ AsyncEventingBasicConsumer：
static void Main(string[] args)
{
Console.Title = "Consumer";
var factory = new ConnectionFactory() { DispatchConsumersAsync = true };
const string queueName = "myqueue";
using (var connection = factory.CreateConnectio
浏览 3提问于2017-12-16得票数 32
1回答
有一种情况是，我有单独的CommandBus和EventBus，我有一个使用者侦听命令总线中的命令，并且在处理操作之后，它会将相关事件发布到事件总线。我希望在EventBus上内置支持事务性发件箱模式。
以下是应用程序的配置：
public static void ConfigureServices(HostBuilderContext host, IServiceCollection services)
{
services.Configure<MessageBrokerConfiguration>(host.Configuration.GetSect
浏览 12提问于2022-12-03得票数 0
回答已采纳
这里是Java & RabbitMQ。我需要实现某种毒丸模式，在处理特定消息时，使用者需要取消自己，停止接收/处理任何进一步的消息。停下来清理干净。消息杀死使用者并释放线程、内存等。
我看到消费者有一个handleCancel方法，他们可以实现这个方法来响应来自外部的取消命令，但是我如何处理消费者内部的一条毒丸消息，该消息告诉消费者死亡？
浏览 8提问于2022-08-16得票数 0
回答已采纳
我将围绕RabbitMQ队列制作一个域驱动的设计，我对此完全陌生。我想知道，考虑到有限制的上下文，是否有一些准则来识别不同的队列。
内容，如每个有界上下文中的一个队列，或有界上下文中的每种资源类型中的一个队列。
由于队列通常会跨越不同的有界上下文，这使得事情变得更加复杂。
有什么建议吗？
浏览 0提问于2019-05-18得票数 3
回答已采纳
我在使用php-amqplib的rabbitmq中遇到了一个特别的问题，consumer.php不使用更新的代码库，而是使用旧的代码。
rabbitmq有没有类似于laravel listen命令的东西？php artisan队列:监听
如果没有，你能为我的用例推荐一些替代方案吗？
浏览 0提问于2020-11-04得票数 0
我在RabbitMq中使用的是Mastrit3.5.0。如果队列使用者抛出异常，默认情况下将对其进行MoveExceptionToTransportFilter处理并移到_error队列。对于_error队列，我有单独的使用者:消费(ConsumeContext>上下文)
过失的行为是完全不同的。部分错误将被处理并从_error队列中删除，但部分错误消息仍然保留在错误队列中，并且不会被该使用者使用。正如我所理解的，如果我有错误使用者，那么_error队列应该是空的。
我找不到解释，为什么错误还在排队。也许是因为这些错误曾经被消耗掉过，但是我在标头中找不到任何指示，或者在哪里？
浏览 2提问于2017-09-09得票数 3
回答已采纳
为了避免常见的并发问题，我有一个单线程的php使用者，它使用来自一个rabbitMQ队列的几条消息。
基本上，相同的php脚本执行X次并等待新消息。
我的问题是：
假设(我的使用者是单线程)设置了1条消息的预取配置是正确的吗？
因为很明显，处理一次不能超过一条消息.
对吗？
浏览 4提问于2016-04-27得票数 2
回答已采纳
1回答
当我们有超过3000个连接/秒的峰值时，我们的rabbitmq服务器不能跟上连接，并且新的连接需要很长时间才能稳定(达到3s的失败限制)。我们需要出版商尽快返回，因为任何延迟传输到用户体验。 我们目前正在考虑将连接到第二个rabbitmq服务器的负载平衡编码为一个快速的临时解决方案。 我们只在需要发布时创建连接，并且按照最佳实践的建议，对相同的web请求/流程重用相同的连接和通道。PHP进程的本质是在web请求之后终止。 我是否可以重用该连接以在web请求之间发布？ 3000连接/秒的峰值是否足以使rabbitmq服务器遭受tpc连接过载？ 当我们将来有10倍的这种连接时，我们应该采取什么方
浏览 79提问于2021-11-12得票数 0
回答已采纳
我有两个节点，NodeA和NodeB。
NodeA有
a) RabbitMQ running
b) an application 'foo' listening on a 'topic' and bound to a 'Q1'.
节点B
a) no RabbitMQ
b) an application 'bar' that sends a RabbitMQ message using the NodeA's IP address.
所以从‘酒吧’到'foo‘的推动是有效的。现在'foo‘可以推到'
浏览 4提问于2016-07-13得票数 0
回答已采纳
1回答
在这个php库的帮助下，我正在使用，现在我的代码以如下方式工作:每个队列都有单独的类来添加新的消息到队列中，以及单独的队列工作者，例如: SmsQueue和SmsWorker。我从cron运行队列工作者(例如SmsWorker)，问题是只有当它还没有运行时，我才想运行它。我认为RabbitMQ有一些方法可以查看当前是否有活跃的队列使用者，但我找不到它。这里的解决方案是什么，我做得对吗？
我刚刚开始使用RabbitMQ，如果这是个愚蠢的问题，我对此不太了解。
浏览 1提问于2016-11-29得票数 0
我开始阅读RabbitMQ来决定是否可以将它用于一个新的网络项目--我现在非常兴奋：)
我看到的所有示例都以使用者的身份在控制台应用程序中使用了一些while(true)循环。在windows平台上实现消费者的可靠和容错的方法。我想是窗户服务吧？是否有人这样做，并在生产中运行，也许可以分享他的经验？
我想做的只是将MQ放在一台服务器上，将消息从web应用程序中推入，并使用第二台服务器连接到第一台服务器上的MQ，轮询消息(每秒钟一次)并执行一些操作。这与RabbitMQ是可能的吗？
Thx Eau
浏览 3提问于2012-06-12得票数 0
回答已采纳
1回答
我正在使用RabbitMQ实现通知系统，并希望了解以下问题的最佳实践。
RabbitMQ服务器安装在本地主机上。
我的制片人代码：
// ... Initialize connection
$this->channel->exchange_declare('my_exchange', 'direct', false, false, false);
// Detect routing key
$parameters = $notification->getParameters();
$routing_
浏览 0提问于2018-08-16得票数 0
我以这里的为例，添加了来自RPCClient的另一个RPC调用，并在stdout中添加了一些登录。因此，当执行第二次调用时，rabbitmq使用具有错误相关id的消费者，这不是预期的行为。是窃听器还是我出了什么问题？
RPCServer：
package com.foo.rabbitmq;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Consu
浏览 0提问于2018-08-06得票数 0
回答已采纳
我正在试图获取RabbitMQ中特定队列的消费者总数。我在C#中使用RabbitMQ客户端为.Net编写了代码。
string user = ConfigurationManager.AppSettings["rmq_user"];
string pword = ConfigurationManager.AppSettings["rmq_pass"];
string port = ConfigurationManager.AppSettings["rmq_port"];
string host = new Uri(ConfigurationMan
浏览 11提问于2017-02-01得票数 1
回答已采纳
我正在使用Spring 和RabbitMQ。
使用RabbitMQ启动码头后：
sudo docker run -t -i --name rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq:3-management
我执行了发行者和订阅者应用程序的示例来观察消息的行为。
我在管理面板()中注意到的一件事是，在启动订阅服务器时创建的队列被配置为auto-delete: true。因此，当没有订阅服务器运行时，队列就不会创建，发布者发送的每一条消息都是丢弃的。这不是我所期望的默认配置！
因此，我想将创建的队列更改为auto-delete: false，因为这
浏览 2提问于2018-02-15得票数 1
回答已采纳
1回答
请建议如何使用java使用值防止在RabbitMQ队列中插入重复记录。
例子：
{
"jsonObject" : {
"code" : "ABC",
"number" : "123456",
"Name" : "Narasimha"
}
}
如果RabbitMq中有一条记录可用。如果尝试使用相同的代码和数字再插入一条记录，则不应该允许插入RabbitMQ。
浏览 3提问于2017-12-06得票数 1
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
回答已采纳
我正在学习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的实例，这似乎很好。我可以将多个订阅者/发布服务器连接到RabbitMQ实例，它们看起来很好。然后，我可以从一个发布服务器发布一条消息，但只有一个订阅服务器正在接收该消息。
我相信这与我排队的方式有关。我看过关于兔子，的教程，但我不知道这是否能转化为Masstransit库。
为了我的生命，我很难弄清楚我做错了什么。
NuGets：
MassTransit.Extensions.DependencyInjection 5.3.2
MassTransit.RabbitMQ 5.3.2
有人能帮忙吗
浏览 0提问于2019-03-12得票数 2
回答已采纳
我有处理传入消息的RabbitMq使用者(RabbitMQ.Client.Events.EventingBasicConsumer)。
但是我注意到，如果关闭连接和模型，它们不会等待完成库处理线程。例如：
如果我将线程休眠几秒钟添加到回调中，那么我注意到在完成Close函数之后，Close函数(Close() of IModel和IConnection)在退出消费者回调之前已经完成，我继续收到一些消息给EventingBasicConsumer::Received回调。<code>H 212</code><code>G 213</code>
那么
浏览 4提问于2020-10-30得票数 2
我有一个RabbitMQ消息队列，我希望从web服务调用ServiceA向队列发布多条消息。同时，还有一个名为ServiceB的web服务，用于在10秒的时间间隔内使用来自RabbitMQ相同队列的消息。对于RabbitMQ队列的实现，这种用例可能吗？
RabbitMQ是否支持发布者和使用者同时(同时)访问相同的队列？
浏览 2提问于2020-01-03得票数 2
回答已采纳
对于我的新项目，每个组件都将部署在Azure中。我有一个使用RabbitMQ处理事件的第三方应用程序，我想订阅这些事件并处理它们，以便将数据存储在我自己的数据库中的事件中。
最好的方法是什么？使用webjobs并为RabbitMQ编写自己的自定义触发器/绑定器？
谢谢你事先的建议
浏览 0提问于2016-09-06得票数 3
我在Docker中有一个LAMP设置，作为我正在开发的Cordova项目的API。 我只研究了PHP入队和RabbitMQ，但卸载任务将是加速照片上传或电子邮件发送等任务的主要帮助。 我有这段代码来监听和使用RabbitMQ消息来发送电子邮件，但是我不确定如何将其作为一种守护进程来启动。我还计划添加更多的队列，这将需要更多的侦听器，所以我的想法是有一个专门用于侦听和使用任务的Docker任务容器。 use Enqueue\AmqpLib\AmqpConnectionFactory;
use Enqueue\AmqpLib\AmqpContext;
/**
* Inititate queu
浏览 10提问于2019-02-28得票数 2
回答已采纳
2回答
在我的应用程序中，我使用RabbitMQ在客户机和服务器之间进行通信。
大多数情况下，客户端向服务器发送信息。但有时客户端需要了解服务器中的一些更新。
目前，我正在使用轮询1分钟间隔询问服务器是否有一些更新。
我的问题是，使用发布/订阅机制向客户端“推送”更新会更好吗？
我有大量的客户(大约10000)。那么，打开10000个队列，每个客户端一个队列可以吗？
浏览 4提问于2015-09-27得票数 3
回答已采纳
我希望我的应用程序同时处理来自RabbitMQ的多条消息。我已经尝试过所有的谷歌页面-1解决方案，但它是行不通的。这是我的设置：
POM.xml
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>1.5.10.RELEASE</version>
</parent>
.
.
.
<dependen
浏览 1提问于2018-10-25得票数 3
回答已采纳
我试图在我的微服务架构中设计一种数据更新机制。为了简单起见，让我们假设我们有两个微服务A和B，B公开了一个用于创建某些任务的API，使用simple，POST /tasks，它创建一个任务并返回一个唯一的任务标识符，以便在- task_id上查询。然后，任何创建的任务都可以使用另一个API端点：GET /tasks/{task_id}来查询状态。现在A可以创建任务并使用轮询机制来跟踪进度。接下来，我们要添加的是"push“--使用message (例如RabbitMQ)进行异步更新。现在，每当状态改变时，B将使用message发布数据更新，而A将获得此更新而不是轮询。
这是预期的流量：
浏览 0提问于2022-06-04得票数 0
我用PHP编写了RabbitMQ生产者和消费者(Symfony 4)。使用者使用的是自定义symfony 4命令以及包php-amqplib/rabbitmq-bundle
这是问题所在。我希望能够设置使用者在任务出现在队列中后立即侦听和使用它们。
我试着把它作为一站式系统服务运行，但它是，不能很好地运行。
系统d：
[Unit]
Description=consumer for rabbitmq
[Service]
Type=oneshot
ExecStart=/bin/sh /var/www/public/rabbit.sh
ExecStop=/usr/bin/pkill -f "
浏览 1提问于2019-02-27得票数 3
我想允许外部服务使用我的RabbitMQ队列，问题是我不想让直接访问连接到RabbitMQ，我想通过网关/ API管理器/ Rest端点公开。
我不确定这是否可能，但我想知道如何将事件留在队列中，以便由外部服务以安全方式公开或像Gateway一样集中使用。
感谢大家的回应：)
浏览 2提问于2019-01-03得票数 1
我一直在关注RabbitMQ教程，以便向NodeJS添加发布者和消费者。但互联网上的文档和一般教程缺乏提供正确的生产设置，以使用Nodejs集群设置的RabbitMQ客户端。
从RabbitMQ channel.consume()启动一个消费者。此使用者是否在Nodejs运行的同一线程中启动？如果我运行4个NodeJS子进程，这意味着它将创建4个消费者，对吗？
通过从环境变量获取worker计数来启动仅运行RabbitMQ worker的Nodejs应用程序的正确方法是什么？
浏览 2提问于2020-02-03得票数 1
我已经建立了一个集群本地兔子up(3节点集群)通过码头。在rabbitmq管理UI上，我能够成功地创建交换/队列，并发布消息。我的问题是，在相同的UI中，我没有看到创建任何使用者的选项，所以我的消息被发布了，但没有以确认或交付的状态出现。下面是一个队列的屏幕截图，你可以看到没有消费者。
我刚接触过rabbitmq，所以我可能误解了使用者的概念(或者如何配置一个消费者)，希望任何人建议如何通过这个UI将使用者配置成队列。
浏览 7提问于2017-07-03得票数 0
回答已采纳
3.1.2 MassTransit.Autofac.3.1.1 MassTransit.RabbitMQ.3.1.1 RabbitMQ.Client.3.6.0 Topshelf.3.3.1
一个Top大陆架Windows服务创建一个总线实例，如下所示：
var builder = new ContainerBuilder();
builder.RegisterConsumers(Assembly.GetExecutingAssembly());
builder.Register<IBusControl>(context =>
{
re
浏览 3提问于2016-01-19得票数 0
回答已采纳
1回答
我试图在两个或更多的spring应用程序之间传递数据。为此，我在RabbitMQ中使用了Spring。现在，我还需要Pub体系结构，在这里，所有订阅者都应该得到消息。目前，在RabbitMQ中，Pub为每个用户创建每个队列。这个我不想要。
我还在查看Pub消息传递系统的列表，这将解决我的问题。
Publisher------>Data----->Subscriber 1
----->Subscriber 2
雷迪斯
阿帕奇卡夫卡
请推荐最佳的消息传递系统。
浏览 1提问于2016-09-08得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储活动推荐
腾讯云开发者
