SpringCloud最新版环境集成-2021年11月

2023-10-27

总述

之前搞过SpringCloud项目,但版本是netflix维护的伦敦地铁站名称的版本。现在想做一下笔记,并尝试最新版本,看有什么变动没。结果还真有一堆坑。此项目集成了eureka、feign、ribbon、hystrix、zuul五大组件。

一.项目结构

项目包含两个eureka集成,两个服务提供者producer,两个服务消费者consumer,一个服务路由zuul
在这里插入图片描述

二、父类项目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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <groupId>com.ykq</groupId>
    <artifactId>springclouddemo</artifactId>
    <version>1.0.0</version>
    <name>springclouddemo</name>
    <description>Demo project for Spring Cloud</description>
    <packaging>pom</packaging>
    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <maven.compiler.source>1.8</maven.compiler.source>
        <maven.compiler.target>1.8</maven.compiler.target>
        <java.version>1.8</java.version>
        <springboot.version>2.5.7</springboot.version>
        <springcloud.version>3.0.4</springcloud.version>
        <springcloud.netflix.version>2.2.10.RELEASE</springcloud.netflix.version>
    </properties>
    <modules>
        <module>springcloud-eureka-server1</module>
        <module>springcloud-eureka-server2</module>
        <module>springcloud-consumer1</module>
        <module>springcloud-consumer2</module>
        <module>springcloud-producer1</module>
        <module>springcloud-producer2</module>
        <module>springcloud-zuul</module>
    </modules>
    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-parent</artifactId>
                <version>${springboot.version}</version>
                <type>pom</type>
            </dependency>

            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
                <version>${springboot.version}</version>
            </dependency>

            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter</artifactId>
                <version>${springcloud.version}</version>
            </dependency>

            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-netflix-eureka-client</artifactId>
                <version>${springcloud.version}</version>
            </dependency>

            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-loadbalancer</artifactId>
                <version>${springcloud.version}</version>
            </dependency>

            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-openfeign</artifactId>
                <version>${springcloud.version}</version>
            </dependency>

            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
                <version>${springcloud.version}</version>
            </dependency>

            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
                <version>${springcloud.netflix.version}</version>
            </dependency>

            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-zuul</artifactId>
                <version>${springcloud.netflix.version}</version>
            </dependency>

            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
                <version>${springcloud.netflix.version}</version>
            </dependency>

            <dependency>
                <groupId>io.github.openfeign</groupId>
                <artifactId>feign-hystrix</artifactId>
                <version>10.12</version>
            </dependency>

            <dependency>
                <groupId>com.netflix.eureka</groupId>
                <artifactId>eureka-client</artifactId>
                <version>1.10.16</version>
            </dependency>

            <dependency>
                <groupId>com.netflix.ribbon</groupId>
                <artifactId>ribbon-eureka</artifactId>
                <version>2.2.5</version>
            </dependency>
        </dependencies>
    </dependencyManagement>

</project>

三、eureka搭建

下面展示两个eureka的文件

1.springcloud-eureka-server1
(1)eureka1的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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>com.ykq</groupId>
        <artifactId>springclouddemo</artifactId>
        <version>1.0.0</version>
    </parent>
    <groupId>com.ykq</groupId>
    <artifactId>springcloud-eureka-server1</artifactId>
    <version>1.0.0</version>
    <name>springcloud-eureka-server1</name>
    <description>Demo project for Spring Cloud</description>
    <properties>
        <java.version>1.8</java.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <type>pom</type>
        </dependency>

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

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
            <exclusions>
                <exclusion>
                    <artifactId>gson</artifactId>
                    <groupId>com.google.code.gson</groupId>
                </exclusion>
            </exclusions>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <version>2.3.0.RELEASE</version>
                <executions>
                    <execution>
                        <goals>
                            <goal>repackage</goal>
                        </goals>
                    </execution>
                </executions>
                <configuration>
                    <classifier>SpringcloudEurekaServerApplication1</classifier>
                    <mainClass>com.ykq.SpringcloudEurekaServerApplication1</mainClass>
                </configuration>
            </plugin>
        </plugins>
    </build>

