目录

• 前置知识
• 搭建
• 使用
• 集成与配置
• 服务间调用
• 服务限流
• 熔断降级
• 总结

前置知识
文章图片

在微服务项目中，如果我们想实现服务间调用，一般会选择Feign。之前介绍过一款HTTP客户端工具Retrofit，配合SpringBoot非常好用！其实Retrofit不仅支持普通的HTTP调用，还能支持微服务间的调用，负载均衡和熔断限流都能实现。今天我们来介绍下Retrofit在Spring Cloud Alibaba下的使用，希望对大家有所帮助！
SpringBoot实战电商项目mall（50k+star）地址：
【微服务间调用Retrofit在Spring|微服务间调用Retrofit在Spring Cloud Alibaba中的使用】https://github.com/macrozheng/mall
本文主要介绍Retrofit在Spring Cloud Alibaba下的使用，需要用到Nacos和Sentinel，对这些技术不太熟悉的朋友可以先参考下之前的文章。
Spring Cloud Alibaba：Nacos 作为注册中心和配置中心使用
Spring Cloud Alibaba：Sentinel实现熔断与限流
还在用HttpUtil？试试这款优雅的HTTP客户端工具吧，跟SpringBoot绝配！

搭建 在使用之前我们需要先搭建Nacos和Sentinel，再准备一个被调用的服务，使用之前的nacos-user-service即可。
首先从官网下载Nacos，这里下载的是nacos-server-1.3.0.zip文件，
下载地址：https://github.com/alibaba/nacos/releases

文章图片

解压安装包到指定目录，直接运行bin目录下的startup.cmd，运行成功后访问Nacos，账号密码均为nacos，访问地址：http://localhost:8848/nacos

文章图片

接下来从官网下载Sentinel，这里下载的是sentinel-dashboard-1.6.3.jar文件，
下载地址：https://github.com/alibaba/Sentinel/releases

文章图片

下载完成后输入如下命令运行Sentinel控制台；

java -jar sentinel-dashboard-1.6.3.jar

Sentinel控制台默认运行在8080端口上，登录账号密码均为sentinel，通过如下地址可以进行访问：http://localhost:8080

文章图片

接下来启动nacos-user-service服务，该服务中包含了对User对象的CRUD操作接口，启动成功后它将会在Nacos中注册。

/** * Created by macro on 2019/8/29. */@RestController@RequestMapping("/user")public class UserController {private Logger LOGGER = LoggerFactory.getLogger(this.getClass()); @Autowiredprivate UserService userService; @PostMapping("/create")public CommonResult create(@RequestBody User user) {userService.create(user); return new CommonResult("操作成功", 200); }@GetMapping("/{id}")public CommonResult getUser(@PathVariable Long id) {User user = userService.getUser(id); LOGGER.info("根据id获取用户信息，用户名称为：{}",user.getUsername()); return new CommonResult<>(user); }@GetMapping("/getUserByIds")public CommonResult> getUserByIds(@RequestParam List ids) {List userList= userService.getUserByIds(ids); LOGGER.info("根据ids获取用户信息，用户列表为：{}",userList); return new CommonResult<>(userList); }@GetMapping("/getByUsername")public CommonResult getByUsername(@RequestParam String username) {User user = userService.getByUsername(username); return new CommonResult<>(user); }@PostMapping("/update")public CommonResult update(@RequestBody User user) {userService.update(user); return new CommonResult("操作成功", 200); }@PostMapping("/delete/{id}")public CommonResult delete(@PathVariable Long id) {userService.delete(id); return new CommonResult("操作成功", 200); }}

使用 接下来我们来介绍下Retrofit的基本使用，包括服务间调用、服务限流和熔断降级。

集成与配置
首先在pom.xml中添加Nacos、Sentinel和Retrofit相关依赖；

com.alibaba.cloudspring-cloud-starter-alibaba-nacos-discoverycom.alibaba.cloudspring-cloud-starter-alibaba-sentinelcom.github.lianjiatechretrofit-spring-boot-starter2.2.18

然后在application.yml中对Nacos、Sentinel和Retrofit进行配置，Retrofit配置下日志和开启熔断降级即可；

