O Couchbase Mobile<\/a> Gateway de sincroniza\u00e7\u00e3o<\/a> O feed de altera\u00e7\u00f5es oferece uma maneira de monitorar eventos em uma implanta\u00e7\u00e3o m\u00f3vel. O feed torna vi\u00e1vel a cria\u00e7\u00e3o de l\u00f3gica comercial sofisticada. Escrevi uma ferramenta para ajudar a examinar e entender o feed. Voc\u00ea pode ler uma introdu\u00e7\u00e3o e uma descri\u00e7\u00e3o em primeira parte<\/a> desta s\u00e9rie de duas partes. O c\u00f3digo tamb\u00e9m serve como exemplo de escuta do feed.<\/p>\n Inclu\u00ed aqui as principais classes do c\u00f3digo do aplicativo. Esta \u00e9 a primeira vers\u00e3o, portanto, ela pode receber muitos aprimoramentos. Os par\u00e2metros est\u00e3o todos conectados. Confira o projeto aqui no GitHub<\/a> para obter atualiza\u00e7\u00f5es. Voc\u00ea tamb\u00e9m pode encontrar instru\u00e7\u00f5es para criar, executar e empacotar o aplicativo l\u00e1.<\/p>\n O JavaFX divide aplicativos simples em uma classe controladora e uma interface de usu\u00e1rio declarativa. Vamos examinar o controlador.<\/p>\n Essa primeira listagem mostra um monte de c\u00f3digo padr\u00e3o. Implemento v\u00e1rios ouvintes para a interface do usu\u00e1rio dentro da pr\u00f3pria classe para reduzir o n\u00famero de arquivos. Isso \u00e9 para fins ilustrativos.<\/p>\n O Em seguida, vem a inicializa\u00e7\u00e3o. O JavaFX chama esse m\u00e9todo como parte de seu ciclo de vida padr\u00e3o.<\/p>\n Separei a inicializa\u00e7\u00e3o da lista de documentos em sua pr\u00f3pria rotina. A lista de documentos \u00e9 vinculada ao Configurei uma consulta em tempo real para monitorar o banco de dados do cliente quanto a quaisquer altera\u00e7\u00f5es. Isso acontece por meio de uma consulta de \"todos os documentos\". Uma consulta de todos os documentos n\u00e3o requer uma visualiza\u00e7\u00e3o associada. Eu defino Com os outros v\u00ednculos em vigor, s\u00f3 precisamos atualizar o As pr\u00f3ximas linhas definem o estado inicial de alguns bot\u00f5es de altern\u00e2ncia. Preciso de um ouvinte extra para manter o Escrevi uma classe separada para monitorar o Sync Gateway. O c\u00f3digo de inicializa\u00e7\u00e3o foi conclu\u00eddo com a cria\u00e7\u00e3o de uma nova inst\u00e2ncia de monitor e seu in\u00edcio.<\/p>\n A pr\u00f3xima se\u00e7\u00e3o cont\u00e9m v\u00e1rios ouvintes.<\/p>\n Aqui est\u00e1 o ouvinte de consulta ao vivo que \u00e9 chamado sempre que o banco de dados local \u00e9 alterado. Eu n\u00e3o projetei a ferramenta para trabalhar com bancos de dados enormes. Portanto, sempre que os dados mudavam, eu simplesmente adotava a abordagem de for\u00e7a bruta de reler todos os documentos. O Esse ouvinte cuida do rastreamento quando um usu\u00e1rio clica em uma entrada na lista de documentos. As entradas s\u00e3o os IDs dos documentos, portanto, podemos usar uma sele\u00e7\u00e3o para extrair o documento diretamente do banco de dados.<\/p>\n Usei uma abordagem de retorno de chamada para obter os resultados do feed de altera\u00e7\u00f5es. A interface \u00e9 definida na se\u00e7\u00e3o Por fim, adicionei um ouvinte para a atividade de replica\u00e7\u00e3o. A interface vem da classe auxiliar DBService. Escrevi um pouco sobre como detectar o estado de uma replica\u00e7\u00e3o aqui<\/a>. Para este aplicativo, s\u00f3 preciso saber se uma replica\u00e7\u00e3o est\u00e1 sendo executada ou n\u00e3o para manter a Em seguida, temos v\u00e1rios m\u00e9todos vinculados a elementos da interface do usu\u00e1rio. O JavaFX cuida de grande parte da fia\u00e7\u00e3o.<\/p>\n Aqui eu defino o uso de credenciais de autentica\u00e7\u00e3o sempre que o bot\u00e3o correspondente for acionado.<\/p>\n Esse c\u00f3digo mostra alguns itens interessantes. Eu uso um Jackson Em seguida, verifico se h\u00e1 uma entrada Portanto, em poucas palavras, temos um exemplo de cria\u00e7\u00e3o e atualiza\u00e7\u00e3o de documentos. Essa n\u00e3o \u00e9 a maneira preferida de atualizar, embora seja suficiente em muitos casos. Voc\u00ea pode ler mais sobre atualiza\u00e7\u00f5es aqui<\/a>.<\/p>\n Isso reage \u00e0 altern\u00e2ncia do O restante do c\u00f3digo aqui s\u00e3o apenas bits auxiliares e uma parte para encerrar tudo antes de sair.<\/p>\n Isso mostra o c\u00f3digo de uma classe auxiliar de banco de dados simples. Na maioria das vezes, considero essa classe um bom pacote das opera\u00e7\u00f5es t\u00edpicas necess\u00e1rias para gerenciar um banco de dados e iniciar um conjunto bidirecional padr\u00e3o de replica\u00e7\u00f5es. Estou incluindo-a aqui porque a considero \u00fatil e para maior clareza.<\/p>\n Eu implemento o Por fim, vamos dar uma olhada na classe auxiliar para monitorar o Sync Gateway. Tamb\u00e9m vou analisar isso em partes.<\/p>\n Eu uso o Biblioteca OkHttp da Square<\/a>. Atualmente, o Couchbase Lite tamb\u00e9m usa essa biblioteca internamente. O OkHttp usa um padr\u00e3o de construtor. Preparo uma inst\u00e2ncia do builder que usarei durante o restante do c\u00f3digo no construtor da classe. Voc\u00ea pode ler sobre o significado de todos os par\u00e2metros na se\u00e7\u00e3o Documenta\u00e7\u00e3o do Sync Gateway<\/a>.<\/p>\n O O Sync Gateway responde com cadeias de caracteres JSON. Voc\u00ea pode ver que o c\u00f3digo separa a resposta e analisa o JSON em um arquivo Para rastrear o que deve ser enviado em seguida, o feed de altera\u00e7\u00f5es depende de um mecanismo de sequ\u00eancia simples. Voc\u00ea deve tratar isso como um objeto opaco. Pegue o valor de N\u00e3o h\u00e1 nenhum dano real em n\u00e3o fornecer o Em um aplicativo do mundo real, talvez voc\u00ea queira ter uma maneira de salvar a \u00faltima sequ\u00eancia de caracteres que seu aplicativo processou, em vez de ficar percorrendo o hist\u00f3rico de altera\u00e7\u00f5es todas as vezes.<\/p>\n O restante do c\u00f3digo \u00e9 apenas um par de m\u00e9todos curtos.<\/p>\n E isso \u00e9 tudo para as classes principais. H\u00e1 outras necess\u00e1rias para o aplicativo completo.<\/p>\n Confira o Reposit\u00f3rio do GitHub<\/a> para ver todo o c\u00f3digo e as instru\u00e7\u00f5es para cri\u00e1-lo.<\/p>\n Leia uma discuss\u00e3o sobre o aplicativo e como us\u00e1-lo em primeira parte<\/a>.<\/p>\n Voc\u00ea pode encontrar mais recursos em nosso portal do desenvolvedor<\/a> e nos siga no Twitter @CouchbaseDev<\/a>.<\/p>\n Voc\u00ea pode postar perguntas em nosso f\u00f3runs<\/a>. E participamos ativamente de Estouro de pilha<\/a>.<\/p>\nO c\u00f3digo<\/h2>\n
JavaFX: A classe Controller<\/h3>\n
pacote com.couchbase.mobile;\r\n\r\nimport com.couchbase.lite.*;\r\nimport com.fasterxml.jackson.core.JsonProcessingException;\r\nimport javafx.application.Platform;\r\nimport javafx.beans.value.ChangeListener;\r\nImportar javafx.beans.value.ObservableValue;\r\nimport javafx.collections.FXCollections;\r\nImportar javafx.collections.ObservableList;\r\nImportar javafx.event.ActionEvent;\r\nimport javafx.fxml.FXML;\r\nimport javafx.scene.control.*;\r\nimport javafx.scene.control.TextField;\r\n\r\nImportar java.io.IOException;\r\nImportar java.net.MalformedURLException;\r\nimport java.net.URL;\r\nimport java.util.Map;\r\n\r\nimport static com.couchbase.mobile.Runtime.mapper;\r\n\r\npublic class Controller implements LiveQuery.ChangeListener, ChangeListener,\r\n SGMonitor.ChangesFeedListener, DBService.ReplicationStateListener {\r\n private static final String SYNC_GATEWAY_HOST = \"https:\/\/localhost\";\r\n private static final String SG_PUBLIC_URL = SYNC_GATEWAY_HOST + \":4984\/\" + DBService.DATABASE;\r\n private static final String SG_ADMIN_URL = SYNC_GATEWAY_HOST + \":4985\/\" + DBService.DATABASE;\r\n\r\n private static final String TOGGLE_INACTIVE = \"-fx-background-color: #e6555d;\";\r\n private static final String TOGGLE_ACTIVE = \"-fx-background-color: #ade6a6;\";\r\n private static final String TOGGLE_DISABLED = \"-fx-background-color: #555555;\";\r\n\r\n @FXML private ListView documentList;\r\n private ObservableList documents = FXCollections.observableArrayList();\r\n @FXML private TextArea contentsText;\r\n @FXML private TextArea changesFeed;\r\n @FXML private TextField usernameText;\r\n @FXML private TextField passwordText; @FXML private TextField passwordText;\r\n @FXML private ToggleButton applyCredentialsBtn;\r\n @FXML private ToggleButton syncBtn;\r\n\r\n Servi\u00e7o DBService privado = DBService.getInstance();\r\n private Database db = service.getDatabase();\r\n SGMonitor privado changesMonitor;\r\n LiveQuery privado liveQuery;\r\n<\/pre>\n@FXML<\/code> marcam todos os campos que a estrutura associar\u00e1 automaticamente a partes da interface do usu\u00e1rio.<\/p>\n @FXML private void initialize() {\r\n documentListInitialize();\r\n documentList.setItems(documents);\r\n\r\n setState(applyCredentialsBtn, false);\r\n setState(syncBtn, false);\r\n\r\n service.addReplicationStateListener(this);\r\n\r\n changesMonitor = new SGMonitor(SG_ADMIN_URL, \"false\", \"true\", \"0\", \"all_docs\", this);\r\n changesMonitor.start();\r\n }\r\n\r\n private void documentListInitialize() {\r\n Query query = db.createAllDocumentsQuery();\r\n query.setAllDocsMode(Query.AllDocsMode.INCLUDE_DELETED);\r\n liveQuery = query.toLiveQuery();\r\n liveQuery.addChangeListener(this);\r\n liveQuery.start();\r\n\r\n documentList.getSelectionModel().selectedItemProperty().addListener(this);\r\n }<\/pre>\ndocumentList<\/code> vari\u00e1vel. Por sua vez documentList<\/code> atualizar\u00e1 a interface do usu\u00e1rio sempre que a lista de itens que passamos for alterada.<\/p>\nINCLUDE_DELETED<\/code> para que a ferramenta possa mostrar a apar\u00eancia de um documento exclu\u00eddo no banco de dados.<\/p>\ndocumentos<\/code> lista. Veremos o ouvinte de consulta ao vivo que faz isso mais adiante.<\/p>\nSincroniza\u00e7\u00e3o<\/code> consistente com o estado real das replica\u00e7\u00f5es. Mais informa\u00e7\u00f5es sobre isso ao longo do artigo.<\/p>\n \/\/ LiveQuery.ChangeListener\r\n @Override\r\n public void changed(LiveQuery.ChangeEvent event) {\r\n if (event.getSource().equals(liveQuery)) {\r\n Platform.runLater(() -> {\r\n QueryEnumerator rows = event.getRows();\r\n\r\n documents.clear();\r\n\r\n rows.forEach(queryRow -> documents.add(queryRow.getDocumentId()));\r\n });\r\n }\r\n }<\/pre>\ngetRows<\/code> retorna um enumerador que indexar\u00e1 e far\u00e1 exatamente isso. O JavaFX se encarrega de atualizar a interface do usu\u00e1rio quando documentos<\/code> mudan\u00e7as.<\/p>\n \/\/ ListView ChangeListener\r\n @Override\r\n public void changed(ObservableValue observable, String oldId, String newId) {\r\n if (null == newId) return;\r\n\r\n Map properties = db.getDocument(newId).getProperties();\r\n\r\n try {\r\n String json = mapper.writeValueAsString(properties);\r\n\r\n contentsText.setText(prettyText(json));\r\n } catch (JsonProcessingException ex) {\r\n ex.printStackTrace();\r\n Dialog.display(ex);\r\n }\r\n }<\/pre>\n \/\/ SGMonitor.ChangesFeedListener\r\n @Override\r\n public void onResponse(String body) {\r\n changesFeed.appendText(prettyText((String) body));\r\n }<\/pre>\nSGMonitor<\/code> classe. Ela tem apenas um m\u00e9todo. Nessa implementa\u00e7\u00e3o, simplesmente pego o corpo da resposta do feed e o coloco sobre o texto existente no painel de texto do feed de altera\u00e7\u00f5es. Tamb\u00e9m foi feita uma pequena formata\u00e7\u00e3o para facilitar a leitura.<\/p>\n \/\/ DBService.ReplicationStateListener\r\n @Override\r\n public void onChange(boolean isActive) {\r\n setState(syncBtn, isActive);\r\n }<\/pre>\nSincroniza\u00e7\u00e3o<\/code> estado do bot\u00e3o consistente. Isso lida com casos em que um usu\u00e1rio tenta iniciar uma sincroniza\u00e7\u00e3o, mas ela falha. Isso pode ocorrer se o usu\u00e1rio precisar fornecer credenciais de autentica\u00e7\u00e3o, mas n\u00e3o as tiver fornecido, por exemplo.<\/p>\n @FXML private void applyCredentialsToggled(ActionEvent event) {\r\n String nome de usu\u00e1rio = null;\r\n String password = null;\r\n\r\n Se (applyCredentialsBtn.isSelected()) {\r\n username = usernameText.getText();\r\n password = passwordText.getText();\r\n }\r\n\r\n DBService.getInstance().setCredentials(username, password);\r\n applyCredentialsBtn.setStyle(applyCredentialsBtn.isSelected() ? TOGGLE_ACTIVE : TOGGLE_INACTIVE);\r\n }<\/pre>\n @FXML private void saveContentsClicked(ActionEvent event) {\r\n Map properties = null;\r\n Document document;\r\n\r\n try {\r\n properties = mapper.readValue(contentsText.getText(), Map.class);\r\n } catch (IOException ex) {\r\n ex.printStackTrace();\r\n Dialog.display(ex);\r\n }\r\n\r\n se (properties.containsKey(\"_id\")) {\r\n document = db.getDocument((String) properties.get(\"_id\"));\r\n } else {\r\n document = db.createDocument();\r\n }\r\n\r\n try {\r\n document.putProperties(properties);\r\n } catch (CouchbaseLiteException ex) {\r\n ex.printStackTrace();\r\n Dialog.display(ex);\r\n }\r\n }\r\n<\/pre>\nMapeador de objetos<\/code> para converter o texto no painel de conte\u00fado em um mapa de propriedades.<\/p>\n_id<\/code>. O Couchbase Mobile reserva a maioria das propriedades que come\u00e7am com um \"_\" para uso do sistema (com exce\u00e7\u00f5es especiais). Se o texto que estivermos tentando converter contiver _id<\/code>Se o documento n\u00e3o for editado, presumo que seja uma edi\u00e7\u00e3o de um documento existente. Caso contr\u00e1rio, crio um novo documento.<\/p>\n @FXML private void syncToggled(ActionEvent event) {\r\n try {\r\n syncBtn.setDisable(true);\r\n syncBtn.setStyle(TOGGLE_DISABLED);\r\n service.toggleReplication(new URL(SG_PUBLIC_URL), true);\r\n } catch (Exception ex) {\r\n ex.printStackTrace();\r\n Dialog.display(ex);\r\n syncBtn.setDisable(false);\r\n }\r\n }<\/code><\/pre>\nSincroniza\u00e7\u00e3o<\/code> bot\u00e3o. Lembre-se, por\u00e9m, de que usamos um ouvinte para verificar o estado em outro lugar.<\/p>\n @FXML private void exitClicked(ActionEvent event) {\r\n \/\/ Tentar encerrar tudo graciosamente\r\n changesMonitor.stop();\r\n liveQuery.stop();\r\n service.stopReplication();\r\n db.close();\r\n db.getManager().close();\r\n\r\n Platform.exit();\r\n }\r\n\r\n private void setState(ToggleButton btn, boolean active) {\r\n btn.setSelected(active);\r\n btn.setStyle(active ? TOGGLE_ACTIVE : TOGGLE_INACTIVE);\r\n btn.setDisable(false);\r\n }\r\n\r\n private String prettyText(String json) {\r\n String out = null;\r\n\r\n try {\r\n Object object = mapper.readValue(json, Object.class);\r\n\r\n out = mapper.writerWithDefaultPrettyPrinter().writeValueAsString(object);\r\n } catch (Exception ex) {\r\n ex.printStackTrace();\r\n }\r\n\r\n return out;\r\n }\r\n}\r\n<\/pre>\nA classe Database Helper<\/h3>\n
Replica\u00e7\u00e3o.ChangeListener<\/code> interface. Isso talvez seja um pouco incomum. Mencionei o motivo anteriormente. Este link leva voc\u00ea \u00e0 p\u00e1gina postagem no blog<\/a> sobre isso.<\/p>\npacote com.couchbase.mobile;\r\n\r\nimport com.couchbase.lite.Database;\r\nimport com.couchbase.lite.JavaContext;\r\nimport com.couchbase.lite.Manager;\r\nImportar com.couchbase.lite.auth.Authenticator;\r\nimport com.couchbase.lite.auth.AuthenticatorFactory;\r\nimport com.couchbase.lite.replicator.Replication;\r\nimport com.couchbase.lite.replicator.ReplicationState;\r\n\r\nimport java.net.URL;\r\nimportar java.util.ArrayList;\r\nImportar java.util.List;\r\n\r\npublic class DBService implements Replication.ChangeListener {\r\n public static final String DATABASE = \"db\";\r\n\r\n private static final String DB_DIRECTORY = \"data\";\r\n\r\n private Manager manager;\r\n private Database database;\r\n private Replication pushReplication = null;\r\n private Replication pullReplication = null;\r\n private boolean replicationActive = false;\r\n private List stateListeners = new ArrayList();\r\n private String nome de usu\u00e1rio = null;\r\n private String password = null;\r\n\r\n private DBService() {\r\n try {\r\n manager = new Manager(new JavaContext(DB_DIRECTORY), Manager.DEFAULT_OPTIONS);\r\n banco de dados = manager.getDatabase(DATABASE);\r\n } catch (Exception ex) {\r\n ex.printStackTrace();\r\n }\r\n }\r\n\r\n classe est\u00e1tica privada Holder {\r\n private static DBService INSTANCE = new DBService();\r\n }\r\n\r\n\r\n interface p\u00fablica ReplicationStateListener {\r\n void onChange(boolean isActive);\r\n }\r\n\r\n public static DBService getInstance() {\r\n return Holder.INSTANCE;\r\n }\r\n\r\n banco de dados p\u00fablico getDatabase() {\r\n return database;\r\n }\r\n\r\n public void setCredentials(String username, String password) {\r\n this.username = nome de usu\u00e1rio;\r\n this.password = password;\r\n }\r\n\r\n public void toggleReplication(URL gateway, boolean continuous) {\r\n se (replicationActive) {\r\n stopReplication();\r\n } else {\r\n startReplication(gateway, continuous);\r\n }\r\n }\r\n\r\n public void startReplication(URL gateway, boolean continuous) {\r\n se (replicationActive) {\r\n stopReplication();\r\n }\r\n\r\n pushReplication = database.createPushReplication(gateway);\r\n pullReplication = banco de dados.createPullReplication(gateway);\r\n pushReplication.setContinuous(continuous);\r\n pullReplication.setContinuous(continuous);\r\n\r\n Se (nome de usu\u00e1rio != null) {\r\n Authenticator auth = AuthenticatorFactory.createBasicAuthenticator(nome de usu\u00e1rio, senha);\r\n pushReplication.setAuthenticator(auth);\r\n pullReplication.setAuthenticator(auth);\r\n }\r\n\r\n pushReplication.addChangeListener(this);\r\n pullReplication.addChangeListener(this);\r\n\r\n pushReplication.start();\r\n pullReplication.start();\r\n }\r\n\r\n public void stopReplication() {\r\n se (!replicationActive) return;\r\n\r\n pushReplication.stop();\r\n pullReplication.stop();\r\n\r\n pushReplication = null;\r\n pullReplication = null;\r\n }\r\n\r\n public void addReplicationStateListener(ReplicationStateListener listener) {\r\n stateListeners.add(listener);\r\n }\r\n\r\n public void removeReplicationStateListener(ReplicationStateListener listener) {\r\n stateListeners.remove(listener);\r\n }\r\n\r\n \/\/ Replication.ChangeListener\r\n @Override\r\n public void changed(Replication.ChangeEvent changeEvent) {\r\n if (changeEvent.getError() != null) {\r\n Throwable lastError = changeEvent.getError();\r\n\r\n Dialog.display(lastError.getMessage());\r\n\r\n return;\r\n }\r\n\r\n Se (changeEvent.getTransition() == null) return;\r\n\r\n ReplicationState dest = changeEvent.getTransition().getDestination();\r\n\r\n replicationActive = ((dest == ReplicationState.STOPPING || dest == ReplicationState.STOPPED) ? false : true);\r\n\r\n stateListeners.forEach(listener -> listener.onChange(replicationActive));\r\n }\r\n}<\/pre>\nA classe Sync Gateway Monitor<\/h3>\n
pacote com.couchbase.mobile;\r\n\r\nimport com.fasterxml.jackson.databind.JsonNode;\r\nimport okhttp3.*;\r\n\r\nimport java.io.IOException;\r\nimport java.net.SocketException;\r\nimport java.util.concurrent.TimeUnit;\r\n\r\nimport static com.couchbase.mobile.Runtime.mapper;\r\n\r\nclasse p\u00fablica SGMonitor {\r\n cliente OkHttpClient final est\u00e1tico privado = novo OkHttpClient.Builder()\r\n .readTimeout(1, TimeUnit.DAYS)\r\n .build();\r\n listener ChangesFeedListener privado;\r\n HttpUrl.Builder urlBuilder privado;\r\n private Thread monitorThread;\r\n private String since = \"0\";\r\n private Call call;\r\n\r\n SGMonitor(String url, String activeOnly, String includeDocs, String since, String style,\r\n ChangesFeedListener listener) {\r\n this.since = since;\r\n\r\n urlBuilder = HttpUrl.parse(url).newBuilder()\r\n .addPathSegment(\"_changes\")\r\n .addQueryParameter(\"active_only\", activeOnly)\r\n .addQueryParameter(\"include_docs\", includeDocs)\r\n .addQueryParameter(\"style\", style)\r\n .addQueryParameter(\"since\", since)\r\n .addQueryParameter(\"feed\", \"longpoll\")\r\n .addQueryParameter(\"timeout\", \"0\");\r\n\r\n this.listener = listener;\r\n }<\/pre>\n public interface ChangesFeedListener {\r\n void onResponse(String body);\r\n }\r\n\r\n public void start() {\r\n monitorThread = new Thread(() -> {\r\n while (!Thread.interrupted()) {\r\n Request request = new Request.Builder()\r\n .url(urlBuilder.build())\r\n .build();\r\n\r\n call = client.newCall(request);\r\n\r\n try (Response response = call.execute()) {\r\n if (!response.isSuccessful()) throw new IOException(\"Unexpected code \" + response);\r\n\r\n String body = response.body().string();\r\n\r\n JsonNode tree = mapper.readTree(body);\r\n\r\n since = tree.get(\"last_seq\").asText();\r\n urlBuilder.setQueryParameter(\"since\", since);\r\n\r\n listener.onResponse(body);\r\n } catch (SocketException ex) {\r\n return;\r\n } catch (IOException ex) {\r\n ex.printStackTrace();\r\n Dialog.display(ex);\r\n }\r\n }\r\n });\r\n\r\n monitorThread.setDaemon(true);\r\n monitorThread.start();\r\n }<\/code><\/pre>\niniciar<\/code> tem a parte mais interessante do c\u00f3digo. Ele ativa um thread em segundo plano. Sob a configura\u00e7\u00e3o do thread e o c\u00f3digo de controle, executo um loop cont\u00ednuo. O loop faz chamadas de rede s\u00edncronas. O tratamento de erros \u00e9 simples. Basta lan\u00e7ar uma exce\u00e7\u00e3o se algo der errado.<\/p>\nJsonNode<\/code> objeto. Isso tudo \u00e9 para chegar ao \u00faltima_seq<\/code> na resposta.<\/p>\n\u00faltima_seq<\/code> da resposta anterior e defina o desde<\/code> para esse mesmo valor na pr\u00f3xima solicita\u00e7\u00e3o.<\/p>\ndesde<\/code> par\u00e2metro. O Sync Gateway apenas reproduzir\u00e1 todas as altera\u00e7\u00f5es desde o in\u00edcio se ele estiver faltando. \u00c9 por isso que voc\u00ea ver\u00e1 que, neste exemplo, eu trapaceio um pouco e sempre crio a inst\u00e2ncia da classe com desde<\/code> definido como a string \"0\".<\/p>\n public void stop() {\r\n monitorThread.interrupt();\r\n call.cancel();\r\n }\r\n\r\n public String getSince() {\r\n return since;\r\n }\r\n}<\/pre>\nP\u00f3s-escrito<\/h2>\n