【探花交友】day00—探花交友前置Dubbo(二)

简介: 【探花交友】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内置的重试机制

相关文章
|
1月前
|
负载均衡 监控 Dubbo
day00—探花交友前置Dubbo
day00—探花交友前置Dubbo
40 0
|
11月前
|
监控 负载均衡 Dubbo
【探花交友】day00—探花交友前置Dubbo(一)
【探花交友】day00—探花交友前置Dubbo
95 0
|
1月前
|
Dubbo Java 应用服务中间件
微服务学习 | Springboot整合Dubbo+Nacos实现RPC调用
微服务学习 | Springboot整合Dubbo+Nacos实现RPC调用
|
7月前
|
负载均衡 Dubbo 应用服务中间件
微服务技术系列教程(31) - Dubbo-原理及负载均衡分析
微服务技术系列教程(31) - Dubbo-原理及负载均衡分析
60 0
|
7月前
|
Dubbo Java 应用服务中间件
微服务技术系列教程(30) - Dubbo-SpringCloud与Dubbo区别
微服务技术系列教程(30) - Dubbo-SpringCloud与Dubbo区别
51 0
|
7月前
|
Dubbo Java 应用服务中间件
阿里新框架干掉微服务,换下Dubbo,Spring CloudAlibaba王者降临
tm快了,不知不觉中金九银十的秋招已经快结束了,不少同学现在已经拿到offer了吧~现在的面试可是越来越难了,动不动就是“互联网三高”。
阿里新框架干掉微服务,换下Dubbo,Spring CloudAlibaba王者降临
|
1月前
|
Dubbo Java 应用服务中间件
阿里巴巴资深架构师深度解析微服务架构设计之SpringCloud+Dubbo
软件架构是一个包含各种组织的系统组织,这些组件包括Web服务器,应用服务器,数据库,存储,通讯层),它们彼此或和环境存在关系。系统架构的目标是解决利益相关者的关注点。
|
21天前
|
Dubbo Cloud Native 应用服务中间件
【阿里云云原生专栏】云原生环境下的微服务治理:阿里云 Dubbo 与 Nacos 的深度整合
【5月更文挑战第25天】阿里云Dubbo和Nacos提供微服务治理的强大工具,整合后实现灵活高效的治理。Dubbo是高性能RPC框架,Nacos则负责服务发现和配置管理。整合示例显示,通过Nacos注册中心,服务能便捷注册发现,动态管理配置。简化部署,提升适应性,但也需注意服务稳定性和策略规划。这种整合为云原生环境的微服务架构带来强大支持,未来应用前景广阔。
214 2
|
1月前
|
Dubbo Java 应用服务中间件
Spring Cloud Dubbo: 微服务通信的高效解决方案
【4月更文挑战第28天】在微服务架构的发展中,服务间的高效通信至关重要。Spring Cloud Dubbo 提供了一种基于 RPC 的通信方式,使得服务间的调用就像本地方法调用一样简单。本篇博客将探讨 Spring Cloud Dubbo 的核心概念,并通过具体实例展示其在项目中的实战应用。
29 2
|
1月前
|
Cloud Native Dubbo 应用服务中间件
【Dubbo3高级特性】「微服务云原生架构」带你从零基础认识搭建公司内部服务用户中心体系(实战指南-序章)
【Dubbo3高级特性】「微服务云原生架构」带你从零基础认识搭建公司内部服务用户中心体系(实战指南-序章)
75 0