在线教育平台-day09-课程预览 Eureka Feign

阅读量：389 次

发布时间：2019-03-05

本文共 7503 字，大约阅读时间需要 25 分钟。

文章目录

1.Eureka注册中心

1.1 需求分析

在前后端分离架构中，服务层被拆分成了很多的微服务，微服务的信息如何管理？Spring Cloud中提供服务注册中心来管理微服务信息。

为什么要用注册中心？

1、微服务数量众多，要进行远程调用就需要知道服务端的ip地址和端口，注册中心帮助我们管理这些服务的ip和端口。

2、微服务会实时上报自己的状态，注册中心统一管理这些微服务的状态，将存在问题的服务踢出服务列表，客户端获取到可用的服务进行调用。

1.2 Eureka注册中心

1.2.1 Eureka介绍

Spring Cloud Eureka 是对Netflix公司的Eureka的二次封装，它实现了服务治理的功能，Spring Cloud Eureka提供服务端与客户端，服务端即是Eureka服务注册中心，客户端完成微服务向Eureka服务的注册与发现。服务端和客户端均采用Java语言编写。下图显示了Eureka Server与Eureka Client的关系：

1、Eureka Server是服务端，负责管理各各微服务结点的信息和状态。

2、在微服务上部署Eureka Client程序，远程访问Eureka Server将自己注册在Eureka Server。

3、微服务需要调用另一个微服务时从Eureka Server中获取服务调用地址，进行远程调用。

1.2.2 Eureka Server搭建

1.2.2.1 单机环境搭建

1、创建xc-govern-center工程：

包结构：com.xuecheng.govern.center

2、添加依赖

在父工程添加：（有了则不用重复添加）


           
    
     org.springframework.cloud
            
    
     spring-cloud-dependencies
            
    
     Finchley.SR1
            
    
     pom
            
    
     import

在Eureka Server工程添加：


         
    
     org.springframework.cloud
          
    
     spring-cloud-starter-netflix-eureka-server

3、启动类

@EnableEurekaServer//标识这是一个Eureka服务@SpringBootApplicationpublic class GovernCenterApplication {     public static void main(String[] args) {       SpringApplication.run(GovernCenterApplication.class, args);  }}

4、从其它服务拷贝application.yml和logback-spring.xml。

application.yml的配置内容如下:

server:  port: ${   PORT:50101} #服务端口spring:  application:    name: xc-govern-center #指定服务名eureka:  client:    registerWithEureka: true #服务注册，是否将自己注册到Eureka服务中    fetchRegistry: true #服务发现，是否从Eureka中获取注册信息    serviceUrl: #Eureka客户端与Eureka服务端的交互地址，高可用状态配置对方的地址，单机状态配置自己（如果不配置则默认本机8761端口）      defaultZone: http://localhost:50101/eureka/  server:    enable‐self‐preservation: false #是否开启自我保护模式    eviction‐interval‐timer‐in‐ms: 60000 #服务注册表清理间隔（单位毫秒，默认是60*1000）

5、启动Eureka Server

启动Eureka Server，浏览50101端口。

1.2.2.2 高可用环境搭建

Eureka Server 高可用环境需要部署两个Eureka server，它们互相向对方注册。如果在本机启动两个Eureka需要注意两个Eureka Server的端口要设置不一样，这里我们部署一个Eureka Server工程，将端口可配置，制作两个Eureka Server启动脚本，启动不同的端口，如下图：

1、在实际使用时Eureka Server至少部署两台服务器，实现高可用。

2、两台Eureka Server互相注册。

3、微服务需要连接两台Eureka Server注册，当其中一台Eureka死掉也不会影响服务的注册与发现。

4、微服务会定时向Eureka server发送心跳，报告自己的状态。

5、微服务从注册中心获取服务地址以RESTful方式发起远程调用。

配置如下：

1、端口可配置

server:  port: ${   PORT:50101} #服务端口

2、Eureka服务端的交互地址可配置

eureka:  client:    registerWithEureka: true #服务注册，是否将自己注册到Eureka服务中    fetchRegistry: true #服务发现，是否从Eureka中获取注册信息    serviceUrl: #Eureka客户端与Eureka服务端的交互地址，高可用状态配置对方的地址，单机状态配置自己（如果不配置则默认本机8761端口）      defaultZone: ${   EUREKA_SERVER:http://eureka02:50102/eureka/}

