【探花交友】day00—探花交友前置Dubbo（二）-阿里云开发者社区

【探花交友】day00—探花交友前置Dubbo（二）

2023-07-25 97

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

简介： 【探花交友】day00—探花交友前置Dubbo（二）

2.5、代码优化

将接口抽取为独立模块，并且把接口有关的domain都放到这个模块中

（1）创建user-api模块引入依赖

（2）将UserService接口和User对象导入user-api模块下

（3）User对象实现序列化接口

1. package cn.itcast.user.domain;
2. 
3. import lombok.Data;
4. 
5. import java.io.Serializable;
6. 
7. @Data
8. public class User implements Serializable {
9. private Long id;
10. private String username;
11. private String address;
12. }

3、Dubbo高级特性

3.2、超时与重试

服务消费者在调用服务提供者的时候发生了阻塞、等待的情形，这个时候，服务消费者会一直等待下去。

在某个峰值时刻，大量的请求都在同时请求服务消费者，会造成线程的大量堆积，势必会造成雪崩。

dubbo 利用超时机制来解决这个问题（使用timeout属性配置超时时间，默认值1000，单位毫秒）
若超时时间较短，当网络波动时请求就会失败，Dubbo通过重试机制避免此类问题的发生

user-consumer模块中添加配置信息

1. dubbo:
2.   registry:
3.     address: nacos://127.0.0.1:8848
4.   consumer:
5.     timeout: 3000
6.     retries: 0

3.3、启动检查

为了保障服务的正常可用，Dubbo 缺省会在启动时检查依赖的服务是否可用，不可用时会抛出异常

在正式环境这是很有必要的一项配置，可以保证整个调用链路的平稳运行

在开发时，往往会存在没有提供者的情况。由于启动检查的原因，可能导致开发测试出现问题

可以通过check=false关闭

user-consumer模块中添加配置信息

1. dubbo:
2.   registry:
3.     address: nacos://127.0.0.1:8848
4.   consumer:
5.     check: false

3.4、多版本

灰度发布：当出现新功能时，会让一部分用户先使用新功能，用户反馈没问题时，再将所有用户迁移到新功能。

Dubbo提供了提供者多版本的支持，平滑处理项目功能升级部署

（1）user-provider定义新的服务实现类UserServiceImpl2，指定版本

1. @DubboService(version = “2.0.0”)
2. public class UserServiceImpl2 implements UserService {
3.     …………
4. }

（2）user-consumer消费者调用时，指定版本调用

1. @RestController
2. @RequestMapping("/user")
3. public class UserController {
4. //引用远程服务
5. @DubboReference(version = "2.0.0")
6. private UserService userService;    
7.     ………
8. }

3.5、负载均衡

在集群部署时，Dubbo提供了4种负载均衡策略，帮助消费者找到最优提供者并调用

Random ：按权重随机，默认值。按权重设置随机概率。
RoundRobin ：按权重轮询
LeastActive：最少活跃调用数，相同活跃数的随机。
ConsistentHash：一致性 Hash，相同参数的请求总是发到同一提供者。

1. @RestController
2. @RequestMapping("/user")
3. public class UserController {
4. //引用远程服务
5. @DubboReference(loadbalance = "roundrobin")
6. private UserService userService;
7. }

4、SpringCloud整合Dubbo

通常来说，RPC协议比REST具有更好的性能。很多开发人员希望享受Spring Cloud的生态，同时有兼顾PRC的效率的效率。SpringCloud Alibaba很好的解决了这个问题。

4.1、功能概述

将Dubbo集成至SpringCloud主要是替换Ribbo或者Feign实现远程调用。加入Dubbo后，整体的架构如下：

4.2、入门案例

4.2.1、抽取接口

定义接口模块dubbo-api，并将UserService接口抽取到此模块下

1. package cn.itcast.dubbo.api;
2. 
3. 
4. import cn.itcast.dubbo.domain.User;
5. 
6. public interface UserService {
7. 
8.     User queryById(Long id);
9. }

4.2.2、项目依赖

父工程加入SpringCloud Alibaba依赖

1. <dependency>
2. <groupId>com.alibaba.cloud</groupId>
3. <artifactId>spring-cloud-alibaba-dependencies</artifactId>
4. <version>2.2.5.RELEASE</version>
5. <type>pom</type>
6. <scope>import</scope>
7. </dependency>

