EventingBasicConsumer:最大线程数
EventingBasicConsumer: max number of threads
在实现使用 EventingBasicConsumer 的 RabbitMQ(.NET) 消费者时,控制最大工作线程数的最简单方法是什么?
据我所知,默认情况下,线程数与传入的消息数相同。例如,如果消费操作打开数据库连接,那么最大线程数应该受到控制。
使用 consumer prefetch limit 来限制允许您的消费者拥有的未确认消息的数量。
如果您想将线程数限制为 1,例如,您可以为该消费者设置 1 的预取限制。
请注意,您需要处于确认模式才能工作,您必须在处理完消息后明确确认消息。
在实现使用 EventingBasicConsumer 的 RabbitMQ(.NET) 消费者时,控制最大工作线程数的最简单方法是什么?
据我所知,默认情况下,线程数与传入的消息数相同。例如,如果消费操作打开数据库连接,那么最大线程数应该受到控制。
使用 consumer prefetch limit 来限制允许您的消费者拥有的未确认消息的数量。
如果您想将线程数限制为 1,例如,您可以为该消费者设置 1 的预取限制。
请注意,您需要处于确认模式才能工作,您必须在处理完消息后明确确认消息。