diff --git a/main.js b/main.js
index 1e0b5f7..42c64d8 100644
--- a/main.js
+++ b/main.js
@@ -60,15 +60,15 @@ export function createApp() {
 	app.config.globalProperties.$constant = constant;
 	app.config.globalProperties.$VerifyPermissions = VerifyPermissions;
 
-	// #ifndef MP
-	// 处理 wx.connectSocket promisify 兼容问题，强制返回 SocketTask
-	uni.connectSocket = (function(connectSocket) {
-		return function(options) {
-			options.success = options.success || function() {}
-			return connectSocket.call(this, options)
-		}
-	})(uni.connectSocket)
-	// #endif
+	// // #ifndef MP
+	// // 处理 wx.connectSocket promisify 兼容问题，强制返回 SocketTask 	*已转移至Mqttjs内
+	// uni.connectSocket = (function(connectSocket) {
+	// 	return function(options) {
+	// 		options.success = options.success || function() {}
+	// 		return connectSocket.call(this, options)
+	// 	}
+	// })(uni.connectSocket)
+	// // #endif
 	return {
 		app
 	}
diff --git a/utils/mqttUtil.js b/utils/mqttUtil.js
index 0fc1ba9..33a9b54 100644
--- a/utils/mqttUtil.js
+++ b/utils/mqttUtil.js
@@ -27,6 +27,16 @@ class MqttUtil {
 
 	//接收创建来的数据
 	constructor(url, stateEvent, messageEvent) {
+		// #ifndef MP
+		// 处理 wx.connectSocket promisify 兼容问题，强制返回 SocketTask
+		uni.connectSocket = (function(connectSocket) {
+			return function(options) {
+				options.success = options.success || function() {}
+				return connectSocket.call(this, options)
+			}
+		})(uni.connectSocket)
+		// #endif
+
 		// const url = import.meta.env.VITE_BASE_MQTT;
 		this.stateEvent = stateEvent;
 		this.messageEvent = messageEvent;