1.打開官網稍微學習一下，了解一下spring cloud是個什么東西，大概有哪些組件等

https://spring.io/projects/spring-cloud

https://docs.spring.io/spring-cloud-netflix/docs/current/reference/html/

2.新建項目

打開網址：https://start.spring.io/

選擇需要引入的組件，然后下載下來即可

3.更改項目結構

為了測試的方便，需將項目結構更改為多模塊的項目。

步驟如下：

(1) 依次新建子模塊register-center/provider/consumer，刪除父模塊中多余的src、target等文件夾

(2) 修改父模塊的pom文件：僅保留<dependencyManagement>配置節，<dependencies>配置節全部注釋掉，因為可在子模塊按需添加依賴。

(3) 修改register-center的pom中的依賴配置

1. <dependencies>
2. <!-- Eureka注冊中心 -->
3. <dependency>
4. <groupId>org.springframework.cloud</groupId>
5. <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
6. </dependency>
7. </dependencies>

(4) 修改provider和consumer的pom中依賴配置

1. <dependencies>
2. <dependency>
3. <groupId>org.springframework.boot</groupId>
4. <artifactId>spring-boot-starter-web</artifactId>
5. </dependency>
6. <dependency>
7. <groupId>org.springframework.cloud</groupId>
8. <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
9. </dependency>
10. </dependencies>

4.新建相應的測試類和配置文件

4.1 register-center模塊

啟動類

1. package com.hdwang.springcloudtest.registercenter;
2.  
3. import org.springframework.boot.SpringApplication;
4. import org.springframework.boot.autoconfigure.SpringBootApplication;
5. import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
6.  
7. @SpringBootApplication
8. @EnableEurekaServer
9. public class Application {
10.  
11. /**
12. * 運行點對點模式（集群模式）時，通過添加VM參數啟動不同的注冊中心節點實例
13. * 例如：-Dspring.profiles.active=peer2
14. *
15. * @param args
16. */
17. public static void main(String[] args) {
18. SpringApplication.run(Application.class, args);
19. }
20.  
21. }

yml配置

1. spring:
2. application:
3. #應用名
4. name: register-center
5. freemarker:
6. template-loader-path: classpath:/templates/
7. prefer-file-system-access: false
8. #激活的配置，可運行時添加參數進行修改 -Dspring.profiles.active=peer2
9. profiles:
10. active: peer1
11.  
12. # #Eureka獨立模式配置，僅有一個注冊中心節點
13. #server:
14. # port: 8090
15. #eureka:
16. # instance:
17. # hostname: localhost
18. # client:
19. # #僅僅作為注冊中心，既不提供服務也不訂閱服務
20. # registerWithEureka: false
21. # fetchRegistry: false
22. # #注冊中心地址
23. # serviceUrl:
24. # defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/
25.  
26. # Eureka點對點模式，保證注冊中心高可用，注冊的實例信息會在點與點之間相互同步
27. eureka:
28. client:
29. serviceUrl:
30. defaultZone: http://peer1.com:8091/eureka/,http://peer2.com:8092/eureka/,http://peer3.com:8093/eureka/
31.  
32. ---
33. #每個注冊中心節點不同的配置
34. spring:
35. profiles: peer1
36. server:
37. port: 8091
38. eureka:
39. instance:
40. #在本機hosts中配置即可
41. hostname: peer1.com
42.  
43. ---
44. spring:
45. profiles: peer2
46. server:
47. port: 8092
48. eureka:
49. instance:
50. hostname: peer2.com
51.  
52. ---
53. spring:
54. profiles: peer3
55. server:
56. port: 8093
57. eureka:
58. instance:
59. hostname: peer3.com

4.2 provider模塊

啟動類

1. package com.hdwang.springcloudtest.provider;
2.  
3. import org.springframework.boot.SpringApplication;
4. import org.springframework.boot.autoconfigure.SpringBootApplication;
5.  
6. @SpringBootApplication
7. public class Application {
8.  
9. /**
10. * 運行時添加VM參數: -Dserver.port=8082可以啟動多個provider實例
11. *
12. * @param args
13. */
14. public static void main(String[] args) {
15. SpringApplication.run(Application.class, args);
16. }
17.  
18. }

服務注冊類

