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=false
username: root
password: 123456
driver-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修改为服务的名称即: userservice
User 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