SpringBoot中使用dubbo实现RPC调用

超、凢脫俗 2022-11-25 04:11 140阅读 0赞

# Dubbo（来自于阿里巴巴） #

Dubbo是一个分布式服务框架，致力于提供高性能和透明化的PRC远程调用服务调用方案。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDk5MDgxOA_size_16_color_FFFFFF_t_70_pic_center]

**Dubbo的的特点**

*  通过`spring`配置的方式即可完成服务化，对于应用无入侵。（`Spring Cloud`有一定的入侵）
 *  通过`maven`的i`nstall &deploy`命令把`interface`和`Model`层发布到仓库中，服务调用方只需要依赖`interface`和`model`层即可。
 *  通过`zookeeper`设置达到注册服务和心跳检测，通过`gateWay`前置网关（`Spring Cloud`使用`Zuul`实现负载均衡将请求转向`Eureka`服务器）隔绝外部直接调用原子服务的风险

# SpringBoot中使用Dubbo #

## 引入依赖 ##

<dependency>
        <groupId>com.alibaba</groupId>
        <artifactId>dubbo</artifactId>
        <version>2.6.6</version>
    </dependency>
    
    
    <dependency>
        <groupId>org.apache.curator</groupId>
        <artifactId>curator-framework</artifactId>
        <version>4.0.1</version>
        <exclusions>
            <exclusion>
                <groupId>org.apache.zookeeper</groupId>
                <artifactId>zookeeper</artifactId>
            </exclusion>
        </exclusions>
    </dependency>
    
    
    <dependency>
        <groupId>org.apache.zookeeper</groupId>
        <artifactId>zookeeper</artifactId>
        <version>3.4.7</version>
    </dependency>

## dubbo常用配置及注意事项 ##

1、启动时检查
    缺省会在启动时检查依赖的服务是否可用，不可用时会抛出异常，阻止Spring初始化完成，以便上线时，能及早发现问题，默认check=true。
    
    
    关闭所有服务的启动时检查：(没有提供者时报错)
    <dubbo:consumer check="false" />
    
    
    关闭某个服务的启动时检查：(没有提供者时报错)
    <dubbo:reference interface="com.foo.BarService" check="false" />
    其它的启动时检查还包括：注册中心
    
    
    2、直连提供者
    在开发及测试环境下，经常需要绕过注册中心，只测试指定服务提供者，这时候可能需要点对点直连，
    点对点直联方式，将以服务接口为单位，忽略注册中心的提供者列表。
    <dubbo:reference id="xxxService" interface="com.alibaba.xxx.XxxService" url="dubbo://localhost:20890" />  
    
    
    3、服务分组
    当一个接口有多种实现时，可以用group区分。
    provider：
    <dubbo:service group="feedback" interface="com.xxx.IndexService" ref="indexServiceFeedback" />
    <dubbo:service group="member" interface="com.xxx.IndexService"   ref="indexServiceMember" />
    
    
    cosumer：
    <dubbo:reference id="feedbackIndexService" group="feedback" interface="com.xxx.IndexService" />
    <dubbo:reference id="memberIndexService" group="member" interface="com.xxx.IndexService" />
    
    
    4、多版本
    当一个接口实现，出现不兼容升级时，可以用版本号过渡，版本号不同的服务相互间不引用。
    一般处理步骤
    1）在低压力时间段，先升级一半提供者为新版本
    2）再将所有消费者升级为新版本
    3）然后将剩下的一半提供者升级为新版本
    <dubbo:service interface="com.foo.BarService" version="1.0.0" />
    <dubbo:service interface="com.foo.BarService" version="2.0.0" />
    5、异步调用
    可完成并行调用多个远程服务。异步总是不等待返回。
    <dubbo:reference id="fooService" interface="com.alibaba.foo.FooService">
        <dubbo:method name="findFoo" async="true" />
    </dubbo:reference>
    
    
    6、延迟暴露
    如果你的服务需要Warmup时间，比如初始化缓存，等待相关资源就位等，可以使用delay进行延迟暴露。
    <dubbo:provider delay="-1" />
    当然，也可以配置到服务级别，但有些需要地方需要注意。
    
    
    7、dubbo:protocol属性
    threadpool：线程池类型，可选：fixed/cached ，默认fixed 。
    threads ：服务线程池大小(固定大小) ，默认为100
    
    
    payload：请求及响应数据包大小限制，单位：字节，默认为88388608(=8M)
    如：<dubbo:protocol name="dubbo" port="27001" threadpool="cached" threads="20"/>
    
    
    ThreadPool
    fixed 固定大小线程池，启动时建立线程，不关闭，一直持有。(缺省)
    cached 缓存线程池，空闲一分钟自动删除，需要时重建。
    limited可伸缩线程池，但池中的线程数只会增长不会收缩。(为避免收缩时突然来了大流量引起的性能问题)。
    
    
    8、dubbo:application
    <dubbo:application name="xxx_service" />
    name必填。当前应用名称，用于注册中心计算应用间依赖关系，注意：消费者和提供者应用名不要一样

