springboot2.0和springcloud Finchley版項(xiàng)目搭建(包含eureka,gateWay,F(xiàn)reign,Hystrix)
前段時間spring boot 2.0發(fā)布了,與之對應(yīng)的spring cloud Finchley版本也隨之而來了,兩者之間的關(guān)系和版本對應(yīng)詳見我這邊文章:spring boot和spring cloud對應(yīng)的版本關(guān)系
項(xiàng)目地址:spring-cloud-demo
spring boot 1.x和spring cloud Dalston和Edgware版本搭建的微服務(wù)項(xiàng)目現(xiàn)在已經(jīng)很流行了,現(xiàn)在很多企業(yè)都已經(jīng)在用了,這里就不多說了。
使用版本說明:
- 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
<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId> </dependency>
新建一個eureka-service注冊中心服務(wù),pom.xml 文件內(nèi)容如下:
<?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.sunvalley</groupId> <artifactId>eureka-service</artifactId> <version>0.0.1-SNAPSHOT</version> <packaging>jar</packaging> <name>eureka-service</name> <description>Demo project for Spring Boot</description> <parent> <groupId>com.sunvalley.springcloud</groupId> <artifactId>spring-cloud-demo</artifactId> <version>0.0.1-SNAPSHOT</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>Finchley.RELEASE</spring-cloud.version> </properties> <dependencies> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </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-service服務(wù)的配置文件,application.yml
spring: application: name: eureka-service server: port: 5000 eureka: instance: hostname: localhost client: registerWithEureka: false fetchRegistry: false serviceUrl: defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/
eureka-service服務(wù)的配置文件,EurekaServiceApplication
@EnableEurekaServer @SpringBootApplication public class EurekaServiceApplication { public static void main(String[] args) { SpringApplication.run(EurekaServiceApplication.class, args); } }
使用IDEA啟動eureka-service服務(wù),本地訪問 http://localhost:5000/ 即可看到注冊中心內(nèi)容。
服務(wù)消費(fèi)者consumer和提供者provider
實(shí)際工作中大多數(shù)一個服務(wù)既是其它服務(wù)的消費(fèi)者又有可能是服務(wù)的提供者,所以我們也就不用刻意的取區(qū)分開。
新建一個order-service服務(wù),pom.xml文件
注意:除了eureka-client,openfeign等jar包外,記得引入spring-boot-starter-web不然會出現(xiàn)啟動報錯。
<?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.sunvalley</groupId> <artifactId>order-service</artifactId> <version>0.0.1-SNAPSHOT</version> <packaging>jar</packaging> <name>order-service</name> <description>Demo project for Spring Cloud</description> <parent> <groupId>com.sunvalley.springcloud</groupId> <artifactId>spring-cloud-demo</artifactId> <version>0.0.1-SNAPSHOT</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>Finchley.RELEASE</spring-cloud.version> </properties> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter</artifactId> </dependency> <!-- eureka 里面已經(jīng)包含 ribbon 了, 所以不用單獨(dú)添加, ribbon依賴, 點(diǎn)擊依賴就去看就知道了 --> <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-openfeign</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-web</artifactId> </dependency> <dependency> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId> <optional>true</optional> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </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> <repositories> <repository> <id>spring-snapshots</id> <name>Spring Snapshots</name> <url>https://repo.spring.io/snapshot</url> <snapshots> <enabled>true</enabled> </snapshots> </repository> <repository> <id>spring-milestones</id> <name>Spring Milestones</name> <url>https://repo.spring.io/milestone</url> <snapshots> <enabled>false</enabled> </snapshots> </repository> </repositories> <pluginRepositories> <pluginRepository> <id>spring-snapshots</id> <name>Spring Snapshots</name> <url>https://repo.spring.io/snapshot</url> <snapshots> <enabled>true</enabled> </snapshots> </pluginRepository> <pluginRepository> <id>spring-milestones</id> <name>Spring Milestones</name> <url>https://repo.spring.io/milestone</url> <snapshots> <enabled>false</enabled> </snapshots> </pluginRepository> </pluginRepositories> </project>
order-service服務(wù)的配置文件,application.yml
spring: application: name: order-service server: port: 5100 eureka: client: service-url: defaultZone: http://localhost:5000/eureka/ feign: hystrix: enabled: true
order-service服務(wù)的啟動類,OrderServiceApplication
@EnableCircuitBreaker @EnableFeignClients @EnableEurekaClient @SpringBootApplication public class OrderServiceApplication { public static void main(String[] args) { SpringApplication.run(OrderServiceApplication.class, args); } }
order-service服務(wù)的接口,OrderController
@RestController @RequestMapping("/order") public class OrderController { @Value("${server.port}") private String port; /** * 獲取服務(wù)端口號 * @return */ @GetMapping("/getOrderPort") public String getOrderPort() { return "order-service port:" + port; } }
新建一個user-service服務(wù),pom.xml文件跟order-service一樣的這里就不列出來了
user-service服務(wù)的配置文件,application.yml
spring: application: name: user-service server: port: 5200 eureka: client: service-url: defaultZone: http://localhost:5000/eureka/ feign: hystrix: enabled: true
user-service服務(wù)的啟動類也跟order-service一樣的
在user-service工程目錄下新建一個package,再新建一個OrderRemote接口使用feign調(diào)用order-service的方法
@FeignClient(value = "order-service", fallback = OrderRemoteHystrix.class) public interface OrderRemote { @GetMapping("/order/getOrderPort") String getOrderPort(); }
熔斷機(jī)制提示類
@Component public class OrderRemoteHystrix implements OrderRemote { @Override public String getOrderPort() { return "order service 調(diào)用失??!"; } }
user-service服務(wù)的接口,UserController
@RestController @RequestMapping("/user") public class UserController { @Autowired OrderRemote orderRemote; @Value("${server.port}") String port; /** * 獲取用戶服務(wù)的端口 * @return */ @GetMapping("/getUserPort") public String getUserPort() { return "user-service port:" + port; } /** * 獲取訂單服務(wù)的端口 * @return */ @GetMapping("/getOrderPort") public String getOrderPort() { return "user-order-service port:" + orderRemote.getOrderPort(); } }
測試,分別啟動eureka-service,order-service,user-service就可以在注冊中心看到服務(wù)
在瀏覽器訪問 http://localhost:5100/order/getOrderPort 調(diào)用order-service的接口
在瀏覽器訪問 http://localhost:5200/user/getOrderPort 通過user-service使用feign聲明式調(diào)用order-service的接口
關(guān)閉order-service,再次調(diào)用就會發(fā)現(xiàn)熔斷機(jī)制起了作用
spring cloud gateway
Spring Cloud Gateway是Spring官方基于Spring 5.0,Spring Boot 2.0和Project Reactor等技術(shù)開發(fā)的網(wǎng)關(guān),Spring Cloud Gateway旨在為微服務(wù)架構(gòu)提供一種簡單而有效的統(tǒng)一的API路由管理方式。Spring Cloud Gateway作為Spring Cloud生態(tài)系中的網(wǎng)關(guān),目標(biāo)是替代Netflix ZUUL,其不僅提供統(tǒng)一的路由方式,并且基于Filter鏈的方式提供了網(wǎng)關(guān)基本的功能,例如:安全,監(jiān)控/埋點(diǎn),和限流等。
新建一個gateway-service服務(wù),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.sunvalley</groupId> <artifactId>gateway-service</artifactId> <version>0.0.1-SNAPSHOT</version> <packaging>jar</packaging> <name>gateway-service</name> <description>Demo project for Spring Cloud</description> <parent> <groupId>com.sunvalley.springcloud</groupId> <artifactId>spring-cloud-demo</artifactId> <version>0.0.1-SNAPSHOT</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>Finchley.RELEASE</spring-cloud.version> </properties> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-actuator</artifactId> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-gateway</artifactId> </dependency> <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-hystrix</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-devtools</artifactId> <scope>runtime</scope> </dependency> <dependency> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId> <optional>true</optional> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </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>
gateway-service的配置文件,application.yml
spring: application: name: gateway-service cloud: # spring cloud gateway 路由配置方式 gateway: discovery: #是否與服務(wù)發(fā)現(xiàn)組件進(jìn)行結(jié)合,通過 serviceId(必須設(shè)置成大寫) 轉(zhuǎn)發(fā)到具體的服務(wù)實(shí)例。默認(rèn)為false,設(shè)為true便開啟通過服務(wù)中心的自動根據(jù) serviceId 創(chuàng)建路由的功能。 locator: #路由訪問方式:http://Gateway_HOST:Gateway_PORT/大寫的serviceId/**,其中微服務(wù)應(yīng)用名默認(rèn)大寫訪問。 enabled: true routes: - id: 163 #網(wǎng)關(guān)路由到網(wǎng)易官網(wǎng) uri: http://www.163.com/ predicates: - Path=/163/** # - id: ORDER-SERVICE #網(wǎng)關(guān)路由到訂單服務(wù)order-service # uri: lb://ORDER-SERVICE # predicates: # - Path=/ORDER-SERVICE/** # - id: USER-SERVICE #網(wǎng)關(guān)路由到用戶服務(wù)user-service # uri: lb://USER-SERVICE # predicates: # - Pach=/USER-SERVICE/** server: port: 5001 logging: level: org.springframework.cloud.gateway: trace org.springframework.http.server.reactive: debug org.springframework.web.reactive: debug reactor.ipc.netty: debug eureka: client: service-url: defaultZone: http://localhost:5000/eureka/ feign: hystrix: enabled: true
gateway-service的啟動類,Application
package com.sunvalley.demo; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.gateway.route.RouteLocator; import org.springframework.cloud.gateway.route.builder.RouteLocatorBuilder; import org.springframework.context.annotation.Bean; @SpringBootApplication public class GatewayServiceApplication { /** * spring cloud gateway 配置方式之一,啟動主程序配置,還有一種是配置文件配置 * @param builder * @return */ @Bean public RouteLocator customRouteLocator(RouteLocatorBuilder builder) { return builder.routes() .route(r -> r.path("/qq/**") .and() .uri("http://www.qq.com/")) .build(); } public static void main(String[] args) { SpringApplication.run(GatewayServiceApplication.class, args); } }
通過上面我們可以看到,gateway網(wǎng)關(guān)路由配置有兩種方式:
1.通過@Bean自定義RouteLocator,在啟動主類Application中配置
2.在配置文件yml中配置
這兩種方式都可以實(shí)現(xiàn)網(wǎng)關(guān)路由是等價的,但是通常項(xiàng)目開發(fā)中會使用配置文件yml方式。
運(yùn)行測試:
訪問 http://localhost:8080/qq,路由轉(zhuǎn)發(fā)到 http://www.qq.com
訪問http://localhost:8080/163, 路由轉(zhuǎn)發(fā)到 http://www.163.com
以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。
相關(guān)文章
SpringBoot?jackson提供對LocalDate的支持方式
這篇文章主要介紹了SpringBoot?jackson提供對LocalDate的支持方式,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教2022-01-01Java判斷數(shù)字位數(shù)的方法總結(jié)
本文給大家整理了Java判斷數(shù)字位數(shù)的兩種常用方法,對此有興趣的可以跟著小編一起學(xué)習(xí)下。2018-02-02SpringBoot中的FailureAnalyzer使用詳解
這篇文章主要介紹了SpringBoot中的FailureAnalyzer使用詳解,Spring Boot的FailureAnalyzer是一個接口,它用于在Spring Boot應(yīng)用啟動失敗時提供有關(guān)錯誤的詳細(xì)信息,這對于開發(fā)者來說非常有用,因?yàn)樗梢詭椭覀兛焖僮R別問題并找到解決方案,需要的朋友可以參考下2023-12-12Java?Stream如何將List分組成Map或LinkedHashMap
這篇文章主要給大家介紹了關(guān)于Java?Stream如何將List分組成Map或LinkedHashMap的相關(guān)資料,stream流是Java8的新特性,極大簡化了集合的處理操作,文中通過代碼介紹的非常詳細(xì),需要的朋友可以參考下2023-12-12Java Clone深拷貝與淺拷貝的兩種實(shí)現(xiàn)方法
今天小編就為大家分享一篇關(guān)于Java Clone深拷貝與淺拷貝的兩種實(shí)現(xiàn)方法,小編覺得內(nèi)容挺不錯的,現(xiàn)在分享給大家,具有很好的參考價值,需要的朋友一起跟隨小編來看看吧2018-10-10SpringBoot整合MybatisPlusGernerator實(shí)現(xiàn)逆向工程
在我們寫項(xiàng)目的時候,我們時常會因?yàn)樾枰獎?chuàng)建很多的項(xiàng)目結(jié)構(gòu)而頭疼,本文主要介紹了SpringBoot整合MybatisPlusGernerator實(shí)現(xiàn)逆向工程,具有一定的參考價值,感興趣的可以了解一下2024-05-05