我使用带有.NET的.NET (v7.1.6)通过RabbitMQ发布和使用消息 configurator.ReceiveEndpoint});例如，在Apache RabbitMQ.Client在MassTransit中，我看到了“并发限制”和“并发消息限制”，但它们并不影响Rabbit级别的消费</e
浏览 22提问于2021-05-31得票数 0
回答已采纳
生产者发送消息rabbitmq，消费者从rabbitmq接收消息，然后消费者通过rabbitmq将消息发送回生产者。
有可能吗？
浏览 0提问于2013-01-30得票数 9
2回答
Python Kombu -阻塞
、、、、
通过生产者/消费者模型，我使用kombu来管理RabbitMQ。我启动了我的生产者，它将100个作业放在一个队列中(我只有一个队列，一个交换)。我想推出多个消费者，同时，并让每个消费者过程一次一个工作。不幸的是，消费者之间相互阻碍(即，当一个消费者从队列中抢夺一份工作时，另一个消费者只是坐在那里闲着)。如果我杀死了工作中的消费者，那么其他消费者中的一个就会开始工作。是否有一种方法可以让所有的使用者同时运行，每一个处理来自队列
浏览 3提问于2014-05-30得票数 1
回答已采纳
我有一个队列和两个消费者c1和c2。我的两个消费者已经启动并运行。当消息发布到队列时，JMS broker (RabbitMQ)如何确保该消息只由一个使用者使用？
浏览 9提问于2021-01-28得票数 0
sns，sqs，redis，rabbitmq或其他什么适合这个吗？系统应该是可靠的，并且顺序很重要。
我假设轮询数据库中的消息，将是一种方法，但我不确定这是否有效？
浏览 31提问于2017-06-29得票数 0
当消费者有一些消息时，会为消费者调用回调函数，还是消费者必须轮询RabbitMQ客户端？
因此，在消费者端，如果有PHP脚本，可以通过RabbitMQ调用它并将消息/参数传递给它。例如，如果rating在分片1上提交，而aggregateRating表在分片2上，那么分片2上的RabbitMQ消费者是否会触发脚本aggRating.php，并传递在分片1中插入的参数？
浏览 2提问于2012-02-06得票数 16
回答已采纳
我这样启动RabbitMQ服务器：docker run -d --hostname my-rabbit-host --name my-rabbit -p 5672:5672 rabbitmq:3使用此代码我们可以确保，即使您在处理消息时使用CTRL+C杀死一个工作人员，也不会有任何损失。我产生了两个消费者，当我对其中一个消费者执行CTRL+C操作时，另一个正在运行的消费者不会收到最初发往前一个消费者的消息。如何
浏览 173提问于2017-10-10得票数 0
RabbitMQ中的消费者利用率(显示在RabbitMQ管理控制台中)是什么？它是消费者通过消费消息而使用RabbitMQ的百分比吗？还是我误解了它？如果是这样的话，如何让消费者100%充分利用RabbitMQ呢？因为，当我增加消费者时，我看不到任何百分比的增加，但在启动新消费者的那一刻，只有几秒的时间。此外，工具提示文档说预取计数会以某种方式影响消费者的利用率，那么有没有公式来修正这个数字呢？
浏览 2提问于2015-09-14得票数 2
MessageType："PublishX“Type1ConsumerXType3ConsumerX
浏览 7提问于2015-03-22得票数 2
回答已采纳
1回答
我有以下几种不同的情景： RabbitMQ起来了。RabbitMQ倒下了。如果消费者试图订阅busControl.Start();，那么它将正确地重新连接。
RabbitMQ倒下了
消费者上升并尝试使用busControl
浏览 3提问于2020-03-06得票数 1
我有一个关于RabbitMq消费者确认的查询，我阅读了RabbitMq上的文档，声明确认消息应该在消费者接收到的同一个通道上。但是，由于某种原因，在收到消息之后，由于某种原因消费者进程被停止，并且没有确认Rabbitmq，当消费者进程重新启动时，消费者开始从RabbitMq获得未被确认的消息，但是在这里，使用者不能向这些消息发送应答
浏览 3提问于2018-11-22得票数 0
我有一个spring应用程序，其中我们使用spring-amqp发布和侦听来自Rabbitmq的消息。如果我的监听器抛出异常，我想修改我的Rabbitmq消息。myObject.toByteArray()).andProperties(properties).build(); } 当我的恢复器收到RabbitMq当侦听器抛出异常时，有没有其他方法可以使用spring-amqp修改我的RabbitMq消息体？
浏览 44提问于2019-09-10得票数 1
回答已采纳
在多个消费者的情况下，是否可以设置消费者应该确认rabbitmq服务器的时间，否则该消息应该被认为是未被RabbitMQ服务器确认的，并且应该被给予另一个消费者？
浏览 0提问于2013-12-14得票数 0
我正在试图获取RabbitMQ中特定队列的消费者总数。我在C#中使用RabbitMQ客户端为.Net编写了代码。factory.CreateConnection()) using (var channel = connection.CreateModel()) var consumerCount = ((RabbitMQ.Client.Impl.ModelBase)(channel)).m_consumers;}
我得到的var consumerCount = ((<e
浏览 11提问于2017-02-01得票数 1
回答已采纳
我有内存有限的RabbitMQ。如果发布者和消费者在线，这是可以的，但当需要重启消费者时，RabbitMQ会填满内存并阻止发布者。当出版商被阻止时，它将快速吞噬RAM。如何配置RabbitMQ使队列溢出到磁盘，内存是否已满？
浏览 0提问于2012-06-19得票数 1
该路由从rabbitmq消费者开始，该消费者正在消费超过10k消息的队列。当我停止路由时，消费者继续使用队列中的新消息。因此，机上交换计数永远不会递减，并且路由等待关闭，直到默认超时值(300s)。从根本上阻止rabbitmq消费者在关闭过程中消费新消息。
浏览 0提问于2015-05-22得票数 0
我在net core 3.1中使用masstransit/rabbitmq。我有一个dispatcher服务，当消息可用时，它会将消息发送到worker服务。每个worker服务在前面都有一个rabbitmq队列，该队列是在服务启动时创建的。我希望确保当worker服务停止时，队列(和交换)需要被删除。, settings.RabbitMq.Port,
浏览 5提问于2021-06-02得票数 0
回答已采纳
rabbitmq服务器或集群重启后，所有队列都恢复了所有消息，即使消息已经确认(从rabbitmq服务器启动时开始)，并重新处理所有消息。
浏览 1提问于2018-07-10得票数 0
我将RabbitMQ作为一个用C#.NET编写的控制台应用程序的消费者，它被编程为永久侦听队列，当它在队列中找到消息时，它就会处理它。消费者平均每秒处理35条消息。
浏览 3提问于2016-01-27得票数 3
回答已采纳
1回答
我正在寻找对我的代码有很大帮助的人。我尽我所能连接一些Symfony功能，我想我要去哪儿了..我有我的评论实体，这是触发它的持久化实体。它触发了我的__invoke函数，但是有一个问题。我不太明白下一步该怎么办。<?php
use ApiPl
浏览 4提问于2020-08-02得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
