02.Dubbo（二）入门（第一个 Dubbo 程序（直连式）、Zookeeper 注册中心、将 Dubbo 应用到 web 工程、Dubbo 管理控制台）

dubbo入门

2. Zookeeper 注册中心

在生产环境下使用最多的注册中心为 Zookeeper，当然，Redis 也可以做注册中心。下面就来学习 Zookeeper 作为注册中心的用法。

2.1 创建提供者 02-provider-zk

(1) 导入依赖

复制前面的提供者工程 01-provider，并更名为 02-provider-zk。修改 pom 文件，并在其中导入 Zookeeper 客户端依赖 curator。

<!-- zk客户端依赖：curator -->
<dependency>
    <groupId>org.apache.curator</groupId>
    <artifactId>curator-recipes</artifactId>
    <version>2.13.0</version>
</dependency>
<dependency>
    <groupId>org.apache.curator</groupId>
    <artifactId>curator-framework</artifactId>
    <version>2.13.0</version>
</dependency>

(2) 修改 spring 配置文件

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:dubbo="http://dubbo.apache.org/schema/dubbo"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
       http://www.springframework.org/schema/beans/spring-beans.xsd
       http://dubbo.apache.org/schema/dubbo
       http://dubbo.apache.org/schema/dubbo/dubbo.xsd">

    <dubbo:application name="02-provider-zk"/>

    <!--声明注册中心：单机版zk-->
    <dubbo:registry address="zookeeper://zkOS:2181"/>
    <!-- 这种写法也可以 -->
    <!--<dubbo:registry protocol="zookeeper" address="zkOS:2181"/>-->

    <!--声明注册中心：zk群集-->
    <!--<dubbo:registry address="zookeeper://zkOS1:2181?backup=zkOS2:2181,zkOS3:2181,zkOS4:2181"/>-->
    <!--<dubbo:registry protocol="zookeeper" address="zkOS1:2181,zkOS2:2181,zkOS3:2181,zkOS4:2181"/>-->

    <bean id="someService" class="com.abc.provider.SomeServiceImpl"/>

    <dubbo:service interface="com.abc.service.SomeService" ref="someService" />

</beans>

注意：别忘了要启动了一个ZK服务器

我启动的ZK地址绑定了域名，所以address中可以直接使用域名

2.3 添加日志文件

通过前面的运行可知，无论是提供者还是消费者，控制台给出的提示信息都太少，若想看到更多的信息，可以在提供者与消费者工程的类路径 src/main/resources 下添加日志文件。可以添加 log4j.xml，即使用 log4j2 日志技术；也可以添加 log4j.properties，即使用 log4j 日志技术。我们这里添加 log4j.properties 文件。

log4j.appender.console=org.apache.log4j.ConsoleAppender
log4j.appender.console.Target=System.out
log4j.appender.console.layout=org.apache.log4j.PatternLayout
log4j.appender.console.layout.ConversionPattern=[%-5p] %m%n

log4j.rootLogger=info,console

在提供者的 src/main/resources 目录中添加 log4j.properties 文件。运行后可以看到如下的日志输出。其中最为重要的是 provider://xxxxx，这里显示的就是当前工程所提供的能够被订阅的服务描述，即服务元数据信息。另外，我们还可以看到当前应用与 qos-server（Quality of Service 服务器，即 Dubbo 的管控平台）进行通信的端口号为 22222。

(2) 消费者添加日志文件

在消费者的 src/main/resources 目录中添加 log4j.properties 文件。运行后在控制台的日志输出中可以看到报错。其报错内容原因是，消费者连接 qos-server 的端口号被占用了。其与 qos-server 通信的端口号默认也为 22222，已经被提供者给占用了。当然，原因主要是由于消费者与提供者都在同一主机，若分别存在于不同的主机也不会报错。

所以解决方案就是为消费者修改与 qos-server 通信的端口号。有两种修改方式。可以在src/main/resources 中新建一个 dubbo.properties 文件，文件内容仅需如下一行：

也可以直接在 spring-consumer.xml 文件中修改。

<dubbo:application name="02-consumer-zk">
    <dubbo:parameter key="qos.port" value="33333"/>
</dubbo:application>

修改端口号后再运行，就没有了报错。

2.4 看下ZK中有哪些数据