## dubbo服务提供者配置 ##

**dubbo-provider.xml** :通过配置`xml`的方式来配置`dubbo`服务的提供者

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://www.springframework.org/schema/beans"
           xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
           xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
           http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
    
        <dubbo:application name="usermanage" />
        <dubbo:registry id="zookeeper_service" protocol="zookeeper" address="127.0.0.1:2181" timeout="15"/>
    
        
        <dubbo:protocol name="dubbo"  port="20880"  threads="1000" />
    
        
        <dubbo:monitor protocol="registry" />
    
        
        <bean id="UserService" class="com.luo.service.impl.UserServiceImpl" />
        <dubbo:service interface="com.luo.service.IUserService" ref="UserService"
                       registry="zookeeper_service" />
    
    
    </beans>

## 在启动类引入配置类 ##

@SpringBootApplication(exclude = { DataSourceAutoConfiguration.class})
    @ImportResource({ "classpath:*dubbo-provider.xml"})
    public class UsermanageAPP extends SpringBootServletInitializer { 
        private static Logger logger= LogManager.getLogger(LogManager.ROOT_LOGGER_NAME);
    
        @Override
        protected SpringApplicationBuilder configure(SpringApplicationBuilder application) { 
            return application.sources(UsermanageAPP.class);
        }
    
        /** * 项目的启动方法 * @param args */
        public static void main(String[] args) { 
            SpringApplication.run(UsermanageAPP.class, args);
            logger.info("======服务已经启动========");
        }
    }

## 服务接口和服务实现类 ##

**服务接口**

public interface IUserService { 
        public String ceshi(String input);
    }

**服务的实现类**

public class UserServiceImpl implements IUserService { 
    
        @Override
        public String ceshi(String input) { 
            return "Hello World,"+input;
        }
    }

## dubbo服务调用者配置 ##

**dubbo-consumer.xml**:通过配置`xml`的方式来配置`dubbo`服务的消费者  
对于核心的业务：

*  `retries="0"`：关闭`dubbo`超时重试，即 超时不重试
 *  提高`timeout`（即超时时间），避免由于网络延迟导致业务流程超时

`Dubbo`的路由机制，会把超时的请求路由到其他机器上，而不是本机尝试，所以 `dubbo`的重试机器也能一定程度的保证服务的质量。

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://www.springframework.org/schema/beans"
           xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
           xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.2.xsd
           http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
    
        <dubbo:application name="nacos" />
        <dubbo:registry id="zookeeper_service" protocol="zookeeper" address="127.0.0.1:2181" timeout="15"/>
    
        
        <dubbo:reference id="user" interface="com.luo.service.IUserService" retries="0" timeout="50000" check="false"/>
    </beans>

## 在启动类引入配置类 ##

@SpringBootApplication(exclude = { DataSourceAutoConfiguration.class, SentinelCircuitBreakerAutoConfiguration.class})
    @ImportResource({ "classpath:*dubbo-consumer.xml"})
    public class NacosApp extends SpringBootServletInitializer { 
        private static Logger logger= LogManager.getLogger(LogManager.ROOT_LOGGER_NAME);
    
        @Override
        protected SpringApplicationBuilder configure(SpringApplicationBuilder application) { 
            return application.sources(NacosApp.class);
        }
    
        /** * 项目的启动方法 * @param args */
        public static void main(String[] args) { 
            SpringApplication.run(NacosApp.class, args);
            logger.info("======服务已经启动========");
        }
    }

## 服务接口和Controller层 ##

**服务接口**

public interface IUserService { 
        public String ceshi(String input);
    }

**Controller层**

@RestController
    public class TestController { 
    
        @Autowired
        IUserService userService;
    
        @RequestMapping("/ceshi")
        public String ceshi(){ 
            return userService.ceshi("luo");
        }
    
    
    }

## 分别启动生产者和消费者，访问消费者接口进行验证： ##

![在这里插入图片描述][20200807100334727.png_pic_center]

项目的源码：[github][]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDk5MDgxOA_size_16_color_FFFFFF_t_70_pic_center 1]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDk5MDgxOA_size_16_color_FFFFFF_t_70_pic_center]: /images/20221124/91f4454f2c2048daafe660692dda51a6.png
[20200807100334727.png_pic_center]: /images/20221124/a59015650a8e414487f47263cb5f2817.png
[github]: https://github.com/luo948521848/JavaWebs/tree/master/dubbo%E6%A8%A1%E6%9D%BF
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDk5MDgxOA_size_16_color_FFFFFF_t_70_pic_center 1]: /images/20221124/8af0efe1c3ef4f0ca03808f66bd68e57.png