spring Cloud 之 Eureka、Feign、Hystrix、Zuul、Config、Bus

淩亂°似流年 2021-10-25 12:56 244阅读 0赞

## 一、服务发现——Netflix Eureka ##

Eureka包含两个组件： Eureka Server和Eureka Client

**1、创建Eureka Server服务端**

（1）、引入依赖 父工程pom.xml定义SpringCloud版本

<dependencyManagement> 
            <dependencies>             
    　　　　　　　　<dependency>                 
    　　　　　　　　　　<groupId>org.springframework.cloud</groupId>                 
    　　　　　　　　　　<artifactId>spring‐cloud‐dependencies</artifactId>
                     <version>Finchley.M9</version>
                     <type>pom</type>
                     <scope>import</scope>
                 </dependency>
             </dependencies>
    </dependencyManagement>

（2）、tensquare\_eureka模块pom.xml引入eureka-server

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

（3）、添加application.yml

server:
      port: 6868
    eureka:
      client:
        register-with-eureka: false #是否将自己注册到Eureka服务中，本身就是服务无需注册
        fetch-registry: false #是否从Eureka服务中获取注册信息
        service-url:
          defaultZone: http://127.0.0.1:${server.port}/eureka/

（4）编写启动类

import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
    
    @SpringBootApplication //SpringBoot    开启注解
    @EnableEurekaServer　　 //EurekaServer  Eureka服务端
    public class EurekaServer {
        public static void main(String[] args) {
            SpringApplication.run(EurekaServer.class);
        }
    }

（5）、结果：

![1645886-20190813201533769-881224665.png][]

## 　2、创建Eureka Client 服务端    ##

（1）、将其他微服务模块添加依赖

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

（2）、修改每个微服务的application.yml，添加注册eureka服务的配置

eureka:
      client:
        service-url:
          defaultZone: http://127.0.0.1:6868/eureka/

（3）、修改每个服务类的启动类，添加注解

@EnableEurekaClient

（4）、结果：将每个微服务启动起来，会发现eureka的注册列表中可以看到这些微服 务了

![1645886-20190813203349566-2078443285.png][]

##  二、服务调用——Netflix Feign 实现服务间的调用　　 ##

Feign是简化Java HTTP客户端开发的工具（java-to-httpclient-binder），

它的灵感 来自于Retrofit、JAXRS-2.0和WebSocket。

Feign的初衷是降低统一绑定Denominator到 HTTP API的复杂度，不区分是否为restful。

**1、在要 通信的 服务上添加依赖**

<dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-openfeign</artifactId>
    </dependency>

**　　2、启动类上，添加注解**

@SpringBootApplication
    @EnableEurekaClient  //客户端标识
    @EnableDiscoveryClient //发现服务
    @EnableFeignClients //用Feign的方式发现服务

**3、创建 com.tensquare.qa.client包，包下创建接口**

@FeignClient(value = "tensquare-base")
    public interface BaseClient {
    
        @GetMapping(value = "/label/{labelId}")
        public Result findById(@PathVariable("labelId") String labelId);
    }

@FeignClient注解用于指定从哪个服务中调用功能 ，注意 里面的名称与被调用的服务 名保持一致，并且不能包含下划线。  
　　@RequestMapping注解用于对被调用的微服务进行地址映射。注意 @PathVariable注 解一定要指定参数名称，否则出错

**4、修改tensquare\_qa模块的 ProblemController**

@Autowired
        private BaseClient baseClient;
    
        @GetMapping(value = "/label/{labelId}")
        public Result findByLabelId(@PathVariable String labelId){
            Result result= baseClient.findById(labelId);
            return result;
        }

**　　5、结果 http://localhost:9003/problem/label/1144250491664994304 获取数据**

**![1645886-20190813211934368-1587615064.png][]**

/label/{labelId} 是 teasquare_base 服务中的方法

原本可由 ：http://localhost:9001/label/1144250491664994304 查询到

## 三、熔断器——Netflix Hystrix ##

在微服务架构中通常会有多个服务层调用，基础服务的故障可能会导致级联故障，

进而造成整个系统不可用的情况，这种现象被称为服务雪崩效应。

服务雪崩效应是一种 因“服务提供者”的不可用导致“服务消费者”的不可用,并将不可用逐渐放大的过程。

如何避免产生这种雪崩效应呢？我们可以使用Hystrix来实现熔断器。

Hystrix 能使你的系统在出现依赖服务失效的时候，通过隔离系统所依赖的服务，

防 止服务级联失败，同时提供失败回退机制，

更优雅地应对失效，并使你的系统能更快地 从异常中恢复。

Feign 本身支持Hystrix，不需要额外引入依赖。

**1、修改tensquare\_qa模块的application.yml ，开启hystrix**

