经验首页 前端设计 程序设计 Java相关 移动开发 数据库/运维 软件/图像 大数据/云计算 其他经验
当前位置：技术经验 » Java相关 » Spring Boot » 查看文章
springboot2.0和springcloud Finchley版项目搭建(包含eureka，gateWay，Freign，Hystrix)
来源：jb51　　时间：2019/5/29 9:50:24　　对本文有异议

前段时间spring boot 2.0发布了，与之对应的spring cloud Finchley版本也随之而来了，两者之间的关系和版本对应详见我这边文章：spring boot和spring cloud对应的版本关系

项目地址：spring-cloud-demo

spring boot 1.x和spring cloud Dalston和Edgware版本搭建的微服务项目现在已经很流行了，现在很多企业都已经在用了，这里就不多说了。

使用版本说明：

  • spring boot 2.0.x
  • spring cloud Finchley.RELEASE
  • jdk 1.8
  • maven 3.9

Eureka 注册中心

spring cloud Finchley在支持spring 2.0时修改了eureka的jar包，把之前netflix系列的jar引入的时候都加上了netflix

  1. <dependency>
  2.   <groupId>org.springframework.cloud</groupId>
  3.   <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
  4. </dependency>
  5.  

新建一个eureka-service注册中心服务，pom.xml 文件内容如下：

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3.   xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  4.   <modelVersion>4.0.0</modelVersion>
  5.  
  6.   <groupId>com.sunvalley</groupId>
  7.   <artifactId>eureka-service</artifactId>
  8.   <version>0.0.1-SNAPSHOT</version>
  9.   <packaging>jar</packaging>
  10.  
  11.   <name>eureka-service</name>
  12.   <description>Demo project for Spring Boot</description>
  13.  
  14.   <parent>
  15.    <groupId>com.sunvalley.springcloud</groupId>
  16.    <artifactId>spring-cloud-demo</artifactId>
  17.    <version>0.0.1-SNAPSHOT</version>
  18.   </parent>
  19.  
  20.   <properties>
  21.    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  22.    <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
  23.    <java.version>1.8</java.version>
  24.    <spring-cloud.version>Finchley.RELEASE</spring-cloud.version>
  25.   </properties>
  26.  
  27.   <dependencies>
  28.    <dependency>
  29.      <groupId>org.springframework.cloud</groupId>
  30.      <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
  31.    </dependency>
  32.  
  33.    <dependency>
  34.      <groupId>org.springframework.boot</groupId>
  35.      <artifactId>spring-boot-starter-test</artifactId>
  36.      <scope>test</scope>
  37.    </dependency>
  38.   </dependencies>
  39.  
  40.   <dependencyManagement>
  41.     <dependencies>
  42.       <dependency>
  43.         <groupId>org.springframework.cloud</groupId>
  44.         <artifactId>spring-cloud-dependencies</artifactId>
  45.       <version>${spring-cloud.version}</version>
  46.         <type>pom</type>
  47.         <scope>import</scope>
  48.       </dependency>
  49.     </dependencies>
  50.   </dependencyManagement>
  51.  
  52.   <build>
  53.    <plugins>
  54.      <plugin>
  55.       <groupId>org.springframework.boot</groupId>
  56.       <artifactId>spring-boot-maven-plugin</artifactId>
  57.      </plugin>
  58.    </plugins>
  59.   </build>
  60.  
  61. </project>

eureka-service服务的配置文件，application.yml

  1. spring:
  2.  application:
  3.   name: eureka-service
  4.  
  5. server:
  6.  port: 5000
  7.  
  8. eureka:
  9.  instance:
  10.   hostname: localhost
  11.  client:
  12.   registerWithEureka: false
  13.   fetchRegistry: false
  14.   serviceUrl:
  15.    defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/

eureka-service服务的配置文件，EurekaServiceApplication

  1. @EnableEurekaServer
  2. @SpringBootApplication
  3. public class EurekaServiceApplication {
  4.  
  5.   public static void main(String[] args) {
  6.    SpringApplication.run(EurekaServiceApplication.class, args);
  7.   }
  8. }

使用IDEA启动eureka-service服务，本地访问 http://localhost:5000/ 即可看到注册中心内容。

服务消费者consumer和提供者provider

