springcloud中Ribbon和RestTemplate实现服务调用与负载均衡
作者:何羡仙 发布时间:2022-06-30 14:58:45
标签:springcloud,服务调用,负载均衡
文件目录结构
文件目录结构很重要,特别注意的是rule文件要放在主启动类上一级位置,才能够扫描。
写pom
<dependencies>
<!--springboot 2.2.2-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!--Spring cloud Hoxton.SR1-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<!--Spring cloud alibaba 2.1.0.RELEASE-->
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<optional>true</optional>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<!--Eureka-Client-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
因为eureka的依赖已经整合了ribbon的依赖,所以不用额外引入新的东西。
改yml
server:
port: 80
spring:
application:
name: cloud-book-consumer
eureka:
client:
register-with-eureka: false
fetch-registry: true
service-url:
defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka
主启动
@SpringBootApplication
@EnableEurekaClient
@RibbonClient(name = "CLOUD-BOOK-SERVICE", configuration = LoadBalanceRule.class) //更换轮询算法
public class RestTemplateMain80 {
public static void main(String[] args) {
SpringApplication.run(RestTemplateMain80.class,args);
}
}
业务逻辑
rules层
在图示文件目录下新建LoadBalanceRule.class,用于更换负载均衡算法。
@Configuration
public class LoadBalanceRule {
@Bean
public IRule iRule() {
// 定义为随机
return new RandomRule();
}
}
config层
开启restTemplate负载均衡
在config文件夹下创建LoadBalanceConfig.class
@Configuration
public class LoadBalanceConfig {
@Bean
@LoadBalanced //开启负载均衡
public RestTemplate getReatTemplate(){
return new RestTemplate();
}
}
controller层
新建BookController.class
写业务代码
@RestController
@Slf4j
public class BookController {
@Resource
private RestTemplate restTemplate;
public static final String PAYMENT_URL = "http://CLOUD-BOOK-SERVICE";
@GetMapping(value = "restTemplate/book/getAllBooks")//只要json数据时
public CommonResult getAllBooks(){
return restTemplate.getForObject(PAYMENT_URL+"/book/getAllBooks",CommonResult.class);
}
@GetMapping("restTemplate/book/getAllBooks2") //需要知道更多数据时,使用getForEntity方法
public CommonResult getAllBooks2(){
ResponseEntity<CommonResult> resultResponseEntit = restTemplate.getForEntity(PAYMENT_URL+"/book/getAllBooks",CommonResult.class);
if (resultResponseEntit.getStatusCode().is2xxSuccessful()){
log.info(resultResponseEntit.getStatusCode()+"\t"+resultResponseEntit.getHeaders());
return resultResponseEntit.getBody();
}else {
return new CommonResult<>(444,"操作失败");
}
}
@GetMapping(value = "restTemplate/book/index")
public String index() {
return restTemplate.getForObject(PAYMENT_URL+"/book/index",String.class);
}
}
使用restTemplate+Ribboin实现服务调用和负载均衡完成。
手写Ribbon负载均衡算法 lb层
1.新建LoadBalancer接口,添加代码
public interface LoadBalancer {
ServiceInstance instances(List<ServiceInstance> serviceInstances);
}
2.新建实现类MyLB
@Component
public class MyLB implements LoadBalancer {
private AtomicInteger atomicInteger = new AtomicInteger(0);
//求第几次访问 自旋锁思想
public final int getAndIncrement(){
int current;
int next;
do {
current = this.atomicInteger.get();
next = current >=2147483647 ? 0 : current+1;
}while(!this.atomicInteger.compareAndSet(current,next));
System.out.println("***第几次访问next->"+next);
return next;
}
//负载均衡算法,实现roundRobin算法
@Override
public ServiceInstance instances(List<ServiceInstance> serviceInstances) {
int index = getAndIncrement() % serviceInstances.size();
return serviceInstances.get(index);
}
}
修改BookController
@RestController
@Slf4j
public class BookController {
@Resource
private RestTemplate restTemplate;
@Resource
private LoadBalancer loadBalancer;
@Resource
private DiscoveryClient discoveryClient;
public static final String PAYMENT_URL = "http://CLOUD-BOOK-SERVICE";
@GetMapping(value = "restTemplate/book/getAllBooks")//只要json数据时
public CommonResult getAllBooks(){
List<ServiceInstance> instances = discoveryClient.getInstances("CLOUD-BOOK-SERVICE");
if (instances == null || instances.size() <= 0){
return null;
}
ServiceInstance serviceInstance = loadBalancer.instances(instances);
URI uri = serviceInstance.getUri();
return restTemplate.getForObject(uri+"/book/getAllBooks",CommonResult.class);
}
@GetMapping(value = "restTemplate/book/index")
public String index() {
List<ServiceInstance> instances = discoveryClient.getInstances("CLOUD-BOOK-SERVICE");
if (instances == null || instances.size() <= 0){
return null;
}
ServiceInstance serviceInstance = loadBalancer.instances(instances);
URI uri = serviceInstance.getUri();
return restTemplate.getForObject(uri+"/book/index",String.class);
}
}
修改文件注解
删去主启动类的更换负载均衡算法注解
@RibbonClient(name = “CLOUD-BOOK-SERVICE”, configuration = LoadBalanceRule.class)
删去LoadBalanceConfig中开启负载均衡算法注解
@LoadBalanced
手写Ribbon算法并使用完成
来源:https://blog.csdn.net/super1223/article/details/115384982
0
投稿
猜你喜欢
- Java虚拟机把描述类的数据从Class文件加载到内存,并对数据进行校验、转换解析和初始化,最终形成可以被虚拟机直接使用的Java类型,这个
- 前几天网上突然出现流言:某东发生数据泄露12G,最终某东在一篇声明中没有否认,还算是勉强承认了吧,这件事对于一般人有什么影响、应该怎么做已经
- 我们通过学习Java基础知识,让自己正式踏入学习Java语言的行列,这篇博客是用来让我们真正的了解并应用面向对象的思想来实现的。使用简单的J
- 调用和回调机制在一个应用系统中, 无论使用何种语言开发, 必然存在模块之间的调用, 调用的方式分为几种:1.同步调用同步调用是最基本并且最简
- Java中List.of()和Arrays.asList()的区别及原因动手写一下,让自己更有印象1.Arrays.asList()可以插入
- 详解java.lang.reflect.Modifier.isInterface()方法java.lang.reflect.Modifier
- 一、问题描述上周不是搭了个SpringBoot整合sharding-jdbc分库分表的架子么,组里老哥不让我把开发环境的配置文件放到reso
- 平常我们工作中基本最多两级嵌套,但是有时候难免会遇到 * 嵌套的业务场景,笔者最近就碰到了,使用一般的嵌套发现赋值为空,这可难倒了菜逼的我,后
- 第一步:后端简单建个SpringBoot项目,提供一个 helloWorld接口;版本选用 2.2.6.RELEASEpackage com
- 前言有时候我们会在属性注入的时候添加@Lazy注解实现延迟注入,今天咱们通过阅读源码来分析下原因一、一个简单的小例子代码如下:@Servic
- 前几天在跟公司大佬讨论一个问题时,看到他使用Handler的一种方式,旁边的同事在说:以前不是这么用的啊。这个问题引发了我的好奇,虽然当时翻
- 用了MyBatis的同行,应该见过foreach,它一般是这样用的:<select id="foreachTest"
- 一. 项目需求我们做项目的时候,数据量比较大,单表千万级别的,需要分库分表,于是在网上搜索这方面的开源框架,最常见的就是mycat,shar
- 老生常谈的配置 但是还是需要说明一下EurekaApplication @EnableEurekaServer指定为server端
- 方法一:1.在pom.xml文件下添加依赖包<dependency><groupId>com.alibaba<
- springboot对kafka的client很好的实现了集成,使用非常方便,本文也实现了一个在springboot中实现操作kafka的d
- 一个发送验证码的需求:包括限制文本框输入长度和只允许输入数字按惯例 先上图:class MyBody extends StatefulWid
- 最近的项目中要实现一个聊天的功能,类似于斗鱼TV的聊天室功能,与服务器端人商量后决定用WebSocket来做,但是在这之前我只知道Socke
- 前言:在没有接触java8的时候,我们遍历一个集合都是用循环的方式,从第一条数据遍历到最后一条数据,现在思考一个问题,为什么要使用循环,因为
- Java中有四种权限修饰符publicprotected(default)private同一个类yesyesyesyes同一个包yesyes