基于dubbo的分布式项目实例应用

Posted 2020-08-16 学习、改良、极致

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了基于dubbo的分布式项目实例应用相关的知识，希望对你有一定的参考价值。

本文主要学习dubbo服务的启动检查、集群容错、服务均衡、线程模型、直连提供者、只定阅、只注册等知识点，希望通过实例演示进一步理解和掌握这些知识点。

启动检查

Dubbo缺省会在启动消费者时检查依赖的服务是否可用，不可用时会抛出异常，阻止Spring初始化完成，以便上线时，能及早发现问题，默认check=true。

关闭没有提供者时报错

<dubbo:reference interface="com.mcweb.api.service.IUserService" id="userService" check="false" />

<dubbo:consumer check="false" />

check="false"表示不启动服务提供者mcweb-logic，mcweb-web照样能正常启动。

关闭注册订阅失败时报错

<dubbo:registry check="false" />

check="false"表示，注册中心未启动，mcweb-web照样能正常启动。

集群容错

基本概念

首先，我们要明确dubbo是怎么做集群的。dubbo的集群即同一个服务部署多台机或者同一台机不同端口注册到注册中心，消费者就通过访问规则访问集群内的不同节点的服务。

集群只需多个相同服务注册相同的注册中心。在每个服务提供者配置相同集群策略和访问策略，对于消费者是透明，消费者通过框架决定访问那个服务提供者。消费者通过注册中心提供的服务端的协议信息，决定访问哪个服务。

dubbo的集群容错即当服务消费者调用服务提供者集群中的服务失败时，Dubbo提供了多种容错方案，缺省为failover重试（失败自动切换，当出现失败，重试其它服务器）。Dubbo提供的集群容错模式有：

Failover Cluster（失败自动切换，当出现失败，重试其它服务器。(缺省)）

Failfast Cluster（快速失败，只发起一次调用，失败立即报错。）

Failsafe Cluster（失败安全，出现异常时，直接忽略。）

Failback Cluster（失败自动恢复，后台记录失败请求，定时重发。）

Forking Cluster（并行调用多个服务器，只要一个成功即返回。）

Broadcast Cluster（广播调用所有提供者，逐个调用，任意一台报错则报错。）

详细解析参考

http://dubbo.io/User+Guide-zh.htm#UserGuide-zh-%E9%9B%86%E7%BE%A4%E5%AE%B9%E9%94%99

集群模式配置

在《基于dubbo构建分布式项目与服务模块》一文中，我们创建了服务消费者mcweb-web与服务提供者mcweb-logic，现在我们再增加两个服务提供者，和mcweb-logic属于同一个服务，便于区分，将模块名称命名为mcweb-logic-a，mcweb-logic-b。现在mcweb-logic，mcweb-logic-a，mcweb-logic-b都属于同一个服务，均提供IUserService服务。需要将三个相同的服务以不同的端口注册到zookeeper中并指定集群容错模式，集群容错模式也可以在服务提供者配置。

<dubbo:reference

interface="com.mcweb.api.service.IUserService"

id="userService"

check="false"

protocol="dubbo"

cluster="failover"

retries="2"

<!---或者->

<dubbo:protocol name="dubbo" port="20880" />

<dubbo:service

interface="com.mcweb.api.service.IUserService"

ref="userService"

protocol="dubbo"

cluster="failover"

retries="2"

运行服务集群

在《基于dubbo构建分布式项目与服务模块》一文中，我们采用了tomcat容器来运行服务消费者和服务提供者，现在我们采用main方法来运行，这种方式通常在测试环境中使用。

public class DubboServiceStart {
    public static void main(String[] args) throws IOException {
        ApplicationContext ctx = new 
                ClassPathXmlApplicationContext("classpath*:spring/applicationContext.xml");
        System.out.println("mcweb-logic 服务已启动...");
        //为保证服务一直开着，利用输入流的阻塞来模拟
        System.in.read(); 
    }
}

分别以这种方式运行另外两个服务。在dubbo管控台可以看到：

集群容错测试

服务集群对消费者来说是透明的，消费者只需注明注册中心和需要的服务即可，无需关注服务是单节点还是集群。因为在同一台机子上测试，将消费者的端口改为20883

<dubbo:protocol name="dubbo" port="20883"/>

现在我们来运行消费者。

public class DubboConsumerStart {
    public static void main(String[] args) throws Exception {
        ApplicationContext ctx=new 
                ClassPathXmlApplicationContext("classpath*:spring/applicationContext.xml");
        System.out.println("mcweb-web 消费者已启动...");
        
        for(int i=0; i<1000;i++) {
            IUserService userService=(IUserService) ctx.getBean("userService");
            User user = userService.query("testid");
            System.out.println(i + ":" + user.getUserName());
            Thread.sleep(1000);
        }
    }
}

运行结果：

...

10:Get user from mcweb-logic-b

11:Get user from mcweb-logic

12:Get user from mcweb-logic-a

13:Get user from mcweb-logic-b

14:Get user from mcweb-logic-a

15:Get user from mcweb-logic

16:Get user from mcweb-logic

17:Get user from mcweb-logic

18:Get user from mcweb-logic-b

19:Get user from mcweb-logic

20:Get user from mcweb-logic

...

可见，默认情况下，dubbo服务集群是带有负载均衡的（默认为random算法随机调用），集群中的服务被均匀的调用，在cluster="failover"模式下，当调用失败时，会尝试调用其他服务器。可以在dubbo管控台中对服务进行“倍权”，“半权”，“禁用”等操作观察消费者的调用情况。

负载均衡

基本概念

负载均衡(Load Balance)是分布式系统架构设计中必须考虑的因素之一，它通常指将请求/数据均匀分摊到多个操作单元（集群服务节点）上执行，负载均衡的关键在于均匀。dubbo在服务集群负载均衡时，提供了多种均衡策略，缺省为random随机调用。

Random LoadBalance随机，按权重设置随机概率。

RoundRobin LoadBalance 轮循，按公约后的权重设置轮循比率。

LeastActive LoadBalance 最少活跃调用数，相同活跃数的随机，活跃数指调用前后计数差。

ConsistentHash LoadBalance 一致性Hash，相同参数的请求总是发到同一提供者。

详细参考

http://dubbo.io/User+Guide-zh.htm#UserGuide-zh-%E9%9B%86%E7%BE%A4%E5%AE%B9%E9%94%99

负载均衡配置

同理，负载均衡可以在消费者或者提供者中配置。

<dubbo:reference

interface="com.mcweb.api.service.IUserService"

id="userService"

check="false"

protocol="dubbo"

cluster="failover"

retries="2"

loadbalance="random"

我们采用random随机均衡算法，在dubbo管控台中设置mcweb-logic（192.168.2.1:20880），mcweb-logic-a（192.168.2.1:20881），mcweb-logic-b（192.168.2.1:20882）的权重分别为200,100,50。

看看mcweb-web的调用情况：

以上是关于基于dubbo的分布式项目实例应用的主要内容，如果未能解决你的问题，请参考以下文章

dubbo本地搭建实例

dubbo学习--简单的入门搭建实例

基于Dubbo的压测调优实例

Rpc基于开源Dubbo分布式RPC服务框架的部署整合

Java架构师springboot，springcloud，dubbo，rocketmq，redis，tomcat大型分布式电商项目实战