为公共交通中的所有消费者设置队列参数

文章/答案/技术大牛

发布

1回答

c#、rabbitmq、masstransit

我有一个使用RabbitMQ的简单公共交通设置，并且正在利用IRabbitMqBusFactoryConfigurator.ConfigureEndpoints自动为我的消费者创建端点。问题是我还想在所有这些队列上设置一些队列参数，即"x-max-length"，"x-overflow“。使用ConfigureEndpoints，它似乎不会复制这些参数

浏览 12提问于2021-11-05得票数 1

回答已采纳

1回答

如何处理备份消息队列中长期运行的第三方呼叫？

performance、message-queue

我必须向第三方服务提出请求它也没有web挂钩或任何回调机制。产品生成的所有消息目前都放在一个队列中。调用第三方服务的相同队列。目前有3个使用者，每个工作线程运行4个工作线程，总共有12个工作线程。这

浏览 0提问于2015-07-24得票数 2

1回答

MassTransit使用者在进行依赖项注入时不使用消息

c#、dependency-injection、masstransit

我已经为依赖注入设置了我的使用者和端点，但是我的使用者没有从消息队列获得消息。我在队列中只有2条给消费者的消息，但是公共交通没有收到它们。这是我的主程序，我在这里设置所有东西。appSettings值是正确的。ep.ConfigureConsumers(context));

浏览 24提问于2021-06-17得票数 1

回答已采纳

2回答

如何延迟使用来自ActiveMQ的Apache Camel中的消息

apache-camel、activemq、throttling

我有一个要求，当客户端应用程序在5秒的时间跨度内发送超过1000个请求时，我需要通过整形(排队)入站流量来限制。我遵循的解决方案是:我有一个camel:throttle，将最大请求数设置为1000，timespan设置为5秒。当超过阈值时，我将捕获节流异常，并且在onException块中，我将节流消息发送到ActiveMQ请求队列，以便稍后进一步处理，因为根据1000请求/5秒配置，Camel过载。我成功地实现了上述，但我希望骆驼消

浏览 8提问于2016-03-07得票数 2

2回答

RabbitMQ上芹菜任务优先级的解决方法？

rabbitmq、celery

我在RabbitMQ上运行Django和Celery作为一个队列来处理一些数据处理任务。当用户第一次注册时，我会启动芹菜任务，并定期更新他们的数据。但是，我当然希望优先考虑当前在线的用户正在运行的任务。我注意到celery中的任务有一个优先级设置，但似乎rabbitmq不支持这一点。此线程建议使用两个不同的队列，一个高优先级队列和一个低优先级队列，或者为低优先级任务设置</

浏览 2提问于2010-08-01得票数 9

回答已采纳

2回答

MassTransit报文速率上限为10

rabbitmq、masstransit

我设置了一个公共交通消费者服务来使用RabbitMQ，但我不知道如何提高消费者的速度-它似乎硬限制在每秒接收10条消息。我已经尝试了这里列出的步骤：，没有成功-将预取和并发消费者设置为25只会增加确认的消息，但它不会增加消息的下载速率。sbc.UseJsonSerializer(); })

浏览 0提问于2014-06-02得票数 3

1回答

ActiveMQ Artemis -按顺序处理消息

activemq-artemis

我试图确保队列(使用消息分组)上的消费者一次只能从它正在处理的每个队列接收一条消息，直到消费者确认该消息为止。对于一个测试，我设置了ActiveMQ Artemis，并让3个消费者使用通配符示例.*，一个发布者向5个队列中的每个队列发送10条消息: EXAMPLE.1 - EXAMPLE.5。我看到的是，每个消费者都会立即从队列</em

浏览 60提问于2020-07-03得票数 0

回答已采纳

1回答

如何在配置RabbitMQ队列时发送额外的标头？

masstransit

我想使用RabbitMQ的单个活动消费者特性，如下所述：。在声明队列时，可以启用单活动使用者，并将x单活动消费者参数设置为true，例如使用Java： Map<String, Object> arguments = new，我找不到添加自定义头的方法。.) });使用ConfigureSend和C

浏览 14提问于2022-06-07得票数 0

1回答

RabbitQM多队列还是单队列？

node.js、rabbitmq、amqp

基本流程是，一旦节点服务器接收到请求，处理程序将向队列发送参数，工作人员将使用该参数，然后将结果发送回指向相应处理程序的另一个队列。最后，处理程序将将结果回复给客户端。1.为每个消费者创建一个队列。一旦队列被请求填充，使用者将处理它。我考虑选项2的唯一原因是在创建队列<

浏览 0提问于2017-02-26得票数 0

回答已采纳

1回答

RabbitMQ独占队列丢失消息

queue、rabbitmq、amqp、messagebroker

对于消费者来说，当声明队列为“排他的”时，当使用者根据文档断开连接时，队列将被删除。提前谢谢。

浏览 0提问于2016-06-10得票数 1

1回答

消费者不使用消息。

c#、asp.net-core、.net-core、rabbitmq、masstransit