</project>
(2)eureka1的application.properties
spring.application.name=springcloud-eureka-server
server.port=10001
# 不向eureka注册
eureka.client.register-with-eureka=false
# 不从eureka获取注册信息
eureka.client.fetch-registry=false
# 向eureka注册的地址,后面服务名称必须为eureka
eureka.client.serviceUrl.defaultZone=http://localhost:10002/eureka/
(3)eureka1的启动类
package com.ykq;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;

@EnableEurekaServer
@SpringBootApplication
public class SpringCloudEurekaServerApplication1 {
    public static void main(String[] args) {
        SpringApplication.run(SpringCloudEurekaServerApplication1.class, args);
    }
}
2.springcloud-eureka-server2
(1)eureka2的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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>com.ykq</groupId>
        <artifactId>springclouddemo</artifactId>
        <version>1.0.0</version>
    </parent>
    <groupId>com.ykq</groupId>
    <artifactId>springcloud-eureka-server2</artifactId>
    <version>1.0.0</version>
    <name>springcloud-eureka-server2</name>
    <description>Demo project for Spring Cloud</description>
    <properties>
        <java.version>1.8</java.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <type>pom</type>
        </dependency>

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

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
            <exclusions>
                <exclusion>
                    <artifactId>gson</artifactId>
                    <groupId>com.google.code.gson</groupId>
                </exclusion>
            </exclusions>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <version>2.3.0.RELEASE</version>
                <executions>
                    <execution>
                        <goals>
                            <goal>repackage</goal>
                        </goals>
                    </execution>
                </executions>
                <configuration>
                    <classifier>SpringcloudEurekaServerApplication2</classifier>
                    <mainClass>com.ykq.SpringcloudEurekaServerApplication2</mainClass>
                </configuration>
            </plugin>
        </plugins>
    </build>

</project>
(2)eureka2的application.properties
spring.application.name=springcloud-eureka-server
server.port=10002
# 不向eureka注册
eureka.client.register-with-eureka=false
# 不从eureka获取注册信息
eureka.client.fetch-registry=false
# 向eureka注册的地址,后面服务名称必须为eureka
eureka.client.serviceUrl.defaultZone=http://localhost:10001/eureka/
(3)eureka2的启动类
package com.ykq;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;

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

四、producer搭建

1.springcloud-producer1
(1)producer1的项目结构

在这里插入图片描述

(2)producer1的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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>com.ykq</groupId>
        <artifactId>springclouddemo</artifactId>
        <version>1.0.0</version>
    </parent>
    <groupId>com.ykq</groupId>
    <artifactId>springcloud-producer1</artifactId>
    <version>1.0.0</version>
    <name>springcloud-producer1</name>
    <description>Demo project for Spring Cloud</description>
    <properties>
        <java.version>1.8</java.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <type>pom</type>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

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

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

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

        <dependency>
            <groupId>com.netflix.eureka</groupId>
            <artifactId>eureka-client</artifactId>
            <exclusions>
                <exclusion>
                    <artifactId>gson</artifactId>
                    <groupId>com.google.code.gson</groupId>
                </exclusion>
            </exclusions>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <version>2.3.0.RELEASE</version>
                <executions>
                    <execution>
                        <goals>
                            <goal>repackage</goal>
                        </goals>
                    </execution>
                </executions>
                <configuration>
                    <classifier>SpringcloudProducerApplication1</classifier>
                    <mainClass>com.ykq.SpringcloudProducerApplication1</mainClass>
                </configuration>
            </plugin>
        </plugins>
    </build>

</project>
(3)producer1的application.properties
spring.application.name=springcloud-producer
server.port=10003
eureka.client.serviceUrl.defaultZone=http://localhost:10001/eureka/,http://localhost:10002/eureka/

