Flutter의 데이터 동기화(Data Synchronization) 사용법

데이터 동기화(Data Synchronization)는 모바일 애플리케이션에서 필수적인 기능 중 하나입니다. 사용자가 오프라인 상태에서 데이터를 수정하거나 추가한 후, 네트워크가 복원되면 서버와 데이터를 동기화하는 작업이 필요합니다. Flutter는 이러한 데이터 동기화를 구현하기 위한 다양한 방법을 제공합니다. 이번 글에서는 Flutter에서 데이터를 동기화하는 방법과 최적화된 동기화를 구현하기 위한 기술을 단계별로 설명하겠습니다.

1. 데이터 동기화란 무엇인가?

데이터 동기화는 오프라인 상태에서 앱 내에서 변경된 데이터를 서버와 일치시키는 프로세스입니다. 이는 모바일 앱이 오프라인 모드에서도 원활히 동작할 수 있도록 하며, 네트워크가 다시 연결되었을 때 최신 데이터를 서버에 반영할 수 있게 해줍니다. 일반적으로 데이터 동기화는 다음과 같은 단계를 포함합니다.

1. 오프라인 상태에서 데이터 저장: 사용자가 오프라인 상태에서 데이터를 추가하거나 수정할 때, 이를 로컬 저장소에 저장.
2. 네트워크 복원 시 서버와 동기화: 네트워크가 연결되면 서버와 로컬 데이터를 비교하여 변경된 데이터를 서버로 전송하고, 최신 서버 데이터를 로컬에 반영.
3. 충돌 해결: 서버와 로컬에서 동일한 데이터를 동시에 수정한 경우, 충돌을 해결하기 위한 로직을 구현.

2. 데이터 동기화를 위한 기본 구성 요소

Flutter에서 데이터 동기화를 구현하기 위해서는 로컬 저장소와 서버 간의 데이터를 관리할 수 있는 적절한 기술이 필요합니다. 이를 위해 주로 다음과 같은 기술을 사용합니다.

• 로컬 저장소: SQLite, Hive, SharedPreferences 등의 로컬 저장소를 사용하여 오프라인 상태에서 데이터를 저장.
• HTTP 클라이언트: 서버와의 통신을 위해 HTTP 패키지를 사용하여 API 요청을 보냄.
• 네트워크 상태 체크: connectivity_plus 패키지를 사용하여 네트워크 연결 상태를 감지하고, 네트워크가 복원되면 동기화를 실행.

3. 데이터 동기화 구현 예제

이제 Flutter에서 데이터 동기화를 구현하는 간단한 예제를 살펴보겠습니다. SQLite와 http 패키지를 사용하여 로컬에 데이터를 저장하고, 네트워크가 복원되면 서버와 데이터를 동기화하는 방법을 설명하겠습니다.

 

3.1 필요한 패키지 설치

pubspec.yaml 파일에 다음과 같은 의존성을 추가합니다.

dependencies:
  flutter:
    sdk: flutter
  sqflite: ^2.0.0+4
  path: ^1.8.0  # SQLite 경로 관리를 위한 패키지
  connectivity_plus: ^2.0.0  # 네트워크 상태 체크
  http: ^0.13.3  # HTTP 요청을 위한 패키지

 

3.2 데이터베이스 설정 (SQLite)

먼저 SQLite를 사용하여 로컬 데이터베이스를 설정하고, 데이터를 추가 및 저장할 수 있는 기능을 구현합니다.

import 'package:flutter/material.dart';
import 'package:sqflite/sqflite.dart';
import 'package:path/path.dart';

class LocalDatabase {
  static Database? _database;

  static Future<Database> getDatabase() async {
    if (_database != null) {
      return _database!;
    }
    String path = join(await getDatabasesPath(), 'sync_example.db');
    _database = await openDatabase(
      path,
      onCreate: (db, version) {
        return db.execute(
          'CREATE TABLE sync_data(id INTEGER PRIMARY KEY, name TEXT, synced INTEGER)',
        );
      },
      version: 1,
    );
    return _database!;
  }

  static Future<void> insertData(String name) async {
    final db = await getDatabase();
    await db.insert(
      'sync_data',
      {'name': name, 'synced': 0},
      conflictAlgorithm: ConflictAlgorithm.replace,
    );
  }

  static Future<List<Map<String, dynamic>>> getUnsyncedData() async {
    final db = await getDatabase();
    return await db.query('sync_data', where: 'synced = ?', whereArgs: [0]);
  }

  static Future<void> markAsSynced(int id) async {
    final db = await getDatabase();
    await db.update(
      'sync_data',
      {'synced': 1},
      where: 'id = ?',
      whereArgs: [id],
    );
  }
}

 

이 코드는 간단한 SQLite 데이터베이스를 생성하고, 동기화되지 않은 데이터를 조회 및 관리하는 기능을 제공합니다. synced 컬럼은 해당 데이터가 서버와 동기화되었는지를 나타냅니다.

 

반응형

 

