fix admin client id fmt 2026-4-24 16:06

src/utils/utils.py

@@ -15,7 +15,7 @@ logger = Logger.getLogger("utils")
 
 def admin_client_id(uid):
     host_str = socket.gethostbyname(socket.gethostname()).replace(".", "_")
-    return f"/eems/admin/{uid}@{host_str}_{os.getpid()}"
+    return f"eems/admin/{uid}@{host_str}_{os.getpid()}"
 
 
 def mqtt_pwd(username):
@@ -31,6 +31,32 @@ def mqtt_pwd(username):
     return hashlib.sha1(username.encode("utf-8")).hexdigest()
 
 
+def conn_mqtt():
+    def on_connect(client, userdata, flags, rc):
+        if rc == 0:
+            print(f"成功连接到 {SETTING.mqtt_host}!")
+            client.disconnect()
+        else:
+            print(f"Failed to connect to MQTT broker. rc={rc}")
+
+    import paho.mqtt.client as mqtt_client
+
+    username = "pot_emqx_super"
+    client_id = admin_client_id("Meter3rdForward")
+    client = mqtt_client.Client(client_id=client_id, clean_session=True)
+    client.username_pw_set(username, mqtt_pwd(username))
+    client.on_connect = on_connect
+
+    print(f"正在连接 {SETTING.mqtt_host}:{SETTING.mqtt_port} ...")
+    client.connect(SETTING.mqtt_host, SETTING.mqtt_port)
+
+    try:
+        client.loop_forever()
+    except KeyboardInterrupt:
+        print("\n测试已手动终止")
+
+
 if __name__ == '__main__':
-    print(admin_client_id("admin"))
+    print(admin_client_id("Meter3rdForward"))
     print(mqtt_pwd("pot_emqx_super"))
+    conn_mqtt()