Eureka注册中心以及Ribbon负载均衡

Eureka注册中心

远程调用的问题

1、服务消费者改如何获取服务提供者的地址消息？

2、如果服务提供者有多个，消费者如何进行选择？

3、 消费者如何得知服务提供者的健康状态？

Eureka的作用

服务每隔30s给Eureka发送心跳，当没有发送请求的时候，Eureka就会在列表中剔除该服务

搭建Eureka

1、创建项目引入Maven依赖

org.springframework.cloud

spring-cloud-starter-netflix-eureka-server

这里没有写明版本信息是因为父工程的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项目中引入依赖

org.springframework.cloud

spring-cloud-starter-netflix-eureka-client

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

相关文章