再见 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

f695395ee9cd7fc763cbd399232bd445.png

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

7f210737d7b80b4e13233f922e7b5aab.png

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

d160994aa29ee9fcc7e75492e2d25937.png

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

java -jar sentinel-dashboard-1.6.3.jar

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

10c9f1c09fced198ef71b8ce358523ca.png

  • 接下来启动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注册中心显示如下；

f4c089d4120cf45d8c3b8c70f96b1367.png

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

5f186c286df7a7ec2b1e226d44478478.png

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

2780386f1bee4c20d713e0b6b8da6e4f.png

服务限流

  • 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控制台创建一个根据资源名称进行限流的规则；

7029819e2c48e5bdb481e25d670ab031.png

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

a8b1263aa7c00d4b028fef4c4896d3ae.png

熔断降级

  • 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的用户，调用过程中会产生异常，所以访问如下接口会返回服务降级结果，返回我们默认的用户信息。

b6d409df540dbe1e0b3b7796c74533c5.png

总结

Retrofit给了我们除Feign和Dubbo之外的第三种微服务间调用选择，使用起来还是非常方便的。记得之前在使用Feign的过程中，实现方的Controller经常要抽出一个接口来，方便调用方来实现调用，接口实现方和调用方的耦合度很高。如果当时使用的是Retrofit的话，这种情况会大大改善。总的来说，Retrofit给我们提供了更加优雅的HTTP调用方式，不仅是在单体应用中，在微服务应用中也一样！

参考资料

官方文档：https://github.com/LianjiaTech/retrofit-spring-boot-starter

项目源码地址

https://github.com/macrozheng/springcloud-learning

ee1a3fabacd37fb05007f68109520da9.gif

往期推荐

Spring Cloud OpenFeign夺命连环9问，这谁受得了？

2022-02-18

24574a1e361e7e6e25a7e167cde10199.png

玩转Nacos参数配置！多图勿点

2022-02-21

d323c2243dd812732b4eac48916c3869.png

【万字长文】Spring Cloud Alibaba  开箱即用！

2022-02-16

16128d38a167b135451943d8f9b314a9.png

求点赞、在看、分享三连21186a64de5fd24823e67ab287b0a9fa.png

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/544286.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

ruby array_Ruby中带有示例的Array.delete_if方法

ruby array_Ruby中带有示例的Array.delete_if方法

ruby arrayRuby Array.delete_if方法 (Ruby Array.delete_if Method) In the last articles, we have studied the Array methods namely Array.select, Array.reject and Array.drop_While, all these methods are non–destructive methods which means that they do not imp…
阅读更多...
UIViewController生命周期的理解

UIViewController生命周期的理解

