分布式与微服务系列SpringBoot+Zookeeper集群+Nginx反向代理+Dubbo分布式托管（提供者消费者）

Posted 2021-09-07 一宿君

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了分布式与微服务系列SpringBoot+Zookeeper集群+Nginx反向代理+Dubbo分布式托管（提供者消费者）相关的知识，希望对你有一定的参考价值。

SpringBoot+Zookeeper集群+nginx反向代理+Dubbo分布式托管（提供者、消费者）

一、软件架构和微服务需求
二、搭建Zookeeper注册中心集群服务
三、启动Dubbo管理控制台可视化界面
四、创建服务提供者集群服务（三个）
五、创建服务消费者集群服务（四个）
六、使用SwitchHosts工具模拟绑定域名
- 6.1、修改主机配置文件hosts的只读属性
- 6.2、以管理员身份运行SwitchHosts工具，新建域名（自定义）
七、使用Nginx反向代理（消费者）
八、通过nginx反向代理，请求消费者，通过消费者访问提供者
九、解决Dubbo内置负载均衡策略问题

一、软件架构和微服务需求

1.1、微服务需求

我们知道软件架构的演化过程，从单体架构，到垂直架构，再到SOA架构，最后到现在较流行的微服务架构。每个架构都有各自的优缺点，随着架构体系的演化和现如今软件整体架构的需求在不断的提高，微服务之所以比较流行就是因为它将系统服务层完全独立出来，抽取为一个一个的服务；微服务架构采用去中心化思想，服务之间采用restful等轻量协议通信，相比ESB更轻量。因为创建一个系统要考虑到全面服务，总体来说要能做到软件架构的三要素：高可用、高性能、高并发。如果一个系统做不到这三个要素，那就不能称为一个好的软件系。

本文我们着重讲解，使用SpringBoot项目整合Zookeeper注册中心，Nginx反向代理和Dubbo远程代理分布式托管，最后实现系统的高可用、高并发和高性能，其核心就是使所有服务器面对海量访问能够实现负载均衡。

1.2、框架选择

SpringBoot是当前比较流行的框架，其底层集成了Spring、mybatis、hibernate等多种优秀框架，这个框架的好用程度就不多说了，用起来可以说是朗朗上手，带劲。
Nginx是一个轻量级/高性能的反向代理Web服务器，而且Nginx支持跨平台、配置简单、高并发连接：处理2-3万并发连接数，官方监测能支持5万并发，内存消耗小：开启10个nginx才占150M内存，nginx处理静态文件好，耗费内存少，它能够实现非常高效的反向代理和负载平衡。
Dubbo是一款微服务开发框架，它提供了RPC通信与微服务治理两大关键能力。这意味着，使用Dubbo开发的微服务，将具备相互之间的远程发现与通信能力，同时利用Dubbo提供的丰富服务治理能力，可以实现诸如服务实现、负载均衡、流量调度等服务治理诉求。同时Dubbo是高度可扩展的，用户几乎可以在任意功能点去定制自己的实现，以改变框架的默认行为来满足自己的业务需求。
Zookeeper是Apache Hadoop的子项目，是一个树型的目录服务，支持变更推送，适合作为Dubbo服务的注册中心，工业强度较高，可用于生产环境，并推荐使用。
我们最终要实现的效果如下图（让其Dubbo分布式中的服务器全部使用集群，实现负载均衡）：

1.3、集群分布(下面为此图实战演示)

简单集成应用可以详细观看分布式与微服务系列（二）、分布式RPC框架Apache Dubbo服务。

二、搭建Zookeeper注册中心集群服务

因为本次测试是在一台电脑上做测试，所以暂不使用Linux虚拟机启动Zookeeper集群服务了，怕到时候电脑啊承受不住，挂掉。我们就先在Windows下使用Zookeeper测试即可。

2.1、配置三台zookeeper注册中心服务器（数量可选）

2.2、修改三台zookeeper配置信息

修改zoo.cfg配置文件信息：

这三行代码（不要修改）依次粘到后两台zookeeper配置文件中，别忘了更改端口号依次为2082、2083：

server.1=127.0.0.1:2801:3801
server.2=127.0.0.1:2802:3802
server.3=127.0.0.1:2803:3803

2.3、配置zookeeper集群区分id

2.4、启动zookeeper集群服务

在启动过程中，发现第一台有报错，莫要慌，不要紧，因为在第一台启动的时候会自动寻找灵台两台zokkeeper，找不到你说急不急，所以就报错了，等三台zookeeper都启动成功了，就不会报错了！

如果实在不放心，可以连接zookeeper自带的客户端，查看下当前节点是否已创建！

