Spring Cloud Ribbon：负载均衡的服务调用

Spring Cloud Ribbon：负载均衡的服务调用

Spring Cloud Ribbon 是Spring Cloud Netflix 子项目的核心组件之一，主要给服务间调用及API网关转发提供负载均衡的功能，本文将对其用法进行详细介绍

Ribbon简介

Ribbon 是 Netflix 公司开源的一个用于负载均衡的客户端组件，它是 Spring Cloud 生态系统中的一部分；Ribbon 的主要目标是提供一种简单且可定制的负载均衡解决方案，用于在微服务架构中实现服务之间的调用和负载均衡

RestTemplate

RestTemplate 是 Spring Framework 提供的一个用于进行 HTTP 请求的客户端工具类；简化了在 Java 应用程序中进行 HTTP 通信的过程，并提供了丰富的方法来处理请求和响应


RestTemplate 提供了各种方法来执行不同类型的 HTTP 请求，包括 GET、POST、PUT、DELETE 等；支持发送请求并接收响应的各种数据类型，如字符串、字节数组、JSON 对象等

GET请求方法

<T> T getForObject(String url, Class<T> responseType, Object... uriVariables);<T> T getForObject(String url, Class<T> responseType, Map<String, ?> uriVariables);<T> T getForObject(URI url, Class<T> responseType);<T> ResponseEntity<T> getForEntity(String url, Class<T> responseType, Object... uriVariables);<T> ResponseEntity<T> getForEntity(String url, Class<T> responseType, Map<String, ?> uriVariables);<T> ResponseEntity<T> getForEntity(URI var1, Class<T> responseType);

POST请求方法

<T> T postForObject(String url, @Nullable Object request, Class<T> responseType, Object... uriVariables);<T> T postForObject(String url, @Nullable Object request, Class<T> responseType, Map<String, ?> uriVariables);<T> T postForObject(URI url, @Nullable Object request, Class<T> responseType);<T> ResponseEntity<T> postForEntity(String url, @Nullable Object request, Class<T> responseType, Object... uriVariables);<T> ResponseEntity<T> postForEntity(String url, @Nullable Object request, Class<T> responseType, Map<String, ?> uriVariables);<T> ResponseEntity<T> postForEntity(URI url, @Nullable Object request, Class<T> responseType);

PUT请求方法

void put(String url, @Nullable Object request, Object... uriVariables);void put(String url, @Nullable Object request, Map<String, ?> uriVariables);void put(URI url, @Nullable Object request);

DELETE请求方法

void delete(String url, Object... uriVariables);void delete(String url, Map<String, ?> uriVariables);void delete(URI url);

创建user-service模块

创建user-service，用于给Ribbon提供服务调用

  • 添加依赖
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId>
</dependency>
  • 添加application.yml配置
server:port: 8201
spring:application:name: user-service
eureka:client:register-with-eureka: truefetch-registry: trueservice-url:defaultZone: http://localhost:8001/eureka/
  • 添加UserController用于提供调用接口
/*** 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);}
}

创建ribbon-service模块

创建ribbon-service模块调用user-service模块演示负载均衡的服务调用

  • 添加依赖
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
</dependency>
  • 配置application.yml

配置端口、注册中心地址及user-service的调用路径

server:port: 8301
spring:application:name: ribbon-service
eureka:client:register-with-eureka: truefetch-registry: trueservice-url:defaultZone: http://localhost:8001/eureka/
service-url:user-service: http://user-service

负载均衡

  • @LoadBalanced注解赋予RestTemplate负载均衡的能力
/*** Created by macro on 2019/8/29.*/
@Configuration
public class RibbonConfig {@Bean@LoadBalancedpublic RestTemplate restTemplate(){return new RestTemplate();}
}
  • 添加UserRibbonController类

注入RestTemplate，使用其调用user-service中提供的相关接口

/*** Created by macro on 2019/8/29.*/
@RestController
@RequestMapping("/user")
public class UserRibbonController {@Autowiredprivate RestTemplate restTemplate;@Value("${service-url.user-service}")private String userServiceUrl;@GetMapping("/{id}")public CommonResult getUser(@PathVariable Long id) {return restTemplate.getForObject(userServiceUrl + "/user/{1}", CommonResult.class, id);}@GetMapping("/getByUsername")public CommonResult getByUsername(@RequestParam String username) {return restTemplate.getForObject(userServiceUrl + "/user/getByUsername?username={1}", CommonResult.class, username);}@GetMapping("/getEntityByUsername")public CommonResult getEntityByUsername(@RequestParam String username) {ResponseEntity<CommonResult> entity = restTemplate.getForEntity(userServiceUrl + "/user/getByUsername?username={1}", CommonResult.class, username);if (entity.getStatusCode().is2xxSuccessful()) {return entity.getBody();} else {return new CommonResult("操作失败", 500);}}@PostMapping("/create")public CommonResult create(@RequestBody User user) {return restTemplate.postForObject(userServiceUrl + "/user/create", user, CommonResult.class);}@PostMapping("/update")public CommonResult update(@RequestBody User user) {return restTemplate.postForObject(userServiceUrl + "/user/update", user, CommonResult.class);}@PostMapping("/delete/{id}")public CommonResult delete(@PathVariable Long id) {return restTemplate.postForObject(userServiceUrl + "/user/delete/{1}", null, CommonResult.class, id);}
}

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

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

