Eureka注册中心
远程调用的问题
1、服务消费者改如何获取服务提供者的地址消息？
2、如果服务提供者有多个，消费者如何进行选择？
3、 消费者如何得知服务提供者的健康状态？
Eureka的作用
服务每隔30s给Eureka发送心跳，当没有发送请求的时候，Eureka就会在列表中剔除该服务
搭建Eureka
1、创建项目引入Maven依赖
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
</dependency>
这里没有写明版本信息是因为父工程的SpringCloud已经声明了版本信息
2、在Main函数上添加@EnableEurekaServer来开启Eureka
@EnableEurekaServer
@SpringBootApplication
public class EurekaApplication {public static void main(String[] args) {SpringApplication.run(EurekaApplication.class, args);}
}
3、在application.yml文件中添加如下信息
#配置eureka服务端口
server:port: 1012
#由于eureka本身也是一个微服务所以
#需要配置服务名称以及服务地址信息
#可用于eureka集群服务
#配置eureka服务名称
spring:application:name: eurekaserver
#配置eureka的地址信息
eureka:client:service-url:defaultZone: http://localhost:1012/eureka
服务注册
注册user-service，将user-service服务注册到EurekaServer
1、在user-service项目中引入依赖
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
2、在user-service项目中application.yml文件中添加如下信息
spring:datasource:url: jdbc:mysql://localhost:3306/cloud_user?useUnicode=true&characterEncoding=utf8&useSSL=falseusername: rootpassword: 123456driver-class-name: com.mysql.jdbc.Driver#配置注册到eureka服务名称application:name: userservice#配置注册到eureka的地址信息
eureka:client:service-url:defaultZone: http://localhost:1012/eureka
3、在浏览器看见对应的服务端口即说明注册成功
4、相同服务启动多个实例
具体操作如下所示
在VM选项中填入-Dserver.port=${你的服务端口}即可
如图所示相同服务启动多个实例就此实现了
Eureka服务发现
order-service完成服务的拉取，服务拉取是基于服务名称获取服务列表，然后对服务列表做负载均衡
1、将远程调用的服务IP改成服务名称
@Autowired
private RestTemplate restTemplate;public Order queryOrderById(Long orderId) {// 1.查询订单Order order = orderMapper.findById(orderId);// 将localhost:8081修改为服务的名称即: userserviceUser user = restTemplate.getForObject("http://userservice/user/"+order.getUserId(), User.class);order.setUser(user);// 4.返回return order;
}
2、在配置类中添加@LoadBalanced
/**
* 创建RestTemplate对象并注入Spring
* 容器
* @return
*/
@Bean
@LoadBalanced
public RestTemplate restTemplate() {return new RestTemplate();
}
即可实现服务发现以及负载均衡，负载均衡默认轮询
Ribbon负载均衡
Ribbon的负载均衡流程
1、服务发起请求，RibbonLoadBanlancerClient拦截请求
2、解析请求获取请求中的服务Id，将服务Id发送到DynamicServerListLoadBalancer
3、DynamicServerListLoadBalancer将拉取eureka的服务列表
4、将返回的服务列表发送到IRule中进行负载均衡
5、选择某个服务后，返回到RibbonLoadBanlancerClient中修改URL并发起请求
Ribbon负载策略
| 内置负载均衡类 | 规则描述 |
|---|---|
| RoundRobinRule | 简单轮询服务列表来选择服务。它是Ribbon默认的负载均衡规则 |
| AvailablilityFilteringRule | 对以下两种服务进行忽略:1、在默认情况下，这台服务器如果3次连接失败，这台服务器就会被设置为“短路”状态。短路状态将持续30秒，如果再次连接失败，短路的持续时间就会几何的增长。2、并发数过高的服务器。如果一个服务器的并发连接数过高，配置了AvailabilityFilteringRule规则的客户端也会将其忽略。并发并发连接数的上线，可以有客户端的..ActiveConnectionsLimit属性进行配置 |
| WeightedResponseTimeRule | 为每一个服务器赋予一个权重值。服务器响应时间越长，这个服务器的权重就越小。这个规则会随机选择服务器，这个权重值会影响服务器的选择。 |
| ZoneAvoidanceRule | 以区域可用的服务器为基础进行服务器的选择。使用Zone对服务器进行分类，这个Zone可以理解为一个机房、一个机架等。而后再对Zone内的多个服务做轮询 |
| BestAvailableRule | 忽略哪些短路的服务器，并选择并发数较低的服务器 |
| RandomRule | 随机选择一个可用的服务器 |
| RetryRule | 重试机制的选择逻辑 |
修改Ribbon负载均衡策略的方式
1、代码方式：在Order-service中的OrderApplication类中，定义一个新的IRule
public static void main(String[] args) {SpringApplication.run(OrderApplication.class, args);
}/*** 创建RestTemplate对象并注入Spring* 容器* @return*/
@Bean
@LoadBalanced
public RestTemplate restTemplate() {return new RestTemplate();
}
// 作用范围是全局的，即全部微服务
@Bean
public IRule randomRule() {return new RandomRule();
}
2、配置文件方式：在Order-service的application.yml文件中,添加新的配置也可以修改规则
userservice:ribbon: # 作用范围是某个微服务NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule #负载均衡规则
Ribbon饥饿加载
Ribbon默认是采用懒加载，即第一次访问时才会去创建LoadBalanceClient，请求时间会很长。而饥饿加载则会在项目启动时创建，降低一次访问的耗时，通过下面配置开启饥饿加载
ribbon:eager-load:enabled: true #开启饥饿加载clients: orderservice #指定饥饿加载的名称
ribbon:eager-load:enabled: true #开启饥饿加载clients:- orderservice #指定饥饿加载的名称 列表- userservice