出现上述节点就说明zookeeper集群此时已经启动成功了，最后一个客户端窗口可以关闭，但是上述仨窗口放着，可千万别关哈！！！

三、启动Dubbo管理控制台可视化界面

我们人如果想要知道服务提供者和消费者是是否成功注册和订阅到zookeeper注册中心，Dubbo官方为我们提供了一个Dubbo管理控制台可视化界面。

启动Dubbo控制台界面有两种方式，详情可以查看我的上篇文章分布式与微服务系列（二）、分布式RPC框架Apache Dubbo服务，第四点有详细介绍如何使用，此处我们就简单介绍下jar包形式启动Dubbo可视化管理控制台，另一个是war包形式。

3.1、修改dubbo-admin的配置文件

3.2、打包dubbo-admin项目

在打开的DOS命令窗口中执行命令mvn clean package，先清除一下，然后打包项目，第一次执行可能会有点慢，大概一分钟左右，稍安勿躁：

打包完成出现target目录：

进入target目录：

3.3、运行`dubbo-admin-0.0.1-SNAPSHOT.jar`包

首先你要确保你的此jar包所在的路径没有中文，你就可以直接在打开DOS命令窗口，切换到此路径下，执行命令java -jar dubbo-admin-0.0.1-SNAPSHOT.jar即可运行；如果有中文，将此jar包直接拷贝到另外一个没有中文的目录下，再执行命令：

如果觉得每次启动打开DOS窗口比较麻烦，那就jar包所在目录下创建一个批处理：

如果你得jar包运行出现错误，那就是你上述的配置或路径写错了，仔细检查一遍按照我上述的步骤重新打包很快的。

启动成功，然后我们就可以在浏览器地址栏输入localhost:7001直接访问了

四、创建服务提供者集群服务（三个）

4.1、新建SpringBoot_dubbo_provider项目

4.2、引入pom.xml坐标依赖文件

<!--springboot启动器-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>

        <!--springboot   web启动器-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <!--springboot  测试启动器-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>

        <!--dubbo与springboot集成启动器-->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>2.7.6</version>
        </dependency>
        <!--dubbo与注册中心zookeeper整合包-->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-registry-zookeeper</artifactId>
            <version>2.7.6</version>
            <exclusions>
                <exclusion>
                    <groupId>org.apache.curator</groupId>
                    <artifactId>curator-recipes</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <!--实现自动化创建节点路径的父节点-->
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-recipes</artifactId>
            <version>4.2.0</version>
        </dependency>

4.3、新建包com.ebuy.service，在此包下新建HelloService接口

package com.ebuy.service;

public interface HelloService {

    public String sayHello(String name);
}

4.4、新建包com.ebuy.service.impl，在此包下新建接口HelloServiceImpl实现类

package com.ebuy.service.impl;

import com.ebuy.service.HelloService;
import org.apache.dubbo.config.annotation.Service;

@Service(loadbalance = "roundrobin",interfaceClass = HelloService.class)
public class HelloServiceImpl implements HelloService {
    @Override
    public String sayHello(String name)
    {
        return "hello---"+name;
    }
}

上述loadbalance=“roundrobin”指的是用户通过消费者服务，访问提供者时，按照轮询的负载均衡策略访问每一台服务提供者；

random：默认就是随机策略的；（推荐）
roundrobin：依次轮询；（推荐）
leastactive：最少活跃调用数（权重）活跃数指调用前后计数差，优先调用高的，相同活跃数的随机。使慢的提供者收到更少请求，因为越慢的提供者的调用前后计数差会越大；
consistenthash：一致性策略，同参数的请求一定分发到同一个 Provider 如果需要某一类请求都到一个节点，那么可以使用一致性 Hash 策略。

注意：@Service注解是org.apache.dubbo.config.annotation.Service包下的，不是spring包下的。

4.5、核心配置文件（使用application.yml树状结构）

server:
  port: 8081  #服务器端口号
dubbo:
  application:
    name: springboot_provider   #提供者应用名
  registry:
    address: 127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183  #连接注册中心集群
    protocol: zookeeper  #dubbo采用的注册中心协议
  protocol:   #连接注册中心协议
    port: 20881   #dubbo端口号为20880，此处我们一会为了做集群区分，先改成20881
    name: dubbo   
  config-center:  #配置中心
    timeout: 25000  #最大超时时间
  scan:
    base-packages: com.ebuy.service.impl   #扫描哪个包下提供的服务

4.6、启动第一台provider-8081提供者服务

在maven webapps项目下，可以直接使用tomcat7插件，只需修改端口号，就可以启动多台服务，在SpringBoot项目下，当然也可以启动多台服务，如下所示：

进入配置中心：

启动之前，确认服务器端口号和dubbo端口号，以及提供服务方法的返回值：