相关文章

Python中模块与包

Python中模块与包

1. 模块 在Python中&#xff0c;模块是一个包含Python代码的文件&#xff0c;可以包含函数、类和变量。模块使得代码的组织和复用变得更简单。 导入模块 使用import语句可以导入模块。常用的标准库模块包括math和random。 示例&#xff1a;使用math和random模块 import ma…
阅读更多...
Node.js：Express 服务 路由

Node.js：Express 服务 路由

Node.js&#xff1a;Express 服务 & 路由 创建服务处理请求req对象 静态资源托管托管多个资源挂载路径前缀 路由模块化 Express是Node.js上的一个第三方框架&#xff0c;可以快速开发一个web框架。本质是一个包&#xff0c;可以通过npm直接下载。 创建服务 Express创建一…
阅读更多...
TensorRT-LLM的k8s弹性伸缩部署方案

TensorRT-LLM的k8s弹性伸缩部署方案

Scaling LLMs with NVIDIA Triton and NVIDIA TensorRT-LLM Using Kubernetes | NVIDIA Technical Blog 一共涉及4个k8s组件&#xff1a; 1. Deployment&#xff1a;跑起来N个pod&#xff1b;指定NVIDIA官方的triton&trt-llm的docker image&#xff0c;指定好model放在哪个…
阅读更多...
运维监控丨16条常用的Kafka看板监控配置与告警规则

运维监控丨16条常用的Kafka看板监控配置与告警规则

本期我们针对企业运维监控的场景&#xff0c;介绍一些监控配置和告警规则。可以根据Kafka集群和业务的具体要求&#xff0c;灵活调整和扩展这些监控配置及告警规则。在实际应用场景中&#xff0c;需要综合运用多种监控工具&#xff08;例如Prometheus、Grafana、Zabbix等&#…
阅读更多...
《基于数据库数据的迁移学习应用》

《基于数据库数据的迁移学习应用》

《基于数据库数据的迁移学习应用》 一、引言二、迁移学习概述&#xff08;一&#xff09;迁移学习的定义和原理&#xff08;二&#xff09;迁移学习的分类&#xff08;三&#xff09;迁移学习的优势 三、数据库的类型与特点&#xff08;一&#xff09;关系型数据库&#xff08;…
阅读更多...
Dockerfile制作Oracle19c镜像

Dockerfile制作Oracle19c镜像

Dockerfile文件 cat > Dockerfile << EOF # 使用 Oracle Linux 8 作为基础镜像 FROM oraclelinux:8# 复制 Oracle 19c 安装包 COPY oracle-database-ee-19c-1.0-1.x86_64.rpm /tmp/# 安装 Oracle 19c 数据库和依赖 RUN yum localinstall -y /tmp/oracle-database-ee-…
阅读更多...
6.0、静态路由

6.0、静态路由

路由器最主要的功能就是转发数据包。路由器转发数据包时需要查找路由表&#xff08;你可以理解为地图&#xff09;&#xff0c;管理员可以直接手动配置路由表&#xff0c;这就是静态路由。 1.什么是路由&#xff1f; 在网络世界中&#xff0c;路由是指数据包在网络中的传输路…
阅读更多...
Java如何实现企业微信审批流程

Java如何实现企业微信审批流程

大家好&#xff0c;我是 V 哥。最近的一个项目中&#xff0c;用到企业微信的审批流程&#xff0c;整理出来分享给大家。在企业微信中实现审批流程可以通过调用企业微信的开放API完成&#xff0c;企业微信提供了审批应用接口&#xff0c;用于创建审批模板、发起审批流程以及获取…
阅读更多...
4. 类和对象(下)

4. 类和对象(下)

1. 初始化列表 • 之前我们实现构造函数时&#xff0c;初始化成员变量主要使⽤函数体内赋值&#xff0c;构造函数初始化还有⼀种⽅ 式&#xff0c;就是初始化列表&#xff0c;初始化列表的使⽤⽅式是以⼀个冒号开始&#xff0c;接着是⼀个以逗号分隔的数据成 员列表&#xff0c…
阅读更多...
AI驱动的医疗创新：信息抽取与知识图谱在临床应用中的转变

AI驱动的医疗创新：信息抽取与知识图谱在临床应用中的转变