实际工作中大多数一个服务既是其它服务的消费者又有可能是服务的提供者，所以我们也就不用刻意的取区分开。

新建一个order-service服务，pom.xml文件

注意：除了eureka-client，openfeign等jar包外，记得引入spring-boot-starter-web不然会出现启动报错。

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3.   xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  4.   <modelVersion>4.0.0</modelVersion>
  5.  
  6.   <groupId>com.sunvalley</groupId>
  7.   <artifactId>order-service</artifactId>
  8.   <version>0.0.1-SNAPSHOT</version>
  9.   <packaging>jar</packaging>
  10.  
  11.   <name>order-service</name>
  12.   <description>Demo project for Spring Cloud</description>
  13.  
  14.   <parent>
  15.    <groupId>com.sunvalley.springcloud</groupId>
  16.    <artifactId>spring-cloud-demo</artifactId>
  17.    <version>0.0.1-SNAPSHOT</version>
  18.   </parent>
  19.  
  20.   <properties>
  21.    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  22.    <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
  23.    <java.version>1.8</java.version>
  24.    <spring-cloud.version>Finchley.RELEASE</spring-cloud.version>
  25.   </properties>
  26.  
  27.   <dependencies>
  28.    <dependency>
  29.      <groupId>org.springframework.boot</groupId>
  30.      <artifactId>spring-boot-starter</artifactId>
  31.    </dependency>
  32.  
  33.    <!-- eureka 里面已经包含 ribbon 了， 所以不用单独添加， ribbon依赖， 点击依赖就去看就知道了 -->
  34.    <dependency>
  35.      <groupId>org.springframework.cloud</groupId>
  36.      <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
  37.    </dependency>
  38.  
  39.    <dependency>
  40.      <groupId>org.springframework.cloud</groupId>
  41.      <artifactId>spring-cloud-starter-openfeign</artifactId>
  42.    </dependency>
  43.  
  44.    <dependency>
  45.      <groupId>org.springframework.cloud</groupId>
  46.      <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
  47.    </dependency>
  48.  
  49.    <dependency>
  50.      <groupId>org.springframework.boot</groupId>
  51.      <artifactId>spring-boot-starter-web</artifactId>
  52.    </dependency>
  53.  
  54.    <dependency>
  55.      <groupId>org.projectlombok</groupId>
  56.      <artifactId>lombok</artifactId>
  57.      <optional>true</optional>
  58.    </dependency>
  59.  
  60.    <dependency>
  61.      <groupId>org.springframework.boot</groupId>
  62.      <artifactId>spring-boot-starter-test</artifactId>
  63.      <scope>test</scope>
  64.    </dependency>
  65.   </dependencies>
  66.  
  67.   <dependencyManagement>
  68.    <dependencies>
  69.      <dependency>
  70.       <groupId>org.springframework.cloud</groupId>
  71.       <artifactId>spring-cloud-dependencies</artifactId>
  72.       <version>${spring-cloud.version}</version>
  73.       <type>pom</type>
  74.       <scope>import</scope>
  75.      </dependency>
  76.    </dependencies>
  77.   </dependencyManagement>
  78.  
  79.   <build>
  80.    <plugins>
  81.      <plugin>
  82.       <groupId>org.springframework.boot</groupId>
  83.       <artifactId>spring-boot-maven-plugin</artifactId>
  84.      </plugin>
  85.    </plugins>
  86.   </build>
  87.  
  88.   <repositories>
  89.    <repository>
  90.      <id>spring-snapshots</id>
  91.      <name>Spring Snapshots</name>
  92.      <url>https://repo.spring.io/snapshot</url>
  93.      <snapshots>
  94.       <enabled>true</enabled>
  95.      </snapshots>
  96.    </repository>
  97.    <repository>
  98.      <id>spring-milestones</id>
  99.      <name>Spring Milestones</name>
  100.      <url>https://repo.spring.io/milestone</url>
  101.      <snapshots>
  102.       <enabled>false</enabled>
  103.      </snapshots>
  104.    </repository>
  105.   </repositories>
  106.  
  107.   <pluginRepositories>
  108.    <pluginRepository>
  109.      <id>spring-snapshots</id>
  110.      <name>Spring Snapshots</name>
  111.      <url>https://repo.spring.io/snapshot</url>
  112.      <snapshots>
  113.       <enabled>true</enabled>
  114.      </snapshots>
  115.    </pluginRepository>
  116.    <pluginRepository>
  117.      <id>spring-milestones</id>
  118.      <name>Spring Milestones</name>
  119.      <url>https://repo.spring.io/milestone</url>
  120.      <snapshots>
  121.       <enabled>false</enabled>
  122.      </snapshots>
  123.    </pluginRepository>
  124.   </pluginRepositories>
  125.  
  126.  
  127. </project>

