update

src-tauri/src/lib.rs

@@ -1,10 +1,38 @@
-use tauri::{generate_context, generate_handler, Builder};
+// use tauri::Emitter
+// use tauri_plugin_mqtt::{Client as MqttClient, Event as MqttEvent};
 
-// 条件编译属性cfg 的属性attr
+// #[tauri::command]
+// pub async fn connect(host: String, port: u16) -> Result<(), String> {
+//     let client = MqttClient::new(host, port);
+//     client.connect().await.map_err(|e| e.to_string())
+// }
+
+// #[tauri::command]
+// pub async fn subscribe(topic: String) -> Result<(), String> {
+//     let client = MqttClient::default();
+//     client.subscribe(topic).await.map_err(|e| e.to_string())
+// }
+
+// #[tauri::command]
+// pub async fn publish(topic: String, message: String) -> Result<(), String> {
+//     let client = MqttClient::default();
+//     client.publish(topic, message).await.map_err(|e| e.to_string())
+// }
+
+// pub fn listen_messages(app: tauri::AppHandle) {
+//     let client = MqttClient::default();
+//     client.on_message(move |msg: MqttMessage| {
+//         let _ = app.emit("mqtt-message", msg);
+//     });
+// }
 pub fn run() {
-    Builder::default()
+    tauri::Builder::default()
         .plugin(tauri_plugin_mqtt::init())
-        .invoke_handler(generate_handler![])
-        .run(generate_context!())
+        .invoke_handler(tauri::generate_handler![connect, subscribe, publish])
+        // .setup(|app| {
+        //     listen_messages(app.handle().clone());
+        //     Ok(())
+        // })
+        .run(tauri::generate_context!())
         .expect("error while running tauri application");
 }

src/pages/login/index.vue

@@ -79,14 +79,14 @@ async function login() {
   const newUrl = `${parsedUrl[0]}:${parsedUrl[1]}?username=${room.value}&password=${name.value}&port=${parsedUrl[2] || ''}&client_id=test33`
   console.log('登陆', newUrl)
 
-  const a = await netService.get('https://restapi.amap.com/v3/ip?key=76f9007ba8c4c44bb9ad757fe27acb44')
-  console.log(123, a)
+  // const a = await netService.get('https://restapi.amap.com/v3/ip?key=76f9007ba8c4c44bb9ad757fe27acb44')
+  // console.log(123, a)
 
   connect(store.mqtt_client_id, newUrl, { skipVerification: true })
-  listen((payload) => {
-    console.log(6666, payload)
-  })
 }
+listen((payload) => {
+  console.log(6666, payload)
+})
 </script>
 <style scoped lang="scss">
 .login {