RabbitMq 与 Mqtt 协议与 ubuntu

Question

我正在使用带有 paho.mqttv3 协议的 RabbitMq 3.6.6 我的简单代码，如

int max_connections =400000;
String broker = "tcp://xxx.xxx.x.xx:1883";
String clientId = "Publisher";
String content="Hii";
int qos=1;
String topic="Cluster";


MemoryPersistence persistence = new MemoryPersistence();
MqttClient sampleClient[] = new MqttClient[max_connections];

Thread t[] = new Thread[max_connections];
MqttConnectOptions connOpts = new MqttConnectOptions();
connOpts.setCleanSession(true);

for (int i = 0; i < max_connections; i++) {
    try {
        sampleClient[i] = new MqttClient(broker, clientId + "" + i, persistence);
        sampleClient[i].connect(connOpts);
    } catch (MqttException ex) {
        ex.printStackTrace();
        return;
    } 
}

我遇到了异常：

线程“MQTT Con：Publisher2919”中的异常 java.lang.OutOfMemoryError：无法创建新的本地线程 java.lang.Thread.start0（本机方法）在 java.lang.Thread.start(Thread.java:714) 在 org.eclipse.paho.client.mqttv3.internal.CommsSender.start(CommsSender.java:60) 在 org.eclipse.paho.client.mqttv3.internal.ClientComms$ConnectBG.run(ClientComms.java:654) 在 java.lang.Thread.run(Thread.java:745)

我的系统 RAM 为 8 GB，带有 Corei5 处理器。

我也在 Windows PC 中尝试过同样的错误，但它高达 7k 连接

so any OS level Configuration in Ubuntu to make more Connection?

Answer 1

错误消息很容易解释。尝试创建 400,000 个线程并不现实。

我假设您正在尝试对您的 MQTT 代理进行负载测试，您最好看看 Apache 的 JMeter 之类的东西，它可以在分布式模式下运行并使用多台机器来产生非常高的负载水平。