order-service服务的配置文件，application.yml

  1. spring:
  2.  application:
  3.   name: order-service
  4.  
  5. server:
  6.  port: 5100
  7.  
  8. eureka:
  9.  client:
  10.   service-url:
  11.    defaultZone: http://localhost:5000/eureka/
  12.  
  13.  
  14. feign:
  15.  hystrix:
  16.   enabled: true

order-service服务的启动类，OrderServiceApplication

  1. @EnableCircuitBreaker
  2. @EnableFeignClients
  3. @EnableEurekaClient
  4. @SpringBootApplication
  5. public class OrderServiceApplication {
  6.  
  7.   public static void main(String[] args) {
  8.    SpringApplication.run(OrderServiceApplication.class, args);
  9.   }
  10. }

order-service服务的接口，OrderController

  1. @RestController
  2. @RequestMapping("/order")
  3. public class OrderController {
  4.   @Value("${server.port}")
  5.   private String port;
  6.  
  7.   /**
  8.    * 获取服务端口号
  9.    * @return
  10.    */
  11.   @GetMapping("/getOrderPort")
  12.   public String getOrderPort() {
  13.     return "order-service port：" + port;
  14.   }
  15. }

新建一个user-service服务，pom.xml文件跟order-service一样的这里就不列出来了

user-service服务的配置文件，application.yml

  1. spring:
  2.  application:
  3.   name: user-service
  4.  
  5. server:
  6.  port: 5200
  7.  
  8. eureka:
  9.  client:
  10.   service-url:
  11.    defaultZone: http://localhost:5000/eureka/
  12.  
  13. feign:
  14.  hystrix:
  15.   enabled: true

user-service服务的启动类也跟order-service一样的

在user-service工程目录下新建一个package，再新建一个OrderRemote接口使用feign调用order-service的方法

  1. @FeignClient(value = "order-service", fallback = OrderRemoteHystrix.class)
  2. public interface OrderRemote {
  3.   @GetMapping("/order/getOrderPort")
  4.   String getOrderPort();
  5. }

熔断机制提示类

  1. @Component
  2. public class OrderRemoteHystrix implements OrderRemote {
  3.   @Override
  4.   public String getOrderPort() {
  5.     return "order service 调用失败！";
  6.   }
  7. }

user-service服务的接口，UserController

  1. @RestController
  2. @RequestMapping("/user")
  3. public class UserController {
  4.   @Autowired
  5.   OrderRemote orderRemote;
  6.   @Value("${server.port}")
  7.   String port;
  8.  
  9.   /**
  10.    * 获取用户服务的端口
  11.    * @return
  12.    */
  13.   @GetMapping("/getUserPort")
  14.   public String getUserPort() {
  15.     return "user-service port：" + port;
  16.   }
  17.  
  18.   /**
  19.    * 获取订单服务的端口
  20.    * @return
  21.    */
  22.   @GetMapping("/getOrderPort")
  23.   public String getOrderPort() {
  24.     return "user-order-service port：" + orderRemote.getOrderPort();
  25.   }
  26. }

测试，分别启动eureka-service，order-service，user-service就可以在注册中心看到服务

在浏览器访问 http://localhost:5100/order/getOrderPort 调用order-service的接口

 在浏览器访问 http://localhost:5200/user/getOrderPort 通过user-service使用feign声明式调用order-service的接口

关闭order-service，再次调用就会发现熔断机制起了作用

spring cloud gateway

