Spring Cloud微服务组件的使用

一时失言乱红尘 2023-02-12 12:21 4阅读 0赞

**目录**

Eureka Server

添加依赖

服务注册

配置

访问

Service Provider

添加依赖

服务注册

配置

spring-cloud-eureka-provider-1

spring-cloud-eureka-provider-2

spring-cloud-eureka-provider-3

访问

Consul 服务治理

关闭防火墙

下载，然后unzip 解压

查看版本

node1启动 Consul

node2启动 Consul,并加入到node1节点

node3启动 Consul,并加入到node1节点

查看节点

添加依赖

服务注册

配置

启动

Ribbon Consumer

添加依赖

开启服务负载均衡

消费提供者方法

添加配置

测试服务

负载均衡

Feign Consumer

添加依赖

开启Feign

定义接口

消费方法

配置

测试

负载均衡响应

断路器监控(Hystrix Dashboard)

Ribbon Hystrix

添加依赖

服务注册

消费提供者方法

配置

测试断路器

Feign Hystrix

服务注册

配置

测试断路器

Hystrix Dashboard

添加依赖

开启 HD

声明断路点

配置

测试服务

Spring Cloud Zuul

添加依赖

开启服务注册

添加配置

测试服务

TokenFilter 过滤器

PasswordFilter 过滤器

开启过滤器

token 测试

Spring Cloud Config

一、Config Server

添加依赖

开启服务注册

添加配置

测试服务

二、Config Client

添加依赖

开启服务注册

添加配置

测试服务

三、集成 Eureka

开启服务注册

配置

测试服务

四、Config Client Eureka

添加依赖

开启服务注册

添加配置

测试服务

Spring Cloud Bus集成RabbitMQ

一、Config Server

添加依赖

添加配置

二、Config Client

添加依赖

添加配置

测试服务

启动RabbitMQ

启动项目

--------------------

**pom.xml**

<?xml version="1.0" encoding="UTF-8"?>
 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
 <modelVersion>4.0.0</modelVersion>
 <groupId>com.ibm.moses</groupId>
 <artifactId>spring-cloud</artifactId>
 <version>1.0-SNAPSHOT</version>
 <packaging>pom</packaging>
 <name>spring-cloud</name>
 
 <url>http://www.example.com</url>
 <parent>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-parent</artifactId>
 <version>2.2.6.RELEASE</version>
 </parent>
 <properties>
 <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
 <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
 <java.version>1.8</java.version>
 <spring-cloud.version>Hoxton.SR3</spring-cloud.version>
 <swagger2.version>2.9.2</swagger2.version>
 <druid.version>1.1.12</druid.version>
 </properties>
 <modules>
 <module>spring-cloud-zuul-filter</module>
 <module>spring-cloud-eureka-service</module>
 <module>spring-cloud-provider-1</module>
 <module>spring-cloud-provider-2</module>
 <module>spring-cloud-provider-3</module>
 <module>spring-cloud-consul</module>
 <module>spring-cloud-ribbon-consumer</module>
 <module>spring-cloud-feign-consumer</module>
 <module>spring-cloud-ribbon-consumer-hystrix</module>
 <module>spring-cloud-feign-consumer-hystrix</module>
 <module>spring-cloud-ribbon-consumer-hystrix-dashboard</module>
 <module>spring-cloud-config-server</module>
 <module>spring-cloud-config-client</module>
 </modules>
 <dependencies>
 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-test</artifactId>
 <scope>test</scope>
 </dependency>
 
 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-jdbc</artifactId>
 </dependency>
 
 <dependency>
 <groupId>mysql</groupId>
 <artifactId>mysql-connector-java</artifactId>
 <scope>runtime</scope>
 </dependency>
 
 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-web</artifactId>
 </dependency>
 
 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-data-jpa</artifactId>
 </dependency>
 <dependency>
 <groupId>com.alibaba</groupId>
 <artifactId>druid</artifactId>
 <version>${druid.version}</version>
 </dependency>
 <dependency>
 <groupId>org.projectlombok</groupId>
 <artifactId>lombok</artifactId>
 <optional>true</optional>
 </dependency>
 <dependency>
 <groupId>io.springfox</groupId>
 <artifactId>springfox-swagger-ui</artifactId>
 <version>${swagger2.version}</version>
 </dependency>
 <dependency>
 <groupId>io.springfox</groupId>
 <artifactId>springfox-swagger2</artifactId>
 <version>${swagger2.version}</version>
 </dependency>
 </dependencies>
 <dependencyManagement>
 <dependencies>
 <dependency>
 <groupId>org.springframework.cloud</groupId>
 <artifactId>spring-cloud-dependencies</artifactId>
 <version>${spring-cloud.version}</version>
 <type>pom</type>
 <scope>import</scope>
 </dependency>
 </dependencies>
 </dependencyManagement>
 <build>
 <plugins>
 <plugin>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-maven-plugin</artifactId>
 </plugin>
 </plugins>
 </build>
 </project>

