再见 Feign!推荐一款微服务间调用神器,跟 SpringCloud 绝配!
在微服务项目中,如果我们想实现服务间调用,一般会选择Feign。之前介绍过一款HTTP客户端工具
Retrofit
,配合SpringBoot非常好用!其实Retrofit
不仅支持普通的HTTP调用,还能支持微服务间的调用,负载均衡和熔断限流都能实现。今天我们来介绍下Retrofit
在Spring Cloud Alibaba下的使用,希望对大家有所帮助!
搭建
在使用之前我们需要先搭建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<User> getUser(@PathVariable Long id) {User user = userService.getUser(id);LOGGER.info("根据id获取用户信息,用户名称为:{}",user.getUsername());return new CommonResult<>(user);}@GetMapping("/getUserByIds")public CommonResult<List<User>> getUserByIds(@RequestParam List<Long> ids) {List<User> userList= userService.getUserByIds(ids);LOGGER.info("根据ids获取用户信息,用户列表为:{}",userList);return new CommonResult<>(userList);}@GetMapping("/getByUsername")public CommonResult<User> 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相关依赖;
<dependencies><!--Nacos注册中心依赖--><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId></dependency><!--Sentinel依赖--><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-sentinel</artifactId></dependency><!--Retrofit依赖--><dependency><groupId>com.github.lianjiatech</groupId><artifactId>retrofit-spring-boot-starter</artifactId><version>2.2.18</version></dependency></dependencies>
然后在
application.yml
中对Nacos、Sentinel和Retrofit进行配置,Retrofit配置下日志和开启熔断降级即可;
server:port: 8402
spring:application:name: nacos-retrofit-servicecloud:nacos:discovery:server-addr: localhost:8848 #配置Nacos地址sentinel:transport:dashboard: localhost:8080 #配置sentinel dashboard地址port: 8719
retrofit: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.*/
@Configuration
public 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<User> getUser(@Path("id") Long id);@GET("/user/getByUsername")CommonResult<User> 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 = "byResource",blockHandler = "handleException")public CommonResult byResource() {return new CommonResult("按资源名称限流", 200);}@ApiOperation("按URL限流,有默认的限流处理逻辑")@GetMapping("/byUrl")@SentinelResource(value = "byUrl",blockHandler = "handleException")public CommonResult byUrl() {return new CommonResult("按url限流", 200);}@ApiOperation("自定义通用的限流处理逻辑")@GetMapping("/customBlockHandler")@SentinelResource(value = "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 = "/fallback/{id}",method = RequestMethod.GET)@SentinelResource(value = "fallback",fallback = "handleFallback")public CommonResult fallback(@PathVariable Long id) {return userService.getUser(id);}@ApiOperation("忽略异常进行熔断降级")@RequestMapping(value = "/fallbackException/{id}",method = RequestMethod.GET)@SentinelResource(value = "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/springcloud-learning
往期推荐
Spring Cloud OpenFeign夺命连环9问,这谁受得了?
2022-02-18
玩转Nacos参数配置!多图勿点
2022-02-21
【万字长文】Spring Cloud Alibaba 开箱即用!
2022-02-16
求点赞、在看、分享三连
再见 Feign!推荐一款微服务间调用神器,跟 SpringCloud 绝配!相关推荐
- springcloud:Fegin实现微服务间调用
首先给大家看下目录结构,比如要调用basicdata项目,需新建一个basicdata-api 一.引入fegin包至pom文件,如上图中pom文件 二.创建微服务调用的接口文件 @FeignClie ...
- Feign实现微服务间调用返回stream
今天来讲述一下fegin的调用返回stream,得到stream我们可以下载,写入到页面展示图片等: 我们就开始讲述一下: 服务提供者流接口 @RequestMapping(value = " ...
- 2.微服务间调用ribbon
实例:订单服务调用商品服务 在订单服务调用商品服务的时候,首先要考虑负载均衡策略,为了体现出轮巡的结果,我们在商品服务输出的地方加上端口号,以区分是哪个节点. 1.ribbon (消费者) a.创建s ...
- Spring Cloud微服务之Feign——声明式服务间调用
目录 写在前面 服务间调用常见的方案 方案一:HttpClient 方案二:RestTemplate 方案三:Feign 框架版本问题及可能遇到的坑 搭建服务注册中心 搭建服务1--service-a ...
- spring cloud微服务之间调用Feign
微服务之间调用Feign 1.在调用方添加feign依赖: <dependency><groupId>org.springframework.cloud</groupId ...
- Spring Boot微服务间文件返回实现
Feign接口获取文件流问题_Java_wyazyf的博客-CSDN博客 https://blog.csdn.net/wyazyf/article/details/93200033 Spring Bo ...
- 微服务间用户信息共享机制
文章目录 前言 第一节 微服务间用户信息传递问题 第二节 解决思路 第三节 实践操作(基于Feign) 1. 调用链路说明 2. shop-common改造 3. 开启注解 4. 启动服务器测试 第四 ...
- Istio:一个用于微服务间通信的服务网格开源项目
http://www.infoq.com/cn/news/2017/05/istio Istio:一个用于微服务间通信的服务网格开源项目 Google.IBM和Lyft开源了微服务管理.保护和监控框架 ...
- dbnetlib不存在或拒绝访问_idou老师教你学Istio 16:如何用 Istio 实现微服务间的访问控制...
本文由华为云容器Istio团队撰稿,未经允许谢绝转载. 摘要 使用 Istio 可以很方便地实现微服务间的访问控制.本文演示了使用 Denier 适配器和黑白名单两种方法. 使用场景 有时需要对微服务 ...
最新文章
- Vue:Elementui中的Tag与页面其它元素相互交互的两三事
- 【例题 6-6 UVA - 679】Dropping Balls
- linux系列服务总结之四:SAMBA共享设置完整介绍
- 将Chrome设置为Jupyter_notebook的默认浏览器
- python open方法1001python open方法_怎样才能写出 Pythonic 的代码 #P1001#
- uc浏器保存html,UC浏览器不能保存历史记录
- 二进制数据与16进制字符串相互转化方法
- 斯皮尔曼等级相关(Spearman’s correlation coefficient for ranked data)
- 从Tiny-4412开箱到启动Linux内核
- c语言递归算法兔子问题,Java递归算法经典实例(经典兔子问题)
- 二进制数的加法步骤解析
- GEO数据库的使用(一)
- 切换svn地址报错issuer is not trusted
- js逆向-逆向部分技巧总结
- 推荐使用:易企在线客服升级版
- 华工的计算机专业硕士就业前景,这所热门地区的985就业率排名第一!不想了解下吗?...
- AutoJs学习-实现自动发邮件
- 【BIOS】debug命令清除bios密码
- php仿多玩我的世界盒子,多玩我的世界盒子最新版悬浮窗
- unescape,escape加密解密js
热门文章
- php进程通讯方式,PHP进程模型、进程通讯方式、进程线程的区别分别有哪些?
- Mysql截取中英数混合的字符串
- 新手教程:不写JS,在MIP页中实现异步加载数据
- Angular实现灵活的动态创建组件指令
- 【动态规划】魔法石矿
- DAY3-“忙里偷闲”找你玩耍2018-1-11
- Oracle-Decode()函数和CASE语句的不同
- GATK之VariantAnnotator
- reinterpret_cast和static_cast的总结
- CFD分析过程(CFD Analysis Process)