Basado principalmente en el código fuente de dubbo-demo dentro del paquete de Dubbo:
- Estructura del proyecto:
- 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);
}
- 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;
}
}
- 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>
- 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();
}
}
- 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;