eureka.instance.prefer-ip-address=true
(4)producer1的启动类
package com.ykq;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.netflix.hystrix.EnableHystrix;

@EnableHystrix
@EnableDiscoveryClient
@SpringBootApplication
public class SpringCloudProducerApplication1 {
    public static void main(String[] args) {
        SpringApplication.run(SpringCloudProducerApplication1.class, args);
    }
}
(5)producer1的HelloController1
package com.ykq.hello;

import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * @author: kqyin
 * @date: 2021/11/24 14:49
 * @Description: hello world
 */
@RestController
public class HelloController1 {

    @RequestMapping(value = "/hello")
    public String hello() {
        return "hello world, I am producer1";
    }
}
(6)producer1的ProducerController1
package com.ykq.producer;

import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * @author: kqyin
 * @date: 2021/12/2 9:56
 * @Description:
 */
@RestController
public class ProducerController1 {
    @RequestMapping("/producerSupport")
    public String producer() {
        return "Hello, this is producer1 at your service!";
    }
}
(7)producer1的TestController1
package com.ykq.test;

import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * @author: kqyin
 * @date: 2021/11/25 13:57
 * @Description:
 */
@RestController
public class TestController1 {

    @HystrixCommand(fallbackMethod = "hystrixFallBack")
    @RequestMapping(value = "/test")
    public String hystrix() {
        throw new RuntimeException();
    }

    public String hystrixFallBack() {
        return "I am hystrixFallBack1";
    }
}
2.springcloud-producer2
(1)producer2的项目结构

在这里插入图片描述

(2)producer2的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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>com.ykq</groupId>
        <artifactId>springclouddemo</artifactId>
        <version>1.0.0</version>
    </parent>
    <groupId>com.ykq</groupId>
    <artifactId>springcloud-producer2</artifactId>
    <version>1.0.0</version>
    <name>springcloud-producer2</name>
    <description>Demo project for Spring Cloud</description>
    <properties>
        <java.version>1.8</java.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <type>pom</type>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

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


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

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

        <dependency>
            <groupId>com.netflix.eureka</groupId>
            <artifactId>eureka-client</artifactId>
            <exclusions>
                <exclusion>
                    <artifactId>gson</artifactId>
                    <groupId>com.google.code.gson</groupId>
                </exclusion>
            </exclusions>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <version>2.3.0.RELEASE</version>
                <executions>
                    <execution>
                        <goals>
                            <goal>repackage</goal>
                        </goals>
                    </execution>
                </executions>
                <configuration>
                    <classifier>SpringcloudProducerApplication2</classifier>
                    <mainClass>com.ykq.SpringcloudProducerApplication2</mainClass>
                </configuration>
            </plugin>
        </plugins>
    </build>

</project>
(3)producer2的application.properties
spring.application.name=springcloud-producer
server.port=10004
eureka.client.serviceUrl.defaultZone=http://localhost:10001/eureka/,http://localhost:10002/eureka/

eureka.instance.prefer-ip-address=true
(4)producer2的启动类
package com.ykq;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.netflix.hystrix.EnableHystrix;

@EnableHystrix
@EnableDiscoveryClient
@SpringBootApplication
public class SpringCloudProducerApplication2 {
    public static void main(String[] args) {
        SpringApplication.run(SpringCloudProducerApplication2.class, args);
    }
}
(5)producer2的HelloController2
package com.ykq.hello;

import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * @author: kqyin
 * @date: 2021/11/24 14:49
 * @Description: hello world
 */
@RestController
public class HelloController2 {

    @RequestMapping(value = "/hello")
    public String hello() {
        return "hello world, I am producer2";
    }
}
(6)producer2的ProducerController2
package com.ykq.producer;

import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * @author: kqyin
 * @date: 2021/12/2 9:56
 * @Description:
 */
@RestController
public class ProducerController2 {
    @RequestMapping("/producerSupport")
    public String producer() {
        return "Hello, this is producer2 at your service!";
    }
}
(7)producer2的TestController2
package com.ykq.test;