1. package com.hdwang.springcloudtest.provider.restservice;
2.  
3. import org.slf4j.Logger;
4. import org.slf4j.LoggerFactory;
5. import org.springframework.web.bind.annotation.RequestMapping;
6. import org.springframework.web.bind.annotation.RestController;
7.  
8. /**
9. * 注冊的服務
10. */
11. @RestController
12. public class RestService {
13. /**
14. * 日志
15. */
16. private static final Logger LOG = LoggerFactory.getLogger(RestService.class);
17.  
18. @RequestMapping("/sayHello")
19. public String sayHello(String name) {
20. LOG.info("sayHello was called");
21. return "hello, " + name;
22. }
23. }

yml配置

1. spring:
2. application:
3. #應用名，也是eureka的服務名
4. name: provider
5. freemarker:
6. template-loader-path: classpath:/templates/
7. prefer-file-system-access: false
8.  
9. server:
10. #運行時，添加參數-Dserver.port=8082運行新的provider實例
11. port: 8081
12.  
13. eureka:
14. client:
15. #注冊中心地址
16. serviceUrl:
17. #注冊中心獨立模式
18. #defaultZone: http://localhost:8090/eureka/
19. #注冊中心點對點模式
20. defaultZone: http://peer1.com:8091/eureka/,http://peer2.com:8092/eureka/,http://peer3.com:8093/eureka/

4.3 consumer配置

啟動類

1. package com.hdwang.springcloudtest.consumer;
2.  
3. import org.springframework.boot.SpringApplication;
4. import org.springframework.boot.autoconfigure.SpringBootApplication;
5.  
6. @SpringBootApplication
7. public class Application {
8.  
9. public static void main(String[] args) {
10. SpringApplication.run(Application.class, args);
11. }
12.  
13. }

服務調用測試類

1. package com.hdwang.springcloudtest.consumer.controller;
2.  
3. import com.netflix.appinfo.InstanceInfo;
4. import com.netflix.discovery.EurekaClient;
5. import org.springframework.beans.factory.annotation.Autowired;
6. import org.springframework.http.HttpEntity;
7. import org.springframework.http.HttpHeaders;
8. import org.springframework.http.MediaType;
9. import org.springframework.http.ResponseEntity;
10. import org.springframework.util.LinkedMultiValueMap;
11. import org.springframework.util.MultiValueMap;
12. import org.springframework.web.bind.annotation.GetMapping;
13. import org.springframework.web.bind.annotation.RestController;
14. import org.springframework.web.client.RestTemplate;
15.  
16. import java.util.*;
17.  
18. /**
19. * 測試
20. */
21. @RestController
22. public class TestController {
23.  
24. /**
25. * 使用服務名才能負載均衡，不能使用直接使用地址
26. */
27. private static final String REST_URL_PREFIX = "http://provider";
28.  
29. @Autowired
30. private EurekaClient discoveryClient;
31.  
32. @Autowired
33. private RestTemplate restTemplate;
34.  
35. @GetMapping("/testGet")
36. public String testGet() {
37. ResponseEntity<String> res = restTemplate.getForEntity(REST_URL_PREFIX + "/sayHello?name={1}", String.class, getName());
38. return res.getBody();
39. }
40.  
41. @GetMapping("/testPost")
42. public String testPost() {
43. MultiValueMap<String, Object> params = new LinkedMultiValueMap<String, Object>();
44. params.add("name", getName());
45.  
46. // HttpHeaders headers = new HttpHeaders();
47. // headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);
48.  
49. HttpEntity< MultiValueMap<String, Object>> request = new HttpEntity<>(params, null);
50. ResponseEntity<String> res = restTemplate.postForEntity(REST_URL_PREFIX + "/sayHello", request, String.class);
51. return res.getBody();
52. }
53.  
54. private String getName() {
55. List<String> greetings = Arrays.asList("Bob", "Alice", "Jack");
56. Random rand = new Random();
57. int randomNum = rand.nextInt(greetings.size());
58. return greetings.get(randomNum);
59. }
60. }

RestTemplate負責均衡配置類

1. package com.hdwang.springcloudtest.consumer.config;
2.  
3. import org.springframework.cloud.client.loadbalancer.LoadBalanced;
4. import org.springframework.context.annotation.Bean;
5. import org.springframework.context.annotation.Configuration;
6. import org.springframework.web.client.RestTemplate;
7.  
8. @Configuration
9. public class RestTemplateConfig {
10.  
11. /**
12. * 構建有負載均衡功能的RestTemplate實例對象
13. *
14. * @return RestTemplate實例對象
15. */
16. @Bean
17. @LoadBalanced
18. RestTemplate restTemplate() {
19. return new RestTemplate();
20. }
21. }