这是我在Program.cs中的公共交通配置： { await Task.Delay(3000, stoppingToken); }消费者public async Task Consume(ConsumeContext<IOrder>

浏览 7提问于2022-09-20得票数 1

回答已采纳

1回答

如何使用NodeJs (amqplib)获取RabbitMQ队列的未确认消息数

node.js、rabbitmq、node-amqplib

如何使用NodeJs (amqplib)获取RabbitMQ队列的未确认消息数。我们可以使用checkQueue或assertQueue方法轻松地获得队列的总消息数。我有许多动态队列，这些队列被多个消费者消费，我想在处理完所有作业后删除队列。问题是当一个消费者连接到一个队列时，我正在检查消息计数是否为零，如果消息计数为零，那么我将删除该队列，但

浏览 19提问于2021-04-26得票数 0

1回答

RabbitMQ的消费者并没有加起来

rabbitmq、spring-amqp

对于一些队列，消费者的数量没有增加，导致消息传递速度变慢。例如，即使将最大消费者设置为50，对于9000条消息的负载，消费者的数量在大部分时间内保持为6。我们使用SimpleMessageListenerContainer的setMaxConcurr

浏览 2提问于2016-09-30得票数 0

1回答

RabbitMQ标头交换路由:匹配所有列出的标题

rabbitmq、amqp

但是，当我发布消息时，我只想指定必要的标题，例如，具有特定值的feature-1和Feature7。在发布消息时，我甚至不知道所有可用的消费者特性。问题是:如果我在x-match==all时遗漏了一些绑定参数，那么消息将不会被路由，如果我将x-match设置为any，那么唯一匹配的标头就足以路由消息--尽管另一个标头的值可能不匹配。场景1:所以我将它的队列附加(创建绑定)到头，使用

浏览 2提问于2016-11-15得票数 2

回答已采纳

1回答

如果存在内部交换，是否可以将消息发送到队列？

java、python、queue、rabbitmq、message-queue

我有多个生产者，他们产生不同的数据。我希望每个生产者根据参数设置一个临时队列，如果队列为空，则删除该队列。例如，生产者A和B：我想这样做是为了扩大系统的吞吐量。接下来，我希望我的使用者在能够使用时创建一个单一队列，并从两个队列中获取消息。例如，在上面的模板中添加使用者C：

浏览 3提问于2014-02-07得票数 1

回答已采纳

1回答

Spring DefaultMessageListenerContainer和ActiveMQ

spring、activemq

我已经将配置为使用来自队列的消息的ActiveMQ使用者。让我们称之为"Test.Queue“--我在4台不同的机器上部署了这段代码，所有机器都被配置到同一个ActiveMQ实例中，以处理来自同一个"Test.Queue”队列的消息。当所有4台机器启动并运行时，我将最大使用者大小设置为20，我看到队列中的<e

浏览 4提问于2012-08-21得票数 6

回答已采纳

1回答

Apache.NMS.AMQP设置预取大小

amqp、nms、amazon-mq

我使用Apache.NMS.AMQP (v1.8.0)连接到AWS托管ActiveMQ (v5.15.9)代理，但在为连接/消费者/目的地设置预取大小(无法为它们设置自定义值)时遇到问题。其结果是，如预期的那样，第一消费者将200条消息排出队列，第二用户将20条消息排出队列。jms.prefetchPolicy.queuePrefetch=50 在尝试了上面所述的所有内容之后，我尝试通过追加来<e

浏览 3提问于2020-01-08得票数 0

回答已采纳

1回答

如何扩展多个监听器的SQS FIFO队列

amazon-web-services、.net-core、amazon-sqs、fifo、event-sourcing

所有队列都具有如下相同的设置(稍后设置的死信队列)。DynamoDB Stream => Lambda SQS => SQS队列的事件源架构的一部分(由于SNS不支持作为订阅者的先进先出队列) 启用Content-Based Deduplication以避免队列中的重复消息，因为任何队列的<

浏览 16提问于2019-05-03得票数 2

回答已采纳

1回答

RabbitMQ -结合工作队列和路由队列

python-2.7、rabbitmq

我正在构建一个系统，在这个系统中，生产者发送要排队的任务列表，这些任务将被许多消费者使用。假设我有一个任务列表，它们可以分为黑色、橙色和黄色。所有黑任务都被发送到Queue_0，橙发送到Queue_1，黄色发送到Queue_2，我将为每个队列分配一个工作人员(即: Consumer_0到Queue_0，Consumer_1到Queue_1，Consumer如果黑名单变得更大，我想添加一个额外的消费者(即: Consumer_3)到Queue_0，以帮助Consumer

浏览 0提问于2015-02-01得票数 0

1回答

使用Azure Service Bus进行基于消息类型的路由

azure、messaging、azureservicebus、servicebus、azure-queues

使用Azure Service Bus实现基于强类型消息的路由的最简单方法是什么？假设我们只有一个消费者，并且使用服务总线队列，那么是为每个消息类型(在我们的例子中是事件消息)创建一个队列，还是简单地为所有消息创建一个队列并在消费者上处理路由？如果我们有多个消费者，并且想要进行发布-订阅消息传递，我们是应该为每个消息类型创建一个主题，并为每个消费者</em

浏览 2提问于2013-12-24得票数 6

点击加载更多