{"id":1845,"date":"2014-12-16T17:18:35","date_gmt":"2014-12-16T17:18:34","guid":{"rendered":"https:\/\/www.couchbase.com\/blog\/?p=1845"},"modified":"2025-06-13T23:52:04","modified_gmt":"2025-06-14T06:52:04","slug":"xdcr-aspnet-and-nancy","status":"publish","type":"post","link":"https:\/\/www.couchbase.com\/blog\/pt\/xdcr-aspnet-and-nancy\/","title":{"rendered":"XDCR com ASP.NET e Nancy"},"content":{"rendered":"

Voc\u00ea provavelmente conhece o novo Cross Data Center Replication (XDCR<\/a>) do Couchbase Server 2.0. Sua utilidade mais \u00f3bvia \u00e9 permitir a replica\u00e7\u00e3o de dados de um cluster do Couchbase para outro. No entanto, h\u00e1 mais casos de uso novos para o XDCR. Um dos exemplos mais not\u00e1veis \u00e9 a integra\u00e7\u00e3o do Couchbase e do Elastic Search.<\/p>\n

A execu\u00e7\u00e3o do XDCR em um cluster que n\u00e3o seja do Couchbase \u00e9 poss\u00edvel porque o ponto de extremidade de comunica\u00e7\u00e3o \u00e9 implementado usando uma API RESTful simples. Ao implementar alguns m\u00e9todos simples, voc\u00ea pode configurar seu pr\u00f3prio ponto de extremidade de replica\u00e7\u00e3o. H\u00e1 v\u00e1rios motivos pelos quais voc\u00ea pode querer criar seu pr\u00f3prio endpoint XDCR. Um exemplo simples \u00e9 receber notifica\u00e7\u00f5es de altera\u00e7\u00e3o.<\/p>\n

A configura\u00e7\u00e3o de um ponto de extremidade \u00e9 bastante simples e pode ser feita usando qualquer estrutura da Web adequada para a cria\u00e7\u00e3o de APIs RESTful. No .NET, uma op\u00e7\u00e3o \u00e9 o ASP.NET MVC e a nova API da Web. Embora seja uma boa op\u00e7\u00e3o, uma solu\u00e7\u00e3o mais simples seria usar o Sinatra<\/a> inspirado Nancy<\/a>.<\/p>\n

O Nancy \u00e9 um microframework leve para a cria\u00e7\u00e3o de aplicativos baseados em HTTP com o .NET. No caso mais b\u00e1sico, voc\u00ea cria um m\u00f3dulo que se estende a partir de NancyModule<\/em> e criar uma rota e um manipulador.<\/p>\n

\n
p\u00fablico<\/span> classe<\/span> SampleModule :<\/span> Nancy.<\/span>NancyModule<\/span>
\n{<\/span>
\np\u00fablico<\/span> SampleModule(<\/span>)<\/span>
\n{<\/span>
\nObter[<\/span>“\/”<\/span>]<\/span> =<\/span> _ =><\/span> \"Hello World!\"<\/span>;<\/span>
\n}<\/span>
\n}<\/span><\/div>\n<\/div>\n

Para demonstrar como criar um endpoint XDCR usando o Nancy, publiquei um projeto do Couchbase Labs no GitHub chamado couchbase-xdcr-nancy<\/a>. Esse projeto se baseia em grande parte no projeto de Jasdeep couchbase-xdcr-sinatra<\/a> c\u00f3digo.<\/p>\n

Dentro do projeto do Visual Studio, voc\u00ea encontrar\u00e1 v\u00e1rios arquivos de canaliza\u00e7\u00e3o. N\u00e3o analisarei o c\u00f3digo em detalhes aqui, mas mostrarei alguns destaques. O c\u00f3digo mais importante est\u00e1 dentro do arquivo XdcrModule<\/em> class. \u00c9 nela que voc\u00ea encontrar\u00e1 os manipuladores para as v\u00e1rias solicita\u00e7\u00f5es de recursos feitas pelo servi\u00e7o XDCR.<\/p>\n

No construtor desse m\u00f3dulo, voc\u00ea encontrar\u00e1 v\u00e1rios manipuladores de GET que lidam com solicita\u00e7\u00f5es para URIs que come\u00e7am com \/pools. Esses s\u00e3o efetivamente URIs de handshake usados pelo XDCR para descobrir informa\u00e7\u00f5es sobre o cluster e seus buckets (semelhante aos pontos de extremidade usados pelos SDKs do Couchbase para inicializar inst\u00e2ncias de clientes). Observe que, nesta amostra, o bucket est\u00e1 codificado como \"padr\u00e3o\". Voc\u00ea poderia facilmente modificar esse valor ou torn\u00e1-lo uma defini\u00e7\u00e3o de configura\u00e7\u00e3o.<\/p>\n

\n
\n

Obter[<\/span>\"\/pools\"<\/span>]<\/span> =<\/span> x =><\/span>
\n{<\/span>
\nvar output =<\/span> novo<\/span><\/a>
\n{<\/span>
\npiscinas =<\/span> novo<\/span><\/a> objeto<\/span>[<\/span>]<\/span>
\n{<\/span>
\nnovo<\/span><\/a> {<\/span> nome =<\/span> \"default\"<\/span>, uri =<\/span> \"\/pools\/default?uuid=\"<\/span> +<\/span> UUID_POOL }<\/span>
\n}<\/span>,
\nuuid =<\/span> UUID_POOL
\n}<\/span>;<\/span><\/p>\n

retorno<\/span> Resposta.<\/span>ComoJson<\/span>(<\/span>sa\u00edda)<\/span>;<\/span>
\n}<\/span>;<\/span><\/p>\n<\/div>\n<\/div>\n

Ap\u00f3s os manipuladores GET, h\u00e1 alguns manipuladores POST que respondem ao feed real do XDCR. O servi\u00e7o XDCR passar\u00e1 par\u00e2metros como parte do caminho. Rotas baseadas em Regex s\u00e3o usadas para essa finalidade.<\/p>\n

O primeiro manipulador de POST recebe uma lista de documentos e suas revis\u00f5es do servi\u00e7o XDCR.<\/p>\n

\n
\n

Postar[<\/span>DIFEREN\u00c7A DE REGEX_REVS]<\/span> =<\/span> x =><\/span>
\n{<\/span>
\nvar corpo =<\/span> “”<\/span>;<\/span>
\nContexto.<\/span>Solicita\u00e7\u00e3o<\/span>.<\/span>Corpo<\/span>.<\/span>Posi\u00e7\u00e3o<\/span> =<\/span> 0<\/span>;<\/span>
\nusando<\/span> (<\/span>var sr =<\/span> novo<\/span><\/a> StreamReader(<\/span>Contexto.<\/span>Solicita\u00e7\u00e3o<\/span>.<\/span>Corpo<\/span>)<\/span>)<\/span>
\n{<\/span>
\ncorpo =<\/span> sr.<\/span>ReadToEnd<\/span>(<\/span>)<\/span>;<\/span>
\n}<\/span>
\nvar jobj =<\/span> JObjeto.<\/span>Analisar<\/span>(<\/span>corpo)<\/span>;<\/span><\/p>\n

var outDict =<\/span> novo<\/span><\/a> Dicion\u00e1rio<<\/span>string<\/span>, objeto<\/span>=<\/span>“”<\/span>><\/span>(<\/span>)<\/span>;<\/span>
\nantes de<\/span> (<\/span>var item em<\/span> trabalho)<\/span>
\n{<\/span>
\nvar chave =<\/span> item.<\/span>Chave<\/span>;<\/span>
\nvar rev =<\/span> item.<\/span>Valor<\/span>.<\/span>ToString<\/span>(<\/span>)<\/span>;<\/span>
\nse<\/span> (<\/span>manipulador.<\/span>IsMissing<\/span>(<\/span>chave, rev)<\/span>)<\/span>
\n{<\/span>
\noutDict[<\/span>chave]<\/span> =<\/span> novo<\/span><\/a> {<\/span> ausente =<\/span> rev }<\/span>;<\/span>
\n}<\/span>
\n}<\/span><\/p>\n

retorno<\/span> Resposta.<\/span>ComoJson<\/span>(<\/span>outDict)<\/span>;<\/span>
\n}<\/span>;string<\/span>,><\/span><\/span><\/p>\n<\/div>\n<\/div>\n

Nesse manipulador, o JSON \u00e9 analisado para descobrir a chave e a revis\u00e3o. Se essa combina\u00e7\u00e3o n\u00e3o for replicada, ela ser\u00e1 adicionada \u00e0 lista de chaves \"ausentes\" inclu\u00eddas na resposta \u00e0 solicita\u00e7\u00e3o. O XDCR enviar\u00e1 esses documentos para outro manipulador de POST, onde eles ser\u00e3o criados.<\/p>\n

\n
\n

Postar[<\/span>REGEX_BULK_DOCS]<\/span> =<\/span> x =><\/span>
\n{<\/span>
\nvar corpo =<\/span> “”<\/span>;<\/span>
\nContexto.<\/span>Solicita\u00e7\u00e3o<\/span>.<\/span>Corpo<\/span>.<\/span>Posi\u00e7\u00e3o<\/span> =<\/span> 0<\/span>;<\/span>
\nusando<\/span> (<\/span>var sr =<\/span> novo<\/span><\/a> StreamReader(<\/span>Contexto.<\/span>Solicita\u00e7\u00e3o<\/span>.<\/span>Corpo<\/span>)<\/span>)<\/span>
\n{<\/span>
\ncorpo =<\/span> sr.<\/span>ReadToEnd<\/span>(<\/span>)<\/span>;<\/span>
\n}<\/span>
\nvar jobj =<\/span> JObjeto.<\/span>Analisar<\/span>(<\/span>corpo)<\/span>;<\/span><\/p>\n

var newEdits =<\/span> trabalho.<\/span>Valor<\/span><<\/span>bool<\/span>><\/span>(<\/span>\"new_edits\"<\/span>)<\/span>;<\/span>
\nvar docs =<\/span> trabalho.<\/span>Valor<\/span><<\/span>JArray><\/span>(<\/span>\"docs\"<\/span>)<\/span>;<\/span>
\nantes de<\/span> (<\/span>var doc em<\/span> documentos)<\/span>
\n{<\/span>
\nvar originalDoc =<\/span> Codifica\u00e7\u00e3o.<\/span>UTF8<\/span>.<\/span>GetString<\/span>(<\/span>Converter.<\/span>FromBase64String<\/span>(<\/span>doc.<\/span>Valor<\/span><<\/span>string<\/span>><\/span>(<\/span>\"base64\"<\/span>)<\/span>)<\/span>)<\/span>;<\/span>
\nvar meta =<\/span> doc[<\/span>\"meta\"<\/span>]<\/span> como<\/span> JObjeto;<\/span><\/p>\n

var document =<\/span> novo<\/span><\/a> Documento
\n{<\/span>
\nId =<\/span> meta.<\/span>Valor<\/span><<\/span>string<\/span>><\/span>(<\/span>\"id\"<\/span>)<\/span>,
\nRevis\u00e3o =<\/span> meta.<\/span>Valor<\/span><<\/span>string<\/span>><\/span>(<\/span>\"rev\"<\/span>)<\/span>,
\nVencimento =<\/span> meta.<\/span>Valor<\/span><<\/span>int<\/span>><\/span>(<\/span>\"expira\u00e7\u00e3o\"<\/span>)<\/span>,
\nBandeiras =<\/span> meta.<\/span>Valor<\/span><<\/span>int<\/span>><\/span>(<\/span>\"flags\" (sinalizadores)<\/span>)<\/span>,
\nValor =<\/span> originalDoc
\n}<\/span>;<\/span><\/p>\n

manipulador.<\/span>CriarDocumento<\/span>(<\/span>documento)<\/span>;<\/span>
\n}<\/span><\/p>\n

retorno<\/span> HttpStatusCode.<\/span>Criado<\/span>;<\/span>
\n}<\/span>;<\/span><\/p>\n<\/div>\n<\/div>\n

Na amostra, inclu\u00ed uma interface muito simples usada para criar um manipulador conect\u00e1vel que verificar\u00e1 a exist\u00eancia do documento e o criar\u00e1 quando necess\u00e1rio.<\/p>\n

\n
\n

p\u00fablico<\/span> interface<\/span> IReplicationHandler
\n{<\/span>
\nbool<\/span> IsMissing(<\/span>string<\/span> chave, string<\/span> rev)<\/span>;<\/span><\/p>\n

vazio<\/span> CriarDocumento(<\/span>Documento Documento)<\/span>;<\/span>
\n}<\/span><\/p>\n<\/div>\n<\/div>\n

Para fins de demonstra\u00e7\u00e3o, tamb\u00e9m inclu\u00ed um XmlReplicador<\/em> que implementa essa interface. Essa classe usa LINQ para XML para atualizar e consultar um documento XML que cont\u00e9m documentos alimentados pelo servi\u00e7o XDCR.<\/p>\n

\n
\n

p\u00fablico<\/span> classe<\/span> XmlReplicador :<\/span> IReplicationHandler
\n{<\/span>
\nprivado<\/span> somente leitura<\/span> string<\/span> _caminho;<\/span>
\nprivado<\/span> XDocumento doc =<\/span> novo<\/span><\/a> XDocument(<\/span>)<\/span>;<\/span><\/p>\n

p\u00fablico<\/span> XmlReplicador(<\/span>string<\/span> caminho =<\/span> @\"C:tempreplication.xml\"<\/span>)<\/span>
\n{<\/span>
\n_caminho =<\/span> caminho;<\/span>
\nse<\/span> (<\/span>!<\/span> Arquivo.<\/span>Existe<\/span>(<\/span>_caminho)<\/span>)<\/span>
\n{<\/span>
\n\/\/var xml = new XElement(\"documents\");<\/span>
\nArquivo.<\/span>WriteAllText<\/span>(<\/span>caminho,““<\/span>, Codifica\u00e7\u00e3o.<\/span>UTF8<\/span>)<\/span>;<\/span>
\n}<\/span>
\n}<\/span><\/p>\n

…<\/span>
\n}<\/span><\/p>\n<\/div>\n<\/div>\n

Para verificar se o documento existe, IsMissing <\/em>consultar\u00e1 o XML para um documento <\/em>que tem um elemento filho id<\/em> e rev<\/em> elementos que correspondem \u00e0 chave e \u00e0 revis\u00e3o fornecidas.<\/p>\n

\n
p\u00fablico<\/span> bool<\/span> IsMissing(<\/span>string<\/span> chave, string<\/span> rev)<\/span>
\n{<\/span>
\nvar xml =<\/span> XDocument.<\/span>Carga<\/span>(<\/span>_caminho)<\/span>;<\/span>
\nvar documentos =<\/span> xml.<\/span>Documento<\/span>.<\/span>Raiz<\/span>.<\/span>Elementos<\/span>(<\/span>\"document\" (documento)<\/span>)<\/span>;<\/span>
\nvar document =<\/span> documentos.<\/span>Onde<\/span>(<\/span>d =><\/span> d.<\/span>Elemento<\/span>(<\/span>\"meta\"<\/span>)<\/span>.<\/span>Elemento<\/span>(<\/span>\"rev\"<\/span>)<\/span>.<\/span>Valor<\/span> ==<\/span> rev &&<\/span> d.<\/span>Elemento<\/span>(<\/span>\"meta\"<\/span>)<\/span>.<\/span>Elemento<\/span>(<\/span>\"id\"<\/span>)<\/span>.<\/span>Valor<\/span> ==<\/span> chave)<\/span>;<\/span>
\nretorno<\/span> documento.<\/span>Contagem<\/span>(<\/span>)<\/span> ==<\/span> 0<\/span>;<\/span>
\n}<\/span><\/div>\n<\/div>\n

Os documentos s\u00e3o criados simplesmente adicionando-os ao arquivo XML existente.<\/p>\n

\n
\n

p\u00fablico<\/span> vazio<\/span> CriarDocumento(<\/span>Documento Documento)<\/span>
\n{<\/span>
\nvar xml =<\/span> XDocument.<\/span>Carga<\/span>(<\/span>_caminho)<\/span>;<\/span><\/p>\n

var docElement =<\/span> novo<\/span><\/a> XElement(<\/span>\"document\" (documento)<\/span>,
\nnovo<\/span><\/a> XElement(<\/span>\"meta\"<\/span>,
\nnovo<\/span><\/a> XElement(<\/span>\"id\"<\/span>, documento.<\/span>Id<\/span>)<\/span>,
\nnovo<\/span><\/a> XElement(<\/span>\"rev\"<\/span>, documento.<\/span>Revis\u00e3o<\/span>)<\/span>,
\nnovo<\/span><\/a> XElement(<\/span>\"expira\u00e7\u00e3o\"<\/span>, documento.<\/span>Vencimento<\/span>)<\/span>,
\nnovo<\/span><\/a> XElement(<\/span>\"flags\" (sinalizadores)<\/span>, documento.<\/span>Bandeiras<\/span>)<\/span>
\n)<\/span>,
\nnovo<\/span><\/a> XElement(<\/span>\"valor\"<\/span>, novo<\/span><\/a> XCData(<\/span>documento.<\/span>Valor<\/span>)<\/span>)<\/span>
\n)<\/span>;<\/span><\/p>\n

xml.<\/span>Documento<\/span>.<\/span>Raiz<\/span>.<\/span>Adicionar<\/span>(<\/span>docElement)<\/span>;<\/span>
\nxml.<\/span>Salvar<\/span>(<\/span>_caminho)<\/span>;<\/span>
\n}<\/span><\/p>\n<\/div>\n<\/div>\n

Por padr\u00e3o, configurei o Nancy para usar o servidor de desenvolvimento ASP.NET. Voc\u00ea pode hospedar o Nancy como quiser (IIS, auto-hospedado, etc.). Depois de executar o projeto, ser\u00e1 necess\u00e1rio configurar o XDCR no console de administra\u00e7\u00e3o do Couchbase. Alguns valores a saber:<\/p>\n