我如何确定带有rabbitmq消费者的服务器已停机？
确定带有RabbitMQ消费者的服务器是否已停机，可以通过以下步骤进行：
- 监测服务器的网络连接状态：可以使用ping命令或者网络监控工具来检查服务器是否仍然可以访问。如果服务器无法ping通，可能意味着服务器已经停机。
- 监测RabbitMQ服务的状态：使用RabbitMQ提供的管理界面或命令行工具，如rabbitmqctl，查看RabbitMQ服务是否在运行。如果RabbitMQ服务停止，说明服务器已经停机或RabbitMQ服务异常。
- 监测消费者的状态：如果RabbitMQ服务正常运行，可以使用RabbitMQ提供的API或命令行工具，如rabbitmqctl，查看消费者的状态。如果消费者的连接数为0或者消费者没有正在消费的消息，可能表示服务器上的消费者已停机。
- 监测日志文件：查看服务器上的日志文件，特别是RabbitMQ服务的日志文件，可以了解服务器的运行状态。如果日志文件中没有新的日志输出，可能表示服务器已停机。
综上所述，通过监测服务器的网络连接状态、RabbitMQ服务的状态、消费者的状态以及日志文件，可以确定带有RabbitMQ消费者的服务器是否已停机。
腾讯云提供了一系列的云计算产品，包括云服务器、消息队列（TencentMQ）、云监控等，可以用于搭建和管理云计算环境。您可以在腾讯云官网上找到相关产品的介绍和使用文档。
参考链接：
相关·内容
我们一直有来自RabbitMQ的以下问题，并且每个周末都会手动重新启动服务器，作为一项工作。
Network partition detected
Mnesia reports that this RabbitMQ cluster has experienced a network partition. This is a dangerous situation. RabbitMQ clusters should not be installed on networks which can experience partitions.
我们已经浏览了其他关于这个主题的热门文章，例如和
我们的网
浏览 5提问于2015-06-30得票数 1
在下面的场景中，我将使用RabbitMQ。当用户使用高级搜索功能时，我会通过RabbitMQ向几个服务器实例中的一个发送消息。它们运行相同的例程(DB查询和计费)。我希望确保不会多次处理相同的消息。我遇到过，但其中显示的交换类型是"Topic"，这对我不起作用，因为我不止一次地处理相同的消息。
如何在RabbitMQ中实现带有工作队列的请求-响应模式，以便每条消息只处理一次，并且实现负载平衡？
浏览 1提问于2015-11-02得票数 3
在以下情况下，RabbitMQ是否进行消息的循环分发？
RabbitMQ配置：
交换类型-主题路由密钥- notify.#
制作人正在通过以下不同的主题推动上述信息的交换-
notify.log.#，notify.status.#，notify.priceChange.#
有4个使用者正在不同的服务器上运行。
3使用者在负载均衡器下对同一应用程序的不同实例执行相同的处理和运行(他们希望使用生产者推送的每一条消息)。
他们正在监听带有路由密钥"notify.#".的“notify.#”.
剩余的第四个用户正在执行一些与前3个使用者不同的处理，并且运行在不同的服务器上(不同的应
浏览 6提问于2019-12-06得票数 2
我有node.js服务器，它也是一个rabbitmq使用者。我希望将我的应用程序扩展到多个实例，但只保持消费者活动。我该怎么做呢？
谢谢
浏览 2提问于2017-09-11得票数 0
1回答
我在一个MassTransit核心6 web应用程序上使用RabbitMQ和.net。我的目标是使一个应用程序的几个实例保持同步，在不同的设备上运行。应用程序需要能够发布/使用消息。
当一个站点发布某件东西时，它会被广播到所有的站点队列中(同时，它本身也会简单地丢弃消息)。
为了做到这一点，我配置了带有工厂后缀的MassTransit队列名:例如norm- queue -CV、norm MB。我还将使用者配置为绑定到一个通用的扇出交换名称(norm- exchange )。
在这里，我的配置摘要：
public void ConfigureServices(IServiceCollection
浏览 6提问于2022-08-01得票数 0
回答已采纳
我刚刚创建了一个API，其中来自API的请求将使用请求/响应模式通过MassTransit/RabbitMQ转发到后端服务。我们现在正在考虑将其推向生产，并希望在不同的服务上运行应用程序的多个实例(包括API和服务)，并使用负载均衡器在它们之间分发请求。
这使我们处于这样一个位置，如果由于任何原因其中一台服务器被移出池，我们可能会丢失所有消息。我正在考虑在服务器之间创建一个RabbitMQ集群(每个服务器都有一个本地安装)，并且想知道如何在这个实例中设置竞争的消费者。
RabbitMQ或MassTransit是否会处理此问题，以便只有一个消费者会收到请求，还是所有消费者都会收到请求并尝试响应？
浏览 0提问于2012-06-17得票数 1
回答已采纳
我在net core 3.1中使用masstransit/rabbitmq。我有一个dispatcher服务，当消息可用时，它会将消息发送到worker服务。每个worker服务在前面都有一个rabbitmq队列，该队列是在服务启动时创建的。我希望确保当worker服务停止时，队列(和交换)需要被删除。当我在配置(Program.cs)中设置标志AutoDelete时，我可以让它工作：
services.AddMassTransit(x =>
{
x.AddBus(provider => Bus.Factory.CreateU
浏览 5提问于2021-06-02得票数 0
回答已采纳
1回答
我正在将我的应用程序构建在一个微服务模型上。
让我们说
服务器D1上有一个数据库
服务器U1上有一个用户服务。
服务器N1上有通知服务。
服务器R1上有一个rabbitmq服务。
通知服务将消息发布到rabbitmq服务，然后该服务将消息发送给用户服务，用户服务侦听rabbitmq服务，接收消息并将一些数据写入数据库。
这是完美的！
问题是，如果我将用户服务扩展到另一个服务器(比如U2 )，这意味着用户服务现在同时运行在服务器上，即U1和U2 (由nginx负载均衡器支持)，而现在收听rabbitmq服务的用户服务将接收从通知服务发送的消息，并且都将写入数据库(我不想要
浏览 5提问于2021-07-30得票数 0
我在后台有一个带有RabbitMQ的应用程序。因此，我想开发定制的第三方分析代码，它连接RabbitMQ上的应用程序队列并收集数据。所以我的问题是，我希望确保应用程序和我的代码都不会丢失rabbitmq中的任何数据。
如果可能，如何配置RabbitMQ队列？我对RabbitMQ具有管理访问权限。我希望这不是生产者的代码问题，因为我没有访问应用程序代码的权限
谢谢你的帮忙
浏览 2提问于2017-10-17得票数 1
我将严格遵循以下教程：。
我这样启动RabbitMQ服务器：
docker pull rabbitmq
docker run -d --hostname my-rabbit-host --name my-rabbit -p 5672:5672 rabbitmq:3
来自本教程：
使用此代码我们可以确保，即使您在处理消息时使用CTRL+C杀死一个工作人员，也不会有任何损失。工作进程死后不久，所有未确认的消息都将被重新传递。
我产生了两个消费者，当我对其中一个消费者执行CTRL+C操作时，另一个正在运行的消费者不会收到最初发往前一个消费者的消息。如何在其中一个消费者发出CTRL+C‘’ing后重
浏览 173提问于2017-10-10得票数 0
2回答
我使用EC2上的spot实例来使用RabbitMQ队列中的数据。每个作业都需要几秒钟，并且需要手动“确认”。
销毁实例时会出现问题。没有时间干净利落地关闭AMQP消费者，所以我留下了RabbitMQ服务器，仍然认为死亡的消费者仍然存在。它不会重新提供他们的工作，它仍然会向他们发送新的工作。
如何让RabbitMQ自动使僵尸消费者超时，并将其从工作池中删除？
浏览 0提问于2012-11-16得票数 7
我有一个带有rabbitmq-native 3.3.1插件的Grails 3.1.12应用程序。
在build.gradle中
compile "org.grails.plugins:rabbitmq-native:3.3.1"
此应用程序在集群中运行，我希望实例充当工作程序。写入交换的消息应该转到一个实例，下一条消息应该转到另一个实例，依此类推。
我可以使用每个消费者中的static块将消费者绑定到队列：
static rabbitConfig = [
"queue": "my.queue.that.is.bound.to.some.e
浏览 2提问于2016-10-22得票数 3
1回答
我用芹菜和RabbintMQ做我的项目。
我有三个服务器(主服务器，A服务器，B服务器)。A和B正在计算主服务器上的任务，然后将响应发送给他。
这是一个组织问题:我需要在哪里安装芹菜和RabbitMQ？
正如我所认为的，RabbitMQ必须安装在主服务器(创建rabbitmq用户等)、芹菜-在A和B服务器上。或者A和B也需要安装RabbitMQ？
谢谢!
浏览 1提问于2014-10-20得票数 1
回答已采纳
1回答
在面向服务的体系结构中，我使用RabbitMQ作为消息队列，其中许多单独的web服务发布绑定到RabbitMQ队列的消息。这些队列反过来又被执行后台工作的各种消费者订阅；这是RabbitMQ的一个很普通的用例。
现在，我想更改一些队列参数(具体来说，我希望将队列绑定到一个新的带有特定路由密钥的死信交换中)。我的问题是，在生产系统上进行这种改变是有问题的，原因有几个。
在生产系统中，向这些新队列过渡而又不丢失消息的最佳方法是什么？
我已经考虑了从版本化队列名到使用新设置创建新的vhost，再到执行所有适当的更改。
以下是我面临的一些问题：
因为RabbitMQ队列是幂等的，所以不同的web服
浏览 3提问于2014-08-12得票数 21
回答已采纳
golang写的rabbitmq客户端，在mq断掉重连之后，消费者不能接受到消息。
哪位大神指点一下
浏览 1457提问于2019-04-19
我正在使用MassTransit和RabbitMQ创建一个简单的发布者/订阅服务器。发布服务器有以下代码来初始化总线：
/** create the bus */
var bus = Bus.Factory.CreateUsingRabbitMq(cfg =>
{
var host = cfg.Host(new Uri("rabbitmq://localhost/"), h =>
{
h.Username("guest");
h.Password("guest");
});
})
浏览 1提问于2016-01-12得票数 5
回答已采纳
我们有两个rabbitmq经纪人。
我们发布到Broker1的队列A，Broker2的队列B可以直接订阅到队列A，这样就没有延迟了，比如为它编写处理程序(使用@rabbitListener)，然后发布到另一个队列。
我的问题是，Broker2是否可以使用任何rabit处理程序直接订阅broker1，或者broker2(另一个队列)是否可以直接使用broker1中的队列数据？有可能吗？
如果是，如何通过spring-amqp实现？
注意:两个不同的RabbitMq服务器中的两个rabbitmq代理
浏览 2提问于2019-06-07得票数 0
我们希望将RabbitMq降级为一个较小的计划，但显然不希望丢失数据或出现中断。我们正在与Heroku一起使用RabbitMq，似乎找不到任何文档。
我们似乎需要使用一个联邦队列来将消息转移到一个新队列，但是我们想知道，例如Heroku是否有一个快速而简单的解决方案。
浏览 2提问于2019-11-24得票数 1
回答已采纳
rabbitmq服务器或集群重启后，所有队列都恢复了所有消息，即使消息已经确认(从rabbitmq服务器启动时开始)，并重新处理所有消息。
队列详细信息
根据我的理解，在消息参数中将persistenet设置为false，如果代理重新启动，消息将不会继续存在。此外，我还将队列的durabele设置为false。
我是否遗漏了任何其他设置？
浏览 1提问于2018-07-10得票数 0
我对RabbitMQ中的这两种类型的消息感到困惑。
我已经看到，我的一些队列有0个“未确认”和1000个“就绪”消息，而另一些队列有1000个“未确认”和0个“就绪”消息。
它们之间的区别是什么？
我如何知道消费者读取了多少消息？
浏览 1提问于2015-08-10得票数 101
回答已采纳
1回答
我想使用RabbitMQ将图像从客户端传输到服务器。然而，从我所读到的内容来看，我了解到RabbitMQ只能传输文本流。那么，如何传输图像呢？
浏览 8提问于2017-09-06得票数 1
我正在Python项目中工作。
它的功能之一是有人从web应用程序中发送一些数据，将数据提前发送到移动设备。
对于此功能，应用程序使用第三方服务作为和。以下是应用程序的数据流。
Web应用
由于Amazon端可能存在网络延迟、操作延迟和故障等问题，web应用程序使用作为调度器应用程序来实现异步、重试等行为，并将SNS发送任务存储在队列中并进行异步处理。
芹菜作为调度器使用RabbitMQ作为它的代理应用程序。以下是数据流。
Web >芹菜-> RabbitMQ -> Amazon > GCM -> Android设备
确定了一个与芹菜和Rabbit
浏览 0提问于2018-04-11得票数 0
我使用python的Kombu (3.0.26)和librabbitmq连接器连接到EC2实例的AWS中的rabbitmq。当我启动和停止应用程序时，到兔子的连接就会出现，并按预期的方式离开。当我用术语杀死这个应用程序或者再次杀死的时候，连接就会像兔子一样消失。
但是，如果我使用AWS控制台来停止或终止实例，则连接将永久停留在rabbitmq上，直到我进入并强制关闭连接为止。
我可能可以通过在应用程序上添加一个AMQP心跳来解决这个问题，并弄清楚如何不断地让服务器知道应用程序还在运行。然而，我有一些阻塞呼叫，如果心跳不及时通信，可能会过早地切断连接。我宁愿rabbitmq服务器只知道TCP连接
浏览 2提问于2015-08-18得票数 3
我需要一个python客户端，它可以在重新启动的RabbitMQ服务器交换上发现队列，然后启动一个客户端，以恢复使用每个队列中的消息。如何从一些兼容RabbitMQ的python api/库中发现队列？
浏览 1提问于2010-11-27得票数 40
回答已采纳
1回答
我在我的Linux服务器上经历了一些兔子my的崩溃。要重新启动它，我执行以下命令：
systemctl restart rabbitmq-server.service
服务器正确地重新启动。
另一个问题是，在崩溃之前，我必须重新启动连接到rabbitmq的所有Node应用程序。
以下是我的问题：
有办法在崩溃时自动重新启动rabbitmq吗？如何使我的节点应用程序自动重新连接到rabbitmq?
非常感谢你的帮助！蒂埃里
浏览 3提问于2019-11-27得票数 0
我正在尝试实现应用服务器，就像使用rabbitMq的聊天服务器一样。
客户端直接连接到兔子服务器。应用服务器应该能够知道哪些客户端已经连接，以及当客户端断开连接时，应该在应用服务器中触发事件。
能用Rabbitmq实现这种功能吗？
Rabbitmq对连接事件有任何类型的事件分派吗？(不是为客户端，而是为我的应用服务器)
我正在为Rabbitmq使用官方的C#客户端。
浏览 1提问于2019-09-08得票数 0
回答已采纳
我在一个SpringBoot应用程序中实现了这个方法 @Scheduled(fixedDelay = 5000)
public void pullMessage() {
MessageDTO message = null;
try {
message = rabbitTemplate.receiveAndConvert(properties.getQueueName(), new ParameterizedTypeReference<MessageDTO>() {});
// more code here...
} 每隔5秒，我就会从
浏览 82提问于2021-10-13得票数 0
回答已采纳
1回答
带Vue JS的RabbitMq
、、、、
我尝试使用rabbitMq来处理来自前端的消息，我已经有了rabbitMq和(AMQP)。我在rabbitMq中搜索Vue-Js或JavaScript，但没有找到任何有用的信息。
那么我如何使用javaScript/vue-Js从rabbitMq中消费呢？
谢谢。
浏览 1提问于2020-02-28得票数 0
我在rabbitMQ上工作，使用C# .net客户端，发布者和订阅者组件是由两个不同的团队设计和管理的，他们使用不同的解决方案。
设计发布者的团队1通过将类型A的消息转换为字节数组来发送消息。设计订阅者的团队2接收团队A发布的字节数据，并需要将其转换为类型A以进行进一步处理。
演示消息类型
class Message
{
public string Name { get; set; } = "Publishing message to Q";
}
因此，在这种情况下，两个团队都需要处理共享的“类型A”，因为如果两个团队在他们的终端维护相同的消息类型，那么它就不能工作。
浏览 0提问于2018-04-18得票数 0
我是RabbitMQ的新手，我已经使用tutorials 尝试过RabbitMQ示例。
有没有人可以解释一下如何发布消息，而不是一次发布一条消息。还有如何从队列中订阅消息作为一组消息，而不是一次订阅一条消息。
也就是说，如何在RabbitMQ中实现将队列消息作为作业集发布和消费？
提前谢谢。
浏览 1提问于2015-03-31得票数 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
RabbitMQ中的消费者利用率(显示在RabbitMQ管理控制台中)是什么？它是消费者通过消费消息而使用RabbitMQ的百分比吗？还是我误解了它？如果是这样的话，如何让消费者100%充分利用RabbitMQ呢？因为，当我增加消费者时，我看不到任何百分比的增加，但在启动新消费者的那一刻，只有几秒的时间。我不能从tool-tip中提供的小解释中得到很多东西。
此外，工具提示文档说预取计数会以某种方式影响消费者的利用率，那么有没有公式来修正这个数字呢？
so many consumers = this many fetch counts
(或)
time taken by a consumer
浏览 2提问于2015-09-14得票数 2
1回答
我正在构建一个应用程序来使用来自RabbitMQ的高容量(流)消息。情况如下：
发布服务器发布实时匹配数据的有RabbitMQ，这意味着数据量非常快(每秒100次)，RabbitMQ中的最大队列长度为500 ，意味着如果用户不能很快地接收消息，消息将丢失
以下是我的疑问
：对于上述场景，哪种模式/体系结构/工具最适合？(非常快地使用消息)
MassTransit会满足上述要求吗？
浏览 2提问于2021-10-24得票数 3
回答已采纳
石英和RabbitMQ，这两种技术的区别是什么？它们能一起使用吗？这些技术可以安装在承载web服务器的硬件上吗?还是为它们配备专用硬件更好呢？
浏览 2提问于2012-09-08得票数 1
1回答
我有两台服务器，分别叫做A和B。B运行RabbitMQ，而A通过Kombu连接到RabbitMQ。如果我在B上重新启动RabbitMQ，则kombu连接断开，消息不再传递。然后，我必须重置A上的进程以重新建立连接。有没有更好的方法，也就是说，有没有一种方法可以让Kombu自动重新连接，即使RabbitMQ进程重新启动了？
我的基本代码实现如下，提前感谢！:)
def start_consumer(routing_key, incoming_exchange_name, outgoing_exchange_name):
global rabbitmq_producer
inco
浏览 6提问于2016-06-02得票数 1
我使用的是RabbitMQ和QoS=1上的MQTT插件，生产者和消费者都在使用。我对RabbitMQ还是非常陌生的，所以我想了解是否有一种方法/有效的模式来确保在消费者不消费他订阅的主题的信息的情况下出现退路。
例如，如果客户端不使用MQTT主题的消息，那么在几秒钟后就能够向服务器发送警报触发另一个通道(电子邮件、推送通知)？
谢谢你的帮助!
浏览 3提问于2014-12-23得票数 1
回答已采纳
在多个消费者的情况下，是否可以设置消费者应该确认rabbitmq服务器的时间，否则该消息应该被认为是未被RabbitMQ服务器确认的，并且应该被给予另一个消费者？
浏览 0提问于2013-12-14得票数 0
RabbitMQ版本: 3.8.2 Erlang 22.2
由于一些问题，我不得不在服务器上重新安装RabbitMQ和Erlang。
尽管重新安装了应用程序，但来自上一个实例的队列仍然存在，并且正在创建新的队列( Guid's给出的队列名称因此是唯一的)。
这是正常行为吗？如何删除没有附加使用者的旧队列？我以这种方式得到了25000个队列：
谢谢
浏览 3提问于2020-03-21得票数 0
回答已采纳
1回答
当消费者确认消息时，RabbitMQ或某些插件提供的事件会被“触发”吗？例如，事件结果可以是发送到特定队列或网络挂钩的消息。有什么解决方案或建议吗？
预期场景:有一个包含客户端应用程序的消息的队列-应用程序使用来自此队列的消息-应用程序发送轻量级AMQP数据包-服务器接收ack服务器调用某种回调( ack挂钩)
浏览 17提问于2019-11-13得票数 1
1回答
我正在使用spring-boot创建一个批量视频处理系统。在这里，用户将通过xlsx表提供所有视频相关信息，我们将在后端处理视频。我使用Rabbitmq对请求进行排队。假设用户上传了一个有100行的工作表，那么Rabbitmq队列中将有100条消息。在后端，我们会自动扩展订阅者(服务器)。因此，我们将从一个订阅者开始，并根据负载(队列中的消息数量)扩展到15个订阅者。但我们的生产者非常快，它将所有消息分配给我们的第一个订阅者(在其他订阅者到来之前)，而我们所有的新订阅者都不会从队列中获得任何消息。如果在producer开始推送消息之前所有订阅者都可用，那么它会将消息分配给所有服务器。 请为我
浏览 19提问于2019-09-25得票数 0
回答已采纳
我使用带有.NET的.NET (v7.1.6)通过RabbitMQ发布和使用消息
为了将使用者绑定到特定的队列，我以这种方式配置端点：
configurator.ReceiveEndpoint(
"QueueName",
cfg =>
{
cfg.ConfigureConsumer<MyConsumer>(context);
cfg.ExchangeType =
浏览 22提问于2021-05-31得票数 0
回答已采纳
我在使用RabbitMQ Java Driver amqp-client version 5.1.2的应用程序中检测到许多“管道断开”或“连接被拒绝”错误。RabbitMQ服务器版本为3.7.3。
为了限制传入的消息，我将使用autoAck=0在DefaultConsumer中添加一个Thread.sleep(2000)循环。当然，我可以设置channel.basicQos(..)，但我需要限制的不仅仅是“我当前有多少条消息”。
但是，这个伪代码会导致java.net.SocketException
// register new connection
// register new chan
浏览 4提问于2018-02-22得票数 0
回答已采纳
我们现在使用的是带有WCF激活功能的MSMQ，它使我们能够不拉队列来读取消息。它喜欢将消息推送到应用程序。
当我们看到从MSMQ到RabbitMQ的移植时，我们需要从消息队列中完成所需的工作。
关于RabbitMQ .net客户端支持从订阅队列接收消息通知，我什么都不能做？
RabbitMQ中有什么.net可以推送通知给订阅者的东西，比如MSMQ?
或者我们需要不断检查消息的服务运行？
浏览 3提问于2010-10-14得票数 8
如何将MassTransit配置为在失败之前重试context.Publish()，例如，当RabbitMQ服务器暂时不可用时？
浏览 1提问于2017-06-07得票数 3
回答已采纳
我的服务器上有一个Java API，我想让它创建任务并通过RabbitMQ将它们添加到Celery。我遵循了下面的教程，，其中我使用java作为客户端(send.java)，使用python接收(receive.py)。在调用回调方法的receive.py中，我调用了用@celery.task注释的方法，以便将任务添加到芹菜中。
我想知道所有这一切是如何部署在服务器上的，特别是为什么会有一个receive.py文件。receive.py是必须在服务器上持续运行的进程吗？有没有办法配置RabbitMQ，让它自动将java客户端任务路由到celery？
谢谢!
浏览 0提问于2013-07-15得票数 0
回答已采纳
我是ruby on rails开发人员。在我的项目中，当数据进入队列时，我将使用rabbitMQ来处理一些数据。我正在使用兔子创业板，一个RabbitMq客户端，它提供与rabbitMQ交互的接口。
我的问题是，每当出现异常或服务器在处理队列中的数据时意外停止时，来自队列的消息就会丢失。
我想知道人们如何处理rabbitMQ队列中丢失的消息。有没有办法把这些消息拿回来进行处理。
浏览 1提问于2016-10-16得票数 0
回答已采纳
我正在使用graphql-apollo。客户端订阅一些消息，服务器使用redis将它们发送给客户端。 如果在客户端updateQuery中抛出错误但没有捕获，这会以某种方式影响发布消息的服务器函数的运行吗？服务器函数是否会崩溃或不能正确完成？ 谢谢。
浏览 25提问于2020-08-27得票数 0
如果我有一个RabbitMQ使用者批量检索100条消息，但在将这些消息标记为已处理之前就会崩溃，那么这些消息是否丢失了？我希望队列中的每条消息至少处理一次。在确认消息之前，有什么推荐的方法来处理那些崩溃的消费者？
RabbitMQ是否以某种方式将它们重新放到了队列中，或者我需要做些什么来实现它呢？
浏览 8提问于2017-02-21得票数 11
我正在学习https://www.rabbitmq.com/tutorials/tutorial-one-python.html上的教程 我已经使用docker设置了RabbitMQ。在那里定义了交换，等等。 管理UI显示创建的exchange。当第一次执行发送者脚本时，队列也会显示在UI中。 我首先运行消费者&然后是发布者。但是，当消息被发布时(假设消息已经发布，因为send脚本没有抛出任何错误)，消费者不会收到任何消息。我可以看到AMQP连接被正确地建立和关闭(在发布者的情况下)。但是队列是空的。 管理UI还显示一个空队列。我尝试使用UI本身发布持久和非持久消息，但即使在那里，当
浏览 257提问于2021-10-24得票数 0
我有一个启用了Spring cloud stream的Spring引导应用程序。此项目包含API端点和生产者/消费者流。在我们的例子中，RabbitMQ是绑定器。我们已经启用了Spring安全性，但它适用于API端点。
我需要知道如何对来自RabbitMQ的流请求实施安全性。因为与此相关的用户上下文和其他服务都不会将其请求发布到队列中(我们的云流具有该队列的侦听器)，并且不会直接调用API。因此，我不确定如何在其中使用客户端凭据流。
浏览 2提问于2021-05-18得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
云直播
即时通信 IM活动推荐
腾讯云开发者
