Data Synchronization Across iOS Devices Using Couchbase Mobile

이 게시물에서는 Couchbase Mobile을 사용하여 iOS 기기에서 데이터 복제/동기화를 시작하는 방법을 살펴봅니다. Couchbase 모바일 스택은 Couchbase 서버, 동기화 게이트웨이 및 Couchbase Lite 임베디드 NoSQL 데이터베이스로 구성됩니다. 이전 post에서 Couchbase Lite를 iOS 앱에서 독립형 임베디드 NoSQL 데이터베이스로 사용하는 방법에 대해 설명했습니다. 이 게시물에서는 푸시 및 풀 복제, 인증 및 액세스 제어, 채널 및 동기화 기능의 핵심 개념을 보여주는 동기화 게이트웨이와 함께 샘플 iOS 앱을 안내합니다.

여기서는 Swift의 iOS 앱 컨텍스트에서 데이터 동기화를 살펴볼 것이지만, 여기서 설명하는 모든 내용은 다른 플랫폼(Android, iOS(ObjC), Xamarin)에서 개발된 모바일 앱에도 동일하게 적용됩니다. 편차는 이와 같이 명시됩니다.

참고: 현재 프로덕션 릴리스인 Couchbase Mobile v1.4에 대해 논의할 예정입니다. 최신 개발자 미리보기 새롭고 흥미로운 기능이 많이 포함된 Couchbase Mobile 버전 2.0을 출시했습니다.

카우치베이스 모바일

Couchbase 모바일 스택은 Couchbase 서버, 동기화 게이트웨이 및 Couchbase Lite 임베디드 NoSQL 데이터베이스로 구성됩니다. 이 게시물에서는 NoSQL의 기본 사항에 대해 설명합니다. 데이터 복제 및 동기화 카우치베이스 모바일을 사용합니다. 여기서는 iOS 앱 개발, Swift의 기본, NoSQL의 기본에 익숙하고 Couchbase에 대해 어느 정도 이해하고 있다고 가정하겠습니다. Couchbase Mobile에 대해 더 자세히 알고 싶으시다면 이 글의 끝부분에서 많은 리소스를 찾아보실 수 있습니다.

카우치베이스 동기화 게이트웨이

카우치베이스 동기화 게이트웨이는 장치 간은 물론 장치와 클라우드 간에 데이터를 안전하게 동기화하는 인터넷 기반 동기화 메커니즘입니다.

다음을 제공하는 웹 인터페이스를 노출합니다.

디바이스 및 클라우드 간 데이터 동기화
액세스 제어
데이터 유효성 검사

모든 HTTP 클라이언트를 사용하여 인터페이스를 자세히 살펴볼 수 있습니다. 다음 내용을 확인하세요. post 인터페이스 쿼리를 위해 Postman을 사용하는 방법에 대해 설명합니다.

동기화 게이트웨이를 사용한 데이터 복제 또는 동기화와 관련된 세 가지 주요 개념이 있습니다.

채널

채널은 태그와 메시지 대기열의 조합으로 볼 수 있습니다. 모든 문서는 하나 이상의 채널에 할당할 수 있습니다. 문서는 문서에 액세스할 수 있는 사용자를 지정하는 채널에 할당됩니다. 사용자는 하나 이상의 채널에 대한 액세스 권한이 부여되며 해당 채널에 할당된 문서만 읽을 수 있습니다. 자세한 내용은 채널에 대한 문서를 참조하세요.

동기화 기능

동기화 함수는 동기화 게이트웨이에서 실행되는 JavaScript 함수입니다. 데이터베이스에 새 문서, 수정본 또는 삭제가 추가될 때마다 동기화 함수가 호출됩니다. 동기화 함수는 다음을 담당합니다.

문서 유효성 검사,
변경 승인하기
채널에 문서 할당 및
사용자에게 채널에 대한 액세스 권한을 부여합니다.

자세한 내용은 다음을 확인하세요. 동기화 기능에 대한 문서 .

복제

복제 또는 동기화는 로컬 데이터베이스와 원격 동기화 게이트웨이 간의 변경 사항을 동기화하는 프로세스입니다. 두 가지 종류가 있습니다.

푸시 복제는 로컬 데이터베이스에서 원격 데이터베이스로 변경 사항을 푸시하는 데 사용됩니다.
풀 복제는 원격 데이터베이스에서 로컬 데이터베이스로 변경 사항을 가져오는 데 사용됩니다.

자세한 내용은 다음을 확인하세요. 복제 관련 문서.

카우치베이스 동기화 게이트웨이 설치

다음을 따르십시오. 설치 가이드 를 클릭하여 동기화 게이트웨이를 설치합니다.

다음 구성 파일을 사용하여 동기화 게이트웨이를 시작합니다. 구성 파일의 정확한 위치는 플랫폼에 따라 다릅니다. 자세한 내용은 설치 가이드를 참조하세요.

