אפליקציה ניידת לפיתוח IoT תעשייתי (IIoT)

אפליקציית מובייל ל-IIoT: שיקולי פיתוח מרכזיים

ה-IoT התעשייתי שונה מה-IoT הצרכני בשלוש דרכים: אמינות חשובה יותר מנוחות, נתונים זורמים 24/7, ומחיר הטעות הוא עצירת ייצור. אפליקציית מובייל ל-IIoT אינה כלי "הדלק את האור"—היא כלי עבודה למפעיל שקורא קריאות מ-PLC מסוג Siemens S7-1500 דרך OPC UA, עוקב אחר רטט מיסבים דרך נתוני IO-Link, ומקבל התראות כאשר טמפרטורת התבנית עולה על 195°C. גישת הפיתוח חייבת להתאים. אנו בונים אפליקציות כאלה כבר למעלה מ-5 שנים—צברנו ניסיון באינטגרציה עם ציוד של Siemens, Schneider Electric ו-Omron. הצוות שלנו מציע מחזור מלא: מבדיקת פרוטוקולים ועד פרסום ב-App Store וב-Google Play. צרו קשר לייעוץ—נעזור לכם להעריך את הפרויקט ולבחור את הארכיטקטורה הנכונה.

איך לבחור פרוטוקול לאפליקציית IIoT?

השאלה הראשונה בבריף: באילו פרוטוקולים הציוד שלכם מדבר? האפשרויות הנפוצות ביותר בתעשייה:

אפליקציית מובייל לא צריכה לדבר ישירות עם Modbus TCP או OPC UA—זו רמה נמוכה מדי. הארכיטקטורה הנכונה: שער קצה (Edge Gateway) אוסף נתונים מהציוד, מנרמל אותם לפורמט אחיד (בדרך כלל MQTT או REST), והאפליקציה הניידת מתקשרת עם השער בערוץ מאובטח. מפרט OPC Unified Architecture ממליץ על OPC UA להעברת נתונים מ-PLC לרמה העליונה, ועל MQTT לטלמטריה בהספק נמוך.

ПЛК / датчики ↓
OPC UA / Modbus TCP Edge Gateway (на производстве) ↓
MQTT TLS / HTTPS MQTT Broker / Backend (облако или локальный сервер) ↓
WebSocket / REST Мобильное приложение

MQTT בזמן אמת על Android

עבור אפליקציות תעשייתיות על Android, אנו משתמשים ב-Eclipse Paho MQTT או בגרסאות MQTT BLE. הפרמטר המרכזי הוא QoS. עבור טלמטריה (טמפרטורה פעם בשנייה), QoS 0 מספיק. עבור פקודות בקרה והתראות קריטיות, השתמשו ב-QoS 2 עם משלוח חד-פעמי מדויק:

class MqttService : Service() {
    private lateinit var client: MqttAndroidClient

    fun connect(brokerUrl: String, credentials: MqttCredentials) {
        client = MqttAndroidClient(applicationContext, brokerUrl, clientId)
        client.setCallback(object : MqttCallbackExtended {
            override fun connectComplete(reconnect: Boolean, serverURI: String) {
                subscribeToTopics()
            }

            override fun messageArrived(topic: String, message: MqttMessage) {
                val payload = String(message.payload)
                processMessage(topic, payload)
            }

            override fun connectionLost(cause: Throwable?) {
                // Логируем, triggering reconnect через ExponentialBackoff
                scheduleReconnect(cause)
            }

            override fun deliveryComplete(token: IMqttDeliveryToken) {}
        })

        val options = MqttConnectOptions().apply {
            userName = credentials.username
            password = credentials.password.toCharArray()
            isCleanSession = false // Сохраняем подписки между переподключениями
            keepAliveInterval = 30
            connectionTimeout = 10
            isAutomaticReconnect = true
            socketFactory = credentials.sslSocketFactory
        }

        client.connect(options)
    }
}

ПЛК / датчики ↓ OPC UA / Modbus TCP Edge Gateway (на производстве) ↓ MQTT TLS / HTTPS MQTT Broker / Backend (облако или локальный сервер) ↓ WebSocket / REST Мобильное приложение הוא קריטי עבור אפליקציות תעשייתיות: אם הטלפון מאבד קישוריות, לאחר החיבור מחדש ה-broker ימסור את כל ההודעות QoS 1/2 שהוחמצו במהלך ההפסקה.

איך להבטיח משלוח התראות אמין ללא אינטרנט?

