From 768d7fd32e7a0b94f9d1bf8f6a369984c90cdef3 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=9D=8E=E5=AF=BB=E6=AC=A2?= <1101766085@qq.com>
Date: Tue, 17 Aug 2021 19:05:13 +0800
Subject: [PATCH] =?UTF-8?q?:sparkles:=20=E4=BC=98=E5=8C=96=E5=8E=8B?=
 =?UTF-8?q?=E6=B5=8B=E5=B7=A5=E5=85=B7?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/net/dreamlu/iot/mqtt/benchmark/MqttBenchmark.java     | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/mica-mqtt-example/src/main/java/net/dreamlu/iot/mqtt/benchmark/MqttBenchmark.java b/mica-mqtt-example/src/main/java/net/dreamlu/iot/mqtt/benchmark/MqttBenchmark.java
index b26b46f..24b6cda 100644
--- a/mica-mqtt-example/src/main/java/net/dreamlu/iot/mqtt/benchmark/MqttBenchmark.java
+++ b/mica-mqtt-example/src/main/java/net/dreamlu/iot/mqtt/benchmark/MqttBenchmark.java
@@ -18,6 +18,7 @@ package net.dreamlu.iot.mqtt.benchmark;
 
 import net.dreamlu.iot.mqtt.core.client.MqttClient;
 
+import java.util.UUID;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 
@@ -44,7 +45,7 @@ public class MqttBenchmark {
 	private static void newClient(String ip, int i) {
 		MqttClient.create()
 			.ip(ip)
-			.clientId("MICA-MQTT-" + i)
+			.clientId(UUID.randomUUID().toString() + '-' + i)
 			.username("admin")
 			.password("123456")
 			.readBufferSize(512)
-- 
GitLab