我正在使用以下代码在listem上发布消息并将其发布到Java中的Rabbitmqserver
ConnectionFactory factory = new ConnectionFactory();
factory.setHost(hostName);
factory.setPort(portNumber);
factory.setVirtualHost(virtualHost);
factory.setUsername(username);
factory.setPassword(password);
return factory.newConnection();
Run Code Online (Sandbox Code Playgroud)
我可以建立多少个连接?我在Rabbit文档中找不到我们的任何限制。当我尝试建立超过137个连接时,它似乎无法正常工作。我无法在Rabbitmq日志或应用程序日志中找到ny错误。当我尝试调试它时,看起来就像最后一行一样,请稍等。我下一步要弄清楚RABBITMQ Java客户端代码中发生了什么。
任何帮助或指导将是有益的,并非常感谢。
好吧,看来我的 Rabbitmq 服务器耗尽了套接字,并且不会抛出错误,只是等待另一个连接空闲。我使用的是 Mac 操作系统,默认 ulimit 为 256,它最终提供 156 个文件处理程序和 138 个连接。我所做的只是将 ulimit 更改为 1024。
| 归档时间: |
|
| 查看次数: |
5843 次 |
| 最近记录: |