import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * @author: kqyin
 * @date: 2021/11/25 13:57
 * @Description:
 */
@RestController
public class TestController2 {

    @HystrixCommand(fallbackMethod = "hystrixFallBack")
    @RequestMapping(value = "/test")
    public String hystrix() {
        throw new RuntimeException();
    }

    public String hystrixFallBack() {
        return "I am hystrixFallBack2";
    }
}

五、consumer搭建

1.springcloud-consumer1
(1)consumer1的项目结构

在这里插入图片描述

(2)consumer1的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">
    <parent>
        <artifactId>springclouddemo</artifactId>
        <groupId>com.ykq</groupId>
        <version>1.0.0</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.ykq</groupId>
    <artifactId>springcloud-consumer1</artifactId>
    <version>1.0.0</version>
    <properties>
        <java.version>1.8</java.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <type>pom</type>
        </dependency>

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

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

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

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

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

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

        <dependency>
            <groupId>io.github.openfeign</groupId>
            <artifactId>feign-hystrix</artifactId>
        </dependency>

        <dependency>
            <groupId>com.netflix.eureka</groupId>
            <artifactId>eureka-client</artifactId>
            <exclusions>
                <exclusion>
                    <artifactId>gson</artifactId>
                    <groupId>com.google.code.gson</groupId>
                </exclusion>
            </exclusions>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <version>2.3.0.RELEASE</version>
                <executions>
                    <execution>
                        <goals>
                            <goal>repackage</goal>
                        </goals>
                    </execution>
                </executions>
                <configuration>
                    <classifier>SpringCloudConsumerApplication1</classifier>
                    <mainClass>com.ykq.SpringCloudConsumerApplication1</mainClass>
                </configuration>
            </plugin>
        </plugins>
    </build>
</project>
(3)consumer1的application.properties
spring.application.name=springcloud-consumer
server.port=10005
eureka.client.serviceUrl.defaultZone=http://localhost:10001/eureka/,http://localhost:10002/eureka/
eureka.instance.appname=springcloud-consumer
server.servlet.context-path=/springcloud-consumer
# 开启hystrix断路器,老版本为feign。hystrix.enable==true
feign.circuitbreaker.enabled=true
#允许存在多个Feign调用相同Service的接口
spring.main.allow-bean-definition-overriding=true

eureka.instance.prefer-ip-address=true
(4)consumer1的启动类
package com.ykq;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.openfeign.EnableFeignClients;

/**
 * @author: kqyin
 * @date: 2021/11/24 15:00
 * @Description:
 */
@EnableDiscoveryClient
@EnableFeignClients
@SpringBootApplication
public class SpringCloudConsumerApplication1 {
    public static void main(String[] args) {
        SpringApplication.run(SpringCloudConsumerApplication1.class, args);
    }
}
(5)consumer1的HelloController
package com.ykq.hello;

import com.ykq.api.HelloFeign;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.RestController;

/**
 * @author: kqyin
 * @date: 2021/11/24 15:04
 * @Description:
 */
@RestController
public class HelloController {
    @Autowired
    private HelloFeign helloFeign;

    @RequestMapping(value = "/hello")
    public String hello() {
        return helloFeign.hello();
    }
}
(6)consumer1的HelloFeign
package com.ykq.api;

import com.ykq.api.hystrix.HelloFeignHystrix;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;

/**
 * @author: kqyin
 * @date: 2021/11/24 15:06
 * @Description:
 */
@FeignClient(name= "springcloud-producer", fallback= HelloFeignHystrix.class)
public interface HelloFeign {
    @RequestMapping(value = "/hello")
    String hello();
}
(7)consumer1的HelloFeignHystrix
package com.ykq.api.hystrix;

import com.ykq.api.HelloFeign;
import org.springframework.stereotype.Component;

/**
 * @author: kqyin
 * @date: 2021/11/25 10:00
 * @Description: helloFeign断路器
 */
