diff --git a/mica-mqtt-core/src/main/java/net/dreamlu/iot/mqtt/core/client/MqttClientAioListener.java b/mica-mqtt-core/src/main/java/net/dreamlu/iot/mqtt/core/client/MqttClientAioListener.java
index e01155c5ee1c52aa792eb48cd3463a44885a8303..6c96534ccd19bf12b40f21a7626e9e666c05672f 100644
--- a/mica-mqtt-core/src/main/java/net/dreamlu/iot/mqtt/core/client/MqttClientAioListener.java
+++ b/mica-mqtt-core/src/main/java/net/dreamlu/iot/mqtt/core/client/MqttClientAioListener.java
@@ -104,6 +104,10 @@ public class MqttClientAioListener extends DefaultClientAioListener {
 
 	@Override
 	public void onBeforeClose(ChannelContext channelContext, Throwable throwable, String remark, boolean isRemove) {
+		// 先判断是否配置监听
+		if (connectListener == null) {
+			return;
+		}
 		try {
 			connectListener.onDisconnect(channelContext, throwable, remark, isRemove);
 		} catch (Throwable e) {