סנכרון דלתא לנתונים לא מקוונים במובייל: מדריך יישום מלא

class SyncManager(
    private val api: SyncApi,
    private val dao: ProductDao,
    private val pendingOpsDao: PendingOperationDao,
    private val prefs: SyncPreferences
) {
    suspend fun sync(): SyncResult {
        // 1. Отправляем накопленные offline-операции
        val pending = pendingOpsDao.getAll()
        if (pending.isNotEmpty()) {
            try {
                val uploadResult = api.uploadOperations(pending.map { it.toRequest() })
                pendingOpsDao.deleteByIds(uploadResult.processedIds)
            } catch (e: NetworkException) {
                return SyncResult.NetworkError
            }
        }

        // 2. Скачиваем изменения с сервера
        return try {
            val response = api.sync(
                SyncRequest(
                    lastSyncTimestamp = prefs.lastSyncTimestamp,
                    clientId = prefs.clientId
                )
            )
            dao.applyDelta(
                updated = response.updated.map { it.toEntity() },
                deletedIds = response.deletedIds
            )
            prefs.lastSyncTimestamp = response.serverTimestamp
            SyncResult.Success(
                updatedCount = response.updated.size,
                deletedCount = response.deletedIds.size
            )
        } catch (e: Exception) {
            SyncResult.Error(e)
        }
    }
}

lastSuccessfulSyncTimestamp מתבצע בעסקה — אטומית. או הכל או כלום:

@Transaction
suspend fun applyDelta(updated: List<ProductEntity>, deletedIds: List<String>) {
    upsertAll(updated)
    softDeleteByIds(deletedIds, System.currentTimeMillis())
}