@Component
public class HelloFeignHystrix implements HelloFeign {
    public String hello() {
        return "hello world, I am feign hystrix1";
    }
}
(8)consumer1的ConsumerController
package com.ykq.consumer;

import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * @author: kqyin
 * @date: 2021/12/2 9:52
 * @Description:
 */
@RestController
public class ConsumerController {
    @RequestMapping("/consumerSupport")
    public String consumer(){
        return "Hello, this is consumer1 at your service!";
    }
}
(9)consumer1的TestController
package com.ykq.test;

import com.ykq.api.TestFeign;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * @author: kqyin
 * @date: 2021/11/25 14:08
 * @Description:
 */
@RestController
public class TestController {
    @Autowired
    private TestFeign testFeign;

    @RequestMapping("/test")
    public String test() {
        return testFeign.test();
    }
}
(10)consumer的TestFeign
package com.ykq.api;

import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.RequestMapping;

/**
 * @author: kqyin
 * @date: 2021/11/25 14:08
 * @Description:
 */
@FeignClient(name= "springcloud-producer")
public interface TestFeign {
    @RequestMapping(value = "/test")
    String test();
}
2.springcloud-consumer2
(1)consumer2的项目结构

在这里插入图片描述

(2)consumer2的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">
    <parent>
        <artifactId>springclouddemo</artifactId>
        <groupId>com.ykq</groupId>
        <version>1.0.0</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.ykq</groupId>
    <artifactId>springcloud-consumer2</artifactId>
    <version>1.0.0</version>
    <properties>
        <java.version>1.8</java.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <type>pom</type>
        </dependency>

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

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

<!--        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
            <version>2.5.7</version>
        </dependency>-->

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

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

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

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

        <dependency>
            <groupId>io.github.openfeign</groupId>
            <artifactId>feign-hystrix</artifactId>
        </dependency>

        <dependency>
            <groupId>com.netflix.eureka</groupId>
            <artifactId>eureka-client</artifactId>
            <exclusions>
                <exclusion>
                    <artifactId>gson</artifactId>
                    <groupId>com.google.code.gson</groupId>
                </exclusion>
            </exclusions>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <version>2.3.0.RELEASE</version>
                <executions>
                    <execution>
                        <goals>
                            <goal>repackage</goal>
                        </goals>
                    </execution>
                </executions>
                <configuration>
                    <classifier>SpringCloudConsumerApplication2</classifier>
                    <mainClass>com.ykq.SpringCloudConsumerApplication2</mainClass>
                </configuration>
            </plugin>
        </plugins>
    </build>
</project>
(3)consumer2的application.properties
spring.application.name=springcloud-consumer
server.port=10006
eureka.client.serviceUrl.defaultZone=http://localhost:10001/eureka/,http://localhost:10002/eureka/
eureka.instance.appname=springcloud-consumer
server.servlet.context-path=/springcloud-consumer
# 开启hystrix断路器,老版本为feign。hystrix.enable==true
feign.circuitbreaker.enabled=true
#允许存在多个Feign调用相同Service的接口
spring.main.allow-bean-definition-overriding=true

eureka.instance.prefer-ip-address=true
(4)consumer2的启动类
package com.ykq;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.openfeign.EnableFeignClients;

/**
 * @author: kqyin
 * @date: 2021/11/24 15:00
 * @Description:
 */
@EnableDiscoveryClient
@EnableFeignClients
@SpringBootApplication
public class SpringCloudConsumerApplication2 {
    public static void main(String[] args) {
        SpringApplication.run(SpringCloudConsumerApplication2.class, args);
    }
}
(5)consumer2的HelloController
package com.ykq.hello;

import com.ykq.api.HelloFeign;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.RestController;

/**
 * @author: kqyin
 * @date: 2021/11/24 15:04
 * @Description:
 */
@RestController
public class HelloController {
    @Autowired
    private HelloFeign helloFeign;

    @RequestMapping(value = "/hello")
    public String hello() {
        return helloFeign.hello();
    }
}
(6)consumer2的HelloFeign
package com.ykq.api;

