內容
SpringBoot整合SpringCloud的Eureka、Zuul等組件,快速實現簡單易懂且具有服務熔斷、負載均衡的分布式架構1.0,體驗微服務的魅力。
版本
IDE:IDEA 2017.2.2 x64
JDK:1.8.0_171
manve:3.3.3
SpringBoot:1.5.9.RELEASE
SpringCloud:Dalston.SR1
適合人群
Java開發人員
說明
轉載請說明出處:SpringCloud從入門到進階(六)——使用SpringBoot搭建微服務
參考
SpringCloud從入門到進階(二)——注冊中心Eureka的偽分布式部署
項目目錄
pom.xml
在原有SpringBoot項目的基礎上引入SpringCloud的默認依賴,以及eureka client的依賴。
<?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.leo</groupId> <artifactId>service</artifactId> <version>1.0-SNAPSHOT</version> <!-- 通過繼承的方式引入spring boot --> <!--parent標簽用於指定父pom--> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>1.5.9.RELEASE</version> </parent> <!--properties標簽用於聲明一些常量,例如源碼編碼為UTF-8,輸出代碼也為UTF-8,Java版本為1.8--> <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>Dalston.SR1</spring-cloud.version> </properties> <!--添加1:在dependencyManagement標簽中聲明默認依賴的SpringCloud的版本, 所有的SpringCloud組件的依賴都將使用該版本SpringCloud中規定的版本號 --> <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> <dependencies> <!--添加2:SpringCloud-Eureka相關依賴 --> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-eureka</artifactId> </dependency> <!-- SpringBoot相關等其他依賴省略 --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> </dependencies> <!-- Spring Boot的Maven插件,使用Maven插件的方式來啟動Spring Boot工程 如果不添加該插件在使用mvn命令打包的jar有問題,執行時會報錯:xxx.jar中沒有主清單屬性--> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> <executions> <execution> <goals> <goal>repackage</goal> </goals> </execution> </executions> </plugin> </plugins> </build> </project>
yaml
在原有項目的基礎上增加eurekaSever的連接信息、微服務的應用名稱、多profiles的配置。為了演示負載均衡的效果,本示例添加三個profiles。
spring: #添加3:設置springboot項目的應用名稱,並默認啟動peer1 application: name: application-serviceA #注意:此處的名稱一定要個路由接入服務器中的配置名一致 profiles: active: peer1 http: multipart: #上傳文件總的最大值為30MB max-request-size: 30MB #單個文件的最大值為10MB max-file-size: 10MB #省略原有Springboot項目的數據源、redis、mybatis、分頁等配置 #添加4:eurekaSever的連接信息 eureka: instance: #要求Client通過ip的方式進行注冊 prefer-ip-address: true client: service-url: defaultZone: http://172.26.125.114:7001/eureka,http://172.26.125.115:7001/eureka,http://172.26.125.118:7001/eureka #日志輸出,指明日志存放位置;同時需要在資源路徑下引入配置文件 logging: file: logs/application-idleGoodService-${server.port}.logs #添加5:增加peer1和peer2、peer3多個profiles的配置 --- spring: profiles: peer1 server: port: 8881 #Eureka實例名的配置 eureka: instance: instance-id: application-serviceA-A2-8881 #actuator的配置 management: port: 8811 security: enabled: false --- spring: profiles: peer2 server: port: 8882 #Eureka實例名的配置 eureka: instance: instance-id: application-serviceA-A2-8882 #actuator的配置 management: port: 8812 security: enabled: false --- spring: profiles: peer3 server: port: 8883 #Eureka實例名的配置 eureka: instance: instance-id: application-serviceA-A2-8883 #actuator的配置 management: port: 8813 security: enabled: false
SpringApplication
在主程序類中增加@EurekaClient,開啟eureka服務。
//開啟EurekaClient @EnableEurekaClient @SpringBootApplication //包掃描、Swagger、事務的配置省略 public class IdlegoodApplication { //一些bean的注入和創建省略public static void main(String[] args) { SpringApplication.run(IdlegoodApplication.class, args); } }
Controller
SpringBoot項目改造成微服務時,業務邏輯只要保證無狀態即可,不要進行額外配置。本示例為了演示功能,在Controller中寫兩個服務,一個是普通POST接口處理,一個是文件上傳的接口。
@RequestMapping("/test") @RestController public class DemoController { //從配置文件中讀取實例名稱 @Value("${eureka.instance.instance-id}") String instanceID; @PostMapping("/hello/{name}") public String sayHello(@PathVariable(value = "name") String name, @RequestParam(value = "from") String user){ return "Hello "+name+",this is DemoTest.From "+user+"@:"+instanceID+"."; } @PostMapping("/upload") public String uploadFile(@RequestParam("file") MultipartFile file){ String str="file名稱:"+file.getOriginalFilename()+",file大小:"+file.getSize()+"From "+instanceID+"."; System.out.println(str); return str; } }
測試接口1:http://localhost:8881/test/hello/leo,正常。
按照之前的操作進行項目打包、上傳,具體過程可參考:SpringCloud從入門到進階(二)——注冊中心Eureka的偽分布式部署 。
先啟動Eureka集群和路由Zuul,然后在同一個局域網內的主機上,分別執行下列命令啟動微服務的三個實例。啟動后可以通過jps命令可以看到相應的進程:
[user@Serverjars]$java -Dspring.profiles.active=peer1 -jar service-1.0-SNAPSHOT.jar & #服務器A [user@Serverjars]$java -Dspring.profiles.active=peer2 -jar service-1.0-SNAPSHOT.jar & #服務器B [user@Serverjars]$java -Dspring.profiles.active=peer3 -jar service-1.0-SNAPSHOT.jar & #服務器B #通過jps命令可以看到相應的進程,-v選型表示打印jvm參數。 [user@Serverjars]$ jps -v 29410 jar -Dspring.profiles.active=peer1 29366 jar -Dspring.profiles.active=peer2 29321 jar -Dspring.profiles.active=peer3
訪問EurekaSever,確認服務正常啟動。
測試多次,可以看到Zuul會將請求在多個微服務實例中做負載均衡,默認情況按照輪詢算法分配請求。
請求轉發到實例1處理:
請求轉發到實例2處理:
請求轉發到實例3處理:
向服務器上傳小於1MB的文件,測試多次,也可以看到負載均衡的效果。
請求轉發到實例1處理:
請求轉發到實例2處理:
請求轉發到實例3處理:
但是,當上傳超過1MB大小的文件時,服務報錯。
出現這個問題,想必大家都有疑問。同樣的請求,為什么直接調用服務時正常,但是通過Zuul路由調用服務就會出錯呢。如果你在上傳文件的測試中,還遇到服務調用失敗、中文亂碼等詭異報錯,那么說明你測得很全面。對於這些問題的解釋和解決,請看下篇文章 。