建站报价,常用网站后台地址,医院的网络推广方案,企业网站官网建设目录
1.什么是Ribbo❤️❤️❤️
2.eureka自带Ribbon ❤️❤️❤️
3. RestTemplate❤️❤️❤️ 4.IRule❤️❤️❤️ 5.负载均衡算法❤️❤️❤️ 1.什么是Ribbo 1.Spring Cloud Ribbon是基于Netflix Ribbon实现的一套客户端,负载均衡的工具。2.主要功能是提供客户端的软件…
目录
1.什么是Ribbo❤️❤️❤️
2.eureka自带Ribbon ❤️❤️❤️
3. RestTemplate❤️❤️❤️ 4.IRule❤️❤️❤️ 5.负载均衡算法❤️❤️❤️ 1.什么是Ribbo 1.Spring Cloud Ribbon是基于Netflix Ribbon实现的一套客户端,负载均衡的工具。2.主要功能是提供客户端的软件负载均衡算法和服务调用。3.Ribbon客户端组件提供一系列完善的配置项如连接超时重试等。4.在配置文件中列出Load Balancer 简称LB后面所有的机器Ribbon会自动的帮助你基于某种规则如简单轮询,随机连接等去连接这些机器。 2.eureka自带Ribbon 之前没引入Ribbon为啥也能负载均衡 因为我们引入eureka时eureka自动引入了ribbon 3. RestTemplate restTemplate有两种方式 1.restTempalte.getForObject2.restTemplate.getForEntity GetMapping(/payment/get/{id})public CommonResultPayment getPayment(PathVariable(id) Integer id) {log.info(进入查询功能成功);return restTemplate.getForObject(PAYMENT_URL /payment/selectById/ id, CommonResult.class);}GetMapping(/payment/get2/{id})public CommonResultPayment getPayment2(PathVariable(id) Integer id) {log.info(进入查询功能成功);ResponseEntityCommonResult entity restTemplate.getForEntity(PAYMENT_URL /payment/selectById/ id, CommonResult.class);if (entity.getStatusCode().is2xxSuccessful()){log.info(entity.getStatusCode()\tentity.getHeaders());return entity.getBody();}else {return new CommonResult(404,查询失败~);}} 4.IRule
4.1轮询策略 1.RoundRobinRule --------轮询2.RandomRule ---------随机3.RetryRule ---------重试 (先轮询如果失败在执行时间内重试 4.2如何替换
1.创建配置类 注意创建的配置类不能被ComponentSacn所扫描不能与主启动类同包 2.创建IRule对象 使用Bean创建对象根据要求返回具体实现类 Configuration
public class MySelfRule {Beanpublic IRule myRule(){return new RandomRule();//定义为随机}
} 3.添加RibbonClient name属性表示要访问服务的名称。必须与Eureka中的名称一致包括大小写 configuration属性表示要访问的自定义IRUle配置类 SpringBootApplication
EnableDiscoveryClient
RibbonClient(name COULD-PAYMENT-SERVICE,configuration MySelfRule.class)
public class OrderMain80 {public static void main(String[] args) {SpringApplication.run(OrderMain80.class);}
} 5.负载均衡算法
5.1原理 算法rest接口第几次请求数 % 服务器集群总数量 实际调用服务器位置下标每次服务重启动后rest接口计数从1开始。 例如 ListServiceInstance instances discoveryClient.getInstances(CLOUD-PAYMENT-SERVICE); 获取实例 List [0] instances 127.0.0.1:8002 List [1] instances 127.0.0.1:8001 8001和8002组成集群共两台机器 当总请求数为1时: 1%21对应下标位置为1 ,则获得服务地址为127.0.0.1:8001 当总请求数位2时: 2%20对应下标位置为0,则获得服务地址为127.0.0.1:8002 当总请求数位3时: 3%21对应下标位置为1 ,则获得服务地址为127.0.0.1:8001 当总请求数位4时: 4%20对应下标位置为0,则获得服务地址为127.0.0.1:8002 5.2手写轮询
自定义轮询算法
Component
public class MyLb implements LoadBalance {private AtomicInteger atomicInteger new AtomicInteger(0);public final int getAndIncrement() {int current;int next;do {current this.atomicInteger.get();next current Integer.MAX_VALUE ? 0 : current 1;} while (!this.atomicInteger.compareAndSet(current, next));System.out.println(next: next);return next;}Overridepublic ServiceInstance instances(ListServiceInstance serviceInstance) {int index getAndIncrement() % serviceInstance.size();return serviceInstance.get(index);}
}80服务使用自定义轮询 //自己的负载均衡算法Autowiredprivate LoadBalance loadBalance;Autowiredprivate DiscoveryClient discoveryClient;GetMapping(/payment/lb)public String getPaymentLb() {ListServiceInstance instances discoveryClient.getInstances(COULD-PAYMENT-SERVICE);if (instances null || instances.size() 0) {return null;}ServiceInstance serviceInstanceloadBalance.instances(instances);URI uri serviceInstance.getUri();return restTemplate.getForObject(uri/payment/lb,String.class);}
