Dubbo服务集群实现负载均衡

作用

当某个服务并发量特别大的时候，一个服务延迟太高，我们就需要进行服务集群，例如某个项目一天注册量10万，这个注册功能就必须要进行集群了，否则一个服务无法应付这么大的并发量

企业级项目多个服务集群，每个服务都放不同机器，不仅能实现负载均衡，也能进行容错；就算一个机器挂了，其他机器可以继续服务

多个服务也提供权重设置，来动态设置请求分发量

实现方法

dubbo的服务集群很简单，只需要配置文件里改个端口即可，其他代码不需要动

代码实现

在之前Provider子模块项目的基础上，直接修改dubbo-demo-provider.xml的端口号即可（端口号只要不被占用即可，不需要和本文章的端口号一样）

1 2	<!--使用dubbo协议在20880端口暴露服务--> <dubbo:protocol name="dubbo" port="20880"/>

修改后：

1 2	<!--使用dubbo协议在20881端口暴露服务--> <dubbo:protocol name="dubbo" port="20881"/>

上面的教程已经实现了服务集群，下面的教程只是为了可以更直观看到结果

为了可以更直观看到结果，我不直接修改dubbo-demo-provider.xml的端口号，而是新建三个文件：DemoProviderServiceImpl2.java、dubbo-demo-provider2.xml、ProviderTest2.java（路径和原来的文件一样），执行ProviderTest.java和ProviderTest2.java会分别发布两个Dubbo服务：一个端口为20880，另一个端口为20881，三个文件的代码如下：

dubbo-demo-provider2.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">
    <!--提供方应用名称, 用于计算依赖关系-->
    <dubbo:application name="demo-provider"/>
    <!--使用zookeeper注册中心暴露服务地址-->
    <dubbo:registry address="zookeeper://localhost:2181"/>
    <!--使用dubbo协议在20881端口暴露服务-->
    <dubbo:protocol name="dubbo" port="20881"/>
    <!--service实现类作为本地的一个bean-->
    <bean id="demoProviderService" class="service.impl.DemoProviderServiceImpl2"/>
    <!--声明需要暴露的服务接口-->
    <dubbo:service interface="service.DemoProviderService" ref="demoProviderService"/>
</beans>

DemoProviderServiceImpl2.java

package service.impl;

import service.DemoProviderService;

/**
 * 服务提供者接口实现类
 *
 * @author LeDao
 * @company
 * @create 2021-08-10 2:54
 */
public class DemoProviderServiceImpl2 implements DemoProviderService {

    @Override
    public String sayHello(String name) {
        return "服务员（端口：20881）" + name;
    }
}

ProviderTest2.java

import org.springframework.context.support.ClassPathXmlApplicationContext;

import java.io.IOException;

/**
 * @author LeDao
 * @company
 * @create 2021-08-10 2:55
 */
public class ProviderTest2 {

    public static void main(String[] args) {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("dubbo-demo-provider2.xml");
        context.start();
        System.out.println("服务提供者注册成功（端口：20881）");
        try {
            System.in.read();
        } catch (IOException e) {
            e.printStackTrace();
        }
        context.close();
    }
}