בתעשייה, FCM/APNs אינם מתאימים להתראות קריטיות—אין ערובה למשלוח. עבור התראות מסוג "עצירת מכונה", יש צורך ב-WebSocket ישיר או ב-push דרך MQTT עם אזעקה מקומית כגיבוי. יישום ב-Android: WebSocket פועל ב-Foreground Service (סוג class MqttService : Service() { private lateinit var client: MqttAndroidClient fun connect(brokerUrl: String, credentials: MqttCredentials) { client = MqttAndroidClient(applicationContext, brokerUrl, clientId) client.setCallback(object : MqttCallbackExtended { override fun connectComplete(reconnect: Boolean, serverURI: String) { subscribeToTopics() } override fun messageArrived(topic: String, message: MqttMessage) { val payload = String(message.payload) processMessage(topic, payload) } override fun connectionLost(cause: Throwable?) { // Логируем, triggering reconnect через ExponentialBackoff scheduleReconnect(cause) } override fun deliveryComplete(token: IMqttDeliveryToken) {} }) val options = MqttConnectOptions().apply { userName = credentials.username password = credentials.password.toCharArray() isCleanSession = false // Сохраняем подписки между переподключениями keepAliveInterval = 30 connectionTimeout = 10 isAutomaticReconnect = true socketFactory = credentials.sslSocketFactory } client.connect(options) } } ); בעת קבלת אירוע קריטי, קראו ל-isCleanSession = false עם dataSync ו-NotificationManager בעוצמה מקסימלית:

fun showCriticalAlert(message: AlertMessage) {
    val channel = NotificationChannel(
        CRITICAL_CHANNEL_ID,
        "Critical Alerts",
        NotificationManager.IMPORTANCE_HIGH
    ).apply {
        enableVibration(true)
        vibrationPattern = longArrayOf(0, 500, 200, 500)
        lockscreenVisibility = Notification.VISIBILITY_PUBLIC
    }
    notificationManager.createNotificationChannel(channel)
    val notification = NotificationCompat.Builder(context, CRITICAL_CHANNEL_ID)
        .setContentTitle("\u26A0 \${message.deviceName}")
        .setContentText(message.description)
        .setPriority(NotificationCompat.PRIORITY_MAX)
        .setCategory(NotificationCompat.CATEGORY_ALARM)
        .setAutoCancel(true)
        .build()
    notificationManager.notify(message.id.hashCode(), notification)
}

ב-iOS—באופן דומה עם Critical Alerts (דורש הרשאה מיוחדת: IMPORTANCE_HIGH), שמתנגנים גם במצב Do Not Disturb.

אחסון טלמטריה מקומי

נתוני הציוד חייבים להישמר מקומית—ייצור במרתף ללא אינטרנט, סיבובי מפעיל ללא קישוריות. Room עם Flow:

@Entity(tableName = "telemetry")
data class TelemetryRecord(
    @PrimaryKey(autoGenerate = true) val id: Long = 0,
    val deviceId: String,
    val parameter: String,
    val value: Double,
    val unit: String,
    val timestamp: Long,
    val synced: Boolean = false
)

@Dao
interface TelemetryDao {
    @Insert(onConflict = OnConflictStrategy.REPLACE)
    suspend fun insert(record: TelemetryRecord)

    @Query("SELECT * FROM telemetry WHERE deviceId = :deviceId ORDER BY timestamp DESC LIMIT :limit")
    fun observeLatest(deviceId: String, limit: Int): Flow<List<TelemetryRecord>>

    @Query("SELECT * FROM telemetry WHERE synced = 0")
    suspend fun getUnsynced(): List<TelemetryRecord>
}

WorkManager מסנכרן רשומות שלא סונכרנו כאשר הרשת זמינה.

UX עבור מפעיל הייצור

UX תעשייתי אינו Material Design. המפעיל עובד עם כפפות כבדות, תאורה חלשה, טלפון ביד אחת. דרישות:

• כפתורים בגודל 48×48 dp לפחות, רצוי 64×64 dp
• ערכת נושא בניגודיות גבוהה עם אפשרות היפוך לאור שמש ישיר
• ניווט מינימלי: מידע נדרש ב-1-2 הקשות
• מצב לא מקוון עם מחוון "אין חיבור" ברור

אבטחה וגישה

אימות באפליקציית IIoT משתמש ב-LDAP/Active Directory עם SAML או OAuth 2.0 עם IdP ארגוני. פתיחת נעילה ביומטרית מותרת לאימות חוזר, לא לכניסה ראשונית. כל פקודות הבקרה מתועדות עם חותמת זמן ו-user_id—מסלול ביקורת הוא חובה.

מה כלול בפיתוח אפליקציית IIoT במפתח מלא?

ההיקף כולל: תיעוד ארכיטקטוני, גישה למאגר הקוד, מדריכי תפעול, הדרכת צוות (2-3 מפגשים), תמיכה טכנית בשלב הפיילוט.

למה להפקיד בידינו את הפיתוח?

אנו מתמחים בפיתוח תעשייתי כבר למעלה מ-5 שנים. הפורטפוליו שלנו כולל 20+ פרויקטים למפעלים בתעשיות הנפט והגז, המתכות והכימיה. כל אפליקציה עוברת בדיקות עומס חובה—אנו מדמים עד 10,000 הודעות טלמטריה נכנסות בשנייה. זמן השהיית נתונים מהחיישן למסך המפעיל הוא מתחת ל-100 אלפיות השנייה. אנו מבטיחים עמידה בתקני האבטחה OWASP Mobile Top 10 ובהנחיות סקירת App Store (סעיפים 4.2, 5.1). הפתרונות שלנו יכולים להפחית עלויות תחזוקת ציוד בעד 35% באמצעות ניתוח חיזוי.

הערכת לוחות זמנים: 3 עד 5 חודשים בהתאם למורכבות האינטגרציה. העלות מחושבת באופן אישי לאחר ניתוח מפורט של מחסן הטכנולוגיות שלכם. צרו קשר כדי לקבל הערכה ראשונית.