Databases
StackOverflow2013
Postsdbo
POjava.io.EOFException with paho
 

Note that there are some explanatory texts on larger screens.

plurals
  1. POjava.io.EOFException with paho
    primarykey
    data
    text
    <p>i want to make stress test on mosquitto, so i create some code as below</p> <pre><code>for (int i = 0; i &lt; 800; i++) { final int j = i; Thread t = new Thread(new Runnable() { @Override public void run() { System.out.println(j + " : ************"); try { MqttClient client = new MqttClient("tcp://192.168.88.203", SERVER_CLIENTID_PREFIX + j); client.connect(); MqttMessage message = new MqttMessage((j + ":me").getBytes()); message.setQos(2); client.publish(TOPIC_PREFIX + j, message); } catch (MqttSecurityException e) { e.printStackTrace(); } catch (MqttException e) { e.printStackTrace(); } } }); t.start(); } </code></pre> <p>But, I got some errors like <code>EOFException</code> during run and some client is disconnect. I want to know how many clients can publish messages at same time with one mosquitto server, and how can I make the stress test. Thanks!</p> <p>The detail exception is :</p> <pre><code> Connection lost (32109) - java.io.EOFException at org.eclipse.paho.client.mqttv3.internal.CommsReceiver.run(CommsReceiver.java:162) at java.lang.Thread.run(Thread.java:662) Caused by: java.io.EOFException at java.io.DataInputStream.readByte(DataInputStream.java:250) at org.eclipse.paho.client.mqttv3.internal.wire.MqttInputStream.readMqttWireMessage(MqttInputStream.java:51) at org.eclipse.paho.client.mqttv3.internal.CommsReceiver.run(CommsReceiver.java:121) ... 1 more </code></pre> <p>And I found some log from mosquitto server: </p> <pre><code>1383736170: Socket read error on client Server-82, disconnecting. </code></pre> <p>Please help me, thanks!</p>
    singulars
    1. This table or related slice is empty.
    1. This table or related slice is empty.
    1. PTQuestion
    1. USralight
    1. UStom
    plurals
    1. This table or related slice is empty.
    1. This table or related slice is empty.
    1. This table or related slice is empty.
    1. This table or related slice is empty.
    1. VO
      singulars
      1. POjava.io.EOFException with paho
      1. USAndy Piper
      1. VTFavorite
    1. COCan you post the exact exception? Sounds like the socket was closed. Can you try with a higher MQTT keepAlive value? I suspect that under this high load the Paho client doesn't manage to send pings properly.
      singulars
      1. POjava.io.EOFException with paho
      1. USDominik Obermaier
    2. COthanks for your answer, i have append detail exception. What about the "keepAlive" value which you mention. i can not found it in mosquitto.conf , i only found "keepalive_interval" , is it right? thanks again
      singulars
      1. POjava.io.EOFException with paho
      1. UStom
    3. CO32109 is the error code for "Connection Lost" on the client side. That means the socket was closed unexpectedly. If you want a higher keepAlive, you have to pass a MqttConnectOptions object to your connect() method with the defined keepAlive. If that doesn't help, I suspect that perhaps you are reaching a limit on the server side. Did you try with other brokers like HiveMQ or RabbitMQ?
      singulars
      1. POjava.io.EOFException with paho
      1. USDominik Obermaier
 

Querying!

 
Guidance
A row detail

Detail views are divided into sections. All the information in the data section comes from columns in the selected row. The other sections display data from other, related rows.

Related data can be related in a to-one or a to-many fashion. Captions of data related in a to-many fashion link to a list view showing a filtered view of the table.

Try moving around until you find a non-empty to-many entry and click on the label to get to one. You can move back to the root by clicking on the database name in the header.

SQuiL has stopped working due to an internal error.

If you are curious you may find further information in the browser console, which is accessible through the devtools (F12).

Reload