diff --git a/app/build.gradle.kts b/app/build.gradle.kts index cdb0a89..3655d09 100644 --- a/app/build.gradle.kts +++ b/app/build.gradle.kts @@ -23,7 +23,8 @@ android { debug { // TODO: 内网测试时改回 http://192.168.1.181:8091/ buildConfigField("String", "SERVICE_URL", "\"https://app.updatexiaoqu.com:9443/\"") - buildConfigField("String", "MQTT_URL", "\"mqtt.ququbranch.com:8085/mqtt\"") + // MQTT TCP 连接地址（端口 1883 在 MqttConfig 中定义） + buildConfigField("String", "MQTT_HOST", "\"mqtt.ququbranch.com\"") } release { isMinifyEnabled = false @@ -32,7 +33,7 @@ android { "proguard-rules.pro" ) buildConfigField("String", "SERVICE_URL", "\"https://app.updatexiaoqu.com:9443/\"") - buildConfigField("String", "MQTT_URL", "\"mqtt.ququbranch.com:8085/mqtt\"") + buildConfigField("String", "MQTT_HOST", "\"mqtt.ququbranch.com\"") } } diff --git a/app/src/main/java/com/xiaoqu/watch/event/AppEvent.kt b/app/src/main/java/com/xiaoqu/watch/event/AppEvent.kt index d6e0fa4..5683688 100644 --- a/app/src/main/java/com/xiaoqu/watch/event/AppEvent.kt +++ b/app/src/main/java/com/xiaoqu/watch/event/AppEvent.kt @@ -23,4 +23,10 @@ sealed class AppEvent { data class BluetoothStateChanged(val isOn: Boolean) : AppEvent() data class BluetoothDeviceConnected(val deviceName: String) : AppEvent() data class BluetoothDeviceDisconnected(val deviceName: String) : AppEvent() + + // MQTT 相关 + data object MqttConnected : AppEvent() + data object MqttDisconnected : AppEvent() + /** MQTT 消息到达，type=messageType，rawJson=原始 JSON 字符串 */ + data class MqttMessageReceived(val type: Int, val rawJson: String) : AppEvent() } diff --git a/app/src/main/java/com/xiaoqu/watch/network/EnvConfig.kt b/app/src/main/java/com/xiaoqu/watch/network/EnvConfig.kt index a238432..10c060a 100644 --- a/app/src/main/java/com/xiaoqu/watch/network/EnvConfig.kt +++ b/app/src/main/java/com/xiaoqu/watch/network/EnvConfig.kt @@ -8,6 +8,8 @@ import com.xiaoqu.watch.BuildConfig * release 构建 → production 环境 */ object EnvConfig { + /** HTTP API 基础地址 */ val serviceUrl: String = BuildConfig.SERVICE_URL - val mqttUrl: String = BuildConfig.MQTT_URL + /** MQTT 服务器地址（不含端口，端口在 MqttConfig 中定义） */ + val mqttHost: String = BuildConfig.MQTT_HOST } diff --git a/app/src/main/java/com/xiaoqu/watch/service/manager/MqttConfig.kt b/app/src/main/java/com/xiaoqu/watch/service/manager/MqttConfig.kt new file mode 100644 index 0000000..85f5332 --- /dev/null +++ b/app/src/main/java/com/xiaoqu/watch/service/manager/MqttConfig.kt @@ -0,0 +1,39 @@ +package com.xiaoqu.watch.service.manager + +/** + * MQTT 连接配置常量 + */ +object MqttConfig { + /** TCP 端口（标准 MQTT 端口） */ + const val PORT = 1883 + + /** 认证用户名（所有手表设备共用） */ + const val USERNAME = "watch" + + /** 认证密码 */ + const val PASSWORD = "xiaoquwatch" + + /** 心跳间隔（秒）— 满足 ≥60s 功耗红线，低于 4G NAT 超时 */ + const val KEEP_ALIVE_INTERVAL = 120 + + /** 连接超时（秒） */ + const val CONNECTION_TIMEOUT = 15 + + /** 是否自动重连（Paho 内置指数退避：1s→2s→4s→...→128s） */ + const val AUTO_RECONNECT = true + + /** 清除会话（每次连接重新订阅） */ + const val CLEAN_SESSION = true + + /** 订阅 QoS — 设备专属 Topic */ + const val QOS_DEVICE = 2 + + /** 订阅 QoS — 广播 Topic */ + const val QOS_BROADCAST = 0 + + /** 广播 Topic：手表参数变更 */ + const val TOPIC_WATCH_PARAMS = "WatchSetParamsInit" + + /** 广播 Topic：振动方案变更 */ + const val TOPIC_SHOCK_PARAMS = "WatchShockSetParamsInit" +} diff --git a/app/src/main/java/com/xiaoqu/watch/service/manager/MqttManager.kt b/app/src/main/java/com/xiaoqu/watch/service/manager/MqttManager.kt new file mode 100644 index 0000000..268a8f1 --- /dev/null +++ b/app/src/main/java/com/xiaoqu/watch/service/manager/MqttManager.kt @@ -0,0 +1,179 @@ +package com.xiaoqu.watch.service.manager + +import com.xiaoqu.watch.data.prefs.DevicePrefs +import com.xiaoqu.watch.event.AppEvent +import com.xiaoqu.watch.event.EventBus +import com.xiaoqu.watch.network.EnvConfig +import kotlinx.coroutines.CoroutineScope +import kotlinx.coroutines.Dispatchers +import kotlinx.coroutines.SupervisorJob +import kotlinx.coroutines.launch +import org.eclipse.paho.client.mqttv3.* +import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence +import org.json.JSONObject +import timber.log.Timber +import javax.inject.Inject +import javax.inject.Singleton + +/** + * MQTT 连接管理器 + * 负责连接/断连/消息接收/EventBus 分发 + * + * 使用方式：HomeFragment 中 initDevicePrefs() 之后调用 connect() + * + * 消息处理： + * 收到消息 → 解析 messageType → EventBus.emit(MqttMessageReceived) + * 各业务模块通过 EventBus 订阅自己关心的 messageType + */ +@Singleton +class MqttManager @Inject constructor( + private val devicePrefs: DevicePrefs, + private val eventBus: EventBus +) { + /** 协程作用域（用于发送 EventBus 事件） */ + private val scope = CoroutineScope(Dispatchers.Main + SupervisorJob()) + + /** MQTT 异步客户端 */ + private var client: MqttAsyncClient? = null + + /** 是否已连接 */ + val isConnected: Boolean get() = client?.isConnected == true + + /** + * 连接 MQTT Broker + * 使用 DevicePrefs.imei 作为 clientId，TCP 协议连接 + */ + fun connect() { + val imei = devicePrefs.imei + if (imei.isEmpty()) { + Timber.w("MQTT: IMEI 为空，无法连接") + return + } + + // 已连接则跳过 + if (isConnected) { + Timber.d("MQTT: 已连接，跳过") + return + } + + try { + // 构建 TCP 连接地址 + val serverUri = "tcp://${EnvConfig.mqttHost}:${MqttConfig.PORT}" + Timber.d("MQTT: 连接 $serverUri, clientId=$imei") + + // 创建客户端（使用内存持久化） + client = MqttAsyncClient(serverUri, imei, MemoryPersistence()).apply { + // 设置回调 + setCallback(mqttCallback) + } + + // 构建连接选项 + val options = MqttConnectOptions().apply { + userName = MqttConfig.USERNAME + password = MqttConfig.PASSWORD.toCharArray() + keepAliveInterval = MqttConfig.KEEP_ALIVE_INTERVAL + connectionTimeout = MqttConfig.CONNECTION_TIMEOUT + isAutomaticReconnect = MqttConfig.AUTO_RECONNECT + isCleanSession = MqttConfig.CLEAN_SESSION + } + + // 发起连接 + client?.connect(options, null, connectCallback) + + } catch (e: Exception) { + Timber.e(e, "MQTT: 连接异常") + } + } + + /** 断开 MQTT 连接 */ + fun disconnect() { + try { + client?.disconnect() + Timber.d("MQTT: 已断开") + } catch (e: Exception) { + Timber.w(e, "MQTT: 断开异常") + } + } + + /** 连接回调：成功后订阅 3 个 Topic */ + private val connectCallback = object : IMqttActionListener { + override fun onSuccess(asyncActionToken: IMqttToken?) { + Timber.d("MQTT: 连接成功") + emitEvent(AppEvent.MqttConnected) + subscribeTopics() + } + + override fun onFailure(asyncActionToken: IMqttToken?, exception: Throwable?) { + Timber.e(exception, "MQTT: 连接失败") + } + } + + /** 订阅 3 个 Topic */ + private fun subscribeTopics() { + val imei = devicePrefs.imei + try { + // 设备专属 Topic（绑定/解绑/任务/工作状态等） + client?.subscribe(imei, MqttConfig.QOS_DEVICE) + Timber.d("MQTT: 订阅 Topic=$imei, QoS=${MqttConfig.QOS_DEVICE}") + + // 手表参数广播 Topic + client?.subscribe(MqttConfig.TOPIC_WATCH_PARAMS, MqttConfig.QOS_BROADCAST) + Timber.d("MQTT: 订阅 Topic=${MqttConfig.TOPIC_WATCH_PARAMS}") + + // 振动方案广播 Topic + client?.subscribe(MqttConfig.TOPIC_SHOCK_PARAMS, MqttConfig.QOS_BROADCAST) + Timber.d("MQTT: 订阅 Topic=${MqttConfig.TOPIC_SHOCK_PARAMS}") + + } catch (e: Exception) { + Timber.e(e, "MQTT: 订阅异常") + } + } + + /** MQTT 消息回调 */ + private val mqttCallback = object : MqttCallbackExtended { + /** 连接完成（包括自动重连后） */ + override fun connectComplete(reconnect: Boolean, serverURI: String?) { + if (reconnect) { + Timber.d("MQTT: 重连成功，重新订阅") + subscribeTopics() + emitEvent(AppEvent.MqttConnected) + } + } + + /** 连接丢失 */ + override fun connectionLost(cause: Throwable?) { + Timber.w(cause, "MQTT: 连接丢失，等待自动重连") + emitEvent(AppEvent.MqttDisconnected) + } + + /** 收到消息 */ + override fun messageArrived(topic: String?, message: MqttMessage?) { + try { + val payload = message?.payload ?: return + val json = String(payload) + Timber.d("MQTT: 收到消息 topic=$topic, payload=$json") + + // 解析 messageType + val jsonObj = JSONObject(json) + val messageType = jsonObj.optInt("messageType", -1) + + if (messageType >= 0) { + // 通过 EventBus 分发，业务模块各自订阅处理 + emitEvent(AppEvent.MqttMessageReceived(messageType, json)) + } + } catch (e: Exception) { + Timber.w(e, "MQTT: 消息解析异常") + } + } + + /** 消息发送完成（本项目不发消息，空实现） */ + override fun deliveryComplete(token: IMqttDeliveryToken?) {} + } + + /** 通过 EventBus 发送事件 */ + private fun emitEvent(event: AppEvent) { + scope.launch { + eventBus.emit(event) + } + } +} diff --git a/app/src/main/java/com/xiaoqu/watch/ui/home/HomeFragment.kt b/app/src/main/java/com/xiaoqu/watch/ui/home/HomeFragment.kt index 0b6d7a1..c8237a4 100644 --- a/app/src/main/java/com/xiaoqu/watch/ui/home/HomeFragment.kt +++ b/app/src/main/java/com/xiaoqu/watch/ui/home/HomeFragment.kt @@ -16,6 +16,7 @@ import com.xiaoqu.watch.device.sensor.VibrationController import com.xiaoqu.watch.device.sensor.VibrationDefaults import com.xiaoqu.watch.event.AppEvent import com.xiaoqu.watch.event.EventBus +import com.xiaoqu.watch.service.manager.MqttManager import com.xiaoqu.watch.ui.common.BaseFragment import com.xiaoqu.watch.ui.widget.NavBarHelper import com.xiaoqu.watch.ui.widget.QuTipDialog @@ -42,6 +43,7 @@ class HomeFragment : BaseFragment() { @Inject lateinit var nfcController: NfcController @Inject lateinit var vibrationController: VibrationController @Inject lateinit var eventBus: EventBus + @Inject lateinit var mqttManager: MqttManager /** 提示弹窗 */ private lateinit var tipDialog: QuTipDialog @@ -66,6 +68,9 @@ class HomeFragment : BaseFragment() { // 设置 NavBar 为首页模式 NavBarHelper.setupHomePage(binding.root) + // 连接 MQTT（必须在 initDevicePrefs 之后，确保 IMEI 可用） + mqttManager.connect() + // 初始化弹窗 val dialogContainer = requireActivity().findViewById(R.id.dialog_container) tipDialog = QuTipDialog(dialogContainer) @@ -120,6 +125,7 @@ class HomeFragment : BaseFragment() { } sb.appendLine("屏幕: ${if (screenController.isScreenOn()) "亮" else "灭"}") sb.appendLine("NFC: ${if (nfcController.isOpen()) "开" else "关"}") + sb.appendLine("MQTT: ${if (mqttManager.isConnected) "已连接" else "未连接"}") binding.tvStatus.text = sb.toString() } catch (e: Exception) { Timber.w(e, "更新状态信息异常") @@ -213,6 +219,13 @@ class HomeFragment : BaseFragment() { // 蓝牙连接/断开 is AppEvent.BluetoothDeviceConnected -> updateStatus() is AppEvent.BluetoothDeviceDisconnected -> updateStatus() + // MQTT 连接/断连/消息 + is AppEvent.MqttConnected -> updateStatus() + is AppEvent.MqttDisconnected -> updateStatus() + is AppEvent.MqttMessageReceived -> { + Timber.d("MQTT消息: type=${event.type}") + updateStatus() + } else -> {} // 其他事件不处理 } }