3、配置hostname

Eureka 组成高可用，两个Eureka互相向对方注册，这里需要通过域名或主机名访问，这里我们设置两个Eureka服

务的主机名分别为 eureka01、eureka02。

完整的eureka配置如下：

server:  port: ${   PORT:50101} #服务端口spring:  application:    name: xc-govern-center #指定服务名eureka:  client:    registerWithEureka: true #服务注册，是否将自己注册到Eureka服务中    fetchRegistry: true #服务发现，是否从Eureka中获取注册信息    serviceUrl: #Eureka客户端与Eureka服务端的交互地址，高可用状态配置对方的地址，单机状态配置自己（如果不配置则默认本机8761端口）      defaultZone: ${   EUREKA_SERVER:http://eureka02:50102/eureka/}  server:    enable‐self‐preservation: false #是否开启自我保护模式    eviction‐interval‐timer‐in‐ms: 60000 #服务注册表清理间隔（单位毫秒，默认是60*1000）  instance:    hostname: ${   EUREKA_DOMAIN:eureka01}

4、在IDEA中制作启动脚本

启动1

启动2

运行两个启动脚本，分别浏览：

http://localhost:50101/

http://localhost:50102/

1.2.3 服务注册

1.2.3.1 将cms注册到Eureka Server

下边实现cms向Eureka Server注册。

依赖


           
               
    
     org.springframework.cloud
                
    
     spring-cloud-starter-netflix-eureka-client

在application.yml配置

eureka:  client:    registerWithEureka: true #服务注册开关    fetchRegistry: true #服务发现开关    serviceUrl: #Eureka客户端与Eureka服务端进行交互的地址，多个中间用逗号分隔      defaultZone: ${   EUREKA_SERVER:http://localhost:50101/eureka/,http://localhost:50102/eureka/}  instance:    prefer‐ip‐address: true #将自己的ip地址注册到Eureka服务中    ip‐address: ${   IP_ADDRESS:127.0.0.1}    instance‐id: ${   spring.application.name}:${   server.port} #指定实例id

在启动类上添加注解
在启动类上添加注解 @EnableDiscoveryClient ，表示它是一个Eureka的客户端

刷新Eureka Server查看注册情况

2. Feign远程调用

在前后端分离架构中，服务层被拆分成了很多的微服务，服务与服务之间难免发生交互，比如：课程发布需要调用CMS服务生成课程静态化页面，本节研究微服务远程调用所使用的技术。

工作流程如下：

1、cms服务将自己注册到注册中心。

2、课程管理服务从注册中心获取cms服务的地址。

3、课程管理服务远程调用cms服务。

2.1 Ribbon

2.1.1 Ribbon介绍

Ribbon是Netflix公司开源的一个负载均衡的项目（https://github.com/Netflix/ribbon），它是一个基于HTTP、TCP的客户端负载均衡器。

1、什么是负载均衡？

负载均衡是微服务架构中必须使用的技术，通过负载均衡来实现系统的高可用、集群扩容等功能。负载均衡可通过硬件设备及软件来实现，硬件比如：F5、Array等，软件比如：LVS、Nginx等。

用户请求先到达负载均衡器（也相当于一个服务），负载均衡器根据负载均衡算法将请求转发到微服务。负载均衡算法有：轮训、随机、加权轮训、加权随机、地址哈希等方法，负载均衡器维护一份服务列表，根据负载均衡算法将请求转发到相应的微服务上，所以负载均衡可以为微服务集群分担请求，降低系统的压力.

2、什么是客户端负载均衡？

上图是服务端负载均衡，客户端负载均衡与服务端负载均衡的区别在于客户端要维护一份服务列表，Ribbon从Eureka Server获取服务列表，Ribbon根据负载均衡算法直接请求到具体的微服务，中间省去了负载均衡服务。

如下图是Ribbon负载均衡的流程图:

1、在消费微服务中使用Ribbon实现负载均衡，Ribbon先从EurekaServer中获取服务列表。