import com.ykq.api.hystrix.HelloFeignHystrix;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;

/**
 * @author: kqyin
 * @date: 2021/11/24 15:06
 * @Description:
 */
@FeignClient(name= "springcloud-producer", fallback= HelloFeignHystrix.class)
public interface HelloFeign {
    @RequestMapping(value = "/hello")
    String hello();
}
(7)consumer2的HelloFeignHystrix
package com.ykq.api.hystrix;

import com.ykq.api.HelloFeign;
import org.springframework.stereotype.Component;

/**
 * @author: kqyin
 * @date: 2021/11/25 10:00
 * @Description: helloFeign断路器
 */
@Component
public class HelloFeignHystrix implements HelloFeign {
    public String hello() {
        return "hello world, I am feign hystrix2";
    }
}
(8)consumer2的ConsumerController
package com.ykq.consumer;

import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * @author: kqyin
 * @date: 2021/12/2 9:52
 * @Description:
 */
@RestController
public class ConsumerController {
    @RequestMapping("/consumerSupport")
    public String consumer(){
        return "Hello, this is consumer2 at your service!";
    }
}
(9)consumer2的TestController
package com.ykq.test;

import com.ykq.api.TestFeign;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * @author: kqyin
 * @date: 2021/11/25 14:08
 * @Description:
 */
@RestController
public class TestController {
    @Autowired
    private TestFeign testFeign;

    @RequestMapping("/test")
    public String test() {
        return testFeign.test();
    }
}
(10)consumer2的TestFeign
package com.ykq.api;

import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.RequestMapping;

/**
 * @author: kqyin
 * @date: 2021/11/25 14:08
 * @Description:
 */
@FeignClient(name= "springcloud-producer")
public interface TestFeign {
    @RequestMapping(value = "/test")
    String test();
}

六、zuul搭建

1.springcloud-zuul
(1)zuul的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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <artifactId>springclouddemo</artifactId>
        <groupId>com.ykq</groupId>
        <version>1.0.0</version>
    </parent>
    <groupId>com.ykq</groupId>
    <artifactId>springcloud-zuul</artifactId>
    <version>1.0.0</version>
    <name>springcloud-zuul</name>
    <description>Demo project for Spring Boot</description>
    <properties>
        <java.version>1.8</java.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <type>pom</type>
        </dependency>

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

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

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

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

        <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-ribbon</artifactId>
        </dependency>

        <dependency>
            <groupId>com.netflix.eureka</groupId>
            <artifactId>eureka-client</artifactId>
            <exclusions>
                <exclusion>
                    <artifactId>gson</artifactId>
                    <groupId>com.google.code.gson</groupId>
                </exclusion>
            </exclusions>
        </dependency>

        <dependency>
            <groupId>com.netflix.ribbon</groupId>
            <artifactId>ribbon-eureka</artifactId>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <version>2.3.0.RELEASE</version>
                <executions>
                    <execution>
                        <goals>
                            <goal>repackage</goal>
                        </goals>
                    </execution>
                </executions>
                <configuration>
                    <classifier>SpringCloudZuulApplication</classifier>
                    <mainClass>com.ykq.SpringCloudZuulApplication</mainClass>
                </configuration>
            </plugin>
        </plugins>
    </build>

</project>
(2)zuul的application.properties
spring.application.name=springcloud-zuul
server.port=10007

eureka.client.fetch-registry=true
eureka.client.serviceUrl.defaultZone=http://localhost:10001/eureka/,http://localhost:10002/eureka/
eureka.instance.prefer-ip-address=true
#server.servlet.context-path=/zuul