yml配置

1. spring:
2. application:
3. #應用名，也是Eureka的服務名
4. name: cosumer
5.  
6. server:
7. port: 8088
8.  
9. eureka:
10. client:
11. #注冊中心地址
12. serviceUrl:
13. #注冊中心獨立模式
14. #defaultZone: http://localhost:8090/eureka/
15. #注冊中心點對點模式
16. defaultZone: http://peer1.com:8091/eureka/,http://peer2.com:8092/eureka/,http://peer3.com:8093/eureka/

5.運行測試

5.1本機hosts配置

127.0.0.1 peer1.com
127.0.0.1 peer2.com
127.0.0.1 peer3.com

5.2 編輯運行配置

三個注冊中心節點運行配置

兩個服務提供者的運行配置

5.3 運行程序

(1) 啟動注冊中心

依次啟動RegisterCenter1->RegisterCenter2->RegisterCenter3，啟動成功后，可訪問http://localhost:8091/ 或http://localhost:8092/ 或http://localhost:8093/ 查看是否啟動成功

(2)啟動服務提供者provider

依次啟動Provider1->Provider2, 隨便訪問一個注冊中心地址首頁即可查看狀態，如下圖

(3) 啟動消費者cosumer

(4) 在瀏覽器中進行測試

測試地址：http://localhost:8088/testPost / http://localhost:8088/testGet

(5) 在Provider1/Provider2的控制臺中可以看到輸出結果

2021-04-07 15:26:56.043  INFO 8796 --- [nio-8081-exec-1] c.h.s.provider.restservice.RestService   : sayHello was called
2021-04-07 15:26:58.860  INFO 8796 --- [nio-8081-exec-2] c.h.s.provider.restservice.RestService   : sayHello was called
2021-04-07 15:26:59.535  INFO 8796 --- [nio-8081-exec-3] c.h.s.provider.restservice.RestService   : sayHello was called
2021-04-07 15:26:59.925  INFO 8796 --- [nio-8081-exec-4] c.h.s.provider.restservice.RestService   : sayHello was called
2021-04-07 15:27:00.266  INFO 8796 --- [nio-8081-exec-5] c.h.s.provider.restservice.RestService   : sayHello was called
2021-04-07 15:27:00.663  INFO 8796 --- [nio-8081-exec-6] c.h.s.provider.restservice.RestService   : sayHello was called
2021-04-07 15:27:00.938  INFO 8796 --- [nio-8081-exec-7] c.h.s.provider.restservice.RestService   : sayHello was called

2021-04-07 15:26:58.602  INFO 17828 --- [nio-8082-exec-1] c.h.s.provider.restservice.RestService   : sayHello was called
2021-04-07 15:26:59.194  INFO 17828 --- [nio-8082-exec-2] c.h.s.provider.restservice.RestService   : sayHello was called
2021-04-07 15:26:59.737  INFO 17828 --- [nio-8082-exec-3] c.h.s.provider.restservice.RestService   : sayHello was called
2021-04-07 15:27:00.109  INFO 17828 --- [nio-8082-exec-4] c.h.s.provider.restservice.RestService   : sayHello was called
2021-04-07 15:27:00.414  INFO 17828 --- [nio-8082-exec-5] c.h.s.provider.restservice.RestService   : sayHello was called
2021-04-07 15:27:00.815  INFO 17828 --- [nio-8082-exec-6] c.h.s.provider.restservice.RestService   : sayHello was called

恭喜！至此，Spring Clound 微服務集群框架您已經搭建成功！

附錄

github地址：https://github.com/hdwang123/springcloudtest

參考文章：

https://www.zhihu.com/question/283286745/answer/763040709

https://www.cnblogs.com/qdhxhz/p/9357502.html

https://www.cnblogs.com/cjsblog/p/8005766.html

https://blog.csdn.net/weixin_44448094/article/details/88535475

到此這篇關于SpringCloud搭建netflix-eureka微服務集群的過程詳解的文章就介紹到這了,更多相關SpringCloud搭建netflix-eureka集群內容請搜索服務器之家以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持服務器之家！

原文鏈接：https://www.cnblogs.com/hdwang/archive/2021/04/07/14628372.html