4.7、启动第二台provider-8082提供者服务

修改application.yml配置文件中的端口号，两处port：

4.8、启动第三台provider-8083提供者服务

修改application.yml配置文件中的端口号，两处port：

此时三台服务提供者已经全部启动，但是是否成功注册到zookeeper中心了，我们可以通过上述dubbo-admin管理控制台，查看：

到这，我们就可以很安心的往下接着走下去了，三个服务者已经注册到registory服务中心了。

五、创建服务消费者集群服务（四个）

5.1、新建SpringBoot_dubbo_consumer项目

5.2、引入pom.xml坐标依赖文件

<!--springboot启动器-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>

        <!--springboot   web启动器-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <!--springboot  测试启动器-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>

        <!--dubbo与springboot集成启动器-->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>2.7.6</version>
        </dependency>
        <!--dubbo与注册中心zookeeper整合包-->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-registry-zookeeper</artifactId>
            <version>2.7.6</version>
            <exclusions>
                <exclusion>
                    <groupId>org.apache.curator</groupId>
                    <artifactId>curator-recipes</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <!--实现自动化创建节点路径的父节点-->
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-recipes</artifactId>
            <version>4.2.0</version>
        </dependency>


        <!-- 实现对 Spring Session 使用 Redis 作为数据源的自动化配置 -->
        <dependency>
            <groupId>org.springframework.session</groupId>
            <artifactId>spring-session-data-redis</artifactId>
        </dependency>

        <!-- 实现对 Spring Data Redis 的自动化配置 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-redis</artifactId>
            <exclusions>
                <!-- 去掉对 Lettuce 的依赖，因为 Spring Boot 优先使用 Lettuce 作为 Redis 客户端 -->
                <exclusion>
                    <groupId>io.lettuce</groupId>
                    <artifactId>lettuce-core</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <!-- 引入 Jedis 的依赖，这样 Spring Boot 实现对 Jedis 的自动化配置 -->
        <dependency>
            <groupId>redis.clients</groupId>
            <artifactId>jedis</artifactId>
        </dependency>

5.3、新建包com.ebuy.service,在此包下新建HelloService接口，与提供者接口保持一致

package com.ebuy.service;

public interface HelloService {

    public String sayHello(String name);
}

5.4、新建包com.ebuy.controller,在此包下新建HelloController类

package com.ebuy.controller;

import com.ebuy.service.HelloService;
import org.apache.dubbo.config.annotation.Reference;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import javax.servlet.http.HttpServletRequest;


@Controller
@RequestMapping("/demo")
public class HelloController {

    @Reference
    HelloService helloService;

    int port=2011;

    @RequestMapping("/hello")
    @ResponseBody
    public String getName(String name){
        //远程调用,获取响应结果
        String result = helloService.sayHello(name);
        System.out.println("consumer-" + port + "\\t" + result);
        return result;
    }
}

注意：

@Reference
HelloService helloService;

此处的HelloService访问的是远程的Provider所提供的服务，所有使用@Autowire注解是加载不到的，要使用@Reference注解调用远程提供者发布的@Service注解标注的服务注册接口。

5.5、核心配置文件（使用application.yml树状结构）

server:
  port: 2011  #服务器端口号
dubbo:
  application:
    name: springboot_consumer   #消费者服务名称
  registry: #注册中心
    address: 127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183   #zookeeper集群
    protocol: zookeeper #dubbo采用zookeeper注册中心协议
  consumer: #消费者节点
    check: false  #启动时不用检测提供者是否已经注册
  config-center:
    timeout: 25000   #超时时间  单位秒

在启动消费者前，要注意一点，因为SpringBoot内部机制会自动加载DataSource数据源和Redis相关配置，即使你没有配任何置数据库相关配置信息，它内部也会默认加载，这个时候我们启动消费者服务就会出现如下错误：

Error creating bean with name ‘enableRedisKeyspaceNotificationsInitializer‘

这个时候如果你配置了数据库和redis相关配置，暂时先全部注释掉，然后在消费者主入口类的@SpringBootApplication排除运行期间不包括的服务，如下：

package com.ebuy;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframe以上是关于分布式与微服务系列SpringBoot+Zookeeper集群+Nginx反向代理+Dubbo分布式托管（提供者消费者）的主要内容，如果未能解决你的问题，请参考以下文章 
 分布式与微服务系列Dubbo入门开发（服务提供方服务消费方）
 分布式与微服务系列软件架构的演化过程
 SpringCloud微服务组件介绍
 手撸golang GO与微服务 Saga模式之8 集成测试
 Java面试八股文--分布式与微服务Nginx面试题
 手撸golang GO与微服务 Saga模式之1