SpringCloud Eureka 服务治理

向右看齐 2023-02-14 02:39 57阅读 0赞

### 目录 ###

*   *   *  SpringCloud简介
         *  搭建服务注册中心 eureka-server
         *  服务提供者
         *  服务消费者
         *  RestTemplate常用方法
         *  解决@ResponseBody、@RestController返回xml而非json的问题
         *  Eureka的架构
         *  Eureka Server的服务保护机制
         *  Eureka Client的缓存机制

### SpringCloud简介 ###

技术栈

*  Eureka ：服务治理
 *  Ribbon ：负载均衡
 *  Feign ：声明式服务调用
 *  Hystrix：断路器，容错保护
 *  Zuul：网关（API Gateway），路由转发、请求过滤
 *  Config：配置中心，集中管理配置
 *  Bus：总线
 *  Sleuth+Zipkin：分布式链路追踪

Eureka、Ribbon、Feign、Hystrix都是netflix的开源项目，SpringCloud都将它们集成进来了。

springcloud的版本  
![在这里插入图片描述][20200531144440689.png]  
其它框架的版本是1.x，2.x…，SpringCloud的版本是Axx、Bxx、Cxx这样命名走的。

ga是稳定版、通用版，snapshot是开发版。

### 搭建服务注册中心 eureka-server ###

springcloud需要自己写一个服务（模块），作为服务注册中心。

1、新建子模块eureka-server，创建时勾选 Spring Cloud Discovery -> Eureka Server ，或者手动添加依赖

<dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
    </dependency>

2、引导类上加 @EnableEurekaServer

3、application.yml

server:
      port: 8761
    
    spring:
      application:
        name: eureka-server
    
    eureka:
      instance:
        #所在机器的hostname或者ip
        hostname: 127.0.0.1
      client:
        #不注册到其它eureka server上
        registerWithEureka: false
        #不从其它eureka server上拉取、同步注册信息
        fetchRegistry: false
      #此eureka server绑定的注册中心地址
      serviceUrl:
        defaultZone: http://${ eureka.instance.hostname}:${ server.port}/eureka/

如果要搭建Eureka Server集群，将上面2个false改为true即可。

启动应用，访问 127.0.0.1:8761 即可看到eureka server的页面。

### 服务提供者 ###

1、新建子模块order-service，创建时勾选Spring Cloud Discovery -> Eureka Discovery Client，也可以手动添加依赖

<dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    </dependency>

每个服务提供者、消费者都是Eureka Client

2、引导类上加 @EnableEurekaClient 或 @EnableDiscoveryClient

一个是eureka的注解、一个是springcloud的注解，效果一样。也可以都不加，因为classpath中有eureka client的依赖 spring-cloud-starter-netflix-eureka-client 时，启动应用时会自动在引导类上加 @EnableEurekaClient。

3、application.yml

server:
      port: 8771
    
    spring:
      application:
        name: order-service  #服务名称
    
    eureka:
      client:
        serviceUrl:
          defaultZone: http://127.0.0.1:8761/eureka/  #注册中心地址，如果是Eureka Server集群，url之间逗号分隔

不用写全部的Eureka Server的url，写一部分即可。注册时只注册到第一个url上，Eureka Server之间会同步数据，后面的url都是备胎，前面的故障时才会使用后一个。

4、model、service、controller

mdoel

@Getter
    @Setter
    public class Order implements Serializable { 
    
    }

service

public interface OrderService { 
        List<Order> findOrdersByUserId(Integer userId);
    }

@Service
    public class OrderServiceImpl implements OrderService { 
    	
        @Override
        public List<Order> findOrdersByUserId(Integer userId) { 
            
        }
    	
    }

controller

@Controller
    @RequestMapping("/api/v1/order")
    public class OrderController { 
        @Autowired
        private OrderService orderService;
        
        @RequestMapping("/list/{user_id}")
        @ResponseBody
        public List<Order> findOrdersByUserId(@PathVariable("user_id") Long userId){ 
    
        }
    
    }

### 服务消费者 ###

1、创建子模块user-service，创建时勾选Spring Cloud Discovery -> Eureka Discovery Client

2、引导类

@SpringBootApplication
    @EnableEurekaClient  //非必需
    public class UserServiceApplication { 
        
        @Bean
        @LoadBalanced   
        public RestTemplate restTemplate() {   //创建RestTemplate这个bean
            return new RestTemplate();
        }
    
        public static void main(String[] args) { 
            SpringApplication.run(UserServiceApplication.class, args);
        }
    
    }

3、application.yml

server:
      port: 8781
    
    spring:
      application:
        name: user-service  #服务名称
    
    eureka:
      client:
        serviceUrl:
          defaultZone: http://127.0.0.1:8761/eureka/  #注册中心地址，如果是Eureka Server集群，url之间逗号分隔

