rabbitmq处理大量消费者、连接和通道
文件描述符：256个可用套接字描述符：138个可用
显然我不能打开超过138个连接。
问题1：这个限制是基于什么？我能提高它吗？我想知道在生产机器上（需要哪种EC2实例），每个用户有一个连接是否是一个好主意。我读到过限制可能与ulimit有关，但当我在命令行上运行ulimit时，我看到的是'unlimited'。
还有什么其他的策略？
共有1个答案
-
我对RabbitMQ很陌生，所以如果我的问题听起来很琐碎，请原谅。我想在RabbitMQ上发布消息，它将由RabbitMQ消费者处理。 我的消费者机器是一个多核机器（最好是azure上的工作者角色）。但QueueBasicConsumer一次推送一条消息。我如何编程来利用我可以同时处理多个消息的所有核心。 一种解决方案是在多个线程中打开多个通道，然后在那里处理消息。但在这种情况下，我将如何决定线程
-
我已经用MassTransit实现了一个简单的发布者/使用者集，我想让使用者从同一个队列中读取消息。但是，当我运行它时，我看到很大一部分消息被发送到错误队列，而不是被消耗。从我看到的讨论（所以，论坛）来看，对于RabbitMQ来说，这应该非常非常简单（只需指向相同的队列），但它并不起作用。是否有应该设置的附加配置？ 这是我的出版商 还有我的消费者
-
启动使用者接收消息 根据我的理解，consumer直接使用来自broker的消息，但在上面的consumer命令中，我们没有提到broker，而只提到zookeeper。消费者是否会连接到zookeeper（而不是broker）来消费消息？
-
Camel RabbitMQ的新手。用Apache Camel写了一个简单的RabbitMQ消费者。 当前在从队列中弹出一个值后进行一个简单的rest调用。它可以处理大约100条消息，并开始抛出此错误 我不确定我做错了什么，任何帮助都是感激的。
-
我想在远程位置检查Kafka消费者的连接。 可以确定是否将使用者分配给分区。 在远程位置，我可以从Kafka代理获得有关该主题的详细信息。 但是消费者能否保证消费者能够收到消费者与主题分区匹配的消息？
-
我为RabbitMQ制作了一个消费者，作为一个用C#.NET编写的控制台应用程序。它被编程为永久监听队列，每当它在队列中发现消息时，它就处理它。使用者平均每秒处理35条消息。使用者被安排在系统启动时在任务计划程序中运行。消费者运行良好的3-4天。但是，它们继续运行，但不处理任何消息，尽管队列中有消息。当使用者停止并再次启动时，它再次开始正确处理消息。但是，当您手动重新启动时，数以百万计的消息排在队