刘珍 created IOTDB-1220: ------------------------- Summary: MQTT insert 10 rows ,elapsed time is 5s ,and the inserted row count is less than 10. Key: IOTDB-1220 URL: https://issues.apache.org/jira/browse/IOTDB-1220 Project: Apache IoTDB Issue Type: Bug Components: Server Reporter: 刘珍
master branch. commit id :5fcff40f2299caeb0c8a9ae42f68bc18ecf8fee7 ## Usage * Update configuration to enable MQTT service. (`enable_mqtt_service=true` in iotdb-engine.properties) * Launch the IoTDB server. * Setup storage group `SET STORAGE GROUP TO root.sg` and create time timeseries `CREATE TIMESERIES root.sg.d1.s1 WITH DATATYPE=DOUBLE, ENCODING=PLAIN`. * Run `org.apache.iotdb.mqtt.MQTTClient` to run the mqtt client and send events to server. cat ../../src/main/java/org/apache/iotdb/mqtt/MQTTClient.java package org.apache.iotdb.mqtt; import org.fusesource.mqtt.client.BlockingConnection; import org.fusesource.mqtt.client.MQTT; import org.fusesource.mqtt.client.QoS; import java.util.Random; public class MQTTClient { public static void main(String[] args) throws Exception { MQTT mqtt = new MQTT(); mqtt.setHost("127.0.0.1", 1883); mqtt.setUserName("root"); mqtt.setPassword("root"); BlockingConnection connection = mqtt.blockingConnection(); connection.connect(); Random random = new Random(); for (int i = 0; i < 10; i++) { String payload = String.format( "{\n" + "\"device\":\"root.sg.d1\",\n" + "\"timestamp\":%d,\n" + "\"measurements\":[\"s1\"],\n" + "\"values\":[%f]\n" + "}", System.currentTimeMillis(), random.nextDouble()); connection.publish("root.sg.d1.s1", payload.getBytes(), QoS.AT_LEAST_ONCE, false); } connection.disconnect(); } } run time java -classpath ".:...." org/apache/iotdb/mqtt/MQTTClient 2 times,the elapsed time: real 0m5.573s user 0m0.352s sys 0m0.055s real 0m0.584s user 0m0.371s sys 0m0.039s IoTDB> select s1 from root.sg.d1; +-----------------------------+-------------+ | Time|root.sg.d1.s1| +-----------------------------+-------------+ |2021-03-12T11:52:50.687+08:00| 0.338776| |2021-03-12T11:52:50.692+08:00| 0.250776| |2021-03-12T11:52:50.694+08:00| 0.575861| |2021-03-12T11:52:50.695+08:00| 0.229369| |2021-03-12T11:52:50.696+08:00| 0.149007| |2021-03-12T11:52:50.697+08:00| 0.182348| |2021-03-12T11:52:50.698+08:00| 0.334755| |2021-03-12T11:52:50.699+08:00| 0.757181| |2021-03-12T11:53:02.649+08:00| 0.618037| |2021-03-12T11:53:02.655+08:00| 0.789077| |2021-03-12T11:53:02.656+08:00| 0.797554| |2021-03-12T11:53:02.657+08:00| 0.660189| |2021-03-12T11:53:02.658+08:00| 0.70841| |2021-03-12T11:53:02.659+08:00| 0.044449| |2021-03-12T11:53:02.660+08:00| 0.130961| +-----------------------------+-------------+ Total line number = 15 It costs 0.014s the "Total line number" should be 20. -- This message was sent by Atlassian Jira (v8.3.4#803005)