送る多くのメッセージを公開：あまりにも多くの進捗エラーで公開してい

Question

ここPAHO非同期クライアントである：ここで

client = new MqttAsyncClient(appProps.getProperty("mqtt.broker"), 
      appProps.getProperty("mqtt.clientId"), new MemoryPersistence()); 
    client.setCallback(this); 
    client.connect(null, new IMqttActionListener() { 
     @Override 
     public void onSuccess(IMqttToken imt) { 
      try { 
       client.subscribe(Constants.internalTopics, Constants.internalTopicQOS); 
      } catch (MqttException ex) { 
       ex.printStackTrace(); 
      } 
     } 

     @Override 
     public void onFailure(IMqttToken imt, Throwable thrwbl) { 
      thrwbl.printStackTrace(); 
     } 
    }); 

私はループ内でメッセージを送信しています：

 while (iterator.hasNext()) { 
      try { 
       client.publish("user/" + userId + "/downstream", mqttMessage); 
      } catch(Exception ex) { 
       ex.printStackTrace(); 
      } 
     } 

エラー：

Too many publishes in progress (32202) 
    at org.eclipse.paho.client.mqttv3.internal.ClientState.send(ClientState.java:436) 
    at org.eclipse.paho.client.mqttv3.internal.ClientComms.internalSend(ClientComms.java:121) 
    at org.eclipse.paho.client.mqttv3.internal.ClientComms.sendNoWait(ClientComms.java:139) 
    at org.eclipse.paho.client.mqttv3.MqttAsyncClient.publish(MqttAsyncClient.java:858) 
    at org.eclipse.paho.client.mqttv3.MqttAsyncClient.publish(MqttAsyncClient.java:836) 

は、

私は使用していますRabbitmq

Answer 1

Pahoクライアントのsourceを見ると、デフォルトで最大の機内メッセージ数は10になります。

パブリッシュループが厳しいため、ネットワークレイヤーでは少し遅くなりますあなたはいつでも送信される過程で10以上のメッセージで終わることになります。あなたはあなたがclient.connect()メソッドに渡されMQTTConnectionsOptionsオブジェクト上のsetMaxInflight(int n)メソッドでデフォルトを変更することができQOS 0より大きい

で送信しようとした場合にのみ悪くなります。

適切な値を見つけるために実験することをおすすめします。