Ribbon简介
Ribbon是Netflix发布的开源项目,主要功能是提供客户端的软件负载均衡算法,将Netflix的中间层服务连接在一起。Ribbon客户端组件提供一系列完善的配置项如连接超时,重试等。简单的说,就是在配置文件中列出Load Balancer后面所有的机器,Ribbon会自动的帮助你基于某种规则(如简单轮询,随即连接等)去连接这些机器。我们也很容易使用Ribbon实现自定义的负载均衡算法。
参考:
http://cloud.spring.io/spring-cloud-static/Dalston.SR5/single/spring-cloud.html#spring-cloud-ribbon
依赖
groupid org.springframework.cloud
artifactid spring-cloud-starter-ribbon
Main方法处添加负载均衡RestTemplate
@LoadBalanced //自动装配
@Bean //实例化
RestTemplate restTemplate() {
return new RestTemplate();
}
客户端请求
Book book = new Book(); book.setName(“红楼梦”);
ResponseEntity<Book> responseEntity = restTemplate.postForEntity(“http://服务名/路径", book, Book.class);
return responseEntity.getBody();
服务端接收
@RequestMapping(value = "/getbook2", method = RequestMethod.POST)
public Book book2(@RequestBody Book book) {}
定义规则类
public class RuleSetting {
@Bean
public IRule ribbonRule(IClientConfig config) {
return new RandomRule();//也可以返回自带一些规则 比如随机选择等
}
注解配置
@RibbonClient(value="IDSERVER",configuration=RuleSetting.class)
Xml配置
IDSERVER.ribbon.NFLoadBalancerRuleClassName=cn.et1.MyRule
实例——客户端负载均衡
默认轮循方法,注意控制层是 @RestController 注解
ui界面controller调用userService Controller
@GetMapping()
public String test(){
String url="http://ouyang/aa";
String forObject = rest.getForObject(url, String.class);
return forObject;
}
userService Controller 层
@GetMapping("/aa")
public String test(){
return "8882";
}
随机算法,有成为RR算法
@Bean
public IRule rule(){
return new RandomRule();
}
客户端自定义算法,不能加spring的注解
//需要继承抽象类 AbstractLoadBalancerRule
public class MyRule extends AbstractLoadBalancerRule{
@Override
public void initWithNiwsConfig(IClientConfig iClientConfig) {
}
@Override
public Server choose(Object o) {
ILoadBalancer loadBalancer = this.getLoadBalancer();
//获取所有已注册服务,选取一个分配
List<Server> reachableServers = loadBalancer.getReachableServers();
return reachableServers.get(1);
}
}
//客户端控制层 new 自定义的规则类,Bean所有服务使用此配置,yml方式仅指定微服务使用此配置
@Bean
public IRule rule(){
return new MyRule();
}
application.yml资源文件方式实例化
yml 方式仅指定微服务使用此配置,未指定的服务使用系统默认的
# 需要调用的微服务名为OUYANG。 ribbon,NFLoadBalancerRuleClassName名字不可更改
OUYANG:
ribbon:
NFLoadBalancerRuleClassName: cn..ps.rule.MyRule #自定义的规则类
Feign简介
Feign是从Netflix中分离出来的轻量级项目,能够在类接口上添加注释,成为一个REST API 客户端。
Feign中对 Hystrix 有依赖关系。Feign只是一个便利的rest框架,简化调用,最后还是通过ribbon在注册服务器中找到服务实例,然后对请求进行分配。
参考:
http://cloud.spring.io/spring-cloud-static/Dalston.SR5/single/spring-cloud.html#spring-cloud-feign
Feign自定义调用代码,applicationMain 类上必须加注解 @EnableFeignClients,启用feign
//使用FeignClient 确定要调用的服务,默认使用ribbon进行负载均衡
//注: 此为接口定义
@FeignClient(name="idserver")
public interface TestClient {
//因为是调用必须明确告诉是GET方式传入的参数是id
@RequestMapping(method = RequestMethod.GET, value = "/getUser/{id}")
public User getId(@PathVariable("id") String id) ;
//post请求必须添加@RequestBody
@RequestMapping(method = RequestMethod.POST, value = "/saveUser",consumes="application/json")
public User saveUser(@RequestBody User user) ;
}
客户端注解EnableEurekaClient 与EnableDiscoveryClient
@EnableEurekaClient //本服务启动后会自动注册进Eureka服务中
@EnableDiscoveryClient //服务发现
其实用更简单的话来说,就是如果选用的注册中心是eureka,那么就推荐@EnableEurekaClient,如果是其他的注册中心,那么推荐使用@EnableDiscoveryClient。
Feign方法调用思路
html页面→用户界面Controller注解@EnableFeignClients→
增删查改 @FeignClient(“微服务名”)→微服务控制层→
逻辑判断service层→数据库操作Mapper
→ 调用