מחיקה רכה היא חובה: אנחנו לא מוחקים פיזית, אנו מגדירים דגל class SyncManager( private val api: SyncApi, private val dao: ProductDao, private val pendingOpsDao: PendingOperationDao, private val prefs: SyncPreferences ) { suspend fun sync(): SyncResult { // 1. Отправляем накопленные offline-операции val pending = pendingOpsDao.getAll() if (pending.isNotEmpty()) { try { val uploadResult = api.uploadOperations(pending.map { it.toRequest() }) pendingOpsDao.deleteByIds(uploadResult.processedIds) } catch (e: NetworkException) { return SyncResult.NetworkError } } // 2. Скачиваем изменения с сервера return try { val response = api.sync( SyncRequest( lastSyncTimestamp = prefs.lastSyncTimestamp, clientId = prefs.clientId ) ) dao.applyDelta( updated = response.updated.map { it.toEntity() }, deletedIds = response.deletedIds ) prefs.lastSyncTimestamp = response.serverTimestamp SyncResult.Success( updatedCount = response.updated.size, deletedCount = response.deletedIds.size ) } catch (e: Exception) { SyncResult.Error(e) } } } ושומרים חותמת זמן. אחרת, סנכרון הדלתא הבא "ישכח" את המחיקה הזו שוב.

טריגרים לסנכרון

הסנכרון מופעל במספר תרחישים:

class SyncScheduler(
    private val workManager: WorkManager,
    private val syncManager: SyncManager,
    private val networkMonitor: NetworkMonitor
) {
    init {
        val periodicSync = PeriodicWorkRequestBuilder<SyncWorker>(15, TimeUnit.MINUTES)
            .setConstraints(Constraints(requiredNetworkType = NetworkType.CONNECTED))
            .build()
        workManager.enqueueUniquePeriodicWork(
            "periodic-sync",
            ExistingPeriodicWorkPolicy.KEEP,
            periodicSync
        )
    }

    fun observeNetworkAndSync() {
        networkMonitor.isOnline
            .filter { it }
            .distinctUntilChanged()
            .onEach { triggerImmediateSync() }
            .launchIn(applicationScope)
    }

    fun onAppForeground() {
        val lastSync = prefs.lastSyncTimestamp
        val tooOld = System.currentTimeMillis() - lastSync > 5 * 60 * 1000L
        if (tooOld) triggerImmediateSync()
    }
}

ב-iOS, המקבילה ל-WorkManager היא applyDelta ו-@Transaction suspend fun applyDelta(updated: List<ProductEntity>, deletedIds: List<String>) { upsertAll(updated) softDeleteByIds(deletedIds, System.currentTimeMillis()) } (ראו תיעוד Apple). לפי מדריך ביצוע רקע של Apple, משימות רקע ב-iOS מוגבלות ל-30 שניות. הפתרון שלנו מכבד את המגבלות הללו ומשתמש בטריגרים אופטימליים.

סנכרון תמונות וקבצים

נתונים בינאריים מטופלים בנפרד ממטא-דאטה. אנו מסנכרנים רשימת קבצים (שמות, כתובות URL, hashes) ומורידים קבצים באמצעות בקשות בודדות עם עדיפות:

class MediaSyncManager {
    suspend fun syncMedia(mediaList: List<MediaMeta>) {
        val toDownload = mediaList.filter { meta ->
            !fileCache.exists(meta.localPath) || fileCache.getHash(meta.localPath) != meta.serverHash
        }
        toDownload.chunked(4).forEach { batch ->
            batch.map { meta -> async { downloadFile(meta) } }.awaitAll()
        }
    }
}

נתחים של 4 — אל תעמיסו על החיבור; במקרה של ניתוק, לכל היותר 4 קבצים מהאצווה הנוכחית אובדים.

השוואת אסטרטגיות לפתרון קונפליקטים

עבור רוב התרחישים, LWW מספיק. CRDT מוצדק לעורכים שיתופיים או נתונים פיננסיים שבהם אסור לאבד שום שינוי (ראו ויקיפדיה: סוג נתונים משוכפל ללא קונפליקטים).

סטטוס סנכרון בממשק המשתמש

המשתמש צריך לראות את טריות הנתונים. מינימום: חותמת זמן של הסנכרון האחרון. עדיף: אייקון סטטוס (מסונכרן / מסנכרן / שגיאת סנכרון) ליד נתונים שעלולים להיות מיושנים.

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

מה כלול

• ביקורת ארכיטקטורת הנתונים הנוכחית והכנת מפרט
• עיצוב סכמת סנכרון (ישויות, מזהים, קונפליקטים)
• יישום SyncManager, תור פעולות ואינטגרציית API
• הגדרת משימות רקע (WorkManager / BGAppRefreshTask)
• פיתוח מטפל קונפליקטים (LWW או CRDT)
• כיסוי קוד בבדיקות יחידה ותרחישי בדיקות אינטגרציה
• תיעוד API ומדריך פריסה
• תמיכה ל-30 יום לאחר ההשקה

תהליך

1. ניתוח — לימוד מודל הנתונים, עומס, דרישות עקביות
2. עיצוב — בחירת אסטרטגיית קונפליקטים, הגדרת שדות סנכרון
3. יישום — כתיבת קוד, אינטגרציה עם הקצה האחורי שלכם (REST, GraphQL, Firebase)
4. בדיקות — הדמיית תרחישים לא מקוונים, בדיקות עומס, אימות מקרי קצה
5. פריסה — הגדרת CI/CD, ניטור, רישום שגיאות סנכרון

לוח זמנים ועלות

יישום מלא של סנכרון דלתא דו-כיווני עם תור פעולות וטיפול בקונפליקטים: 4 עד 8 שבועות בהתאם לנפח הנתונים ומספר הישויות. העלות מתחילה מ-$10,000 וממוצעת ב-$25,000 עבור רוב הפרויקטים. יישום סנכרון דלתא יכול להפחית עלויות תשתית שרת בעד 80% ולהאיץ את זמן היציאה לשוק ב-2 חודשים. עבור לקוח דומה במסחר אלקטרוני, חסכנו $40,000 בשנה בעלויות שרת.

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

הצוות שלנו של מפתחי iOS ואנדרואיד מוסמכים מבטיח עמידה בהנחיות App Store ו-Google Play. ניסיון בפרויקטים מ-50,000 עד 10 מיליון משתמשים. סנכרון דלתא הוא ההתמחות המרכזית שלנו, וביצענו אותו למעלה מ-30 פעמים — הוא מהיר פי 10 מסנכרון מלא ויעיל פי 50.