4、model、service、controller

model

@Getter
    @Setter
    public class Order implements Serializable { 
    
    }

代码冗余多，如果要使用其它服务中的类，需要copy过去才能使用。可以用一个单独的模块写公用的类，打包为jar，再要使用的服务中引用。

service

public interface UserService { 
        List<Order> findOrdersById(Integer id);
    }

@Service
    public class UserServiceImpl implements UserService { 
        @Autowired  //注入RestTemplate
        private RestTemplate restTemplate;
    
        @Override
        public List<Order> findOrdersById(Integer id){ 
            // 远程调用
            return restTemplate.getForObject("http://order-service/api/v1/order/list/" + id, List.class);
        }
    
    }

controller

@Controller
    @RequestMapping("/api/v1/user")
    public class UserController { 
        @Autowired
        private UserService UserService;
    
        @RequestMapping("/{user_id}/order")
        @ResponseBody
        public List<Order> findOrdersById(@PathVariable("user_id") Integer id){ 
            return userService.findOrdersById(id);
        }
    
    }

### RestTemplate常用方法 ###

RestTemplate用于以restful方式远程调用服务，常用方法如下

//参数：远程服务接口，返回值类型（目标类型）
    List orders = restTemplate.getForObject("http://order-service/api/v1/order/list/" + userId, List.class);
    
    //url中的参数可以使用+号拼接，也可以使用占位符{1},{2}...，在目标类型后面写参数值（Object...)
    List orders = restTemplate.getForObject("http://order-service/api/v1/order/list/{1}" + userId, List.class,1);
    
    //可以用map向服务提供者传递数据
    HashMap<String, Object> map = new HashMap<>();
    List orders = restTemplate.getForObject("http://order-service/api/v1/order/list/" + userId, List.class,map);

xxxForObject()，get是查询，post是新建，put是更新，delete是删除，用法都差不多。post、put可混用。

### 解决@ResponseBody、@RestController返回xml而非json的问题 ###

在controller上用produces指定为json格式，默认是xml

@RequestMapping(value = "/api/v1/user",produces = "application/json;charset=utf-8")

### Eureka的架构 ###

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoeV8xODg4MzcwMTE2MQ_size_16_color_FFFFFF_t_70]

### Eureka Server的服务保护机制 ###

Eureka Server默认开启了服务保护：

Eureka Server在90s内都未收到某个服务节点的心跳包时，会开启为期15min的心跳检测，这期间不会把该服务节点的信息从服务注册列表中删除。Eureka Server控制台也会用一段红色文字提示：这个服务节点进入了服务保护模式。

如果15min内实际收到该节点的心跳数占应接收心跳数的比值小于0.85，就认为是该服务节点与Eureka Server之间的网络故障导致的心跳包丢失，该服务节点本身没有问题，保留该节点的注册信息；如果比值大于0.85，就认为是该服务节点自身出了问题，从服务注册列表中删除该服务节点的信息。

造成的问题：某个服务节点可能真的出问题了，但依然被当做正常节点使用。

项目上线时一般也不关闭服务保护，公司的项目，服务节点数量往往成百上千，如果关闭服务保护，网络不稳定时（网络波动、延迟、断线等）会导致大量的服务反复注册、删除、再注册，会降低程序性能。开启服务保护，某些服务节点故障时，无非就是注册列表中有少量无效节点，不一定会调用集群中的这些无效节点，就算调用了无效节点不能正确处理请求，用户刷新几次，转发给集群中正常的节点处理就ok了。

开发、调试时可以关闭Eureka Server的服务保护，快速清理掉无效节点

eureka:
      server:
        #关闭Eureka Server的服务保护
        enableSelfPreservation: false

### Eureka Client的缓存机制 ###

Eureka Client | ZK Client都会缓存Eureka Server | ZK Server返回的服务节点列表，缓存一直有效，直到此Client下线。

消费者调用服务时都是先从本地缓存中找该服务的节点列表，没有才会从Eureka Server | ZK Server获取该服务的节点列表。即使Eureka Server | ZK Server集群所有节点都宕机，服务消费者也可以调用服务提供者（以前调用过）。

ZK Client通过订阅来监听ZK Server上服务节点列表的变化，Eureka Client通过轮询来确定缓存的服务节点列表是否有更新，有更新时会自动从ZK Server | Eureka Server上获取服务节点列表的更新。

[20200531144440689.png]: https://img-blog.csdnimg.cn/20200531144440689.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoeV8xODg4MzcwMTE2MQ_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20200531165038872.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoeV8xODg4MzcwMTE2MQ==,size_16,color_FFFFFF,t_70