server:port: 8402spring:application:name: nacos-retrofit-servicecloud:nacos:discovery:server-addr: localhost:8848 #配置Nacos地址sentinel:transport:dashboard: localhost:8080 #配置sentinel dashboard地址port: 8719retrofit:log:# 启用日志打印enable: true# 日志打印拦截器logging-interceptor: com.github.lianjiatech.retrofit.spring.boot.interceptor.DefaultLoggingInterceptor# 全局日志打印级别global-log-level: info# 全局日志打印策略global-log-strategy: body# 熔断降级配置degrade:# 是否启用熔断降级enable: true# 熔断降级实现方式degrade-type: sentinel# 熔断资源名称解析器resource-name-parser: com.github.lianjiatech.retrofit.spring.boot.degrade.DefaultResourceNameParser

• 再添加一个Retrofit的Java配置，配置好选择服务实例的Bean即可。

/** * Retrofit相关配置 * Created by macro on 2022/1/26. */@Configurationpublic class RetrofitConfig {@Bean@Autowiredpublic ServiceInstanceChooser serviceInstanceChooser(LoadBalancerClient loadBalancerClient) {return new SpringCloudServiceInstanceChooser(loadBalancerClient); }}

服务间调用
使用Retrofit实现微服务间调用非常简单，直接使用@RetrofitClient注解，通过设置serviceId为需要调用服务的ID即可；

/** * 定义Http接口，用于调用远程的User服务 * Created by macro on 2019/9/5. */@RetrofitClient(serviceId = "nacos-user-service", fallback = UserFallbackService.class)public interface UserService {@POST("/user/create")CommonResult create(@Body User user); @GET("/user/{id}")CommonResult getUser(@Path("id") Long id); @GET("/user/getByUsername")CommonResult getByUsername(@Query("username") String username); @POST("/user/update")CommonResult update(@Body User user); @POST("/user/delete/{id}")CommonResult delete(@Path("id") Long id); }

我们可以启动2个nacos-user-service服务和1个nacos-retrofit-service服务，此时Nacos注册中心显示如下；

文章图片

然后通过Swagger进行测试，调用下获取用户详情的接口，发现可以成功返回远程数据，访问地址：http://localhost:8402/swagger-ui/

文章图片

查看nacos-retrofit-service服务打印的日志，两个实例的请求调用交替打印，我们可以发现Retrofit通过配置serviceId即可实现微服务间调用和负载均衡。

文章图片


服务限流
Retrofit的限流功能基本依赖Sentinel，和直接使用Sentinel并无区别，我们创建一个测试类RateLimitController来试下它的限流功能；

/** * 限流功能 * Created by macro on 2019/11/7. */@Api(tags = "RateLimitController",description = "限流功能")@RestController@RequestMapping("/rateLimit")public class RateLimitController {@ApiOperation("按资源名称限流，需要指定限流处理逻辑")@GetMapping("/byResource")@SentinelResource(value = "https://www.it610.com/article/byResource",blockHandler = "handleException")public CommonResult byResource() {return new CommonResult("按资源名称限流", 200); }@ApiOperation("按URL限流，有默认的限流处理逻辑")@GetMapping("/byUrl")@SentinelResource(value = "https://www.it610.com/article/byUrl",blockHandler = "handleException")public CommonResult byUrl() {return new CommonResult("按url限流", 200); }@ApiOperation("自定义通用的限流处理逻辑")@GetMapping("/customBlockHandler")@SentinelResource(value = "https://www.it610.com/article/customBlockHandler", blockHandler = "handleException",blockHandlerClass = CustomBlockHandler.class)public CommonResult blockHandler() {return new CommonResult("限流成功", 200); }public CommonResult handleException(BlockException exception){return new CommonResult(exception.getClass().getCanonicalName(),200); }}

接下来在Sentinel控制台创建一个根据资源名称进行限流的规则；

文章图片

之后我们以较快速度访问该接口时，就会触发限流，返回如下信息。

文章图片


熔断降级
Retrofit的熔断降级功能也基本依赖于Sentinel，我们创建一个测试类CircleBreakerController来试下它的熔断降级功能；