if (self [super init])》if (self [super initWithNibName:nibNameOrNil bundle:nibBundleOrNil]) 》- (void)viewDidLoad{ [super viewDidLoad]; NSLog("---111111");} 》if (self [super initWithNibName:nibNameOrNil bundle:nibBundleOrNil]) { …
阅读更多...
Spring Cloud Alibaba Nacos 的 2 种健康检查机制！

Spring Cloud Alibaba Nacos 的 2 种健康检查机制！

作者 | 磊哥来源 | Java中文社群&#xff08;ID&#xff1a;javacn666&#xff09;转载请联系授权&#xff08;微信ID&#xff1a;GG_Stone&#xff09;Spring Cloud Alibaba Nacos 作为注册中心不止提供了服务注册和服务发现功能&#xff0c;它还提供了服务可用性监测的机制。…
阅读更多...
在Python中使用一个元素创建一个元组

在Python中使用一个元素创建一个元组

Its not simple to create a tuple with one element, if we try to create a tuple with parenthesis or without parenthesis, tuple will not be created. 创建具有一个元素的元组并不简单&#xff0c;如果我们尝试创建带有括号或不带括号的元组&#xff0c;则不会创建元组。…
阅读更多...
Python之包管理工具

Python之包管理工具

在Python环境中已经有很多成熟的包&#xff0c;可以通过安装这些包来扩展我们的程序。 例如&#xff0c;很多时候Python开发人员都会去PyPI网站去查找自己想要使用的包&#xff0c;然后进行安装。PyPI &#xff08; Python Package Index&#xff09;是获得第三方 Python 软件包…
阅读更多...
为什么wait和notify必须放在synchronized中？

为什么wait和notify必须放在synchronized中？

作者 | 磊哥来源 | Java面试真题解析&#xff08;ID&#xff1a;aimianshi666&#xff09;转载请联系授权&#xff08;微信ID&#xff1a;GG_Stone&#xff09;在多线程编程中&#xff0c;wait 方法是让当前线程进入休眠状态&#xff0c;直到另一个线程调用了 notify 或 notify…
阅读更多...
java字符串转字符串列表_Java中的字符串列表示例

java字符串转字符串列表_Java中的字符串列表示例

java字符串转字符串列表We have to read total number string i.e. "n", create a list of the Strings and input "n" strings, add then to print the all stings of the list in Java. 我们必须读取总数字符串&#xff0c;即“ n”&#xff0c;创建字符…
阅读更多...
聊聊并发编程的10个坑

聊聊并发编程的10个坑

前言对于从事后端开发的同学来说&#xff0c;并发编程肯定再熟悉不过了。说实话&#xff0c;在java中并发编程是一大难点&#xff0c;至少我是这么认为的。不光理解起来比较费劲&#xff0c;使用起来更容易踩坑。不信&#xff0c;让继续往下面看。今天重点跟大家一起聊聊并发编…
阅读更多...
macbook终端使用记（二）终端快捷键

macbook终端使用记（二）终端快捷键

为什么80%的码农都做不了架构师&#xff1f;>>> Command K清屏 Command T新建标签 Command M最小化窗口 Command W 关闭当前标签页 Command S 保存终端输出 Command D 垂直分隔当前标签页 Command Shift D 水平分隔当前标签页 Command shift {或}向左/向…
阅读更多...
uint32_t 是常数吗_UINT_MAX常数，带C ++示例

uint32_t 是常数吗_UINT_MAX常数，带C ++示例

uint32_t 是常数吗C UINT_MAX宏常量 (C UINT_MAX macro constant) UINT_MAX constant is a macro constant which is defied in climits header, it is used to get the minimum value of an unsigned int object, it returns the minimum value that an unsigned int object …
阅读更多...
颜值爆表！Redis 官方可视化工具来啦，功能真心强大！

颜值爆表！Redis 官方可视化工具来啦，功能真心强大！

最近逛了一下Redis官方网站&#xff0c;发现Redis不仅推出了很多新特性&#xff0c;而且还发布了一款可视化工具RedisInsight。试用了一下感觉非常不错&#xff0c;最关键的是能支持RedisJSON之类的新特性&#xff0c;这是第三方工具无法比拟的。今天带大家体验一下RedisInsigh…
阅读更多...
20个响应式网页设计中的“神话”误区

20个响应式网页设计中的“神话”误区

关于响应式网页的重要性我们已经证实了很长时间了&#xff0c;现在是该把焦点放到如何做出好的响应式网页设计的时候了。一起来看看吧&#xff01; 虽然很多人都在谈论响应式网页&#xff0c;但并不是每个人都知道他们在说什么。很多时候你看到网上的一些信息也在挑战你对响应式…
阅读更多...
char 类型的常数_CHAR_MAX常数，带C ++示例

char 类型的常数_CHAR_MAX常数，带C ++示例

char 类型的常数C CHAR_MAX宏常量 (C CHAR_MAX macro constant) CHAR_MAX constant is a macro constant which is defied in climits header, it is used to get the maximum value of a char object, it returns the maximum value that a char object can store, which is …
阅读更多...
MySQL 索引失效的 15 种场景！

MySQL 索引失效的 15 种场景！

背景 无论你是技术大佬&#xff0c;还是刚入行的小白&#xff0c;时不时都会踩到Mysql数据库不走索引的坑。常见的现象就是&#xff1a;明明在字段上添加了索引&#xff0c;但却并未生效。前些天就遇到一个稍微特殊的场景&#xff0c;同一条SQL语句&#xff0c;在某些参数下生效…
阅读更多...
如何对手机使用adb

如何对手机使用adb

因为要配合前端做测试&#xff0c;所以我需要在本机中安装adb驱动&#xff0c;以便可以连接手机进行各种操作。 好吧。。。装adb驱动这块当时我没有把流程给做记录。。。郁闷&#xff0c;下次再安装的时候再谷歌吧。 使用的简单脚本就是 有没有连接设备&#xff1a;adb devices…
阅读更多...
scala 转换为字符串_如何在Scala中将字符串转换为布尔值？

scala 转换为字符串_如何在Scala中将字符串转换为布尔值？

scala 转换为字符串String in Scala is a sequence of characters. In Scala, the String object is immutable. Scala中的String是一个字符序列。 在Scala中&#xff0c;String对象是不可变的。 Example: 例&#xff1a; String("includehelp.com")A Boolean is a…
阅读更多...
Java夺命21连问！（附答案）

Java夺命21连问！（附答案）

大家好&#xff0c;我是磊哥。有位朋友工作三年&#xff0c;去面试&#xff0c;给大家整理一下面试题&#xff0c;并附上答案。Mysql索引在什么情况下会失效MySql的存储引擎InnoDB与MyISAM的区别Mysql在项目中的优化场景&#xff0c;慢查询解决等Mysql有什么索引&#xff0c;索…
阅读更多...
固有属性与自定义属性

固有属性与自定义属性

javascript有两个很相近的东西&#xff0c;property与attribute&#xff0c;懒一点的人都翻译成“属性”。 如果专业点&#xff0c;则区别为“属性”与“特性”。我认为叫做固有属性与自定义属性比较好一点。 property是来自于原型链&#xff0c;所有HTML元素&#xff0c;都是H…
阅读更多...
weakhashmap_Java WeakHashMap get（）方法与示例

weakhashmap_Java WeakHashMap get（）方法与示例

weakhashmapWeakHashMap类的get()方法 (WeakHashMap Class get() method) get() method is available in java.util package. get()方法在java.util包中可用。 get() method is used to get the value to which the given key element (key_ele) associated in this map otherw…
阅读更多...
SpringCloud Nacos + Ribbon 调用服务的 2 种方法！

SpringCloud Nacos + Ribbon 调用服务的 2 种方法！

作者 | 磊哥来源 | Java中文社群&#xff08;ID&#xff1a;javacn666&#xff09;转载请联系授权&#xff08;微信ID&#xff1a;GG_Stone&#xff09;在 Nacos 中&#xff0c;服务调用主要是通过 RestTemplate Ribbon 实现的&#xff0c;RestTemplate 是 Spring 提供的 Rest…
阅读更多...
最新文章

Copyright @ 2022~2023