feign:
      hystrix:
        enabled: true

**　　2、在com.tensquare.qa.client包下创建impl包，包下创建熔断实现类，实现自接口 LabelClient**

@Component
    public class BaseClientImpl implements BaseClient {
        @Override
        public Result findById(String labelId) {
            return new Result(false, StatusCode.ERROR,"触发熔断器");
        }
    }

**　　3、修改LabelClient的注解 **

@FeignClient(value = "tensquare-base",fallback = BaseClientImpl.class)

**　　4、测试运行**

重新启动问答微服务，测试看熔断器是否运行

![1645886-20190813214849629-97583841.png][]

## 四、服务网关——Netflix Zuul ##

**　　1、创建子模块tensquare\_web，pom.xml引入eureka-client 和zuul的依赖**

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

**　　2、创建application.yml**

server:
      port: 9012
    spring:
      application:
        name: tensquare-web
    eureka:
      client:
        service-url:
          defaultZone: http://127.0.0.1:6868/eureka/
      instance:
        prefer-ip-address: true
    zuul:
      routes:
        tensquare-base:
          path: /base/**
          serviceId: tensquare-base
        tensquare-user:
          path: /user/**
          serviceId: tensquare-user
        tensquare-qa:
          path: /qa/**
          serviceId: tensquare-qa

**　　3、编写启动类**

@SpringBootApplication
    @EnableEurekaClient
    @EnableZuulProxy
    public class WebApplication {
        public static void main(String[] args) {
            SpringApplication.run(WebApplication.class);
        }
    }

**　　4、Zuul过滤器**

@Component
    public class WebFilter extends ZuulFilter {
        @Override
        public String filterType() {
            return "pre"; // 前置过滤器
        }
    
        @Override
        public int filterOrder() {
            return 0; // 优先级为0，数字越大，优先级越低
        }
    
        @Override
        public boolean shouldFilter() {
            return true; // 是否执行该过滤，此处为true,说明需要过滤
        }
    
        @Override
        public Object run() throws ZuulException {
            System.out.println("zuul过滤器..."); return null;
        }
    }

**5、结果 **

**　　工作台输出：zuul过滤器...     **

原本路径 ：http://localhost:9001/label/1144250491664994304 查询到

原本路径 改成这个 9012/base/**

**　访问路径：http://localhost:9012/base/label/1144250491664994304**

**![1645886-20190813223310216-1030878395.png][]**

## 五、分布式配置——Spring Cloud Config ##

在Spring Cloud中，有分布式配置中心组件spring cloud config ，它支持配置服务放在配置服务的内存中（即本地），

也支持放在远程Git仓库 中。在spring cloud config 组件中，分两个角色，一是config server，二是config client。

Config Server是一个可横向扩展、集中式的配置服务器，它用于集中管理应用程序各个 环境下的配置，

默认使用Git存储配置文件内容，也可以使用SVN存储，或者是本地文件 存储。

Config Client是Config Server的客户端，用于操作存储在Config Server中的配置内容。

微服务在启动时会请求Config Server获取配置文件的内容，请求到后再启动容器。

**　1、配置中心微服务 **

**（1）、创建工程模块 配置中心微服务  tensquare\_config，pom.xml引入依赖**

<dependency>
         <groupId>org.springframework.cloud</groupId>
         <artifactId>spring-cloud-config-server</artifactId>
    </dependency>

**　　（2）、创建启动类ConfigServerApplication**

@SpringBootApplication
    @EnableConfigServer  //开启配置服务
    public class ConfigApplication {
        public static void main(String[] args) {
            SpringApplication.run(ConfigApplication.class);
        }
    }

**　　（3）、编写配置文件application.yml**

server:
      port: 12000
    spring:
      application:
        name: tensquare_config
      cloud:
        config:
          server:
            git:
              uri: https://github.com/MengWangwang/tensquare_dev.git

**　　(4)、测试结果  将 tensquare\_base 中的application.yml内容上传到github**

**![1645886-20190814210032035-1205754504.png][]**

**　　　(5)、测试结果 开启 tensquare\_config，[http://localhost:12000/base-dev.yml][http_localhost_12000_base-dev.yml]测试**

**![1645886-20190814205520054-1733572078.png][]**

**2、配置客户端 **

**　　（1）、在tensquare\_base工程添加依赖**

<dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-config</artifactId>
    </dependency>

**　　（2）、添加bootstrap.yml ,删除application.yml **

spring:
      cloud:
        config:
          name: base
          profile: dev
          label: master
          uri: http://127.0.0.1:12000

**　　（3）测试： 启动工程tensquare\_eureka   tensquare\_config  tensquare\_base  tensquare\_common，看是 否可以正常运行**

**　　　　测试路径：http://localhost:9001/label**

![1645886-20190814220648357-1070203624.png][]

## 六、消息总线 —— Spring Cloud Bus ##

在不重启微服务的情况 下更新配置如何来实现呢?  我们使用SpringCloudBus来实现配置的自动更新

**　1、配置服务端 **

**　　（1）、修改tensquare\_config工程的pom.xml，引用依赖**

**　　（2）、修改application.yml ，添加配置**

server:
      port: 12000
    spring:
      application:
        name: tensquare_config
      cloud:
        config:
          server:
            git:
              uri: https://github.com/MengWangwang/tensquare_dev.git
      rabbitmq:
        host: 127.0.0.1
    management: #暴露触发消息总线的地址
      endpoints:
        web:
          exposure:
            include: bus-refresh

**　2、配置客户端 ****　**

**（1）、修改tensquare\_base工程 ，引入依赖**

<dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-bus</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-stream-binder-rabbit</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-actuator</artifactId>
    </dependency>

**　（2）、修改 base-dev.yml 将  ip:127.0.0.1111111111 修改为  ip:127.0.0.222222222**

![1645886-20190814224523993-1733616578.png][]

![1645886-20190814224737164-1056578361.png][]

**　　（3）、点击测试  http://127.0.0.1:12000/actuator/bus-refresh，就会刷新配置。**

ip:127.0.0.11111111111111
    ++++++++++++++:Bearer eyJhbGciOiJIUzI1NiJ9.eyJqdGkiOiIxMTQ4NTcwMjc0OTA4NzM3NTM2Iiwic3ViIjoiYWRtaW4iLCJpYXQiOjE1NjMwNzU3ODQsInJvbGVzIjoiYWRtaW4iLCJleHAiOjE1NjMwNzkzODR9.LFKjNF8F6PdbrL_EYgRtOWuAtgYW8Qw2DlWEjdXZGfk

**（4）、点击测试  http://localhost:9001/label，查询。**

![1645886-20190814225216521-1900430810.png][]

ip:127.0.0.222222222
    ++++++++++++++:Bearer eyJhbGciOiJIUzI1NiJ9.eyJqdGkiOiIxMTQ4NTcwMjc0OTA4NzM3NTM2Iiwic3ViIjoiYWRtaW4iLCJpYXQiOjE1NjMwNzU3ODQsInJvbGVzIjoiYWRtaW4iLCJleHAiOjE1NjMwNzkzODR9.LFKjNF8F6PdbrL_EYgRtOWuAtgYW8Qw2DlWEjdXZGfk

## 七、github源码：[https://github.com/MengWangwang/tensquare][https_github.com_MengWangwang_tensquare]　　 ##

## 　　Spring Cloud Config的GitHub：[https://github.com/MengWangwang/tensquare\_dev][https_github.com_MengWangwang_tensquare_dev] ##

注：本工程还用到了rabbitMq和redis，以及mongodb，所以启动相关模块时，记得开启工具。

转载于:https://www.cnblogs.com/mww-NOTCOPY/p/11280693.html

[1645886-20190813201533769-881224665.png]: /images/20211025/4551bf51f002445cbb260e5b98f0a78f.png
[1645886-20190813203349566-2078443285.png]: /images/20211025/ab76a04fecf04ca0ac07ed295535a80a.png
[1645886-20190813211934368-1587615064.png]: /images/20211025/d8d577307ed4419baad964016e2f0524.png
[1645886-20190813214849629-97583841.png]: /images/20211025/cf199bd2ad2f4e1d918a7f12e9b15aa1.png
[1645886-20190813223310216-1030878395.png]: /images/20211025/c2a23742d371443f93734abe610995fc.png
[1645886-20190814210032035-1205754504.png]: /images/20211025/c22a7d0f4b744fcaacfa30f49063e320.png
[http_localhost_12000_base-dev.yml]: http://localhost:12000/base-dev.yml
[1645886-20190814205520054-1733572078.png]: /images/20211025/c368f5d658fe47b3bbf91797e4ab65e6.png
[1645886-20190814220648357-1070203624.png]: /images/20211025/67787d01c8424d85a982864bf30ae47b.png
[1645886-20190814224523993-1733616578.png]: /images/20211025/b7f0dff9689c402aab970678b9b653a8.png
[1645886-20190814224737164-1056578361.png]: /images/20211025/acf2d3bf7c81471691c3042f4c917f8f.png
[1645886-20190814225216521-1900430810.png]: /images/20211025/575ac78c02b342e9a6cfa365a9447079.png
[https_github.com_MengWangwang_tensquare]: https://github.com/MengWangwang/tensquare
[https_github.com_MengWangwang_tensquare_dev]: https://github.com/MengWangwang/tensquare_dev