diff --git a/mica-mqtt-core/src/main/java/net/dreamlu/iot/mqtt/core/server/MqttServerAioHandler.java b/mica-mqtt-core/src/main/java/net/dreamlu/iot/mqtt/core/server/MqttServerAioHandler.java
index f52a78323d472cd4276666d2b001bf66f90b7184..3b93f34b0d61f34864ae7cca4a0412f20c52b5a5 100644
--- a/mica-mqtt-core/src/main/java/net/dreamlu/iot/mqtt/core/server/MqttServerAioHandler.java
+++ b/mica-mqtt-core/src/main/java/net/dreamlu/iot/mqtt/core/server/MqttServerAioHandler.java
@@ -104,7 +104,7 @@ public class MqttServerAioHandler implements ServerAioHandler {
 		// 3. 客户端 id 是创建连接之后才有的，如果客户端 id 为空，直接关闭
 		String clientId = context.getBsId();
 		if (StrUtil.isBlank(clientId)) {
-			context.setClosed(true);
+			Tio.close(context, "Mqtt connected but clientId is isBlank.");
 			return;
 		}
 		// 4. 按类型的消息处理