/** * 熔断降级 * Created by macro on 2019/11/7. */@Api(tags = "CircleBreakerController",description = "熔断降级")@RestController@RequestMapping("/breaker")public class CircleBreakerController {private Logger LOGGER = LoggerFactory.getLogger(CircleBreakerController.class); @Autowiredprivate UserService userService; @ApiOperation("熔断降级")@RequestMapping(value = "https://www.it610.com/fallback/{id}",method = RequestMethod.GET)@SentinelResource(value = "https://www.it610.com/article/fallback",fallback = "handleFallback")public CommonResult fallback(@PathVariable Long id) {return userService.getUser(id); }@ApiOperation("忽略异常进行熔断降级")@RequestMapping(value = "https://www.it610.com/fallbackException/{id}",method = RequestMethod.GET)@SentinelResource(value = "https://www.it610.com/article/fallbackException",fallback = "handleFallback2", exceptionsToIgnore = {NullPointerException.class})public CommonResult fallbackException(@PathVariable Long id) {if (id == 1) {throw new IndexOutOfBoundsException(); } else if (id == 2) {throw new NullPointerException(); }return userService.getUser(id); }public CommonResult handleFallback(Long id) {User defaultUser = new User(-1L, "defaultUser", "123456"); return new CommonResult<>(defaultUser,"服务降级返回",200); }public CommonResult handleFallback2(@PathVariable Long id, Throwable e) {LOGGER.error("handleFallback2 id:{},throwable class:{}", id, e.getClass()); User defaultUser = new User(-2L, "defaultUser2", "123456"); return new CommonResult<>(defaultUser,"服务降级返回",200); }}

由于我们并没有在nacos-user-service中定义id为4的用户，调用过程中会产生异常，所以访问如下接口会返回服务降级结果，返回我们默认的用户信息。

文章图片


总结 Retrofit给了我们除Feign和Dubbo之外的第三种微服务间调用选择，使用起来还是非常方便的。记得之前在使用Feign的过程中，实现方的Controller经常要抽出一个接口来，方便调用方来实现调用，接口实现方和调用方的耦合度很高。如果当时使用的是Retrofit的话，这种情况会大大改善。总的来说，Retrofit给我们提供了更加优雅的HTTP调用方式，不仅是在单体应用中，在微服务应用中也一样！
参考资料
官方文档：https://github.com/LianjiaTech/retrofit-spring-boot-starter
项目源码地址 https://github.com/macrozheng/mall
以上就是微服务间调用Retrofit在Spring Cloud Alibaba中的使用的详细内容，更多关于Retrofit微服务调用Spring Cloud Alibaba的资料请关注脚本之家其它相关文章！

推荐阅读

• 

  盐水加白醋泡脚的好处 舒服每一晚
• 

  床单起球是质量问题吗
• 

  马上消费金融额度是多少
• 

  上环后图片 避孕环是什么样子图片
• 

  SpringBoot配置并使用Redis缓存服务
• 

  1秒钟等于几毫秒 一秒等于多少毫秒多少微秒
• 

  罗汉松有哪些品种如何区分
• 

  中年之殇
• 

  电脑里编程的软件有哪些，目前计算机编程的常用软件有什么
• 

  网易怒斥暴雪:离婚不离身 暴雪是不是网易的
• 

  cfree里面怎么一步一步分析结果
• 

  山东良法领导干部知识竞赛题目是什么？领导干部知识题库大全
• 

  95和98的暗语是什么意思 98是什么
• 

  vxlan 格式 分析
• 

  如何在手机上连接黑魂2服务器？ 黑魂2服务器怎么用手机
• 

  医生竟会对孕检女子做出这事，女子怀孕去医院检查
• 

  崩坏3新版本新增内容汇总 3.4版本相关调整内容前瞻
• 

  中国民俗的“鬼节”有哪些？中元节和清明节有什么区分？
• 

  张裕干红葡萄酒口感怎么样 张裕特选级干红葡萄酒怎么样
• 

  看财报|苏酒老二今世缘百亿冲刺第一战：7%的省外营收如何撬动全国化市场？｜ 看财报

• 周鸿祎|周鸿祎披露360 toN新战略，服务中小微企业是今年OKR
• 学习的三重境界
• 面试|网上疯传的《阿里Java架构师成长之路》！，网友瞬间沸腾了
• 投稿|抖音电商，流量尽头唯有直播间
• Mysql数据库按时间点恢复实战记录
• Java利用Geotools实现不同坐标系之间坐标转换
• 微软|【极客日报】约会网站228万用户数据遭泄露；Uber 大量高管离职；周鸿祎称360曾发现特斯拉有漏洞...
• 用单例的方法实现夜间模式
• 学习到底是怎样的
• 8月微软技术课程，欢迎参与！