Spring Cloud Gateway是Spring官方基于Spring 5.0，Spring Boot 2.0和Project Reactor等技术开发的网关，Spring Cloud Gateway旨在为微服务架构提供一种简单而有效的统一的API路由管理方式。Spring Cloud Gateway作为Spring Cloud生态系中的网关，目标是替代Netflix ZUUL，其不仅提供统一的路由方式，并且基于Filter链的方式提供了网关基本的功能，例如：安全，监控/埋点，和限流等。

新建一个gateway-service服务，pom.xml文件如下

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3.   xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  4.   <modelVersion>4.0.0</modelVersion>
  5.  
  6.   <groupId>com.sunvalley</groupId>
  7.   <artifactId>gateway-service</artifactId>
  8.   <version>0.0.1-SNAPSHOT</version>
  9.   <packaging>jar</packaging>
  10.  
  11.   <name>gateway-service</name>
  12.   <description>Demo project for Spring Cloud</description>
  13.  
  14.   <parent>
  15.    <groupId>com.sunvalley.springcloud</groupId>
  16.    <artifactId>spring-cloud-demo</artifactId>
  17.    <version>0.0.1-SNAPSHOT</version>
  18.   </parent>
  19.  
  20.   <properties>
  21.    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  22.    <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
  23.    <java.version>1.8</java.version>
  24.    <spring-cloud.version>Finchley.RELEASE</spring-cloud.version>
  25.   </properties>
  26.  
  27.   <dependencies>
  28.    <dependency>
  29.      <groupId>org.springframework.boot</groupId>
  30.      <artifactId>spring-boot-starter-actuator</artifactId>
  31.    </dependency>
  32.    <dependency>
  33.      <groupId>org.springframework.cloud</groupId>
  34.      <artifactId>spring-cloud-starter-gateway</artifactId>
  35.    </dependency>
  36.    <dependency>
  37.      <groupId>org.springframework.cloud</groupId>
  38.      <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
  39.    </dependency>
  40.    <dependency>
  41.      <groupId>org.springframework.cloud</groupId>
  42.      <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
  43.    </dependency>
  44.  
  45.    <dependency>
  46.      <groupId>org.springframework.boot</groupId>
  47.      <artifactId>spring-boot-devtools</artifactId>
  48.      <scope>runtime</scope>
  49.    </dependency>
  50.    <dependency>
  51.      <groupId>org.projectlombok</groupId>
  52.      <artifactId>lombok</artifactId>
  53.      <optional>true</optional>
  54.    </dependency>
  55.    <dependency>
  56.      <groupId>org.springframework.boot</groupId>
  57.      <artifactId>spring-boot-starter-test</artifactId>
  58.      <scope>test</scope>
  59.    </dependency>
  60.   </dependencies>
  61.  
  62.   <dependencyManagement>
  63.    <dependencies>
  64.      <dependency>
  65.       <groupId>org.springframework.cloud</groupId>
  66.       <artifactId>spring-cloud-dependencies</artifactId>
  67.       <version>${spring-cloud.version}</version>
  68.       <type>pom</type>
  69.       <scope>import</scope>
  70.      </dependency>
  71.    </dependencies>
  72.   </dependencyManagement>
  73.  
  74.   <build>
  75.    <plugins>
  76.      <plugin>
  77.       <groupId>org.springframework.boot</groupId>
  78.       <artifactId>spring-boot-maven-plugin</artifactId>
  79.      </plugin>
  80.    </plugins>
  81.   </build>
  82.  
  83.  
  84. </project>