Dubbo中的元数据信息都是URL的形式。

3. 将 Dubbo 应用到 web 工程

前面所有提供者与消费者均是 Java 工程，而在生产环境中，它们都应是 web 工程，Dubbo如何应用于 Web 工程中呢？

3.1 创建提供者 03-provider-web

(1) 创建工程

创建 Maven 的 web 工程，然后将 02-provider-zk 中的 Service 实现类及 spring-provider配置文件复制到当前工程中。

(2) 导入依赖

这里使用的 Spring 的版本为 4.3.16。
需要的依赖有：

dubbo2.7.0 版本依赖
zk 客户端 curator 依赖
spring 相关依赖
spring 需要的 commons-logging 依赖
自定义 00-api 依赖

<properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <maven.compiler.source>1.8</maven.compiler.source>
    <maven.compiler.target>1.8</maven.compiler.target>
    <!-- 自定义版本号 -->
    <spring-version>4.3.16.RELEASE</spring-version>
</properties>

<dependencies>
    <!-- zk客户端依赖：curator -->
    <dependency>
        <groupId>org.apache.curator</groupId>
        <artifactId>curator-recipes</artifactId>
        <version>2.13.0</version>
    </dependency>
    <dependency>
        <groupId>org.apache.curator</groupId>
        <artifactId>curator-framework</artifactId>
        <version>2.13.0</version>
    </dependency>

    <!-- dubbo依赖 -->
    <dependency>
        <groupId>org.apache.dubbo</groupId>
        <artifactId>dubbo</artifactId>
        <version>2.7.0</version>
    </dependency>

    <!-- Spring依赖 -->
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-beans</artifactId>
        <version>${spring-version}</version>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-core</artifactId>
        <version>${spring-version}</version>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-context</artifactId>
        <version>${spring-version}</version>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-expression</artifactId>
        <version>${spring-version}</version>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-aop</artifactId>
        <version>${spring-version}</version>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-aspects</artifactId>
        <version>${spring-version}</version>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-tx</artifactId>
        <version>${spring-version}</version>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-jdbc</artifactId>
        <version>${spring-version}</version>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-web</artifactId>
        <version>${spring-version}</version>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-webmvc</artifactId>
        <version>${spring-version}</version>
    </dependency>

    <!-- commons-logging依赖 -->
    <dependency>
        <groupId>commons-logging</groupId>
        <artifactId>commons-logging</artifactId>
        <version>1.2</version>
    </dependency>
    	
    <!--业务接口工程依赖-->
    <dependency>
        <groupId>com.abc</groupId>
        <artifactId>00-api</artifactId>
        <version>1.0-SNAPSHOT</version>
    </dependency>

</dependencies>

(3) 定义 web.xml

<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns="http://xmlns.jcp.org/xml/ns/javaee"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee http://xmlns.jcp.org/xml/ns/javaee/web-app_3_1.xsd"
         version="3.1">

    <!--注册Spring配置文件-->
    <context-param>
        <param-name>contextConfigLocation</param-name>
        <param-value>classpath:spring-*.xml</param-value>
    </context-param>

    <!--注册ServletContext监听器-->
    <listener>
        <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
    </listener>

</web-app>

(4) 修改 spring-provider.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://dubbo.apache.org/schema/dubbo"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd">

    <dubbo:application name="03-provider-web"/>

    <!--指定服务注册中心：zk单机-->
    <dubbo:registry address="zookeeper://zkOS:2181"/>

    <!--注册服务执行对象-->
    <bean id="someService" class="com.abc.provider.SomeServiceImpl"/>

    <!--服务暴露-->
    <dubbo:service interface="com.abc.service.SomeService"
                   ref="someService" />

</beans>

3.2 创建消费者 03-consumer-web

(1) 创建工程

创建 Maven 的 web 工程，然后将 02-consumer-zk 中的 spring-provider 配置文件复制到当前工程中。

(2) 导入依赖

与提供者工程中的依赖相同。
消费者这边有页面，多加servlet 与 jsp 依赖。

<!-- Servlet依赖 -->
<dependency>
    <groupId>javax.servlet</groupId>
    <artifactId>javax.servlet-api</artifactId>
    <version>3.1.0</version>
    <scope>provided</scope>
</dependency>

