Publicación de Servicios en Dubbo

Basado principalmente en el código fuente de dubbo-demo dentro del paquete de Dubbo:

  1. Estructura del proyecto:
  2. Dependencias en pom.xml:
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  <modelVersion>4.0.0</modelVersion>
  <groupId>com.example</groupId>
  <artifactId>dubbo-servicio</artifactId>
  <version>1.0.0-SNAPSHOT</version>
  
  <dependencies>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>dubbo</artifactId>
            <version>2.6.0</version>
        </dependency>
        <dependency>
            <groupId>com.101tec</groupId>
            <artifactId>zkclient</artifactId>
            <version>0.10</version>
        </dependency>
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-framework</artifactId>
            <version>4.0.1</version>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>1.2.46</version>
        </dependency>
        <dependency>
            <groupId>log4j</groupId>
            <artifactId>log4j</artifactId>
            <version>1.2.17</version>
        </dependency>
        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-api</artifactId>
            <version>1.7.25</version>
        </dependency>
        <dependency>
            <groupId>org.apache.commons</groupId>
            <artifactId>commons-lang3</artifactId>
            <version>3.4</version>
        </dependency>
        <dependency>
            <groupId>io.netty</groupId>
            <artifactId>netty-all</artifactId>
            <version>4.0.35.Final</version>
        </dependency>
    </dependencies>
    
</project>

Ver Código3. Interfaz del proveedor de servicios: ServicioDemo:

package com.example.servicio;

/**
 * Interfaz del proveedor de servicios
 *
 */
public interface ServicioDemo {
    
    String saludar(String nombre);
}

  1. Clase de implementación de la interfaz del proveedor de servicios: ServicioDemoImpl:
package com.example.servicio.impl;

import com.example.servicio.ServicioDemo;

/**
 * Clase de implementación del proveedor de servicios
 *
 */
public class ServicioDemoImpl implements ServicioDemo {

    public String saludar(String nombre) {
        return "Hola," + nombre;
    }

}

  1. Archivo de configuración de dubbo: dubbo-servidor.xml:
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
       xmlns="http://www.springframework.org/schema/beans"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
       http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
    
    <!-- Nombre de la aplicación del proveedor, utilizado para calcular las dependencias -->
    <dubbo:application name="demo-servidor"/>
    
    <!-- Usar el registro de zookeeper para exponer la dirección del servicio -->
    <dubbo:registry address="zookeeper://127.0.0.1:2181"/>
    
    <!-- Usar protocolo dubbo, exponer el servicio en el puerto 20880 -->
    <dubbo:protocol name="dubbo" port="20880"/>
    
    <!-- Clase de implementación del servicio como bean local -->
    <bean id="servicioDemo" class="com.example.servicio.impl.ServicioDemoImpl"/>
    
    <!-- Declarar la interfaz del servicio que necesita ser expuesta -->
    <dubbo:service interface="com.example.servicio.ServicioDemo" ref="servicioDemo"/>

</beans>

  1. Clase de prueba: ServidorPrueba:
import java.io.IOException;

import org.springframework.context.support.ClassPathXmlApplicationContext;

public class ServidorPrueba {

    public static void main(String[] args) {
        ClassPathXmlApplicationContext contexto = new ClassPathXmlApplicationContext(new String[]{"dubbo-servidor.xml"});
        contexto.start();
        System.out.println("El proveedor de servicios se ha registrado exitosamente en el registro de zookeeper (puerto: 20880)");
        try {
            System.in.read();        // presione cualquier tecla para salir
        } catch (IOException e) {
            e.printStackTrace();
        } 
        contexto.close();
    }
}

  1. Prueba:

Primero inicie el servicio zookeeper, ejecute zkServer.cmd;

Luego ejecute ServidorPrueba.java, la consola mostrará:

log4j:WARN No se encontraron appenders para el logger (org.springframework.core.env.StandardEnvironment).
log4j:WARN Por favor inicialice el sistema log4j correctamente.
log4j:WARN Ver http://logging.apache.org/log4j/1.2/faq.html#noconfig para más información.
El proveedor de servicios se ha registrado exitosamente en el registro de zookeeper (puerto: 20880)

En la ventana de comandos de zkServer se puede ver:

2018-09-16 11:12:57,314 [myid:] - INFO  [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181:NIOServerCnxnFactory@215] - Aceptada
conexión de socket desde /127.0.0.1:59894
2018-09-16 11:12:57,321 [myid:] - INFO  [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181:ZooKeeperServer@938] - Cliente intent
ando establecer nueva sesión en /127.0.0.1:59894
2018-09-16 11:12:57,376 [myid:] - INFO  [SyncThread:0:ZooKeeperServer@683] - Sesión establecida 0x1000786f7320000 con
timeout negociado 30000 para el cliente /127.0.0.1:59894
2018-09-16 11:12:57,424 [myid:] - INFO  [ProcessThread(sid:0 cport:2181)::PrepRequestProcessor@653] - Se obtuvo excepción de Keeper
 de nivel de usuario al procesar sessionid:0x1000786f7320000 tipo:create cxid:0x4 zxid:0xa txntype:-1 reqpath:n/a Error Path
 :/dubbo/com.example.servicio.ServicioDemo/configurators Error:KeeperErrorCode = NodeExists para /dubbo/com.example.servicio.Serv
icioDemo/configurators

zookeeper aceptó la conexión del programa en el puerto 59894:

C:\Users\Usuario>netstat -aon | findstr "59894" TCP 127.0.0.1:2181 127.0.0.1:59894 ESTABLECIDO 9192 es el programa java.exe de la máquina virtual de prueba;

Etiquetas: Dubbo servicios-distribuidos Zookeeper RPC

Publicado el 6-23 17:12