【发布时间】：2018-12-29 13:03:56
【问题描述】：
我正在尝试使用在 suse linux 上运行的 MQTT 协议 (V3.1) 和 IBM MQ (8.0.0.0) 代理构建推送通知服务，但是我遇到了一个问题。我编写了一个简单的 java 程序来测试 IBM MQ 中的并发连接数。它只是开始实例化 MqttClient 并将它们中的每一个连接到远程 IBM MQ 代理。
public MyConsumer(String topic) throws MqttException{
this.client = new MqttClient(SERVER_ADDRESS, MqttClient.generateClientId(), new MemoryPersistence());
client.setCallback(new MyCallback());
MqttConnectOptions connectOptions = new MqttConnectOptions();
connectOptions.setMqttVersion(MqttConnectOptions.MQTT_VERSION_3_1);
connectOptions.setCleanSession(false);
try
{
if (!this.client.isConnected())
{
this.client.connect(connectOptions);
this.client.subscribe(topic);
}
}
catch (Exception e)
{
System.out.println("****** error ******");
e.printStackTrace();
}
}
奇怪的是，在大约 870 个客户端成功连接到代理后，我得到了“连接丢失 (32109) - java.io.EOFException”异常：
Connection lost (32109) - java.io.EOFException
at org.eclipse.paho.client.mqttv3.internal.CommsReceiver.run(CommsReceiver.java:146)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.io.EOFException
at java.io.DataInputStream.readByte(DataInputStream.java:267)
at org.eclipse.paho.client.mqttv3.internal.wire.MqttInputStream.readMqttWireMessage(MqttInputStream.java:65)
at org.eclipse.paho.client.mqttv3.internal.CommsReceiver.run(CommsReceiver.java:107)
... 1 more
我同时在两台不同的计算机上运行测试程序，以确保问题与测试计算机无关。此外，我在队列管理器中定义了两个遥测通道，每个通道都部署在不同的端口上，但连接到代理的客户端总数仍约为 870！ 最后，我创建了两个队列管理器，在这种情况下，客户端连接的数量增加了一倍。我检查了 mqxr 日志，但没有错误日志。谁能告诉我为什么每个队列管理器只接受这个号码连接。
P.S：提及我使用emqtt broker（另一个 mqtt 代理）测试此示例可能会有所帮助，它运行良好（连接数超过 5k）
【问题讨论】：
-
IBM WebSpereMQ 中有许多硬性限制。几乎它们中的任何一个都可以在某个地方进行配置。很可能并发连接的数量或类似的东西已经用尽。但它真的打算同时连接 5k 个并发 应用程序 吗？通常一个应用程序在一个连接中服务多个队列。注意 /sessions/ 的数量不等于连接的数量。
-
@Marcel 您可能知道，MQTT 协议在 TCP/IP 上中继，这意味着它是状态完整的。通过这个测试，我想知道每个 IBM 队列可以处理的最大连接数。显然，每个连接都会在 IBM MQ 上创建一个会话，我看到 IBM MQ 维护所有会话。问题是，如果代理连接到 870 个客户端，新客户端将无法连接到客户端。