<!-- JSP依赖 -->
<dependency>
    <groupId>javax.servlet.jsp</groupId>
    <artifactId>javax.servlet.jsp-api</artifactId>
    <version>2.2.1</version>
    <scope>provided</scope>
</dependency>

(3) 定义处理器

@Controller
public class SomeController {
    @Autowired
    private SomeService service;

    @RequestMapping("/some.do")
    public String someHandle() {
        String result = service.hello("China");
        System.out.println("消费者端接收到 = " +  result);
        return "/welcome.jsp";
    }
}

(4) 定义欢迎页面

在 src/main/webapp 目录下定义欢迎页面。

<html>
<body>
<h2>welcome you!</h2>
</body>
</html>

(5) 定义 web.xml

<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns="http://xmlns.jcp.org/xml/ns/javaee"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee http://xmlns.jcp.org/xml/ns/javaee/web-app_3_1.xsd"
         version="3.1">

    <!--对于2.6.4版本（dubbo），其Spring配置文件必须指定从<context-param>中加载-->
    <!--<context-param>-->
        <!--<param-name>contextConfigLocation</param-name>-->
        <!--<param-value>classpath:spring-*.xml</param-value>-->
    <!--</context-param>-->

    <!--字符编码过滤器-->
    <filter>
        <filter-name>CharacterEncodingFilter</filter-name>
        <filter-class>org.springframework.web.filter.CharacterEncodingFilter</filter-class>
        <init-param>
            <param-name>encoding</param-name>
            <param-value>utf-8</param-value>
        </init-param>
        <init-param>
            <param-name>forceEncoding</param-name>
            <param-value>true</param-value>
        </init-param>
    </filter>
    <filter-mapping>
        <filter-name>CharacterEncodingFilter</filter-name>
        <url-pattern>/*</url-pattern>
    </filter-mapping>

    <!--注册中央调度器-->
    <servlet>
        <servlet-name>springmvc</servlet-name>
        <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
        <init-param>
            <param-name>contextConfigLocation</param-name>
            <param-value>classpath:spring-*.xml</param-value>
        </init-param>
        <load-on-startup>1</load-on-startup>
    </servlet>
    <servlet-mapping>
        <servlet-name>springmvc</servlet-name>
        <!--不能写/*，不建议写/（静态资源不能访问），建议扩展名方式-->
        <url-pattern>*.do</url-pattern>
    </servlet-mapping>

</web-app>

(6) 修改 spring-consumer.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://dubbo.apache.org/schema/dubbo"
       xmlns:mvc="http://www.springframework.org/schema/context"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">
    
    <dubbo:application name="03-consumer-web"/>

    <!--指定服务注册中心：zk单机-->
    <dubbo:registry address="zookeeper://zkOS:2181"/>

    <!--订阅服务-->
    <dubbo:reference id="someService"
                     interface="com.abc.service.SomeService"/>

    <!--注册处理器-->
    <mvc:component-scan base-package="com.abc.controller"/>
</beans>

3.3 部署运行

为了方便部署测试，这里将提供者与消费者部署到一个 Tomcat 中。

(1) 设置 Tomcat

A、修改 Tomcat 默认端口号
由于 Dubbo 管控台端口号为 8080，所以这里将 Tomcat 默认端口号修改为 8081。
B、两个应用两个 context

(2) 演示

4. Dubbo 管理控制台

2019 年初，官方发布了 Dubbo 管理控制台 0.1 版本。结构上采取了前后端分离的方式，前端使用 Vue 和 Vuetify 分别作为 Javascript 框架和 UI 框架，后端采用 Spring Boot 框架。

4.1 下载

Dubbo 管理控制台的下载地址为：https://github.com/apache/dubbo-admin

下载完毕后会得到一个 zip 文件。

4.2 配置

这是一个 Spring Boot 工程，在下载的 zip 文件的解压目录的如下目录中修改配置文件。主要就是配置注册中心、配置中心，与元数据中心的地址。当然，这是一个 springboot 工程，默认端口号为 8080，若要修改端口号，则在配置文件中增加形如 server.port=8888 的配置。

dubbo-admin-develop\dubbo-admin-server\src\main\resources\application.properties
这个配置文件，针对不同版本 Dubbo 应用的管控，有不同的配置方式。