zuul.routes.springcloud-consumer.path=/springcloud-consumer/**
zuul.routes.springcloud-consumer.serviceId=springcloud-consumer
#zuul.routes.springcloud-consumer.url=http://127.0.0.1:10005/
zuul.routes.springcloud-consumer.strip-prefix=false

springcloud-consumer.ribbon.NIWSServerListClassName=com.netflix.niws.loadbalancer.DiscoveryEnabledNIWSServerList
springcloud-consumer.ribbon.ServerListUpdaterClassName=com.netflix.niws.loadbalancer.EurekaNotificationServerListUpdater
# refresh every minute
springcloud-consumer.ribbon.ServerListRefreshInterval=60000


zuul.routes.springcloud-producer.path=/springcloud-producer/**
# 只添加serviceId是不行的,需要指定NIWSServerListClassName和ServerListUpdaterClassName
#zuul.routes.producer.service-id=springcloud-producer
# 单一url没法实现负载
#zuul.routes.springcloud-producer.url=http://127.0.0.1:10003/
# 指定负载url
springcloud-producer.ribbon.listOfServers=http://127.0.0.1:10003/,http://127.0.0.1:10004/


zuul.routes.baidu.path=/json/**
zuul.routes.baidu.url=http://www.json.cn/

# 设置超时时间
zuul.host.connect-timeout-millis=3000
zuul.host.connection-request-timeout-millis=3000

# 强制加载,不设置会进行懒加载。spring 第一次请求会非常慢
zuul.ribbon.eager-load.enabled=true
# ribbon 从eureka拉取数据
ribbon.eureka.enabled=true
(3)zuul的启动类
package com.ykq;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.cloud.netflix.zuul.EnableZuulProxy;

@EnableZuulProxy
@EnableDiscoveryClient
@EnableEurekaClient
@SpringBootApplication
public class SpringCloudZuulApplication {

    public static void main(String[] args) {
        SpringApplication.run(SpringCloudZuulApplication.class, args);
    }

}
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

SpringCloud最新版环境集成-2021年11月 的相关文章

随机推荐

  • Eclipse Mars(4.5.2) 安装Gradle 插件

    第一步 选择Eclipse Marketplace 第二步 搜索Buildship gradle插件 并安装 第三步 gradle 安装授权协议 第四步 点击confim 完成安装后要求重启 Eclipse 第五步 Eclipse查看是否有
  • 2023牛客暑假多校训练营2

    D The Game of Eating 贪心 题目说每个人只关心自己享用的菜肴 而不考虑他人 每个人的目标都是使得自己喜欢的菜肴尽可能多 也就是说每个人都很鸡贼 它们当下都是做出最有利于自己的选择 对于某一个人 他首先会算在他之后他最喜欢
  • 计算机探秘二 (算盘与二进制)

    上次我们说到如何将数字通过CPU的电路线 后面我们称为数据线 传给它 在说这个问题前 我们一起看下咱老祖宗发明的计算神器 算盘 它长这样的 算盘分上珠和下珠 下珠每个珠子表示一个 上珠每个珠子表示5个 上下珠之间有一根细长的圆杆相连 具体计
  • linux驱动程序运行优先级,如何调整Linux内核启动中的驱动初始化顺序(late_initcall和module_init)...

    在init h 中有如下定义 define pure initcall fn define initcall 0 fn 1 define core initcall fn define initcall 1 fn 1 define core
  • STM32串口IAP(YModem) (转载)

    在之前的 STM32串口IAP 一文中 通过传输数据流来升级程序 但是这种 裸 数据的传输方式存在这许多的问题 比如它没有容错机制 不能保证数据的正确传输 还比如说它无法获知升级文件的信息 导致它在判断何时停止接收数据上 犹豫不决 正式为了
  • Cobalt-Strike基本使用

    Cobalt Strike 简介 Cobalt Strike 简称为CS 是一款基于java的渗透测试工具 尤其是后渗透阶段 自3 0开始已经不再使用Metasploit框架而作为一个独立的平台使用 这款工具有其他很多渗透测试工具没有的团队
  • Git-远程仓库(GitLab)

    系列文章 Git 入门小结 Git 分支 Git 常用命令 Git 注册远程仓库 Git 远程仓库 1 生成SSH KEY ssh keygen t rsa C youremail xx com git里注册的邮箱 可以用git confi
  • MybatisPlus更新时会自动忽略传值为NULL的字段

    三种方案解决MybatisPlus更新时会自动忽略传值为NULL的字段 一 背景 二 解决方案 2 1 使用 TableField updateStrategy FieldStrategy IGNORED 注解添加在字段上 在枚举 Fiel
  • Python数据分析与大数据技术与应用高级教程

    Python数据分析与大数据技术与应用高级教程 教程地址 https www piaodoo com 课程目标 虚拟现实 增强现实及混合现实技术既密切相关 又有显著差别 培训课程旨在帮助学员深入理解这三者的思想精髓及其统一技术构架 梳理出V
  • Hexo 完整使用教程

    官网 官网地址 https hexo io zh cn 环境 1 node hexo 基于 node 所以首先要安装node环境 2 npm 包管理工具 环境配置请参考本站对应安装教程 快速开始 安装 hexo npm install g
  • Mysql数据库内联查询、左连接查询、右连接查询、自连接查询介绍

    目录 一 内联查询 1 inner join 只查询键值一致 交叉 的部分 2 演示 二 左连接 1 left join 以左表为标准 查询输出左表中没有的字段信息 2 演示 三 右连接 1 right join 以右表为标准 查询输出右表
  • 区块如何防篡改_一种区块链防篡改技术的优化方法与流程

    本发明涉及区块链技术领域 具体涉及一种区块链防篡改技术的优化方法 背景技术 区块链是比特币等数字虚拟货币的底层技术 通过去中心化的数据记录 由全网所有的节点共同维护数据 实现安全地存储数据 具有不可伪造性 不可篡改性 可追溯性 匿名性等特点
  • Java编程练习之:水仙花数

    文章目录 1 题目 2 思路 3 代码 4 运行结果 1 题目 打印出所有的 水仙花数 所谓 水仙花数 是指一个三位数 其各位数字立方和等于该数本身 例如 153是一个 水仙花数 因为153 1的三次方 5的三次方 3的三次方 2 思路 这
  • 线程池的简介说明

    在多线程应用程序开发中 如果我们不使用线程池 则每次创建和销毁线程将会消耗宝贵的CPU 内存资源 所以我们必须创建一个线程池 线程池的功能 线程池用于管理线程 用于减少系统资源消耗 创建一个线程池 实现思路 借助线程池类Executor 借
  • Java Map集合 体系

    1 Collection集合 1 1 常用集合的体系 mermaid svg dmg6k5CugOsij3Ax label font family trebuchet ms verdana arial font family var mer
  • openGL之API学习(九十四)几何着色器的几个参数设置含义

    设定输入几何图元的类型 比如GL TRIANGLES glProgramParameteriEXT program GL GEOMETRY INPUT TYPE EXT inputGeometryType 设定输出几何图元的类型 比如GL
  • Leetcode之KMP字符串算法

    针对题目28题 实现strStr 功能找出needle在haystack字符串的第一个位置 否则返回 1 当然有暴力法 但是时间复杂度是O mn 而KMP算法提前计算出needle字符串的重复数据加以利用 j能够有效的回退到可能的位置 时间
  • 树干树叶点云分类

    将扫描的树木点云的树干树枝和树叶分类出来 后续放出程序代码
  • Cluster & Docker

    操作系统解决主要问题之一就是如何在一台机器上调度硬件资源 比如为一个进程分配cpu gpu 存储资源等 使得进程可以高效 按照预期地完成运行 云和互联网解决的主要问题之一是如何在多台机器之间调度硬件资源or调度信息资源 这就产生了更丰富架构
  • SpringCloud最新版环境集成-2021年11月

    总述 之前搞过SpringCloud项目 但版本是netflix维护的伦敦地铁站名称的版本 现在想做一下笔记 并尝试最新版本 看有什么变动没 结果还真有一堆坑 此项目集成了eureka feign ribbon hystrix zuul五大