3.3 네트워크 상태 체크 (Connectivity)

네트워크 상태를 확인하고, 네트워크가 복원되었을 때 동기화를 실행하도록 설정합니다.

import 'package:connectivity_plus/connectivity_plus.dart';

class NetworkManager {
  final Connectivity _connectivity = Connectivity();

  Future<bool> isConnected() async {
    var result = await _connectivity.checkConnectivity();
    return result != ConnectivityResult.none;
  }

  void monitorConnection(Function onConnected) {
    _connectivity.onConnectivityChanged.listen((ConnectivityResult result) {
      if (result != ConnectivityResult.none) {
        onConnected();
      }
    });
  }
}

 

이 클래스는 현재 네트워크 연결 상태를 확인하고, 네트워크 상태가 변경될 때 이벤트를 발생시킵니다.

 

 

3.4 데이터 동기화 로직

다음으로, 동기화 로직을 구현합니다. 서버와 통신하기 위해 http 패키지를 사용합니다.

import 'package:http/http.dart' as http;

class SyncManager {
  static Future<void> syncData() async {
    final unsyncedData = await LocalDatabase.getUnsyncedData();
    
    for (var data in unsyncedData) {
      final response = await http.post(
        Uri.parse('https://example.com/api/sync'),
        body: {'name': data['name']},
      );

      if (response.statusCode == 200) {
        // 서버와 동기화가 성공하면 로컬 데이터를 업데이트
        await LocalDatabase.markAsSynced(data['id']);
      }
    }
  }
}

 

이 함수는 동기화되지 않은 데이터를 조회하고, 서버로 전송한 후 성공적으로 동기화되었을 경우 로컬 데이터의 synced 상태를 업데이트합니다.

 

728x90

 

 

 

3.5 전체 코드 통합 및 실행

이제 위에서 만든 기능을 통합하여 데이터 동기화를 구현하는 간단한 앱을 완성할 수 있습니다.

import 'package:flutter/material.dart';
import 'network_manager.dart';
import 'local_database.dart';
import 'sync_manager.dart';

void main() {
  runApp(MyApp());
}

class MyApp extends StatelessWidget {
  @override
  Widget build(BuildContext context) {
    return MaterialApp(
      home: HomeScreen(),
    );
  }
}

class HomeScreen extends StatefulWidget {
  @override
  _HomeScreenState createState() => _HomeScreenState();
}

class _HomeScreenState extends State<HomeScreen> {
  final NetworkManager _networkManager = NetworkManager();

  @override
  void initState() {
    super.initState();
    _networkManager.monitorConnection(() {
      SyncManager.syncData();  // 네트워크 연결 시 동기화 실행
    });
  }

  Future<void> _addData(String name) async {
    await LocalDatabase.insertData(name);
    ScaffoldMessenger.of(context).showSnackBar(SnackBar(content: Text('Data added')));
  }

  @override
  Widget build(BuildContext context) {
    return Scaffold(
      appBar: AppBar(title: Text('Data Synchronization Example')),
      body: Center(
        child: Column(
          mainAxisAlignment: MainAxisAlignment.center,
          children: [
            TextField(
              onSubmitted: (value) {
                _addData(value);
              },
              decoration: InputDecoration(labelText: 'Enter name to add'),
            ),
          ],
        ),
      ),
    );
  }
}

 

이 코드는 간단한 앱을 만들고, 사용자가 입력한 데이터를 로컬에 저장한 후, 네트워크가 복원되면 서버와 동기화하는 기능을 포함합니다.

4. 동기화 최적화 전략

4.1 배치 동기화

여러 개의 데이터를 하나씩 서버로 전송하는 대신, 배치(batch) 처리로 한 번에 여러 데이터를 동기화하는 것이 효율적입니다. 배치 동기화를 사용하면 서버와의 네트워크 요청을 줄이고, 동기화 속도를 높일 수 있습니다.

4.2 충돌 해결

동기화 중 서버와 로컬에서 동일한 데이터를 서로 다르게 수정한 경우, 충돌을 해결하는 로직이 필요합니다. 일반적으로 다음과 같은 방법을 사용할 수 있습니다.

• 최신 데이터 우선: 타임스탬프를 기준으로 최신 데이터를 우선시.
• 서버 우선: 서버의 데이터를 우선시하여 로컬 데이터를 덮어씀.
• 사용자 선택: 사용자에게 충돌 상황을 알리고, 어떤 데이터를 유지할지 선택하게 함.

결론

Flutter에서 데이터 동기화를 구현하면 사용자가 오프라인 상태에서도 앱을 사용할 수 있으며, 네트워크가 복원될 때 서버와 데이터를 안전하게 동기화할 수 있습니다. SQLite와 같은 로컬 데이터베이스를 사용하여 데이터를 저장하고, 네트워크 상태를 체크하여 동기화를 트리거할 수 있습니다. 이 글에서 설명한 방법들을 활용하여 Flutter 애플리케이션에서 효율적인 데이터 동기화를 구현해보세요.