Dubbo 入门应用

2023-11-29 19:02:58

Dubbo 入门应用

Dubbo概念

Dubbo是阿里巴巴公司开源的一个高性能、轻量级的 Java RPC 框架
致力于提供高性能和透明化的 RPC 远程服务调用方案，以及 SOA 服务治理方案
官网：http://dubbo.apache.org

Dubbo架构

节点角色

Provider: 暴露服务的服务提供方。
Consumer: 调用远程服务的服务消费方。
Registry: 服务注册与发现的注册中心。
Monitor: 统计服务的调用次调和调用时间的监控中心。
Container: 服务运行容器。
List item

服务启动，服务提供方想注册中心注册服务，服务消费方订阅自己需要的服务。然后注册中心将服务方的地址和其他信息发送给消费者，如果有多台服务器，消费者基于负载均衡策略从多台服务中选择一个，其中消费者和提供者的调用过程，会被监控中心所记录。

Dubbo 快速入门

zookeeper安装

官方推荐使用zookeeper作为Dubbo的注册中心
过程略，感兴趣看博主zookeeper 安装一文

spring 简单应用

1.创建服务提供者Provider模块

创建服务消费者Consumer模块

创建目录结构，如上图，service作为服务提供方，web作为服务消费方。

在服务提供者模块编写 UserServiceImpl 提供服务

在我们普通的spring项目中，项目结构是controller->service->serviceimpl这种模式，而dubbo中，接口需要多个服务共用，所以单独建立一个模块，让其他服务去依赖他，这样可达到公用的效果，所以在dubbo-interface模块中，引入一以下依赖。在这里插入代码片

在服务消费者中的 UserController 远程调用UserServiceImpl 提供的服务

公共接口

package com.itheima.service;

import com.itheima.pojo.User;

public interface UserService {


    public String sayHello();

    /**
     * 查询用户
     */
    public User findUserById(int id);
}

实现类

package com.itheima.service.impl;

import com.itheima.pojo.User;
import com.itheima.service.UserService;
import org.apache.dubbo.config.annotation.Service;


@Service(timeout = 3000,retries = 0)
public class UserServiceImpl implements UserService {
    @Override
    public String sayHello() {
        return "hello,dubbo";
    }

    @Override
    public User findUserById(int id) {

        User user=new User(1, "11", "123");

        return user;
    }
}

5 分别启动两个服务，测试

Dubbo高级特性

序列化

dubbo 内部已经将序列化和反序列化的过程内部封装了
我们只需要在定义pojo类时实现Serializable接口即可
一般会定义一个公共的pojo模块，让生产者和消费者都依赖该模块。

地址缓存

注册中心挂了，服务是否可以正常访问？

可以，因为dubbo服务消费者在第一次调用时，会将服务提供方地址缓存到本地，以后在调用则不会访问注册中心。
当服务提供者地址发生变化时，注册中心会通知服务消费者。

超时与重试

服务消费者在调用服务提供者的时候发生了阻塞、等待的情形，这个时候，服务消费者会一直等待下去。
在某个峰值时刻，大量的请求都在同时请求服务消费者，会造成线程的大量堆积，势必会造成雪崩。

多版本

灰度发布：当出现新功能时，会让一部分用户先使用新功能，用户反馈没问题时，再将所有用户迁移到新功能。
dubbo 中使用version 属性来设置和调用同一个接口的不同版本

负载均衡

负载均衡策略

集群容错

集群容错模式：

Failover Cluster：失败重试。默认值。当出现失败，重试其它服务器，默认重试2次，使用 retries 配置。一般用于读操作
Failfast Cluster ：快速失败，只发起一次调用，失败立即报错。通常用于写操作。
Failsafe Cluster ：失败安全，出现异常时，直接忽略。返回一个空结果。
Failback Cluster ：失败自动恢复，后台记录失败请求，定时重发。通常用于消息通知操作。
Forking Cluster ：并行调用多个服务器，只要一个成功即返回。
Broadcast Cluster ：广播调用所有提供者，逐个调用，任意一台报错则报错。

服务降级

降级 Dubbo 服务
可以通过服务降级功能临时屏蔽某个出错的非关键服务，并定义降级后的返回策略。

向注册中心写入动态配置覆盖规则：

RegistryFactory registryFactory = ExtensionLoader.getExtensionLoader(RegistryFactory.class).getAdaptiveExtension();
Registry registry = registryFactory.getRegistry(URL.valueOf("zookeeper://10.20.153.10:2181"));
registry.register(URL.valueOf("override://0.0.0.0/com.foo.BarService?category=configurators&dynamic=false&application=foo&mock=force:return+null"));

其中：

mock=force:return+null 表示消费方对该服务的方法调用都直接返回 null 值，不发起远程调用。用来屏蔽不重要服务不可用时对调用方的影响。
还可以改为 mock=fail:return+null 表示消费方对该服务的方法调用在失败后，再返回 null 值，不抛异常。用来容忍不重要服务不稳定时对调用方的影响。

后续的学习会继续更新
gitee码云地址

码农公寓