יישום ניטור מכשירי IoT בזמן אמת תחת קורת גג אחת

class MqttService : Service() {
    private lateinit var mqttClient: MqttAsyncClient

    override fun onCreate() {
        val options = MqttConnectOptions().apply {
            isAutomaticReconnect = true
            isCleanSession = false
            keepAliveInterval = 30
        }

        mqttClient = MqttAsyncClient(brokerUrl, clientId, MqttDefaultFilePersistence())
        mqttClient.connect(options).waitForCompletion()

        mqttClient.subscribe("devices/+/status", 1) { topic, message ->
            val deviceId = topic.split("/")[1]
            DeviceRepository.getInstance().updateStatus(deviceId, message.toString())
        }
    }
}

כאשר האפליקציה עוברת לרקע, אנדרואיד עלול להרוג שירות רגיל. val request = Request.Builder().url("$baseUrl/api/devices/stream").build() val eventSource = EventSources.createFactory(okHttpClient) .newEventSource(request, object : EventSourceListener() { override fun onEvent(source: EventSource, id: String?, type: String?, data: String) { val update = json.decodeFromString<DeviceStatusUpdate>(data) repository.updateDeviceStatus(update.deviceId, update.status) } override fun onFailure(source: EventSource, t: Throwable?, response: Response?) { scheduleReconnect() } }) עם התראה מספק הגנה מפני הרג. באנדרואיד 14, שירות רקע דורש סוג מפורש: class MqttService : Service() { private lateinit var mqttClient: MqttAsyncClient override fun onCreate() { val options = MqttConnectOptions().apply { isAutomaticReconnect = true isCleanSession = false keepAliveInterval = 30 } mqttClient = MqttAsyncClient(brokerUrl, clientId, MqttDefaultFilePersistence()) mqttClient.connect(options).waitForCompletion() mqttClient.subscribe("devices/+/status", 1) { topic, message -> val deviceId = topic.split("/")[1] DeviceRepository.getInstance().updateStatus(deviceId, message.toString()) } } } . ארכיטקטורה זו מבטיחה 99.9% זמינות חיבור.

הבטחת פעולה תקינה במהלך שינויי רשת

יש לשקף שלושה מצבים בממשק המשתמש:

לא ידוע הוא מקרה נפרד. אם הטלפון עצמו איבד רשת, לא ניתן להציג את כל המכשירים כמנותקים — זה יהיה שגוי. זהה את מצב הרשת באמצעות startForeground():

val networkCallback = object : ConnectivityManager.NetworkCallback() {
    override fun onAvailable(network: Network) {
        viewModel.setConnectionState(ConnectionState.CONNECTED)
    }

    override fun onLost(network: Network) {
        viewModel.setConnectionState(ConnectionState.NO_NETWORK)
        // Показать баннер "Нет подключения" вместо offline-статусов
    }
}

כאשר הרשת אובדת, כל המכשירים עוברים למצב לא ידוע עד לחיבור מחדש. לאחר חזרת הרשת, הסטטוסים מתעדכנים באמצעות LWT או keepalive — זה מונע אזעקות ניתוק שגויות. אובדן חבילות נשאר מתחת ל-0.01%, ועיכוב ההתאוששות הוא מתחת ל-200 אלפיות השנייה.

יישום לקוח MQTT באנדרואיד: מדריך שלב אחר שלב

1. הגדר ברוקר MQTT. בחר ברוקר (למשל Mosquitto, EMQX) והגדר TLS, גישת שם משתמש/סיסמה. השתמש ב-QoS 1 לעדכוני סטטוס כדי לאזן בין אמינות לעומס.
2. הוסף את הספרייה. ב-android:foregroundServiceType="connectedDevice": ConnectivityManager.NetworkCallback
3. צור שירות רקע. הרחב את val networkCallback = object : ConnectivityManager.NetworkCallback() { override fun onAvailable(network: Network) { viewModel.setConnectionState(ConnectionState.CONNECTED) } override fun onLost(network: Network) { viewModel.setConnectionState(ConnectionState.NO_NETWORK) // Показать баннер "Нет подключения" вместо offline-статусов } } , קרא ל-build.gradle עם התראה. צור implementation 'org.eclipse.paho:org.eclipse.paho.client.mqttv3:1.2.5' ב-Service עם מפגש מתמשך (clean session = false).
4. התחבר לברוקר. השתמש ב-startForeground() עם MqttAsyncClient ו-onCreate. הגדר את הודעת LWT עם דגל retained.
5. הירשם לנושאים. לדוגמה, MqttConnectOptions עם QoS 1.
6. טפל ב-LWT. מכשירים רושמים LWT בעת חיבור; בעת ניתוק, הברוקר מפרסם את סטטוס הניתוק עם QoS 1 כדי להבטיח מסירה.
7. טפל בשינויי רשת. השתמש ב-automaticReconnect = true כדי לעבור בין מצבי מחובר/אין רשת.

מקרה בוחן: עבור חברת לוגיסטיקה עם 2,000 עוקבים, יישמנו MQTT עם keepalive של 60 שניות. זה אפשר זיהוי מכשירים שאבדו תוך 120 שניות (שני keepalives + LWT). זמן התגובה של צוות התורן הופחת ב-30%. החברה השיגה חיסכון בעלויות של $15,000 בשנה על זמן השבתה לא פרודוקטיבי.

מה כלול

• ארכיטקטורה: בחירת תעבורה (MQTT/WebSocket/SSE) לצרכים שלך, הגדרת ברוקר או צד שרת עם רמות QoS מתאימות.
• יישום לקוח: אינטגרציית MQTT/WebSocket עם שירות רקע, טיפול במחזור חיים, חיבור מחדש עם backoff אקספוננציאלי.
• מצבי רשת: הצגה נכונה של מחובר/מנותק/לא ידוע, טיפול בשינויי רשת באמצעות ConnectivityManager.
• סמני ממשק משתמש: אייקונים, צבעים, זמן יחסי, רמת סוללה למכשירים המופעלים על סוללה.
• בדיקות: בדיקות עומס עם 10,000+ מכשירים, תרחישי הפרעות חיבור, ובדיקות השפלת רשת.
• תיעוד והדרכה: העברת גישה, תיאור ארכיטקטורה, הדרכת צוות לתמיכה.
• אחריות: 30 ימים של תמיכה חינם לאחר מסירה.

סמני ממשק משתמש

סמן ירוק/אדום פשוט קריא אך לא אינפורמטיבי. אנו ממליצים:

• אייקון + צבע: ירוק = מחובר, אפור = מנותק, אדום = שגיאה, צהוב = אזהרה.
• זמן פעילות אחרון למכשירים מנותקים: "מנותק · לפני שעתיים".
• למכשירים המופעלים על סוללה, רמת טעינה ליד הסטטוס.

הזמן "לפני שעתיים" לא צריך להיות חותמת זמן ישירה ממסד הנתונים. עצב באמצעות keepAliveInterval = 30 באנדרואיד או devices/+/status — אחרת, פתיחה שעה לאחר מכן עדיין תציג "לפני שעתיים" עד שהמסך ירענן.

יישום סטטוס ניטור בזמן אמת עם MQTT/WebSocket: 2–4 שבועות תלוי בתעבורה ובמספר המכשירים. הערכת ארכיטקטורה ביום אחד. MQTT. צור קשר לייעוץ על הפרויקט שלך. הזמן יישום ניטור בזמן אמת היום — המהנדסים שלנו יעזרו לך לבחור את הגישה האופטימלית.