一、思通数科平台支持多种输入格式&#xff0c;如电子病历、临床数据和医学文献等&#xff0c;并能将这些信息快速转换为结构化数据&#xff0c;包括自动360度不同角度的旋转识别&#xff0c;提升数据的可操作性和可检索性。通过我们的解决方案&#xff0c;医疗机构能够有效整合…
阅读更多...
线程的joinable属性，以及主线程出现异常时，对其等待应该进行的处理

线程的joinable属性，以及主线程出现异常时，对其等待应该进行的处理

在C多线程编程中&#xff0c;线程的 joinable 属性是一个重要的概念&#xff0c;用于判断线程是否可以调用 join() 或 detach() 方法。当线程已经调用过 join() 或 detach() 之后&#xff0c;它将不再 joinable&#xff0c;此时调用 join() 或 detach() 会导致程序崩溃。 此外…
阅读更多...
关注！这些型号SSD有Windows蓝屏问题需要修复

关注！这些型号SSD有Windows蓝屏问题需要修复

近期&#xff0c;在闪迪官方有一个SSD FW升级提醒&#xff0c;主要是为了解决Windows 11 24H2系统蓝屏的问题&#xff1a; Fix问题&#xff1a;这些SSD的主机内存缓冲区&#xff08;Host Memory Buffer&#xff0c;简称HMB&#xff09;功能可能会导致系统出现蓝屏死机&#xff…
阅读更多...
Rust 力扣 - 1461. 检查一个字符串是否包含所有长度为 K 的二进制子串

Rust 力扣 - 1461. 检查一个字符串是否包含所有长度为 K 的二进制子串

文章目录 题目描述题解思路题解代码题目链接 题目描述 题解思路 长度为k的二进制子串所有取值的集合为[0, sum(k)]&#xff0c;其中sum(k)为1 2 4 … 1 << (k - 1) 我们只需要创建一个长度为sum(k) 1的数组 f &#xff0c;其中下标为 i 的元素用来标记字符串中子串…
阅读更多...
xtu oj 连接字符串

xtu oj 连接字符串

文章目录 回顾思路代码 回顾 AB III问题 H: 三角数问题 G: 3个数等式 数组下标查询&#xff0c;降低时间复杂度1405 问题 E: 世界杯xtu 数码串xtu oj 神经网络xtu oj 1167 逆序数&#xff08;大数据&#xff09;xtu oj 原根xtu oj 不定方程的正整数解xtu oj 最多的可变换字符串…
阅读更多...
如何编写STM32的定时器程序

如何编写STM32的定时器程序

编写STM32的定时器程序通常涉及以下步骤&#xff1a; 1. 选择定时器和时钟配置 首先&#xff0c;你需要选择一个可用的定时器&#xff08;TIM&#xff09;&#xff0c;并配置其时钟源。时钟源可以是内部时钟或外部时钟&#xff0c;通常通过RCC&#xff08;Reset and Clock Con…
阅读更多...
gradle的安装及其配置

gradle的安装及其配置

1、下载网址 Gradle | Releases 2、 3、配置环境变量 4、 5、cmd输入gradle-v查看版本
阅读更多...
数据结构与算法基础总结

数据结构与算法基础总结

为什么学习数据结构与算法&#xff1f; 关于数据结构和算法&#xff0c;以前只是看过一些零散的文章或者介绍&#xff0c;从来都没有系统的去学习过。随着工作之余&#xff0c;看了几本书&#xff0c;读了一些高质量的专栏&#xff0c;也接触了一些有关梦想的故事&#xff0c;发…
阅读更多...
在工作中常用到的 Linux 命令总结

在工作中常用到的 Linux 命令总结

引言 我之前找工作面试的时候。几乎每次面试几乎都会问到 Linux 常用命令&#xff0c;会问一些命令的应用场景。目的是考察我们是否在实际开发中经常用、用得熟练。今天我就来系统地总结一下开发过程中最常用的 Linux 命令&#xff0c;算是一个复习总结。 基本操作 文件管理…
阅读更多...
VB中的单元测试（Unit Testing）和集成测试（Integration Testing）

VB中的单元测试（Unit Testing）和集成测试（Integration Testing）

在VB&#xff08;Visual Basic&#xff09;中&#xff0c;单元测试&#xff08;Unit Testing&#xff09;和集成测试&#xff08;Integration Testing&#xff09;是软件开发过程中至关重要的两个环节&#xff0c;它们分别关注于不同的测试层面和目标。以下是对这两种测试方法的…
阅读更多...
Uniapp打包发布App Store时(90894)错误

Uniapp打包发布App Store时(90894)错误

Missing Info.plist value. Apps with the com.apple.developer.usernotifications.communication entitlement must specify either “INSendMessageIntent” or “INStartCallIntent” in the value of the NSUserActivityTypes Info.plist key. (90894) 解决： 这个警告是…
阅读更多...
最新文章

Copyright @ 2022~2023