{"id":13061,"date":"2022-04-12T10:11:38","date_gmt":"2022-04-12T17:11:38","guid":{"rendered":"https:\/\/www.couchbase.com\/blog\/?p=13061"},"modified":"2024-05-08T07:18:22","modified_gmt":"2024-05-08T14:18:22","slug":"event-broker-integration-with-couchbase-solace-java","status":"publish","type":"post","link":"https:\/\/www.couchbase.com\/blog\/es\/event-broker-integration-with-couchbase-solace-java\/","title":{"rendered":"Integraci\u00f3n de Event Broker con Couchbase, Solace y Java"},"content":{"rendered":"

En el anterior <\/span>entrada del blog<\/span><\/a> hablamos de c\u00f3mo Couchbase puede integrarse perfectamente en un <\/span>Arquitectura basada en eventos<\/span><\/i>. Usando el Servicio de Eventos de Couchbase, las mutaciones de documentos pueden ser publicadas a un <\/span>Solace PubSub+<\/span><\/a> desde donde los datos se ponen a disposici\u00f3n de los microservicios suscriptores casi en tiempo real.<\/span><\/p>\n

Este post se centra en c\u00f3mo los microservicios como Topic subscribers pueden aprovechar Couchbase como un almac\u00e9n de datos escalable y resistente.<\/span><\/p>\n

Visi\u00f3n general de la arquitectura y aplicaci\u00f3n de ejemplo<\/b><\/p>\n

En este solicitud de muestra<\/a>nos suscribimos a un tema Solace PubSub+, procesamos los datos y actualizamos el documento en Couchbase.<\/span><\/p>\n

En nuestra aplicaci\u00f3n de ejemplo, almacenamos los detalles del hotel en Couchbase. Las actualizaciones de la configuraci\u00f3n del hotel se publican en un tema Solace PubSub+. Construimos una aplicaci\u00f3n que se suscribe al Topic, recupera los datos actualizados y actualiza la configuraci\u00f3n del hotel existente en Couchbase.<\/span><\/p>\n

Utilizamos el <\/span>viaje-muestra<\/span><\/i> que contiene datos de muestra como <\/span>vuelos<\/span><\/i>, <\/span>rutas<\/span><\/i> y otros. En nuestro ejemplo, nos centramos en el <\/span>hotel<\/span><\/i> documentos almacenados en el <\/span>inventario<\/span><\/i> \u00e1mbito en el <\/span>hotel<\/span><\/i> colecci\u00f3n. Todos los documentos de hotel constan de un documento JSON con varios atributos.<\/span><\/p>\n

En este tutorial s\u00f3lo actualizaremos un peque\u00f1o subconjunto de atributos, como por ejemplo <\/span>mascotas_permitidas<\/span><\/i> y <\/span>internet_libre<\/span><\/i>.<\/span><\/p>\n

\"Event-driven

La aplicaci\u00f3n de ejemplo se suscribe a un Solace Topic y actualiza los datos del hotel en Couchbase. Otras aplicaciones pueden proporcionar los cambios de configuraci\u00f3n del hotel. Utilizamos un servicio simple que publica actualizaciones en el Topic.<\/p><\/div>\n

Leyenda: La aplicaci\u00f3n de ejemplo se suscribe a un Solace Topic y actualiza los datos del hotel en Couchbase. Otras aplicaciones pueden proporcionar los cambios de configuraci\u00f3n del hotel. Usamos un servicio simple que publica actualizaciones al Topic.<\/span><\/i><\/p>\n

Requisitos previos<\/span><\/h2>\n

Revise los requisitos previos para esta solicitud de muestra:<\/span><\/p>\n

Couchbase Capella<\/b><\/p>\n

Crear un <\/span>Couchbase Capella<\/span><\/a> y siga las instrucciones para aprovisionar su cl\u00faster de prueba. Esto s\u00f3lo le llevar\u00e1 unos minutos y le proporcionar\u00e1 un cl\u00faster de Couchbase completo, incluyendo los m\u00f3dulos <\/span>Datos<\/span><\/i> y el conjunto de datos de muestra, <\/span>muestra-viaje,<\/span><\/i> que utilizaremos a lo largo de esta entrada del blog.<\/span><\/p>\n

Puede utilizar este tutorial cuando no utilice nuestra oferta gestionada Couchbase Capella. El <\/span>viaje-muestra<\/span><\/i> bucket forma parte del producto del servidor Couchbase y puede importarse utilizando la consola de Couchbase.<\/span><\/p>\n

Nube de intermediarios de eventos Solace PubSub<\/b><\/p>\n

Inscr\u00edbete gratis <\/span>Prueba en la nube de Solace<\/span><\/a> y crear un Servicio\/VPN. Utilizaremos la VPN para conectarnos a un tema de Solace.<\/span><\/p>\n

 <\/p>\n

Revisi\u00f3n del c\u00f3digo - Suscriptor y editor de Solace<\/span><\/h2>\n

Para suscribirse a los mensajes de Solace Topic utilizamos la API Java de Solace. Este ejemplo de implementaci\u00f3n se deriva de los ejemplos de la documentaci\u00f3n de Solace. Para m\u00e1s detalles sobre la implementaci\u00f3n, consulte la documentaci\u00f3n de Solace.<\/span><\/p>\n

final JCSMPProperties properties = new JCSMPProperties();\r\nproperties.setProperty(JCSMPProperties.HOST, \"tcps:\/\/yourhost.messaging.solace.cloud:55443\");\r\nproperties.setProperty(JCSMPProperties.USERNAME, \"solace-cloud-client\");\r\nproperties.setProperty(JCSMPProperties.PASSWORD, \"password\");\r\nproperties.setProperty(JCSMPProperties.VPN_NAME, \"couchbasedemo\");\r\nJCSMPSession session = JCSMPFactory.onlyInstance().createSession(properties);\r\nsession.connect();\r\n\r\nfinal Topic topic = JCSMPFactory.onlyInstance().createTopic(\"tutorial\/topic\");<\/pre>\n
Configuramos el <\/span>JCSMPProperties<\/span><\/i> con la informaci\u00f3n de acceso pertinente disponible en la interfaz web de Solace. A continuaci\u00f3n, creamos un <\/span>JCSMPSession<\/span><\/i> y un <\/span>Tema<\/span><\/i>.<\/span><\/p>\n
Para suscribirnos a los mensajes del Topic implementamos un <\/span>XMLMessageConsumer<\/span><\/i>:<\/span><\/p>\n
\/\/ ### Message Receiver - Subscribe to Topic ###\r\nfinal XMLMessageConsumer cons = session.getMessageConsumer(new XMLMessageListener() {\r\n  @Override\r\n  public void onReceive(BytesXMLMessage msg) {\r\n    if (msg instanceof TextMessage) {\r\n      System.out.printf(\"SUBSCRIBE: Message received: '%s'%n\", ((TextMessage) msg).getText());\r\n      UpdateHotelData.getInstance().upsertHotelData(((TextMessage) msg).getText());\r\n    } else {\r\n      System.out.println(\"Message received.\");\r\n    }\r\n  }\r\n\r\n  @Override\r\n  public void onException(JCSMPException e) {\r\n    System.out.printf(\"Consumer received exception: %s%n\", e);\r\n  }\r\n});\r\nsession.addSubscription(topic);\r\nSystem.out.println(\"SUBSCRIBE: Connected. Awaiting message...\");\r\ncons.start();<\/pre>\n
En el onReceive<\/i> tomamos el mensaje, lo convertimos en una cadena y llamamos al m\u00e9todo upsertHotelData<\/i> m\u00e9todo de ActualizarDatosHotel <\/i>que contiene la implementaci\u00f3n de Couchbase de la que hablaremos m\u00e1s adelante.<\/p>\n
A\u00f1adimos la suscripci\u00f3n al tema a la sesi\u00f3n e iniciamos el consumidor de mensajes.<\/span><\/p>\n
Para poder probar la implementaci\u00f3n, tambi\u00e9n creamos un publicador de mensajes. Para ello, primero implementamos un <\/span>XMLMessageProducer<\/span><\/i>.<\/span><\/p>\n
\/\/ ### Message Producer - Send message to Topic\r\nXMLMessageProducer prod = session.getMessageProducer(new JCSMPStreamingPublishCorrelatingEventHandler() {\r\n  @Override\r\n  public void responseReceivedEx(Object key) {\r\n    System.out.println(\"Producer received response for msg: \" + key.toString());\r\n  }\r\n\r\n  @Override\r\n  public void handleErrorEx(Object key, JCSMPException cause, long timestamp) {\r\n    System.out.printf(\"Producer received error for msg: %s@%s - %s%n\", key.toString(), timestamp, cause);\r\n  }\r\n});<\/pre>\n
Con el productor de mensajes en su lugar, ahora podemos enviar mensajes como se ve a continuaci\u00f3n.\u00a0<\/span><\/p>\n
\/\/ Send messages. Here we loop through and send the same message multiple times.\r\nfor (int msgsSent = 0; msgsSent < 2; ++msgsSent) {\r\n  TextMessage msg = JCSMPFactory.onlyInstance().createMessage(TextMessage.class);\r\n  msg.setText(data);\r\n  System.out.printf(\"PUBLISH: Sending message '%s' to topic '%s'...%n\", data, topic.getName());\r\n  prod.send(msg, topic);\r\n  \/\/Gives us some time to follow the console logs\r\n  Thread.sleep(3000);\r\n}<\/pre>\n
Inserci\u00f3n de los datos en Couchbase<\/span><\/h3>\n
Con la l\u00f3gica para suscribirse y publicar mensajes en su lugar, ahora vamos a centrarnos en c\u00f3mo actualizar los documentos del hotel en Couchbase.<\/span><\/p>\n
Para este ejemplo, supondremos que el mensaje recuperado del tema tiene el formato JSON que se indica a continuaci\u00f3n. Incluyendo un <\/span>hotel_id<\/span><\/i> que utilizaremos como id de documento de los documentos del hotel almacenados en Couchbase, as\u00ed como una serie de atributos que podemos modificar:<\/span><\/p>\n
{\r\n\u00a0\u00a0\"hotel_id\": \"hotel_10025\",\r\n\u00a0\u00a0\"pets_ok\": true,\r\n\u00a0\u00a0\"free_breakfast\": true,\r\n\u00a0\u00a0\"free_internet\": true,\r\n\u00a0\u00a0\"free_parking\": true\r\n}<\/pre>\n
Para establecer una conexi\u00f3n segura desde nuestra aplicaci\u00f3n a Couchbase Capella, necesitamos:<\/span><\/p>\n