동기화 게이트웨이 구성 파일

{
  "log": ["*"],
  "CORS": {
     "Origin":["*"]
  },
  "databases": {
    "demo": {
      "server": "walrus:",
      "bucket": "default",
      "users": { 
        "GUEST": { "disabled": true, "admin_channels": ["*"] } ,
        "joe": {"password":"password" ,"disabled": false, "admin_channels":["_public","_joe"]} ,
        "jane":{"password":"password" ,"disabled": false, "admin_channels":["_public","_jane"]}
      },
      "unsupported": {
        "user_views": {
          "enabled":true
        }
      },
    
  
  "sync": 
  `
      
      function (doc, oldDoc){
     

        // Check if doc is being deleted
        if (doc._deleted == undefined) {
          // Validate current version has relevant keys
          validateDocument(doc);
        }
        else {
          // Validate  old document has relevant keys
          validateDocument(oldDoc);
        }

        var docOwner = (doc._deleted == undefined) ? doc.owner : oldDoc.owner;
    

        var publicChannel = "_public";

        var privateChannel = "_"+docOwner;

        // Grant user read access to public channels and user's own channel
        access(docOwner,[publicChannel,privateChannel]);


        // Check if this was a doc update (as opposed to a doc create or delete)
        if (doc._deleted == undefined && oldDoc != null && oldDoc._deleted == undefined) {

            if (doc.tag != oldDoc.tag) {
                 throw({forbidden: "Cannot change tag of document"});
         
            }
        }


        // Check if new/updated document is tagged as "public" 
        var docTag =  (doc._deleted == undefined) ? doc.tag : oldDoc.tag;
    
        if (doc._deleted == undefined) {
          if (docTag == "public") {
           
            // All documents tagged public go into "public" channel which to open to all
            channel(publicChannel);
         
        }
        else {

            // Ensure that the owner of document is the user making the request
            requireUser(docOwner);

            // All non-public tagged docs go into a user user specific channel
            channel(privateChannel);

         }
       }
       else {
          channel(doc.channels);
       }


        function validateDocument (doc) {
           // Basic validation of document
          if (!doc.tag ) {
            // Every doc must include a tag
            throw({forbidden: "Invalid document type: Tag not provided" + doc.tag});
          }

           if (!doc.owner) {
            // Every doc must include a owner
            throw({forbidden: "Invalid document type: Owner not provided" + doc.owner});
          
          }
        }
      }
  

`
    }
  }
}

100

101

102

103

