内容简介:交互图
Spring Cloud
为开发者提供了在分布式系统中的一些常用的组件(例如配置管理,服务发现,断路器,智能路由,微代理,控制总线,一次性令牌,全局锁定,决策竞选,分布式会话集群状态)。使用Spring Cloud开发人员可以快速地完成实现这些模式的服务和应用程序。它们在任何分布式环境中都能很好地工作
Ribbon
Ribbon
是 Netflix
开源的基于 HTTP
和 TCP
的客户端负载均衡器框架,目前也已被 Spring Cloud
团队集成在 spring-cloud-netflix
子项目下,主要用于客户端软负载功能,内部已实现了 随机
、 轮训
、 权重
、 减压(选取压力最小的)
等常见的负载算法,同时也提供了 ILoadBalance
与 IRule
两个接口方便我们自己编写适合自己的负载算法
- 负载均衡
- 容错
- 多协议(HTTP,TCP,UDP)支持异步和反应模型
- 缓存和批处理
交互图
Try
要尝试 Spring Cloud Ribbon
首要的就是准备一个服务注册中心,还不太清楚的可以在回头看看上一章 认识Eureka
,这里就不做过多赘述了,准备 eureka-server(回顾上一章)
、 product-server
、 order-server
三个项目,后面的两个可以理解为上一章的 eureka-client
Eureka Server
详情参考上一章,或从文末的 GITHUB 链接获取对应篇幅的完整代码
Product Server
一个普通的 Eureka Client
即可,详情参考上一章,或从文末的 GITHUB 链接获取对应篇幅的完整代码
Order Server
一个普通的 Eureka Client
依赖
细心的小伙伴会发现,这和一个普通的 Eureka Client
也没啥区别啊,没任何额外依赖的,那是因为在 spring-cloud-starter-netflix-eureka-client
中已经帮我们依赖过 spring-cloud-starter-netflix-ribbon
了。假如使用 consul
、 zookeeper
、 etcd
等容器为服务发现为者时,就必须依赖 spring-cloud-starter-netflix-ribbon
包
<dependencies> <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> </dependencies>
配置文件
在 src/main/resources
目录下创建一个 bootstrap.yml
的文件,写上 eureka 相关配置信息
server: port: 7072 spring: application: name: order-server eureka: instance: prefer-ip-address: true instance-id: ${spring.cloud.client.ip-address}:${spring.application.instance_id:${server.port}} client: service-url: defaultZone: http://localhost:7071/eureka/
主函数
各位小伙伴对 Spring Boot
中的 RestTemplate
应该都不陌生,它是由 Spring Boot
提供而不是 Spring Cloud
,无负载功能,为了方便开发者, Spring Cloud
团队提供了一个 @LoadBalanced
注解(默认采用轮训算法)
package com.battcn; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.client.discovery.EnableDiscoveryClient; import org.springframework.cloud.client.loadbalancer.LoadBalanced; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.web.client.RestTemplate; /** * @author Levin */ @EnableDiscoveryClient @SpringBootApplication public class OrderApplication { @Configuration class MyConfiguration { @LoadBalanced @Bean RestTemplate restTemplate() { return new RestTemplate(); } } public static void main(String[] args) { SpringApplication.run(OrderApplication.class, args); } }
控制器
客户端( order-server:7702
)从 Eureka Server
同步了 product-server:7703
和 product-server:7704
这个时候它是如何知晓注册表中的信息呢?上一章中遗留了一个知识点就是 DiscoveryClient
,通过它就可以获得注册表中客户端的信息了,下列代码块演示了 DiscoveryClient
的简单用法,更多 API 可以自行尝试
package com.battcn.controller; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.cloud.client.ServiceInstance; import org.springframework.cloud.client.discovery.DiscoveryClient; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; import org.springframework.web.client.RestTemplate; import java.util.List; /** * @author Levin * @since 2018/9/28 0028 */ @RestController @RequestMapping("/orders") public class OrderController { private final RestTemplate restTemplate; private final DiscoveryClient discoveryClient; @Autowired public OrderController(RestTemplate restTemplate, DiscoveryClient discoveryClient) { this.restTemplate = restTemplate; this.discoveryClient = discoveryClient; } @GetMapping public String query() { final List<String> services = discoveryClient.getServices(); for (String service : services) { List<ServiceInstance> list = discoveryClient.getInstances(service); for (ServiceInstance instance : list) { System.out.println(instance.getUri() + "/" + service + " - " + instance.getServiceId()); } } return restTemplate.getForObject("http://PRODUCT-SERVER/products", String.class); } }
Why
有的小伙伴对上面的内容会存在一些疑问,为什么没有写 IP:PORT 了,而是写了一串字符,它是怎么做到的?
用通俗的概念来说,它就是编码与解码操作,还记得 Eureka Server UI 中 Application 吗? 编码:根据 spring.application.name 设置 serviceId Server ID:PRODUCT-SERVER Client A :http://localhost:7073/products Client B :http://localhost:7074/products 解码:通过 serviceId 找到对应的客户端, 然后根据客户端配置的负载算法从对应集合中 找出符合当前算法条件的结果,最后拼接出相应的 http 地址即可 解码前:http://PRODUCT-SERVER/products 那么将 http://PRODUCT-SERVER 替换成 instance.getUri() 内容是不是就出来了 http://localhost:7073/products 和 http://localhost:7074/products
自定义 IRule
假如我们不想使用轮训了,换换口味改成随机算法,又或者想自己写一套适合自己的负载算法,可以用下面这种方式
package com.battcn.config; import com.netflix.loadbalancer.IRule; import com.netflix.loadbalancer.RandomRule; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; /** * @author Levin * @since 2018/9/28 0028 */ @Configuration public class RibbonRuleConfiguration { @Bean public IRule ribbonRule() { return new RandomRule(); } } @RibbonClient(name = "ribbonRule",configuration = RibbonRuleConfiguration.class) public class OrderController { }
总结
目前很多大佬都写过关于 Spring Cloud
的教程了,如有雷同,请多多包涵,本教程基于最新的 spring-cloud:Finchley.SR1
编写…
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持 码农网
猜你喜欢:本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们。
C++设计新思维
(美)Andrei Alexandrescu / 侯捷、於春景 / 华中科技大学出版社 / 2003-03 / 59.8
本书从根本上展示了generic patterns(泛型模式)或pattern templates(模式模板),并将它们视之为“在C++中创造可扩充设计”的一种功能强大的新方法。这种方法结合了template和patterns,你可能未曾想过,但的确存在。为C++打开了全新视野,而且不仅仅在编程方面,还在于软件设计本身;对软件分析和软件体系结构来说,它也具有丰富的内涵。一起来看看 《C++设计新思维》 这本书的介绍吧!