SpringCloud搭建netflix-eureka微服務(wù)集群的過程詳解
1.打開官網(wǎng)稍微學(xué)習(xí)一下,了解一下spring cloud是個什么東西,大概有哪些組件等
https://spring.io/projects/spring-cloud
https://docs.spring.io/spring-cloud-netflix/docs/current/reference/html/
2.新建項目
打開網(wǎng)址:https://start.spring.io/
選擇需要引入的組件,然后下載下來即可
3.更改項目結(jié)構(gòu)
為了測試的方便,需將項目結(jié)構(gòu)更改為多模塊的項目。
步驟如下:
(1) 依次新建子模塊register-center/provider/consumer,刪除父模塊中多余的src、target等文件夾
(2) 修改父模塊的pom文件:僅保留<dependencyManagement>配置節(jié),<dependencies>配置節(jié)全部注釋掉,因為可在子模塊按需添加依賴。
(3) 修改register-center的pom中的依賴配置
<dependencies> <!-- Eureka注冊中心 --> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId> </dependency> </dependencies>
(4) 修改provider和consumer的pom中依賴配置
<dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId> </dependency> </dependencies>
4.新建相應(yīng)的測試類和配置文件
4.1 register-center模塊
啟動類
package com.hdwang.springcloudtest.registercenter; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer; @SpringBootApplication @EnableEurekaServer public class Application { /** * 運行點對點模式(集群模式)時,通過添加VM參數(shù)啟動不同的注冊中心節(jié)點實例 * 例如:-Dspring.profiles.active=peer2 * * @param args */ public static void main(String[] args) { SpringApplication.run(Application.class, args); } }
yml配置
spring: application: #應(yīng)用名 name: register-center freemarker: template-loader-path: classpath:/templates/ prefer-file-system-access: false #激活的配置,可運行時添加參數(shù)進行修改 -Dspring.profiles.active=peer2 profiles: active: peer1 # #Eureka獨立模式配置,僅有一個注冊中心節(jié)點 #server: # port: 8090 #eureka: # instance: # hostname: localhost # client: # #僅僅作為注冊中心,既不提供服務(wù)也不訂閱服務(wù) # registerWithEureka: false # fetchRegistry: false # #注冊中心地址 # serviceUrl: # defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/ # Eureka點對點模式,保證注冊中心高可用,注冊的實例信息會在點與點之間相互同步 eureka: client: serviceUrl: defaultZone: http://peer1.com:8091/eureka/,http://peer2.com:8092/eureka/,http://peer3.com:8093/eureka/ --- #每個注冊中心節(jié)點不同的配置 spring: profiles: peer1 server: port: 8091 eureka: instance: #在本機hosts中配置即可 hostname: peer1.com --- spring: profiles: peer2 server: port: 8092 eureka: instance: hostname: peer2.com --- spring: profiles: peer3 server: port: 8093 eureka: instance: hostname: peer3.com
4.2 provider模塊
啟動類
package com.hdwang.springcloudtest.provider; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; @SpringBootApplication public class Application { /** * 運行時添加VM參數(shù): -Dserver.port=8082可以啟動多個provider實例 * * @param args */ public static void main(String[] args) { SpringApplication.run(Application.class, args); } }
服務(wù)注冊類
package com.hdwang.springcloudtest.provider.restservice; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; /** * 注冊的服務(wù) */ @RestController public class RestService { /** * 日志 */ private static final Logger LOG = LoggerFactory.getLogger(RestService.class); @RequestMapping("/sayHello") public String sayHello(String name) { LOG.info("sayHello was called"); return "hello, " + name; } }
yml配置
spring: application: #應(yīng)用名,也是eureka的服務(wù)名 name: provider freemarker: template-loader-path: classpath:/templates/ prefer-file-system-access: false server: #運行時,添加參數(shù)-Dserver.port=8082運行新的provider實例 port: 8081 eureka: client: #注冊中心地址 serviceUrl: #注冊中心獨立模式 #defaultZone: http://localhost:8090/eureka/ #注冊中心點對點模式 defaultZone: http://peer1.com:8091/eureka/,http://peer2.com:8092/eureka/,http://peer3.com:8093/eureka/
4.3 consumer配置
啟動類
package com.hdwang.springcloudtest.consumer; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; @SpringBootApplication public class Application { public static void main(String[] args) { SpringApplication.run(Application.class, args); } }
服務(wù)調(diào)用測試類
package com.hdwang.springcloudtest.consumer.controller; import com.netflix.appinfo.InstanceInfo; import com.netflix.discovery.EurekaClient; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.http.HttpEntity; import org.springframework.http.HttpHeaders; import org.springframework.http.MediaType; import org.springframework.http.ResponseEntity; import org.springframework.util.LinkedMultiValueMap; import org.springframework.util.MultiValueMap; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RestController; import org.springframework.web.client.RestTemplate; import java.util.*; /** * 測試 */ @RestController public class TestController { /** * 使用服務(wù)名才能負載均衡,不能使用直接使用地址 */ private static final String REST_URL_PREFIX = "http://provider"; @Autowired private EurekaClient discoveryClient; @Autowired private RestTemplate restTemplate; @GetMapping("/testGet") public String testGet() { ResponseEntity<String> res = restTemplate.getForEntity(REST_URL_PREFIX + "/sayHello?name={1}", String.class, getName()); return res.getBody(); } @GetMapping("/testPost") public String testPost() { MultiValueMap<String, Object> params = new LinkedMultiValueMap<String, Object>(); params.add("name", getName()); // HttpHeaders headers = new HttpHeaders(); // headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED); HttpEntity< MultiValueMap<String, Object>> request = new HttpEntity<>(params, null); ResponseEntity<String> res = restTemplate.postForEntity(REST_URL_PREFIX + "/sayHello", request, String.class); return res.getBody(); } private String getName() { List<String> greetings = Arrays.asList("Bob", "Alice", "Jack"); Random rand = new Random(); int randomNum = rand.nextInt(greetings.size()); return greetings.get(randomNum); } }
RestTemplate負責(zé)均衡配置類
package com.hdwang.springcloudtest.consumer.config; import org.springframework.cloud.client.loadbalancer.LoadBalanced; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.web.client.RestTemplate; @Configuration public class RestTemplateConfig { /** * 構(gòu)建有負載均衡功能的RestTemplate實例對象 * * @return RestTemplate實例對象 */ @Bean @LoadBalanced RestTemplate restTemplate() { return new RestTemplate(); } }
yml配置
spring: application: #應(yīng)用名,也是Eureka的服務(wù)名 name: cosumer server: port: 8088 eureka: client: #注冊中心地址 serviceUrl: #注冊中心獨立模式 #defaultZone: http://localhost:8090/eureka/ #注冊中心點對點模式 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 編輯運行配置
三個注冊中心節(jié)點運行配置
兩個服務(wù)提供者的運行配置
5.3 運行程序
(1) 啟動注冊中心
依次啟動RegisterCenter1->RegisterCenter2->RegisterCenter3,啟動成功后,可訪問http://localhost:8091/ 或http://localhost:8092/ 或http://localhost:8093/ 查看是否啟動成功
(2)啟動服務(wù)提供者provider
依次啟動Provider1->Provider2, 隨便訪問一個注冊中心地址首頁即可查看狀態(tài),如下圖
(3) 啟動消費者cosumer
(4) 在瀏覽器中進行測試
測試地址:http://localhost:8088/testPost / http://localhost:8088/testGet
(5) 在Provider1/Provider2的控制臺中可以看到輸出結(jié)果
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 微服務(wù)集群框架您已經(jīng)搭建成功!
附錄
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
到此這篇關(guān)于SpringCloud搭建netflix-eureka微服務(wù)集群的過程詳解的文章就介紹到這了,更多相關(guān)SpringCloud搭建netflix-eureka集群內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
springboot添加多數(shù)據(jù)源的方法實例教程
這篇文章主要給大家介紹了關(guān)于springboot添加多數(shù)據(jù)源方法的相關(guān)資料,在實際開發(fā)中經(jīng)??赡苡龅皆谝粋€應(yīng)用中可能要訪問多個數(shù)據(jù)庫多的情況,需要的朋友可以參考下2023-09-09Java并發(fā)編程中的synchronized關(guān)鍵字詳細解讀
這篇文章主要介紹了Java并發(fā)編程中的synchronized關(guān)鍵字詳細解讀,在Java早期版本中,synchronized 屬于 重量級鎖,效率低下,這是因為監(jiān)視器鎖(monitor)是依賴于底層的操作系統(tǒng)的Mutex Lock來實現(xiàn)的,Java 的線程是映射到操作系統(tǒng)的原生線程之上的,需要的朋友可以參考下2023-12-12Java數(shù)據(jù)結(jié)構(gòu)之線索化二叉樹的實現(xiàn)
在二叉樹的結(jié)點上加上線索的二叉樹稱為線索二叉樹,對二叉樹以某種遍歷方式進行遍歷,使其變?yōu)榫€索二叉樹的過程稱為對二叉樹進行線索化。本文將詳解如何實現(xiàn)線索化二叉樹,需要的可以參考一下2022-05-05