# **Eureka Server** #

## **添加依赖** ##

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

## **服务注册** ##

**import** **org.springframework.boot.SpringApplication**;  
**import** **org.springframework.boot.autoconfigure.****SpringBootApplication**;  
**import** **org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration**;  
**import** **org.springframework.cloud.netflix.eureka.server.****EnableEurekaServer**;  
**@SpringBootApplication**(exclude= \{ **DataSourceAutoConfiguration**.**class**\})  
**@EnableEurekaServer**  
**public class** **EurekaServerApplication** \{  
    **public static void** main(**String**\[\] *args*) \{  
        **SpringApplication**.**run**(**EurekaServerApplication**.**class**, *args*);  
    \}  
\}

## **配置** ##

**eureka**:  
  **instance**:  
    **hostname**: localhost  
  **client**:  
    **fetch-registry**: **false  
    register-with-eureka**: **false  
    serviceUrl**:  
      **defaultZone**: http://$\{ **eureka.instance.hostname**\}:$\{ **server.port**\}/eureka/  
  
**spring**:  
  **application**:  
    **name**: eureka-service  
**server**:  
  **port**: **8761**

## **访问** ##

[http://localhost:8761/][http_localhost_8761]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N0ZXZlX2ZyYW5r_size_16_color_FFFFFF_t_70][]

# **Service Provider** #

## **添加依赖** ##

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

## **服务注册** ##

**@SpringBootApplication**(exclude= \{ **DataSourceAutoConfiguration**.**class**\})  
**@EnableEurekaClient  
@RestController**  
**public class** **EurekaProviderApplication** \{  
    **@Value**(**"$\{server.port\}"**)  
    **String** port;  
  
    **@RequestMapping**(**"/"**)  
    **public** **String** home() \{  
        **return** **"Hello world ,port:"** \+ port;  
    \}  
  
    **public static void** main(**String**\[\] *args*) \{  
        **SpringApplication**.**run**(**EurekaProviderApplication**.**class**, *args*);  
    \}  
\}

## **配置** ##

### **`spring-cloud-eureka-provider-1`** ###

**eureka**:  
  **client**:  
    **serviceUrl**:  
      **defaultZone**: http://localhost:8761/eureka/  
  
**spring**:  
  **application**:  
    **name**: eureka-provider  
**server**:  
  **port**: **8081**

### **`spring-cloud-eureka-provider-2`** ###

### **`spring-cloud-eureka-provider-3`** ###

## **访问** ##

[http://localhost:8761/][http_localhost_8761]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N0ZXZlX2ZyYW5r_size_16_color_FFFFFF_t_70 1][]

# **Consul 服务治理** #

## **关闭防火墙** ##

systemctl stop firewalld.service

## **下载，然后unzip 解压** ##

cd /opt/
    unzip consul_1.7.3_linux_amd64.zip
    cp consul /usr/local/bin/

## **查看版本** ##

consul version

<table> 
 <thead> 
 <tr> 
 <td style="border-color:#dbdbdb;"> 主机名称 </td> 
 <td> IP </td> 
 <td> 作用 </td> 
 <td> 是否允许远程访问 </td> 
 </tr> 
 </thead> 
 <tbody> 
 <tr> 
 <td style="border-color:#dbdbdb;"> node1 </td> 
 <td> 192.168.1.101 </td> 
 <td> consul server </td> 
 <td> 是 </td> 
 </tr> 
 <tr> 
 <td style="border-color:#dbdbdb;"> node2 </td> 
 <td> 192.168.1.103 </td> 
 <td> consul client </td> 
 <td> 是 </td> 
 </tr> 
 <tr> 
 <td style="border-color:#dbdbdb;"> node3 </td> 
 <td> 192.168.1.104 </td> 
 <td> consul client </td> 
 <td> 是 </td> 
 </tr> 
 </tbody> 
</table>

## **node1启动 Consul** ##

cd /opt/  
mkdir data  
consul agent -data-dir /opt/data -node=192.168.1.101 -bind=0.0.0.0 -datacenter=dc1 -ui -client=192.168.1.101 -server -bootstrap-expect 1 > /dev/null 2>&1 &

## **node2启动 Consul,并加入到node1节点** ##

cd /opt/  
mkdir data  
consul agent -data-dir /opt/data -node=192.168.1.103 -bind=0.0.0.0 -datacenter=dc1 -ui  -client=192.168.1.103 -join=192.168.1.101 > /dev/null 2>&1 &

## **node3启动 Consul,并加入到node1节点** ##

cd /opt/  
mkdir data  
consul agent -data-dir /opt/data -node=192.168.1.104 -bind=0.0.0.0 -datacenter=dc1 -ui  -client=192.168.1.104 -join=192.168.1.101 > /dev/null 2>&1 &

## **查看节点** ##

[http://192.168.1.101:8500/ui/dc1/nodes][http_192.168.1.101_8500_ui_dc1_nodes]

![20200526141615346.png][]

## **添加依赖** ##

<**dependency**> 
   <**groupId**>org.springframework.cloud</**groupId**> 
   <**artifactId**>spring-cloud-starter-consul-discovery</**artifactId**> 
</**dependency**>

## **服务注册** ##

@SpringBootApplication(exclude = {DataSourceAutoConfiguration.class})
    @EnableDiscoveryClient
    @RestController
    public class ConsulApplication {
        @RequestMapping("/")
        public String home() {
            return "Hello world";
        }
    
        public static void main(String[] args) {
            SpringApplication.run(ConsulApplication.class, args);
        }
    }

## **配置** ##

**spring**:  
  **application**:  
    **name**: consul-client  
  **cloud**:  
    **consul**:  
      **host**: 192.168.1.101  
      **port**: **8500  
     ** **discovery**:  
        **healthCheckPath**: /  
        **healthCheckInterval**: 5s

## **启动** ##

nohup java -jar spring-cloud-consul-client-0.0.1-SNAPSHOT.jar  > /dev/null 2>&1 &

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N0ZXZlX2ZyYW5r_size_16_color_FFFFFF_t_70 2][]

# **Ribbon Consumer** #

## **添加依赖** ##

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

## **开启服务负载均衡** ##

@SpringBootApplication(exclude = {DataSourceAutoConfiguration.class})
    @EnableDiscoveryClient
    public class RibbonConsumerApplication {
        @LoadBalanced
        @Bean
        RestTemplate restTemplate() {
            return new RestTemplate();
        }
    
        public static void main(String[] args) {
            SpringApplication.run(RibbonConsumerApplication.class, args);
        }
    }

## **消费提供者方法** ##

@RestController
    public class ConsumerController {
        @Autowired
        private RestTemplate restTemplate;
    
        @GetMapping(value = "/hello")
        public String hello() {
            return restTemplate.getForEntity("http://eureka-provider/", String.class).getBody();
        }
    }

## **添加配置** ##

**eureka**:  
  **client**:  
    **serviceUrl**:  
      **defaultZone**: http://localhost:8761/eureka/  
  
**spring**:  
  **application**:  
    **name**: ribbon-consumer  
  
**server**:  
  **port**: **9000**

## **测试服务** ##

[http://localhost:8761/][http_localhost_8761]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N0ZXZlX2ZyYW5r_size_16_color_FFFFFF_t_70 3][]

### **负载均衡** ###

[http://localhost:9000/hello][http_localhost_9000_hello]

![20200526141724201.png][]

![20200526141705696.png][]

# **Feign Consumer** #

## **添加依赖** ##

## **开启Feign** ##

@SpringBootApplication(exclude = {DataSourceAutoConfiguration.class})
    @EnableFeignClients
    @EnableDiscoveryClient
    public class FeignConsumerApplication {
        public static void main(String[] args) {
            SpringApplication.run(FeignConsumerApplication.class, args);
        }
    }

## **定义接口** ##

@FeignClient("eureka-provider")
    public interface HomeClient {
        @GetMapping("/")
        String consumer();
    }

## **消费方法** ##

@RestController
    public class ConsumerController {
        @Autowired
        private HomeClient homeClient;
    
        @GetMapping(value = "/hello")
        public String hello() {
            return homeClient.consumer();
        }
    }

## **配置** ##

eureka:
      client:
        serviceUrl:
          defaultZone: http://localhost:8761/eureka/
    
    spring:
      application:
        name: feign-consumer
    
    server:
      port: 9000

## **测试** ##

[http://localhost:8761/][http_localhost_8761]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N0ZXZlX2ZyYW5r_size_16_color_FFFFFF_t_70 4][]

## **  负载均衡响应** ##

![20200526141801169.png][]

# **断路器监控(Hystrix Dashboard)** #

## **Ribbon Hystrix** ##

### **添加依赖** ###

### **服务注册** ###

@EnableHystrix
    @SpringBootApplication(exclude = {DataSourceAutoConfiguration.class})
    @EnableDiscoveryClient
    public class RibbonConsumerApplication {
        @LoadBalanced
        @Bean
        RestTemplate restTemplate() {
            return new RestTemplate();
        }
    
        public static void main(String[] args) {
            SpringApplication.run(RibbonConsumerApplication.class, args);
        }
    }

### **消费提供者方法** ###

@RestController
    public class ConsumerController {
        @Autowired
        private RestTemplate restTemplate;
    
        @HystrixCommand(fallbackMethod = "defaultStores")
        @GetMapping(value = "/hello")
        public String hello() {
            return restTemplate.getForEntity("http://eureka-provider/", String.class).getBody();
        }
    
        public String defaultStores() {
            return "Ribbon + hystrix ,提供者服务挂了";
        }
    }

### **配置** ###

eureka:
      client:
        serviceUrl:
          defaultZone: http://localhost:8761/eureka/
    
    spring:
      application:
        name: ribbon-consumer-hystrix
    
    server:
      port: 9000

### **测试断路器** ###

[http://localhost:8761/][http_localhost_8761]

![20200526141926286.png][]

**停止 spring-cloud-eureka-provider-1**** ****再次访问**

`http://localhost:9000/hello`

![20200526141948390.png][]

![2020052614194284.png][]

## **Feign Hystrix** ##

### **服务注册** ###

@FeignClient(value = "eureka-provider", fallbackFactory = HystrixClientFallbackFactory.class)
    public interface HomeClient {
        @GetMapping("/")
        String consumer();
    }

**`HystrixClientFallbackFactory.java`**

@Component
 public class HystrixClientFallbackFactory implements FallbackFactory<HomeClient> {
 @Override
 public HomeClient create(Throwable throwable) {
 return () -> "Feign + hystrix ,提供者服务挂了";
 }
 }

### **配置** ###

eureka:
      client:
        serviceUrl:
          defaultZone: http://localhost:8761/eureka/
    
    spring:
      application:
        name: feign-consumer-hystrix
    
    server:
      port: 9000
    
    feign:
      hystrix:
        enabled: true

### **测试断路器** ###

![202005261420015.png][]

**停止 spring-cloud-eureka-provider-1 提供者**

`访问http://localhost:9000/hello`

![20200526142007186.png][]

## **Hystrix Dashboard** ##

### **添加依赖** ###

<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-ribbon</artifactId>
 </dependency>
 
 <dependency>
 <groupId>org.springframework.cloud</groupId>
 <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
 </dependency>
 
 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-actuator</artifactId>
 </dependency>
 
 
 <dependency>
 <groupId>org.springframework.cloud</groupId>
 <artifactId>spring-cloud-starter-netflix-hystrix-dashboard</artifactId>
 </dependency>

### **开启 HD** ###

@EnableHystrix
    @EnableHystrixDashboard
    @EnableDiscoveryClient
    @SpringBootApplication(exclude = {DataSourceAutoConfiguration.class})
    public class RibbonConsumerApplication {
        @LoadBalanced
        @Bean
        RestTemplate restTemplate() {
            return new RestTemplate();
        }
    
        public static void main(String[] args) {
            SpringApplication.run(RibbonConsumerApplication.class, args);
        }
    }

### **声明断路点** ###

### **配置** ###

eureka:
      client:
        serviceUrl:
          defaultZone: http://localhost:8761/eureka/
    
    spring:
      application:
        name: ribbon-consumer-hystrix-Dashboard
    server:
      port: 9000

### **测试服务** ###

[http://localhost:8761/][http_localhost_8761]

![20200526142020785.png][]

**Hystrix Dashboard 监控**

**http://localhost:9000/hystrix**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N0ZXZlX2ZyYW5r_size_16_color_FFFFFF_t_70 5][]

http://127.0.0.1:9000/hystrix.stream,2000,hello

# Spring Cloud Zuul #

## 添加依赖 ##

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

## 开启服务注册 ##

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

## 添加配置 ##

spring:
      application:
        name: zuul-service-filter
    server:
      port: 9000
    
    zuul:
      routes:
        api:
          path: /api1/**
          serviceId: eureka-provider
    
    eureka:
      client:
        serviceUrl:
          defaultZone: http://localhost:8761/eureka/

## 测试服务 ##

![20200526180126390.png][]

**负载均衡**

[http://127.0.0.1:9000/api1][http_127.0.0.1_9000_api1]

![20200526154417374.png][]

![20200526180231247.png][]

## **TokenFilter** **过滤器** ##

public class TokenFilter extends ZuulFilter {
        private final Logger LOGGER = LoggerFactory.getLogger(TokenFilter.class);
    
        /**
         * 请求被路由之前调用
         *
         * @return
         */
        @Override
        public String filterType() {
            return "pre";
        }
    
        /**
         * filter执行顺序，通过数字指定 ,优先级为0，数字越大，优先级越低
         *
         * @return
         */
        @Override
        public int filterOrder() {
            return 0;
        }
    
        /**
         * 是否执行该过滤器，此处为true，说明需要过滤
         *
         * @return
         */
        @Override
        public boolean shouldFilter() {
            return true;
        }
    
        @Override
        public Object run() {
            RequestContext ctx = RequestContext.getCurrentContext();
            HttpServletRequest request = ctx.getRequest();
            LOGGER.info("--->>> TokenFilter {},{}", request.getMethod(), request.getRequestURL().toString());
            // 获取请求的参数
            String token = request.getParameter("token");
            if (StringUtils.isNotBlank(token)) {
                //对请求进行路由
                ctx.setSendZuulResponse(true);
                ctx.setResponseStatusCode(200);
                ctx.set("isSuccess", true);
                return null;
            } else {
                //不对其进行路由
                ctx.setSendZuulResponse(false);
                ctx.setResponseStatusCode(400);
                ctx.setResponseBody("token is empty");
                ctx.set("isSuccess", false);
                return null;
            }
        }
    }

## **PasswordFilter 过滤器** ##

public class PasswordFilter extends ZuulFilter {
        private final Logger LOGGER = LoggerFactory.getLogger(TokenFilter.class);
    
        /**
         * 请求处理完成后执行的filter
         *
         * @return
         */
        @Override
        public String filterType() {
            return "post";
        }
    
        /**
         * filter执行顺序，通过数字指定 ,优先级为0，数字越大，优先级越低
         *
         * @return
         */
        @Override
        public int filterOrder() {
            return 1;
        }
    
        /**
         * 判断上一个过滤器结果为true，否则就不走下面过滤器，直接跳过后面的所有过滤器并返回 上一个过滤器不通过的结果。
         *
         * @return
         */
        @Override
        public boolean shouldFilter() {
            RequestContext ctx = RequestContext.getCurrentContext();
            return (boolean) ctx.get("isSuccess");
        }
    
        @Override
        public Object run() {
            RequestContext ctx = RequestContext.getCurrentContext();
            HttpServletRequest request = ctx.getRequest();
            LOGGER.info("--->>> PasswordFilter {},{}", request.getMethod(), request.getRequestURL().toString());
            String username = request.getParameter("password");
            if (null != username && username.equals("123456")) {
                ctx.setSendZuulResponse(true);
                ctx.setResponseStatusCode(200);
                ctx.set("isSuccess", true);
                return null;
            } else {
                ctx.setSendZuulResponse(false);
                ctx.setResponseStatusCode(400);
                ctx.setResponseBody("The password cannot be empty");
                ctx.set("isSuccess", false);
                return null;
            }
        }
    }

## 开启过滤器 ##

@EnableZuulProxy
    @SpringBootApplication(exclude = {DataSourceAutoConfiguration.class})
    public class ZuulFilterApplication {
        @Bean
        public TokenFilter tokenFilter() {
            return new TokenFilter();
        }
    
        @Bean
        public PasswordFilter PasswordFilter() {
            return new PasswordFilter();
        }
    
        public static void main(String[] args) {
            SpringApplication.run(ZuulFilterApplication.class, args);
        }
    }

## token 测试 ##

![20200526181633901.png][]

[http://localhost:9000/api1?token=token-uuid][http_localhost_9000_api1_token_token-uuid]

![20200526181715238.png][]

[http://localhost:9000/api1?token=token-uuid&&password=123456][http_localhost_9000_api1_token_token-uuid_password_123456]

![20200526181747984.png][]

# Spring Cloud Config #

## 一、Config Server ##

## 添加依赖 ##

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

## 开启服务注册 ##

@SpringBootApplication(exclude = {DataSourceAutoConfiguration.class})
    @EnableConfigServer
    public class ConfigServerApplication {
        public static void main(String[] args) {
            SpringApplication.run(ConfigServerApplication.class, args);
        }
    }

## 添加配置 ##

spring:
      application:
        name: config-server
      cloud:
        config:
          label: master
          server:
            git:
              uri: https://github.com/glory2018/spring-cloud-config.git #配置文件所在仓库
              search-paths: spring-cloud-config  #配置文件所在根目录
              #私有仓库需要填写用户名密码,公开仓库不需要
              #          username: github 登录账号
              #          password: github 登录密码
              #          default-label: master #配置文件分支
    server:
      port: 8888

[application-dev.properties][]

content=hello dev

[application-test.properties][]

content=hello test

[application-prod.properties][]

content=hello prod

## 测试服务 ##

[http://localhost:8888/springCloudConfig/dev/master][http_localhost_8888_springCloudConfig_dev_master]

![20200526184338911.png][]

## 二、Config Client ##

## 添加依赖 ##

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

## 开启服务注册 ##

@RestController
    @SpringBootApplication(exclude = {DataSourceAutoConfiguration.class})
    public class ConfigClientApplication {
        @Value("${content}")
        String content;
    
        @RequestMapping("/")
        public String home() {
            return "content:" + content;
        }
    
        public static void main(String[] args) {
            SpringApplication.run(ConfigClientApplication.class, args);
        }
    }

## 添加配置 ##

spring:
      application:
        name: config-client
      cloud:
        config:
          label: master
          profile: dev
          uri: http://localhost:8888 #通过域名访问配置中心服务端
    #      fail-fast: true
    #      discovery:
    #        enabled: true
    server:
      port: 8088

## 测试服务 ##

[http://localhost:8088/][http_localhost_8088]

![2020052619475947.png][]

## 三、集成 Eureka ##

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

## 开启服务注册 ##

@EnableEurekaClient
    @EnableConfigServer
    @SpringBootApplication(exclude = {DataSourceAutoConfiguration.class})
    public class ConfigServerApplication {
        public static void main(String[] args) {
            SpringApplication.run(ConfigServerApplication.class, args);
        }
    }

## 配置 ##

## 测试服务 ##

[http://localhost:8888/springCloudConfig/dev/master][http_localhost_8888_springCloudConfig_dev_master]

![2020052621280916.png][]

## 四、Config Client Eureka ##

`spring-cloud-eureka-provider-1`  
`spring-cloud-eureka-provider-2`  
`spring-cloud-eureka-provider-3`

## 添加依赖 ##

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

## 开启服务注册 ##

@SpringBootApplication(exclude = {DataSourceAutoConfiguration.class})
    @EnableEurekaClient
    @RestController
    public class EurekaProviderApplication {
        @Value("${content}")
        String content;
        @Value("${server.port}")
        String port;
    
        @RequestMapping("/")
        public String home() {
            return "Hello world ,port:" + port + ",content=" + content;
        }
    
        public static void main(String[] args) {
            SpringApplication.run(EurekaProviderApplication.class, args);
        }
    }

## 添加配置 ##

eureka:
      client:
        service-url:
          defaultZone: http://localhost:8761/eureka/
    
    spring:
      application:
        name: eureka-provider
      cloud:
        config:
          label: master
          profile: dev
    #      uri: http://localhost:8888
          discovery:
            enabled: true               #从配置中心读取文件
            service-id: config-server   #通过服务名称去Eureka注册中心找服务
    
    server:
      port: 8081

## 测试服务 ##

`spring-cloud-eureka-service`  
`spring-cloud-config-server`  
`spring-cloud-eureka-provider-1`  
`spring-cloud-eureka-provider-2`  
`spring-cloud-eureka-provider-3`  
`spring-cloud-feign-consumer`

[http://localhost:8761/][http_localhost_8761]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N0ZXZlX2ZyYW5r_size_16_color_FFFFFF_t_70 6][]

[http://localhost:9000/hello][http_localhost_9000_hello]

![20200526220030554.png][]

# **Spring Cloud Bus集成RabbitMQ** #

## **一、Config Server** ##

spring-cloud-config-server

### **添加依赖** ###

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

### 添加配置 ###

eureka:
      client:
        service-url:
          defaultZone: http://localhost:8761/eureka/
    
    spring:
      application:
        name: config-server
      cloud:
        config:
          label: master
          server:
            git:
              uri: https://github.com/glory2018/spring-cloud-config.git #配置文件所在仓库
              search-paths: spring-cloud-config  #配置文件所在根目录
              #私有仓库需要填写用户名密码,公开仓库不需要
              #          username: github 登录账号
              #          password: github 登录密码
              #          default-label: master #配置文件分支
      rabbitmq:
        host: 192.168.1.102
        port: 5672
        username: moses
        password: 123456
    server:
      port: 8888

## 二、Config Client ##

*  `spring-cloud-eureka-provider-1`
 *  `spring-cloud-eureka-provider-2`
 *  `spring-cloud-eureka-provider-3`

### 添加依赖 ###

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

### 添加配置 ###

## **测试服务** ##

### **启动RabbitMQ** ###

### **启动项目** ###

*  `spring-cloud-eureka-service`
 *  `spring-cloud-config-server`
 *  `spring-cloud-eureka-provider-1`
 *  `spring-cloud-eureka-provider-2`
 *  `spring-cloud-eureka-provider-3`
 *  `spring-cloud-feign-consumer`

[http://localhost:8761/][http_localhost_8761]

![20200527104339479.png][]

[http://localhost:15672/\#/queues][http_localhost_15672_queues]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N0ZXZlX2ZyYW5r_size_16_color_FFFFFF_t_70 7][]

[http://localhost:8888/springCloudConfig/dev/master][http_localhost_8888_springCloudConfig_dev_master]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N0ZXZlX2ZyYW5r_size_16_color_FFFFFF_t_70 8][]

修改配置

![20200527104449523.png][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N0ZXZlX2ZyYW5r_size_16_color_FFFFFF_t_70 9][]

[http_localhost_8761]: http://localhost:8761/
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N0ZXZlX2ZyYW5r_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20200526141550103.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N0ZXZlX2ZyYW5r,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N0ZXZlX2ZyYW5r_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20200526141602573.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N0ZXZlX2ZyYW5r,size_16,color_FFFFFF,t_70
[http_192.168.1.101_8500_ui_dc1_nodes]: http://192.168.1.101:8500/ui/dc1/nodes
[20200526141615346.png]: https://img-blog.csdnimg.cn/20200526141615346.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N0ZXZlX2ZyYW5r_size_16_color_FFFFFF_t_70 2]: https://img-blog.csdnimg.cn/20200526141636971.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N0ZXZlX2ZyYW5r,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N0ZXZlX2ZyYW5r_size_16_color_FFFFFF_t_70 3]: https://img-blog.csdnimg.cn/20200526141649142.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N0ZXZlX2ZyYW5r,size_16,color_FFFFFF,t_70
[http_localhost_9000_hello]: http://localhost:9000/hello
[20200526141724201.png]: https://img-blog.csdnimg.cn/20200526141724201.png
[20200526141705696.png]: https://img-blog.csdnimg.cn/20200526141705696.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N0ZXZlX2ZyYW5r_size_16_color_FFFFFF_t_70 4]: https://img-blog.csdnimg.cn/20200526141750363.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N0ZXZlX2ZyYW5r,size_16,color_FFFFFF,t_70
[20200526141801169.png]: https://img-blog.csdnimg.cn/20200526141801169.png
[20200526141926286.png]: https://img-blog.csdnimg.cn/20200526141926286.png
[20200526141948390.png]: https://img-blog.csdnimg.cn/20200526141948390.png
[2020052614194284.png]: https://img-blog.csdnimg.cn/2020052614194284.png
[202005261420015.png]: https://img-blog.csdnimg.cn/202005261420015.png
[20200526142007186.png]: https://img-blog.csdnimg.cn/20200526142007186.png
[20200526142020785.png]: https://img-blog.csdnimg.cn/20200526142020785.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N0ZXZlX2ZyYW5r_size_16_color_FFFFFF_t_70 5]: https://img-blog.csdnimg.cn/20200526142031380.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N0ZXZlX2ZyYW5r,size_16,color_FFFFFF,t_70
[20200526180126390.png]: https://img-blog.csdnimg.cn/20200526180126390.png
[http_127.0.0.1_9000_api1]: http://127.0.0.1:9000/api1
[20200526154417374.png]: https://img-blog.csdnimg.cn/20200526154417374.png
[20200526180231247.png]: https://img-blog.csdnimg.cn/20200526180231247.png
[20200526181633901.png]: https://img-blog.csdnimg.cn/20200526181633901.png
[http_localhost_9000_api1_token_token-uuid]: http://localhost:9000/api1?token=token-uuid
[20200526181715238.png]: https://img-blog.csdnimg.cn/20200526181715238.png
[http_localhost_9000_api1_token_token-uuid_password_123456]: http://localhost:9000/api1?token=token-uuid&&password=123456
[20200526181747984.png]: https://img-blog.csdnimg.cn/20200526181747984.png
[application-dev.properties]: https://github.com/glory2018/spring-cloud-config/blob/master/application-dev.properties
[application-test.properties]: https://github.com/glory2018/spring-cloud-config/blob/master/application-test.properties
[application-prod.properties]: https://github.com/glory2018/spring-cloud-config/blob/master/application-prod.properties
[http_localhost_8888_springCloudConfig_dev_master]: http://localhost:8888/springCloudConfig/dev/master
[20200526184338911.png]: https://img-blog.csdnimg.cn/20200526184338911.png
[http_localhost_8088]: http://localhost:8088/
[2020052619475947.png]: https://img-blog.csdnimg.cn/2020052619475947.png
[2020052621280916.png]: https://img-blog.csdnimg.cn/2020052621280916.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N0ZXZlX2ZyYW5r_size_16_color_FFFFFF_t_70 6]: https://img-blog.csdnimg.cn/20200526221740975.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N0ZXZlX2ZyYW5r,size_16,color_FFFFFF,t_70
[20200526220030554.png]: https://img-blog.csdnimg.cn/20200526220030554.png
[20200527104339479.png]: https://img-blog.csdnimg.cn/20200527104339479.png
[http_localhost_15672_queues]: http://localhost:15672/#/queues
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N0ZXZlX2ZyYW5r_size_16_color_FFFFFF_t_70 7]: https://img-blog.csdnimg.cn/20200527104414330.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N0ZXZlX2ZyYW5r,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N0ZXZlX2ZyYW5r_size_16_color_FFFFFF_t_70 8]: https://img-blog.csdnimg.cn/2020052710442595.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N0ZXZlX2ZyYW5r,size_16,color_FFFFFF,t_70
[20200527104449523.png]: https://img-blog.csdnimg.cn/20200527104449523.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N0ZXZlX2ZyYW5r_size_16_color_FFFFFF_t_70 9]: https://img-blog.csdnimg.cn/20200527104456901.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N0ZXZlX2ZyYW5r,size_16,color_FFFFFF,t_70