{

"log": ["*"],

"CORS": {

"Origin":["*"]

"데이터베이스": {

"demo": {

"서버": "월러스:",

"bucket": "default",

"users": {

"GUEST": { "disabled": true, "admin_channels": ["*"] } ,

"joe": {"비밀번호":"비밀번호" ,"disabled": false, "admin_channels":["_public","_joe"]} ,

"jane":{"비밀번호":"비밀번호" ,"disabled": false, "admin_channels":["_public","_jane"]}

"지원되지 않음": {

"user_views": {

"enabled":true

}

"동기화":

함수 (doc, oldDoc){

// 문서가 삭제되고 있는지 확인

if (doc._deleted == 정의되지 않음) {

// 현재 버전에 관련 키가 있는지 확인

validateDocument(doc);

}

else {

// 이전 문서에 관련 키가 있는지 확인

유효성 검사 문서(oldDoc);

}

var docOwner = (doc._deleted == undefined) ? doc.owner : oldDoc.owner;

var publicChannel = "_public";

var privateChannel = "_"+docOwner;

// 사용자에게 공개 채널 및 사용자 자신의 채널에 대한 읽기 권한 부여하기

access(docOwner,[publicChannel,privateChannel]);

// 문서 생성 또는 삭제가 아닌 문서 업데이트인지 확인합니다.

if (doc._deleted == undefined && oldDoc != null && oldDoc._deleted == undefined) {

if (doc.tag != oldDoc.tag) {

throw({forbidden: "문서의 태그를 변경할 수 없습니다"});

}

// 새 문서/업데이트 문서가 "공개" 태그가 있는지 확인합니다.

var docTag = (doc._deleted == 정의되지 않음) ? doc.tag : oldDoc.tag;

if (doc._deleted == 정의되지 않음) {

if (docTag == "public") {

// 공개로 태그가 지정된 모든 문서는 모든 사람에게 공개되는 '공개' 채널로 이동합니다.

채널(publicChannel);

}

else {

// 문서 소유자가 요청을 하는 사용자인지 확인합니다.

요구 사용자(문서 소유자);

// 비공개 태그가 지정된 모든 문서는 사용자별 채널로 이동합니다.

채널(privateChannel);

}

else {

채널(doc.channels);

}

함수 validateDocument (doc) {

// 문서의 기본 유효성 검사

if (!doc.tag ) {

// 모든 문서에는 태그가 포함되어야 합니다.

throw({forbidden: "잘못된 문서 유형: 태그가 제공되지 않았습니다" + doc.tag});

}

if (!doc.owner) {

// 모든 문서에는 소유자가 포함되어야 합니다.

throw({forbidden: "잘못된 문서 유형: 소유자가 제공되지 않았습니다" + doc.owner});

}

구성 파일에서 주목해야 할 몇 가지 주요 사항은 다음과 같습니다.

8번째 줄: '서버'의 'walrus:' 값은 동기화 게이트웨이가 데이터를 인메모리에 유지해야 하며 Couchbase 서버에 의해 백업되지 않음을 나타냅니다.
11줄: 게스트 사용자 액세스가 비활성화되었습니다.
12-13줄: 시스템에 "Jane"과 "Joe"라는 두 명의 사용자가 구성되어 있습니다. 두 사용자 모두 "_public" 채널에 액세스할 수 있으며 각각 자신의 비공개 채널에 액세스할 수 있습니다.
22-100 라인: 다음을 수행하는 간단한 동기화 기능
1. 29-36줄 : 문서에 사용자 정의 '태그' 및 '소유자' 속성이 포함되어 있는지 확인하기 위한 문서 유효성 검사
  1. "태그" 속성은 문서가 모든 사용자에게 공개적으로 사용 가능한지 또는 사용자에게 비공개로 제공되는지 지정하는 데 사용됩니다.
  2. '소유자' 속성은 문서가 모든 사용자에게 공개적으로 사용 가능한지 또는 사용자에게 비공개로 제공되는지 지정하는 데 사용됩니다.
2. 46줄: 사용자에게 '_공개' 및 비공개 채널(문서 소유자를 사용하여 식별됨)에 대한 액세스 권한을 부여합니다.
3. 51-56줄 : 문서 업데이트인 경우 "태그" 속성이 여러 수정본에서 변경되지 않았는지 확인합니다.
4. 66줄: '공개' 태그가 있는 모든 문서를 '_public' 채널에 할당합니다.
5. 72줄: '공개' 이외의 태그가 있는 모든 문서를 비공개 채널에 할당합니다.
  1. 75번 라인: 비공개 채널 문서의 경우 먼저 문서 소유자가 요청을 한 사람인지 확인합니다.

카우치베이스 라이트

Couchbase Lite는 기기에서 실행되는 임베디드 NoSQL 데이터베이스입니다. Couchbase Lite는 여러 배포 모드에서 사용할 수 있습니다. Couchbase Lite 시작하기 post 에서 독립형 배포 모드에 대해 설명합니다. 카우치베이스 라이트는 여러 기기에서 데이터를 동기화할 수 있는 원격 동기화 게이트웨이와 함께 사용할 수 있습니다. 이 게시물에서는 동기화 게이트웨이를 사용한 배포 모드에 대해 설명합니다.

카우치베이스 라이트 프레임워크를 iOS 앱에 통합할 수 있는 다양한 옵션이 있습니다. Couchbase 모바일을 확인하세요. 시작하기 가이드 를 클릭해 다양한 통합 옵션을 확인하세요.

네이티브 API

카우치베이스 라이트는 앱이 카우치베이스 플랫폼과 쉽게 인터페이스할 수 있는 iOS, 안드로이드, 윈도우용 네이티브 API를 제공합니다. 앱 개발자는 Couchbase Lite 임베디드 데이터베이스의 내부에 대해 걱정할 필요 없이 멋진 앱 구축에만 집중할 수 있습니다. 기본 API를 사용하면 다른 플랫폼 프레임워크/서브시스템과 상호 작용할 때와 마찬가지로 Couchbase Lite 프레임워크와 상호 작용할 수 있습니다. 이 블로그 게시물에서는 다시 한 번 Couchbase Mobile v1.4에 대해 설명하겠습니다. 전체 API 목록은 Couchbase에서 확인할 수 있습니다. 개발자 사이트.

iOS 앱 데모

여기에서 데모 Xcode 프로젝트를 다운로드하세요. 깃허브 리포지토리 를 클릭하고 '동기화 지원' 브랜치로 전환합니다. 이 블로그의 나머지 부분에서는 이 앱을 예시로 사용하겠습니다. 이 앱은 Cocoapods를 사용하여 Couchbase Lite 프레임워크를 통합합니다.

git clone git@github.com:couchbaselabs/couchbase-lite-ios-standalone-sampleapp.git
git checkout syncsupport

1 2	git 복제 git@github.com:카우치바스랩/카우치베이스-lite-ios-독립형-샘플 앱.git git 결제 동기화 지원

사용자 간 문서 동기화

앱을 빌드하고 실행합니다. 로그인 알림이 표시되어야 합니다.
사용자 "jane"과 비밀번호 "password"를 입력합니다. 이 사용자는 동기화 게이트웨이 구성 파일에서 구성되었습니다.
오른쪽 상단의 '+' 버튼을 탭하여 첫 번째 문서를 추가합니다.
1. 문서 이름과 한 줄 설명을 입력합니다.
2. "비공개" 태그를 사용합니다.
3. 푸시 리플리케이터가 문서를 동기화 게이트웨이로 푸시하고 동기화 기능에 의해 처리됩니다. 동기화 기능은 태그를 기반으로 문서를 사용자의 비공개 채널에 할당합니다.
오른쪽 상단의 '+' 버튼을 탭하여 두 번째 문서를 추가합니다.
1. 문서 이름과 한 줄 설명을 입력합니다.
2. "공개" 태그를 사용합니다.
3. 푸시 리플리케이터가 문서를 동기화 게이트웨이로 푸시하고 동기화 기능에 의해 처리됩니다. 동기화 함수는 공개 태그를 기반으로 문서를 공개 채널에 할당합니다.
이제 Jane 을 "로그오프"합니다. 로그인 알림이 다시 표시됩니다.
사용자 "joe"와 비밀번호 "password"를 입력합니다. 이 사용자는 동기화 게이트웨이 구성 파일에서도 구성되었습니다.
Jane이 만든 공개 문서가 나열됩니다.
1. 그 뒤에서 풀 리플리케이터는 조의 비공개 채널과 공개 채널에서 모든 문서를 가져옵니다. Jane이 만든 공개 문서는 가져오기됩니다. 그러나 Joe는 Jane의 비공개 채널에 액세스할 수 없으므로 Jane이 만든 비공개 문서는 가져오지 않습니다.

동기화 게이트웨이의 상태를 확인하려면 Postman 또는 HTTP 클라이언트를 사용하여 관리자 REST 인터페이스에 쿼리할 수 있습니다.

다음은 동기화 게이트웨이에 대한 CURL 요청입니다.

curl -X GET \
 'http://localhost:4985/demo/_all_docs?access=false&channels=false&include_docs=true' \
 -H 'accept: application/json' \
 -H 'cache-control: no-cache' \
 -H 'content-type: application/json'

curl -X GET \

'http://localhost:4985/demo/_all_docs?access=false&channels=false&include_docs=true' \

-H '수락: 신청/제이슨' \

-H '캐시 제어: 캐시 없음' \

-H '콘텐츠 유형: 애플리케이션/json'

동기화 게이트웨이의 응답에는 공개 및 Jane의 비공개 채널에 각각 할당된 두 개의 문서가 표시됩니다.

{
  "rows": [
    {
      "key": "-6gCouN6jj0ScYgpMD7Qj1a",
      "id": "-6gCouN6jj0ScYgpMD7Qj1a",
      "value": {
        "rev": "1-dfa6d453a1515ee3dd64012ccaf53046",
        "channels": [
          "_jane"
        ]
      },
      "doc": {
        "_id": "-6gCouN6jj0ScYgpMD7Qj1a",
        "_rev": "1-dfa6d453a1515ee3dd64012ccaf53046",
        "name": "doc101",
        "overview": "This is a private doc from Jane",
        "owner": "jane",
        "tag": "private"
      }
    },
    {
      "key": "-A2wR44pAFCdu1Yufx14_1S",
      "id": "-A2wR44pAFCdu1Yufx14_1S",
      "value": {
        "rev": "1-1a8cd0ea3b7574cf6f7ba4a10152a466",
        "channels": [
          "_public"
        ]
      },
      "doc": {
        "_id": "-A2wR44pAFCdu1Yufx14_1S",
        "_rev": "1-1a8cd0ea3b7574cf6f7ba4a10152a466",
        "name": "doc102",
        "overview": "This is a public doc shared by Jane",
        "owner": "jane",
        "tag": "public"
      }
    }
  ],
  "total_rows": 2,
  "update_seq": 5
}

{

"행": [

{

"key": "-6gCouN6jj0ScYgpMD7Qj1a",

"id": "-6gCouN6jj0ScYgpMD7Qj1a",

"value": {

"rev": "1-dfa6d453a1515ee3dd64012ccaf53046",

"채널": [

"_jane"

]

"doc": {

"_id": "-6gCouN6jj0ScYgpMD7Qj1a",

"_rev": "1-dfa6d453a1515ee3dd64012ccaf53046",

"name": "doc101",

"개요": "이것은 Jane의 비공개 문서입니다.",

"소유자": "jane",

"tag": "private"

}

{

"key": "-A2wR44pAFCdu1Yufx14_1S",

"id": "-A2wR44pAFCdu1Yufx14_1S",

"value": {

"rev": "1-1a8cd0ea3b7574cf6f7ba4a10152a466",

"채널": [

"_public"

]

"doc": {

"_id": "-A2wR44pAFCdu1Yufx14_1S",

"_rev": "1-1a8cd0ea3b7574cf6f7ba4a10152a466",

"name": "doc102",

"개요": "이것은 Jane이 공유한 공개 문서입니다.",

"소유자": "jane",

"tag": "public"

}

"total_rows": 2,

"update_seq": 5

}

코드 살펴보기

이제 iOS 데모 앱의 관련 코드 스니펫을 살펴보겠습니다.

사용자별 데이터베이스 열기/생성

열기 DocListTableViewController.swift 파일을 찾아 사용자에 대한 데이터베이스 열기 함수입니다.

 do {
       // 1: Set Database Options
       let options = CBLDatabaseOptions()
       options.storageType  = kCBLSQLiteStorage
       options.create = true
            
       // 2: Create a DB for logged in user if it does not exist else return handle to existing one
       self.db  = try cbManager.openDatabaseNamed(user.lowercased(), with: options)
       self.showAlertWithTitle(NSLocalizedString("Success!", comment: ""), message: NSLocalizedString("Database \(user) was opened succesfully at path \(CBLManager.defaultDirectory())", comment: ""))
            
       // 3. Start replication with remote Sync Gateway
       startDatabaseReplicationForUser(user, password: password)
       return true
        }
        catch  {
            // handle error    
        }

do {

// 1: 데이터베이스 옵션 설정

let 옵션 = CBLDatabaseOptions()

옵션.storageType = kCBLSQLiteStorage

옵션.create = true

// 2: 로그인한 사용자에 대한 DB가 존재하지 않으면 기존 사용자로 핸들을 반환합니다.

self.db = 시도 cbManager.오픈 데이터베이스 이름(사용자.소문자(), 와 함께: 옵션)

self.showAlertWithTitle(NSLocalizedString("성공!", 댓글: ""), 메시지: NSLocalizedString("데이터베이스 \(사용자) 에서 성공적으로 오픈되었습니다. \(CBLManager.기본 디렉터리())", 댓글: ""))

// 3. 원격 동기화 게이트웨이로 복제 시작하기

사용자에 대한 데이터베이스 복제 시작(사용자, 비밀번호: 비밀번호)

반환 true

}

catch {

// 오류 처리

}

데이터베이스와 연결할 옵션을 지정합니다. CBLDatabaseOptions 클래스에서 다른 옵션을 살펴보세요.
현재 사용자의 이름으로 데이터베이스를 만듭니다. 이렇게 하면 앱의 모든 사용자가 자신만의 로컬 데이터베이스 복사본을 갖게 됩니다. 해당 이름의 데이터베이스가 존재하면 기존 데이터베이스에 대한 핸들이 반환되고 그렇지 않으면 새 데이터베이스가 생성됩니다. 데이터베이스 이름은 소문자로 입력해야 합니다. 성공하면 로컬 데이터베이스가 존재하지 않으면 새 로컬 데이터베이스가 만들어집니다. 기본적으로 데이터베이스는 기본 경로(/도서관/응용 프로그램 지원)에 만들어집니다. 인스턴스화할 때 다른 디렉터리를 지정할 수 있습니다. CBLManager 클래스.
주어진 사용자 자격 증명에 대해 데이터베이스 복제 프로세스를 시작합니다. 다음 섹션에서 복제 코드에 대해 자세히 설명합니다.

문서 가져오기

DocListTableViewController.swif파일을 찾아 사용자 데이터베이스에 대한 모든 문서 가져오기 함수입니다.

// 1. Create Query to fetch all documents. You can set a number of properties on the query object
liveQuery = self.db?.createAllDocumentsQuery().asLive()
            
guard let liveQuery = liveQuery else {
       return
}
            
// 2: You can optionally set a number of properties on the query object.
// Explore other properties on the query object
liveQuery.limit = UInt(UINT32_MAX) // All documents
            
//   query.postFilter =
            
//3. Start observing for changes to the database
self.addLiveQueryObserverAndStartObserving()
            
            
// 4: Run the query to fetch documents asynchronously
liveQuery.runAsync({ (enumerator, error) in
        switch error {
            case nil:
            // 5: The "enumerator" is of type CBLQueryEnumerator and is an enumerator for the results
            self.docsEnumerator = enumerator
                    
                    
            default:
            self.showAlertWithTitle(NSLocalizedString("Data Fetch Error!", comment: ""), message: error.localizedDescription)
                }
            })            
        }
        catch  {
            // handle error            
        }

// 모든 문서를 가져오려면 쿼리 만들기를 클릭합니다. 쿼리 개체에서 여러 속성을 설정할 수 있습니다.

라이브 쿼리 = self.db?.createAllDocumentsQuery().asLive()

guard let 라이브 쿼리 = 라이브 쿼리 else {

반환

}

// 2: 쿼리 객체에서 선택적으로 여러 속성을 설정할 수 있습니다.

// 쿼리 객체에서 다른 속성 탐색

라이브 쿼리.limit = UInt(UINT32_MAX) // 모든 문서

// query.postFilter =

//3. 데이터베이스 변경 사항 관찰 시작

self.추가 라이브 쿼리 옵저버 및 시작 옵저빙()

// 4: 쿼리를 실행하여 문서를 비동기적으로 가져오기

라이브 쿼리.runAsync({ (열거자, 오류) in

스위치 오류 {

case nil:

// 5: "열거자"는 CBLQueryEnumerator 유형이며 결과의 열거자입니다.

self.문서 열거자 = 열거자

기본값:

self.showAlertWithTitle(NSLocalizedString("데이터 가져오기 오류!", 댓글: ""), 메시지: 오류.현지화된설명)

}

})

}

catch {

// 오류 처리

}

지정된 이름의 데이터베이스에 대한 핸들 가져오기
쿼리 객체를 만듭니다. 이 쿼리는 모든 문서를 가져오는 데 사용됩니다. 동기화 게이트웨이의 동기화 기능은 사용자가 액세스할 수 있는 채널에서만 문서를 가져오도록 합니다. 일반 쿼리 개체 또는 "라이브" 쿼리 개체를 만들 수 있습니다. "라이브" 쿼리 개체는 다음과 같은 유형입니다. CBLLiveQuery 쿼리 결과에 영향을 미치는 방식으로 데이터베이스가 변경될 때마다 자동으로 새로 고쳐집니다. 쿼리에는 결과를 사용자 지정하기 위해 조정할 수 있는 여러 가지 속성이 있습니다. 속성을 수정하고 결과에 미치는 영향을 확인해 보세요.
데이터베이스 변경사항에 대한 알림을 받으려면 라이브 쿼리 개체에 옵저버를 명시적으로 추가해야 합니다. 이에 대해서는 "문서의 로컬 및 원격 동기화된 변경사항 관찰하기" 섹션에서 자세히 설명합니다. 관찰자가 더 이상 필요하지 않으면 관찰자를 제거하고 변경사항 관찰을 중지하는 것을 잊지 마세요!
쿼리를 비동기적으로 실행합니다. 원하는 경우 동기식으로 실행할 수도 있지만 데이터 집합이 큰 경우에는 비동기식으로 실행하는 것이 좋습니다.

쿼리가 성공적으로 실행되면 CBLQueryEnumerator 객체를 얻게 됩니다. 쿼리 열거자를 사용하면 결과를 열거할 수 있습니다. 결과를 표시하는 테이블 보기의 데이터 소스로 매우 적합합니다.

문서에 대한 로컬 및 원격 동기화 변경 사항 관찰하기

열기 DocListTableViewController.swift 파일에서 addLiveQueryObserverAndStartObserving 함수를 찾습니다.

데이터베이스의 변경 사항은 로컬 장치에서 사용자가 수행한 작업의 결과일 수도 있고 다른 장치에서 동기화된 변경 사항의 결과일 수도 있습니다.

 // 1. iOS Specific. Add observer to the live Query object
    liveQuery.addObserver(self, forKeyPath: "rows", options: NSKeyValueObservingOptions.new, context: nil)
        
 // 2. Start observing changes
    liveQuery.start()

// 1. iOS 전용. 라이브 쿼리 개체에 옵저버 추가하기

라이브 쿼리.추가옵저버(self, forKeyPath: "행", 옵션: NS키값 관찰 옵션.new, 컨텍스트: nil)

// 2. 변경 사항 관찰 시작

라이브 쿼리.시작()

쿼리 결과에 영향을 미치는 데이터베이스의 변경 사항을 알림 받으려면 라이브 쿼리 개체에 옵저버를 추가하세요. 대신 iOS의 키-값-옵저버 패턴을 활용하여 변경 사항에 대한 알림을 받습니다. 라이브 쿼리 개체에 KVO 옵저버를 추가하여 라이브 쿼리 개체의 "행" 속성 변경 사항을 관찰하기 시작합니다. 이는 다음과 같은 다른 플랫폼의 적절한 이벤트 핸들러 API를 통해 처리됩니다. 추가 변경 리스너 함수를 호출합니다.
변경 사항 관찰 시작 .

LiveQuery 객체의 "행" 속성에 영향을 미치는 데이터베이스에 변경 사항이 있을 때마다 앱에 변경 알림이 전송됩니다. 변경 알림을 받으면 UI를 업데이트할 수 있으며, 이 경우 테이블 뷰를 다시 로드합니다.

if keyPath == "rows" {
    self.docsEnumerator = self.liveQuery?.rows
    tableView.reloadData()
}

만약 키 경로 == "행" {

self.문서 열거자 = self.라이브 쿼리?.행

tableView.데이터 다시 로드()

}

복제 요청 인증

열기 DocListTableViewController.swift 파일 를 클릭하고 사용자에 대한 데이터베이스 복제 시작 함수입니다.

모든 복제 요청은 인증을 받아야 합니다. 이 앱에서는 HTTP 기본 인증을 사용합니다.

let auth = CBLAuthenticator.basicAuthenticator(withName: user, password: password)

1	let auth = CBLAuthenticator.기본 인증자(withName: 사용자, 비밀번호: 비밀번호)

인증자 유형에는 기본, Facebook, OAuth1, 페르소나, SSL/TLS 인증서 등 여러 가지가 있습니다.

풀 복제

열기 DocListTableViewController.swift 파일 를 클릭하고 시작풀복제위드인증자 함수입니다.

// 1: Create a Pull replication to start pulling from remote source
let pullRepl = db?.createPullReplication(URL(string: kDbName, relativeTo: URL.init(string: kRemoteSyncUrl))!)
        
// 2. Set Authenticator for pull replication
pullRepl?.authenticator = auth
        
// Continuously look for changes
pullRepl?.continuous = true
        
// Optionally, Set channels from which to pull
// pullRepl?.channels = [...]
        
 // 4. Start the pull replicator
 pullRepl?.start()

// 1: 원격 소스에서 풀링을 시작하기 위해 풀 복제를 생성합니다.

let pullRepl = db?.createPullReplication(URL(문자열: kDbName, 상대적 대상: URL.init(문자열: kRemoteSyncUrl))!)

// 2. 풀 복제를 위한 인증자 설정

pullRepl?.인증자 = auth

// 지속적으로 변경 사항 찾기

pullRepl?.연속 = true

// 선택 사항, 가져올 채널 설정

// pullRepl?.channels = [...]

// 4. 풀 리플리케이터를 시작합니다.

pullRepl?.시작()

원격 동기화 게이트웨이에서 변경 사항을 가져오려면 풀 리플리케이터를 만드세요. 원격 동기화 게이트웨이의 kRemoteSyncUrl 는 동기화 게이트웨이에 있는 원격 데이터베이스 엔드포인트의 URL입니다.
인증자를 풀 복제와 연결합니다. 선택적으로 문서를 가져올 채널을 설정할 수 있습니다.
복제를 '지속'으로 설정하면 명시적으로 중지하거나 데이터베이스를 닫지 않는 한 변경 내용 업데이트를 무기한 가져올 수 있습니다.
풀 복제 시작

푸시 복제

열기 DocListTableViewController.swift 파일 를 클릭하고 시작 푸시 복제 위드 인증자 함수입니다.

// 1: Create a push replication to start pushing to remote source
let pushRepl = db?.createPushReplication(URL(string: kDbName, relativeTo: URL.init(string:kRemoteSyncUrl))!)
        
// 2. Set Authenticator for push replication
pushRepl?.authenticator = auth
        
// Continuously push  changes
pushRepl?.continuous = true
        
        
// 3. Start the push replicator
pushRepl?.start()

// 1: 푸시 복제를 생성하여 원격 소스로 푸시를 시작합니다.

let pushRepl = db?.createPushReplication(URL(문자열: kDbName, 상대적 대상: URL.init(문자열:kRemoteSyncUrl))!)

// 2. 푸시 복제를 위한 인증자 설정

pushRepl?.인증자 = auth

// 지속적으로 변경 사항 푸시

pushRepl?.연속 = true

// 3. 푸시 리플리케이터를 시작합니다.

pushRepl?.시작()

푸시 복제기를 만들어 원격 동기화 게이트웨이에 변경 사항을 푸시합니다. 푸시 복제기 kRemoteSyncUrl 는 동기화 게이트웨이에 있는 원격 데이터베이스 엔드포인트의 URL입니다.
인증자를 푸시 복제와 연결합니다.
복제를 '지속'으로 설정하면 명시적으로 중지하거나 데이터베이스를 닫지 않는 한 변경 사항 업데이트를 무기한 푸시할 수 있습니다.
푸시 복제 시작

복제 상태 모니터링

열기 DBListTableViewController.swift 파일을 열고 추가 원격 데이터베이스 변경 옵저버 및 시작 옵저빙 함수를 찾습니다.

// 1. iOS Specific. Add observer to the NOtification Center to observe replicator changes
NotificationCenter.default.addObserver(forName: NSNotification.Name.cblReplicationChange, object: db, queue: nil) {
            [unowned self] (notification) in
          
  // Handle changes to the replicator status - Such as displaying progress
  // indicator when status is .running 
}

// 1. iOS 전용. NOtification Center에 옵저버를 추가하여 리플리케이터 변경 사항 관찰하기

알림 센터.기본값.추가옵저버(forName: NS알림.이름.cbl복제변경, 객체: db, 대기열: nil) {

[소유자 없음 self] (알림) in

// 리플리케이터 상태 변경 처리 - 진행률 표시 등

// 상태가 .running인 경우 표시기

}

iOS 알림 센터에 옵저버를 추가하여 복제 상태를 모니터링하여 다음 알림을 받을 수 있습니다. cbl복제변경 알림을 추가하세요. 예를 들어 알림 핸들러를 사용하여 사용자에게 적절한 진행률 표시기를 표시할 수 있습니다. 이는 다음과 같은 다른 플랫폼의 적절한 이벤트 핸들러 API를 통해 처리됩니다. 추가 변경 리스너 함수를 호출합니다.

다음 단계는 무엇인가요?

여러분의 의견을 듣고 싶습니다. 질문이나 피드백이 있으면 언제든지 트위터로 연락해 주세요. @rajagp 또는 이메일을 보내주세요. priya.rajagopal@couchbase.com. 데모 앱을 개선하고 싶으시면 풀 리퀘스트를 제출해 주세요. 깃허브 리포지토리.

그리고 카우치베이스 모바일 개발자 포럼 는 모바일 관련 질문에 대한 답변을 얻을 수 있는 또 다른 좋은 장소이며, 개발 포털에서 자세한 내용을 확인하세요. 동기화 게이트웨이 그리고 카우치베이스 라이트 . 여기서 논의된 모든 내용은 Couchbase Mobile 1.4의 컨텍스트에 관한 것입니다. Couchbase Mobile 2.0에는 새롭고 흥미로운 변경 사항이 많이 있습니다. 반드시 개발자 미리보기 카우치베이스 모바일 버전 2.0.

프리야 라자고팔, 제품 관리 부문 선임 이사

댓글 하나

바이말레쉬 4월 10, 2019에서 12:09 오전

안녕하세요 프리야..!!!!

Swift의 데이터 동기화에 대한 정말 좋은 포스트였습니다. 객관식 C로도 제공해 주시면 감사하겠습니다.

로그인 하여 답글 남기기
1. 프리야 라자고팔 , 수석 제품 관리자 10월 23, 2019에서 6:18 오전
  
  감사합니다!
  
  로그인 하여 답글 남기기
제인 아브라함 10월 23, 2019에서 3:10 오전

안녕하세요 프리야,

두 개의 시뮬레이터에서 동시에 실행하여 테스트를 시도했지만 유감스럽게도 응용 프로그램이 예상대로 작동하지 않습니다. 다른 시뮬레이터에서 동일한 자격 증명으로 로그인 할 때 데이터가 동기화되지 않습니다. 매번 로컬 DB에서 데이터를 가져 오지만 글로벌 동기화는 작동하지 않습니다 .이 문제에 대해 도와주세요.

로그인 하여 답글 남기기
프리야 라자고팔 , 수석 제품 관리자 10월 23, 2019에서 6:22 오전

귀하의 댓글은 이 블로그 게시물 및 튜토리얼과 관련이 없는 것 같습니다(실제로는 Couchbase Mobile 1.4의 기본 iOS용입니다). 이 Xamarin 튜토리얼의 지침을 따랐나요? https://docs.couchbase.com/userprofile-couchbase-mobile/sync/userprofile/xamarin/userprofile_sync.html. 해당 자습서에서 문제가 발생하는 경우 관련 로그와 함께 개발자 포럼(forums.couchbase.com)에 게시해 주세요.

로그인 하여 답글 남기기

Platform

Self-Managed

Services

Capabilities

Why Couchbase?

Migrate to Capella

By Use Case

By Industry

By Application Need

Popular Docs

By Developer Role

Quickstart

Resource Center

About

Partnerships

Our Services

Partners: Register a Deal

Ready to register a deal with Couchbase?

Marriott

모든 게시물

카우치베이스 모바일을 사용하여 iOS 기기 간 데이터 동기화

카우치베이스 모바일

카우치베이스 동기화 게이트웨이

채널

동기화 기능

복제

카우치베이스 동기화 게이트웨이 설치

동기화 게이트웨이 구성 파일

카우치베이스 라이트

네이티브 API

iOS 앱 데모

코드 살펴보기

사용자별 데이터베이스 열기/생성

문서 가져오기

문서에 대한 로컬 및 원격 동기화 변경 사항 관찰하기

복제 요청 인증

풀 복제

푸시 복제

복제 상태 모니터링

다음 단계는 무엇인가요?

작성자

게시자 프리야 라자고팔, 제품 관리 부문 선임 이사

댓글 하나

댓글 남기기 응답 취소