2、Ribbon根据负载均衡的算法去调用微服务。

2.1.2 Ribbon测试

Spring Cloud引入Ribbon配合 restTemplate 实现客户端负载均衡。Java中远程调用的技术有很多，如：webservice、socket、rmi、Apache HttpClient、OkHttp等，互联网项目使用基于http的客户端较多，本项目使

用OkHttp。

1、在客户端添加Ribbon依赖：


         
    
     com.netflix.feign
          
    
     feign-okhttp

2、配置Ribbon参数

ribbon:  MaxAutoRetries: 2 #最大重试次数，当Eureka中可以找到服务，但是服务连不上时将会重试  MaxAutoRetriesNextServer: 3 #切换实例的重试次数  OkToRetryOnAllOperations: false #对所有操作请求都进行重试，如果是get则可以，如果是post，put等操作,没有实现幂等的情况下是很危险的,所以设置为false  ConnectTimeout: 5000 #请求连接的超时时间  ReadTimeout: 6000 #请求处理的超时时间

3、负载均衡测试

1）启动两个cms服务，注意端口要不一致

启动完成观察Eureka Server的服务列表

2）定义RestTemplate，使用@LoadBalanced注解

在课程管理服务的启动类中定义RestTemplate

@Bean  @LoadBalanced  public RestTemplate restTemplate() {       return new RestTemplate(new OkHttp3ClientHttpRequestFactory());  }

3）测试代码

在课程管理服务工程创建单元测试代码，远程调用cms的查询页面接口：

@Test  public void testRibbon() {       //服务id    String serviceId = "XC-SERVICE-MANAGE-CMS";    for (int i = 0; i < 10; i++) {         //通过服务id调用      ResponseEntity
   
     forEntity = restTemplate.getForEntity("http://" + serviceId          + "/cms/page/get/5a754adf6abb500ad05688d9", CmsPage.class);      CmsPage cmsPage = forEntity.getBody();      System.out.println(cmsPage);    }  }

4）负载均衡测试

添加@LoadBalanced注解后，restTemplate会走LoadBalancerInterceptor拦截器，此拦截器中会通过RibbonLoadBalancerClient查询服务地址，可以在此类打断点观察每次调用的服务地址和端口，两个cms服务会轮

流被调用。

2.2 Feign

2.2.1 Feign介绍

Feign是Netflix公司开源的轻量级rest客户端，使用Feign可以非常方便的实现Http 客户端。Spring Cloud引入Feign并且集成了Ribbon实现客户端负载均衡调用。

2.2.2 Feign测试

1、在客户端添加依赖

在课程管理服务添加下边的依赖：


         
    
     org.springframework.cloud
          
    
     spring-cloud-starter-openfeign
        
       
         
    
     com.netflix.feign
          
    
     feign-okhttp

2、定义FeignClient接口

参考Swagger文档定义FeignClient，注意接口的Url、请求参数类型、返回值类型与Swagger接口一致。

在课程管理服务中创建client包，定义查询cms页面的客户端该用接口.

@FeignClient(value = XcServiceList.XC_SERVICE_MANAGE_CMS)public interface CmsPageClient {     @GetMapping("/cms/page/get/{id}")  CmsPage findById(@PathVariable("id") String id);}

3、启动类添加@EnableFeignClients注解

4、测试

@RunWith(SpringRunner.class)@SpringBootTestpublic class FeignTest {   	@Autowired	CmsPageClient cmsPageClient;	@Test	public void testFeign() {   		//通过服务id调用cms的查询页面接口		CmsPage cmsPage = cmsPageClient.findById("5a754adf6abb500ad05688d9");		System.out.println(cmsPage);	}}

Feign工作原理如下：

1、启动类添加@EnableFeignClients注解，Spring会扫描标记了@FeignClient注解的接口，并生成此接口的代理对象

2、 @FeignClient(value = XcServiceList.XC_SERVICE_MANAGE_CMS)即指定了cms的服务名称，Feign会从注册中心获取cms服务列表，并通过负载均衡算法进行服务调用。

3、在接口方法中使用注解@GetMapping("/cms/page/get/{id}")，指定调用的url，Feign将根据url进行远程调用.