消费者和提供者引入nacos注册中心和Dubbo依赖

1. <!--nacos注册中心的依赖-->
2. <dependency>
3. <groupId>com.alibaba.cloud</groupId>
4. <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
5. </dependency>
6. 
7. <!--springcloud alibaba dubbo依赖   -->
8. <dependency>
9. <groupId>com.alibaba.cloud</groupId>
10. <artifactId>spring-cloud-starter-dubbo</artifactId>
11. </dependency>
12. 
13. <dependency>
14. <groupId>cn.itcast</groupId>
15. <artifactId>dubbo-api</artifactId>
16. <version>1.0-SNAPSHOT</version>
17. </dependency>

4.2.3、服务提供者

修改UserService实现UserApi接口。并使用@DubboService注解替换@Service对外暴露dubbo服务

1. package cn.itcast.user.service;
2. 
3. import cn.itcast.dubbo.api.UserService;
4. import cn.itcast.dubbo.domain.User;
5. import cn.itcast.user.mapper.UserMapper;
6. import org.apache.dubbo.config.annotation.DubboService;
7. import org.springframework.beans.factory.annotation.Autowired;
8. 
9. @DubboService
10. public class UserServiceImpl implements UserService {
11. 
12. @Autowired
13. private UserMapper userMapper;
14. 
15. public User queryById(Long id) {
16. return userMapper.findById(id);
17.     }
18. }

在application.yml中添加配置

1. spring:
2.   datasource:
3.     url: jdbc:mysql://localhost:3306/dubbo-demo?useSSL=false
4.     username: root
5.     password: root
6.     driver-class-name: com.mysql.jdbc.Driver
7.   application:
8.     name: user-service
9.   cloud:
10.     nacos:
11.       discovery:
12.         server-addr: localhost:8848
13. #配置dubbo，注册中心，暴露的端口和协议，dubbo注解的包扫描
14. dubbo:
15.   protocol:
16.     name: dubbo
17.     port: 20881
18.   registry:
19.     address: spring-cloud://localhost   #使用SpringCloud中的注册中心
20.   scan:
21.     base-packages: cn.itcast.user.service  #dubbo中包扫描

4.2.4、服务消费者

在OrderController中引入dubbo服务。调用UserService查询用户

1. package cn.itcast.order.controller;
2. 
3. import cn.itcast.dubbo.api.UserService;
4. import cn.itcast.dubbo.domain.Order;
5. import cn.itcast.dubbo.domain.User;
6. import cn.itcast.order.service.OrderService;
7. import org.apache.dubbo.config.annotation.DubboReference;
8. import org.springframework.beans.factory.annotation.Autowired;
9. import org.springframework.web.bind.annotation.GetMapping;
10. import org.springframework.web.bind.annotation.PathVariable;
11. import org.springframework.web.bind.annotation.RequestMapping;
12. import org.springframework.web.bind.annotation.RestController;
13. 
14. @RestController
15. @RequestMapping("order")
16. public class OrderController {
17. 
18. @Autowired
19. private OrderService orderService;
20. 
21. @DubboReference
22. private UserService userService;
23. 
24. @GetMapping("{orderId}")
25. public Order queryOrderByUserId(@PathVariable("orderId") Long orderId) {
26. //根据id查询订单
27. Order order = orderService.queryOrderById(orderId);
28. //获取用户id
29. Long userId = order.getUserId();
30. //查询用户
31. User user = userService.queryById(userId);
32. //设置用户对象
33.         order.setUser(user);
34. // 根据id查询订单并返回
35. return order;
36.     }
37. }

在Order-service的模块中添加dubbo配置

1. spring:
2.   application:
3.     name: order-service
4.   cloud:
5.     nacos:
6.       discovery:
7.         server-addr: localhost:8848
8. #dubbo配置
9. dubbo:
10.   registry:
11.     address: spring-cloud://localhost  #使用cloud的注册中心
12.   consumer:
13.     check: false   #dubbo默认有启动检查
14.     retries: 0     #dubbo内置的重试机制

【探花交友】day00—探花交友前置Dubbo（二）

2.5、代码优化

3、Dubbo高级特性

3.2、超时与重试

3.3、启动检查

3.4、多版本

3.5、负载均衡

4、SpringCloud整合Dubbo

4.1、功能概述

4.2、入门案例

热门文章

最新文章

相关课程

相关电子书

相关实验场景