您好,登錄后才能下訂單哦!
怎樣使用Spring Cloud搭建服務注冊中心,相信很多沒有經驗的人對此束手無策,為此本文總結了問題出現的原因和解決方法,通過這篇文章希望你能解決這個問題。
與dubbo不同的是,Spring Cloud是一個一站式分布式框架,Spring Cloud為開發人員提供了快速構建分布式系統中一些常見模式的工具(例如配置管理,服務發現,斷路器,智能路由,微代理,控制總線)。分布式系統的協調導致了樣板模式, 使用Spring Cloud開發人員可以快速地支持實現這些模式的服務和應用程序。他們將在任何分布式環境中運行良好,包括開發人員自己的筆記本電腦,裸機數據中心,以及Cloud Foundry等托管平臺。那么今天我希望通過一個簡單的案例帶小伙伴們來了解下Spring Cloud。
OK,那么本文我主要想介紹下在Spring Cloud中使用Eureka搭建一個服務注冊中心,然后再向其中注冊服務。由于Spring Cloud是在Spring Boot的基礎上構建分布式服務的,所以閱讀本文需要有一點Spring Boot的知識儲備。
OK,那么上面所提到的是閱讀本文所需要具備的基礎知識,在此基礎之上我們來看看怎么樣利用Spring Cloud中的Eureka來搭建服務注冊中心。
首先我要說的是Spring Cloud并不是一個東西,和Hadoop類似,Spring Cloud也包含了許多個子項目,我們今天要看的Eureka只是其中的一個子項目,Eureka的功能有點類似于我們之前寫過的zookeeper,它是一個服務治理組件,包含了服務注冊中心、服務注冊與發現機制。其他的組件我們這里先不做介紹,后面的系列文章都會一一提及到。
OK,廢話說了一籮筐,上代碼吧。
首先我們需要創建一個普通的Spring Boot工程,命名為eureka-server,普通到什么程度呢?就是一個starter都不需要添加,創建成功之后就只引用了一個父starter。
工程創建成功之后,向pom.xml文件中添加eureka-server的依賴,目前eureka的穩定版本是Dalston.SR3
,添加完依賴之后,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>org.sang</groupId> <artifactId>eureka-server</artifactId> <version>0.0.1-SNAPSHOT</version> <packaging>jar</packaging> <name>eureka-server</name> <description>Demo project for Spring Boot</description> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>1.5.6.RELEASE</version> <relativePath/> <!-- lookup parent from repository --> </parent> <properties> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding> <java.version>1.8</java.version> </properties> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter</artifactId> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-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>Dalston.SR3</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官網的 http://projects.spring.io/spring-cloud/。
啟動一個服務注冊中心的方式很簡單,就是在Spring Boot的入口類上添加一個@EnableEurekaServer
注解,如下:
@EnableEurekaServer @SpringBootApplication public class EurekaServerApplication { public static void main(String[] args) { SpringApplication.run(EurekaServerApplication.class, args); } }
最后我們再做一點簡單的配置就可以了,配置就寫在Spring Boot的配置文件application.properties中,寫法如下:
server.port=1111 eureka.instance.hostname=localhost eureka.client.register-with-eureka=false eureka.client.fetch-registry=false eureka.client.service-url.defaultZone=http://${eureka.instance.hostname}:${server.port}/eureka/
OK,那么關于這幾行注釋,我說如下幾點:
1.server.port=1111表示設置該服務注冊中心的端口號
2.eureka.instance.hostname=localhost表示設置該服務注冊中心的hostname
3.eureka.client.register-with-eureka=false,由于我們目前創建的應用是一個服務注冊中心,而不是普通的應用,默認情況下,這個應用會向注冊中心(也是它自己)注冊它自己,設置為false表示禁止這種默認行為
4.eureka.client.fetch-registry=false,表示不去檢索其他的服務,因為服務注冊中心本身的職責就是維護服務實例,它也不需要去檢索其他服務
OK,做完這一切之后,我們就可以啟動這一個Spring Boot 服務,服務啟動成功之后,在瀏覽器中輸入:http://localhost:1111就能夠看到如下頁面:
OK,看到上面這個頁面之后,表示你的服務注冊中心已經搭建好了。
我們之前專門有一篇博客介紹如何在Linux上安裝zookeeper【Linux上安裝Zookeeper以及一些注意事項】,但是對于Eureka卻不存在這樣的問題,因為Eureka中的服務注冊中心實際上是一個Spring Boot工程,而Spring Boot工程我們知道可以直接打成一個jar包,然后java -jar命令就可以運行,不管Windows還是Linux上,運行方式都是一致的。
OK,那么現在服務注冊中心有了之后,我們可以考慮向這個服務注冊中心注冊一個服務提供者了。
還是創建一個Spring Boot工程,這次創建比之前創建多一個步驟,在創建的時候選中web的starter,我們來創建一個web工程,在IntelliJ IDEA中創建的時候選中web,如下:
在創建好的工程中,我們需要添加Eureka依賴,添加方式如下:
<?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>org.sang</groupId> <artifactId>provider</artifactId> <version>0.0.1-SNAPSHOT</version> <packaging>jar</packaging> <name>provider</name> <description>Demo project for Spring Boot</description> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>1.5.6.RELEASE</version> <relativePath/> <!-- lookup parent from repository --> </parent> <properties> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding> <java.version>1.8</java.version> </properties> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-eureka</artifactId> </dependency> </dependencies> <dependencyManagement> <dependencies> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-dependencies</artifactId> <version>Dalston.SR3</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>
這是一個web工程,所以我們添加一個Controller,在該Controller中提供一個訪問入口,如下:
@RestController public class HelloController { private final Logger logger = Logger.getLogger(getClass()); @Autowired private DiscoveryClient client; @RequestMapping(value = "/hello", method = RequestMethod.GET) public String index() { List<ServiceInstance> instances = client.getInstances("hello-service"); for (int i = 0; i < instances.size(); i++) { logger.info("/hello,host:" + instances.get(i).getHost() + ",service_id:" + instances.get(i).getServiceId()); } return "Hello World"; } }
這里創建服務之后,在日志中將服務相關的信息打印出來。
在Spring Boot的入口函數處,通過添加@EnableDiscoveryClient注解來激活Eureka中的DiscoveryClient實現(因為我們在HelloController中注入了DiscoveryClient)。
@EnableDiscoveryClient @SpringBootApplication public class ProviderApplication { public static void main(String[] args) { SpringApplication.run(ProviderApplication.class, args); } }
最后的最后,我們在application.properties文件中配置一下服務名和注冊中心地址即可,如下:
spring.application.name=hello-service eureka.client.service-url.defaultZone=http://localhost:1111/eureka
這兩行代碼的含義很簡單,我就不多說了。
做完這一切之后,我們就可以來測試了,直接運行這個Spring Boot工程,運行成功之后,我們刷新剛才的http://localhost:1111,就可以看到有一個服務已經注冊成功了。如下:
同時,我們查看這個服務提供者運行日志,也可以看到服務的信息,如下:
OK,如此之后,我們一個服務注冊中心就搭建成功了,同時也有一個服務提供者成功的注冊了。但是這樣還有一個小問題,那就是我們這里是一個單節點的服務注冊中心,一旦發生了故障整個服務就癱瘓了,所以在實際應用中,我們需要搭建高可用注冊中心。
看完上述內容,你們掌握怎樣使用Spring Cloud搭建服務注冊中心的方法了嗎?如果還想學到更多技能或想了解更多相關內容,歡迎關注億速云行業資訊頻道,感謝各位的閱讀!
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。