Проблема с настройкой репликатора для Couchbase lite 2.x и шлюза синхронизации - PullRequest
Новая
       27

Проблема с настройкой репликатора для Couchbase lite 2.x и шлюза синхронизации

2 голосов
/ 20 июня 2019

Я пытаюсь получить действительно простую синхронизацию между мобильным приложением couchbase lite и сервером couchbase через синхронизирующий шлюз.Я получил шлюз синхронизации для связи с сервером, так как при использовании curl-вызовов REST к шлюзу будет синхронизироваться с основным сервером.

Однако при попытке синхронизации с couchbase-lite просто не синхронизируется couchbase-lite.

public class MainActivity extends AppCompatActivity {

    private static final String TAG = "LOG";

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        // Get the database (and create it if it doesn’t exist).
        DatabaseConfiguration config = new DatabaseConfiguration(getApplicationContext());
        Database database = null;
        try {
            database = new Database("mydb", config);
        } catch (CouchbaseLiteException e) {
            e.printStackTrace();
        }

// Create a new document (i.e. a record) in the database.
        MutableDocument mutableDoc = new MutableDocument()
                .setFloat("version", 2.0F)
                .setString("type", "SDK");

// Save it to the database.
        try {
            database.save(mutableDoc);
        } catch (CouchbaseLiteException e) {
            e.printStackTrace();
        }

// Update a document.
        mutableDoc = database.getDocument(mutableDoc.getId()).toMutable();
        mutableDoc.setString("language", "Java");
        try {
            database.save(mutableDoc);
        } catch (CouchbaseLiteException e) {
            e.printStackTrace();
        }
        Document document = database.getDocument(mutableDoc.getId());
// Log the document ID (generated by the database) and properties
        Log.i(TAG, "Document ID :: " + document.getId());
        Log.i(TAG, "Learning " + document.getString("language"));

// Create a query to fetch documents of type SDK.
        Query query = QueryBuilder.select(SelectResult.all())
                .from(DataSource.database(database))
                .where(Expression.property("type").equalTo(Expression.string("SDK")));
        ResultSet result = null;
        try {
            result = query.execute();
        } catch (CouchbaseLiteException e) {
            e.printStackTrace();
        }
        Log.i(TAG, "Number of rows ::  " + result.allResults().size());

// Create replicators to push and pull changes to and from the cloud.
        Endpoint targetEndpoint = null;
        try {
            targetEndpoint = new URLEndpoint(new URI("ws://10.0.2.2:4984/demobucket"));
        } catch (URISyntaxException e) {
            e.printStackTrace();
        }
        ReplicatorConfiguration replConfig = new ReplicatorConfiguration(database, targetEndpoint);
        replConfig.setReplicatorType(ReplicatorConfiguration.ReplicatorType.PUSH_AND_PULL);

// Add authentication.
        replConfig.setAuthenticator(new BasicAuthenticator("admin", "pass"));

// Create replicator.
        Replicator replicator = new Replicator(replConfig);

// Listen to replicator change events.
        replicator.addChangeListener(change -> {
            if (change.getStatus().getError() != null) {
                Log.i(TAG, "Error code ::  " + change.getStatus().getError().getCode());
            }
        });

// Start replication.
        replicator.start();
    }
}

Этот код был буквально вставлен с сайта документации couchbase https://docs.couchbase.com/couchbase-lite/current/java.html,, но пока не работает.

Я получаю ошибку 11001, что равно "//закрыть, например, из-за того, что хост-приложение завершает работу ", что происходит в прослушивателе репликатора.

Используемый мной файл конфигурации шлюза синхронизации выглядит следующим образом: 

{
    "interface":":4984",
     "logging": {
      "log_file_path": "/var/tmp/sglogs",
      "console": {
        "log_level": "debug",
        "log_keys": ["*"]
      },
      "error": {
        "enabled": true,
        "rotation": {
          "max_size": 20,
          "max_age": 180
        }
      },
      "warn": {
        "enabled": true,
        "rotation": {
          "max_size": 20,
          "max_age": 90
        }
      },
      "info": {
        "enabled": false
      },
      "debug": {
        "enabled": false
      }
    },
    "databases": {
      "demobucket": {
        "import_docs": "continuous",
        "enable_shared_bucket_access":true,  
        "bucket":"demobucket",
        "server": "http://cb-server:8091",
        "username": "admin",
        "password": "password",
        "num_index_replicas":0,
        "users":{
            "GUEST": {"disabled":true},
            "admin": {"password": "password", "admin_channels": ["*"]}
        },
        "revs_limit":20
        }
    }
}

1 Ответ

1 голос
/ 27 июня 2019

@ У Джея есть ответ в его комментарии. Replicator replicator является локальной переменной. Как только Activity остановлен, репликатор имеет право на сборку мусора. Это кажется пиру, как если бы хост останавливался.

...