gateway-service的配置文件,application.yml

  1. spring:
  2.  application:
  3.   name: gateway-service
  4.  cloud:    # spring cloud gateway 路由配置方式
  5.   gateway:
  6.    discovery:   #是否与服务发现组件进行结合，通过 serviceId(必须设置成大写) 转发到具体的服务实例。默认为false，设为true便开启通过服务中心的自动根据 serviceId 创建路由的功能。
  7.     locator:   #路由访问方式：http://Gateway_HOST:Gateway_PORT/大写的serviceId/**，其中微服务应用名默认大写访问。
  8.      enabled: true
  9.    routes:
  10.    - id: 163           #网关路由到网易官网
  11.     uri: http://www.163.com/
  12.     predicates:
  13.      - Path=/163/**
  14. #   - id: ORDER-SERVICE      #网关路由到订单服务order-service
  15. #    uri: lb://ORDER-SERVICE
  16. #    predicates:
  17. #     - Path=/ORDER-SERVICE/**
  18. #   - id: USER-SERVICE      #网关路由到用户服务user-service
  19. #    uri: lb://USER-SERVICE
  20. #    predicates:
  21. #     - Pach=/USER-SERVICE/**
  22.  
  23. server:
  24.  port: 5001
  25.  
  26.  
  27. logging:
  28.  level:
  29.   org.springframework.cloud.gateway: trace
  30.   org.springframework.http.server.reactive: debug
  31.   org.springframework.web.reactive: debug
  32.   reactor.ipc.netty: debug
  33.  
  34.  
  35. eureka:
  36.  client:
  37.   service-url:
  38.    defaultZone: http://localhost:5000/eureka/
  39.  
  40. feign:
  41.  hystrix:
  42.   enabled: true

gateway-service的启动类，Application

  1. package com.sunvalley.demo;
  2.  
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  5. import org.springframework.cloud.gateway.route.RouteLocator;
  6. import org.springframework.cloud.gateway.route.builder.RouteLocatorBuilder;
  7. import org.springframework.context.annotation.Bean;
  8.  
  9. @SpringBootApplication
  10. public class GatewayServiceApplication {
  11.  
  12.   /**
  13.   * spring cloud gateway 配置方式之一，启动主程序配置，还有一种是配置文件配置
  14.   * @param builder
  15.   * @return
  16.   */
  17.   @Bean
  18.   public RouteLocator customRouteLocator(RouteLocatorBuilder builder) {
  19.    return builder.routes()
  20.       .route(r -> r.path("/qq/**")
  21.            .and()
  22.            .uri("http://www.qq.com/"))
  23.       .build();
  24.   }
  25.  
  26.   public static void main(String[] args) {
  27.    SpringApplication.run(GatewayServiceApplication.class, args);
  28.   }
  29. }

通过上面我们可以看到，gateway网关路由配置有两种方式：

1.通过@Bean自定义RouteLocator，在启动主类Application中配置

2.在配置文件yml中配置

这两种方式都可以实现网关路由是等价的，但是通常项目开发中会使用配置文件yml方式。

运行测试：

访问 http://localhost:8080/qq，路由转发到 http://www.qq.com
访问http://localhost:8080/163, 路由转发到 http://www.163.com

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持w3xue。

 友情链接：直通硅谷 　点职佳 　北美留学生论坛

Spring Boot热门文章

  • 史上最详 Thymeleaf 使用教程
  • Spring Boot如何通过java -jar启动
  • Spring Boot 2.x（六）：优雅的统一返回值
  • Springboot使用Logback实现日志配置与异常记录
  • 使用SpringBoot+EasyExcel+Vue实现excel表格的导入和导出详解
  • spring boot上传文件超出大小异常无法捕获问题
  • paging组件的用法和意义
  • springboot2.0集成rabbitmq的示例代码
  • Spring MVC学习step1——框架熟悉
  • spring boot ${}占位符不起作用的解决方案

    • Spring Boot推荐文章

  • 3分钟带你搞定Spring Boot中Schedule
  • 不单独部署注册中心，又要具备注册中心的功能，我能上天！
  • 从零开始学Spring Boot系列-集成Spring Security实现用户认证与授权
  • 不单独部署注册中心，又要具备注册中心的功能，咋不让我上天？
  • EasyExcel 无法读取图片？用poi写了一个工具类
  • 【进阶篇】使用 Stream 流对比两个集合的常用操作分享
  • 关于DDD和COLA的一些总结和思考
  • SnakeYaml反序列化分析
  • RestTemplate进行https请求时适配信任证书
  • Kryo反序列化链分析

    • 本站QQ群：前端 618073944 | Java 606181507 | Python 626812652 | C/C++ 612253063 | 微信 634508462 | 苹果 692586424 | C#/.net 182808419 | PHP 305140648 | 运维 608723728

    W3xue 的所有内容仅供测试，对任何法律问题及风险不承担任何责任。通过使用本站内容随之而来的风险与本站无关。
    关于我们  |  意见建议  |  捐助我们  |  报错有奖  |  广告合作、友情链接（目前9元/月）请联系QQ：27243702 沸活量
    皖ICP备17017327号-2　皖公网安备34020702000426号