eureka 介紹
eureka提供基于rest的服務(wù)，在集群中主要用于服務(wù)管理。eureka提供了基于java語言的客戶端組件，客戶端組件實(shí)現(xiàn)了負(fù)載均衡的功能，為業(yè)務(wù)組件的集群部署創(chuàng)造了條件。使用該框架，可以將業(yè)務(wù)組件注冊到eureka容器中，這些業(yè)務(wù)組件可進(jìn)行集群部署，eureka主要維護(hù)這些服務(wù)的列表并自動檢查它們的狀態(tài)。
程序結(jié)構(gòu)
創(chuàng)建eureka server
maven依賴
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
|
<dependencymanagement> <dependencies> <dependency> <groupid>org.springframework.cloud</groupid> <artifactid>spring-cloud-dependencies</artifactid> <version>dalston.sr1</version> <type>pom</type> <scope>import</scope> </dependency> </dependencies></dependencymanagement><dependencies> <dependency> <groupid>org.springframework.cloud</groupid> <artifactid>spring-cloud-starter-eureka-server</artifactid> </dependency></dependencies> |
更改spring boot 啟動端口 在application.yml
|
1
2
|
server: port: 8761 |
開啟eureka服務(wù)注解 @enableeurekaserver
|
1
2
3
4
5
6
7
8
|
@enableeurekaserver@springbootapplicationpublic class ekserverapplication { public static void main(string[] args) { new springapplicationbuilder(ekserverapplication.class).run(args); }} |
啟動springboot
|
1
2
3
4
|
[thread-11] o.s.c.n.e.server.eurekaserverbootstrap: initialized server context[main] s.b.c.e.t.tomcatembeddedservletcontainer: tomcat started on port(s): 8761 (http)[main] .s.c.n.e.s.eurekaautoserviceregistration: updating port to 8761[main] c.b.firstekserver.ekserverapplication: started ekserverapplication in 8.594 seconds (jvm running for 9.523) |
啟動期間會出現(xiàn)一個(gè)無法連接到服務(wù)器的異常 這個(gè)是由于eureka在啟動的時(shí)候會把自己當(dāng)作一個(gè)客戶端去服務(wù)器抓取注冊信息
com.netflix.discovery.shared.transport.transportexception: cannot execute request on any known server
增加如下配置啟動時(shí)便不會再出現(xiàn)該異常
|
1
2
3
4
|
eureka: client: registerwitheureka: false fetchregistry: false |
registerwitheureka 聲明是否將自己的信息注冊到eureka服務(wù)器，默認(rèn)值為true。
fetchregistry 聲明是否到eureka服務(wù)器中抓取注冊信息，默認(rèn)值為true。
在瀏覽器中訪問 http://localhost:8761 查看eureka控制臺 輸入圖片說明
創(chuàng)建服務(wù)提供者
依賴
|
1
2
3
4
5
6
7
8
9
10
11
12
|
<dependency> <groupid>org.springframework.cloud</groupid> <artifactid>spring-cloud-starter-config</artifactid></dependency><dependency> <groupid>org.springframework.cloud</groupid> <artifactid>spring-cloud-starter-eureka</artifactid></dependency><dependency> <groupid>org.springframework.cloud</groupid> <artifactid>spring-cloud-starter-ribbon</artifactid></dependency> |
在 application.yml 中配置端口、eureka實(shí)例名稱和eureka服務(wù)地址
|
1
2
3
4
5
6
7
8
9
10
11
|
server: port: 8080spring: application: name: ek-providereureka: instance: hostname: localhost client: serviceurl: defaultzone: http://localhost:8761/eureka/ |
創(chuàng)建一個(gè) rest 服務(wù)
|
1
2
3
4
5
6
7
8
|
@restcontrollerpublic class hellocontroller { @requestmapping("/hello") public string hello(httpservletrequest request) { return "hello:" + request.getrequesturl(); }} |
開啟eureka客戶端注解 @enableeurekaserver
|
1
2
3
4
5
6
7
8
|
@enableeurekaclient@springbootapplicationpublic class ekproviderapplication { public static void main(string[] args) { new springapplicationbuilder(ekproviderapplication.class).run(args); }} |
啟動之后在 eureka 控制臺可以看到服務(wù)提供者已經(jīng)在 eureka 中注冊
創(chuàng)建服務(wù)調(diào)用者
依賴
|
1
2
3
4
5
6
7
8
9
10
11
12
|
<dependency> <groupid>org.springframework.cloud</groupid> <artifactid>spring-cloud-starter-config</artifactid></dependency><dependency> <groupid>org.springframework.cloud</groupid> <artifactid>spring-cloud-starter-eureka</artifactid></dependency><dependency> <groupid>org.springframework.cloud</groupid> <artifactid>spring-cloud-starter-ribbon</artifactid></dependency> |
在 application.yml 中配置端口、eureka實(shí)例名稱和eureka服務(wù)地址
|
1
2
3
4
5
6
7
8
9
10
11
|
server: port: 9000spring: application: name: ek-invokeeureka: instance: hostname: localhost client: serviceurl: defaultzone: http://localhost:8761/eureka/ |
編寫一個(gè) rest 服務(wù) 調(diào)用服務(wù)提供者的 “/hello”
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
|
@restcontroller@configurationpublic class invokecontroller { @bean @loadbalanced public resttemplate getresttemplate() { return new resttemplate(); } @requestmapping("/invoke") public string invoke() { resttemplate resttemplate = getresttemplate(); return resttemplate.getforobject("http://ek-provider/hello", string.class); }} |
在傳統(tǒng)模式中，我們通常會用apache中的httpclient來調(diào)用 rest 服務(wù),在這里我們使用 spring 提供調(diào)用 rest 服務(wù)的組件 resttemplate。 resttemplate 本身并不具備調(diào)用分布式服務(wù)的能力，但是resttemplate的bean被@loadbalanced注解修飾后，這個(gè)resttemplate實(shí)例就具有訪問分布式服務(wù)的能力，這得益于 spring 為其提供的各種攔截器
開啟eureka客戶端注解 @enableeurekaserver
|
1
2
3
4
5
6
7
8
|
@enableeurekaclient@springbootapplicationpublic class ekinvokeapplication { public static void main(string[] args) { new springapplicationbuilder(ekinvokeapplication.class).run(args); }} |
啟動之后在 eureka 控制臺可以看到服務(wù)調(diào)用者已經(jīng)在 eureka 中注冊
之后在瀏覽器訪問服務(wù)調(diào)用者的 “invoke” 接口 返回如下
總結(jié)
eureka 服務(wù)器 通過心跳鏈接來維護(hù)最新的注冊信息，這些注冊信息都保存在內(nèi)存中。
eureka 服務(wù)提供者 主要進(jìn)行：
- 向 eureka 服務(wù)器注冊服務(wù)
- 發(fā)送心跳到 eureka服務(wù)器，使 eureka 服務(wù)器注冊信息保持最新
- 向服務(wù)器獲取最新的注冊列表，通常 eureka 客戶端既是服務(wù)提供者也是服務(wù)調(diào)用者，但其主要職責(zé)為服務(wù)提供。
eureka 服務(wù)調(diào)用者 主要進(jìn)行：
- 向 eureka 服務(wù)器注冊服務(wù)
- 發(fā)送心跳到 eureka服務(wù)器，使 eureka 服務(wù)器注冊信息保持最新
- 向服務(wù)器獲取最新的注冊列表，通常 eureka 客戶端既是服務(wù)提供者也是服務(wù)調(diào)用者，但其主要職責(zé)為發(fā)現(xiàn)與調(diào)用。
源碼地址：https://github.com/xc564864894/springcloud/tree/master/eureka(%e4%b8%80)
以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持服務(wù)器之家。
原文鏈接：https://my.oschina.net/u/3444403/blog/1627531
