eureka 介紹
eureka提供基于rest的服務，在集群中主要用于服務管理。eureka提供了基于java語言的客戶端組件，客戶端組件實現了負載均衡的功能，為業務組件的集群部署創造了條件。使用該框架，可以將業務組件注冊到eureka容器中，這些業務組件可進行集群部署，eureka主要維護這些服務的列表并自動檢查它們的狀態。
程序結構
創建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服務注解 @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) |
啟動期間會出現一個無法連接到服務器的異常 這個是由于eureka在啟動的時候會把自己當作一個客戶端去服務器抓取注冊信息
com.netflix.discovery.shared.transport.transportexception: cannot execute request on any known server
增加如下配置啟動時便不會再出現該異常
|
1
2
3
4
|
eureka: client: registerwitheureka: false fetchregistry: false |
registerwitheureka 聲明是否將自己的信息注冊到eureka服務器，默認值為true。
fetchregistry 聲明是否到eureka服務器中抓取注冊信息，默認值為true。
在瀏覽器中訪問 http://localhost:8761 查看eureka控制臺 輸入圖片說明
創建服務提供者
依賴
|
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實例名稱和eureka服務地址
|
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/ |
創建一個 rest 服務
|
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 控制臺可以看到服務提供者已經在 eureka 中注冊
創建服務調用者
依賴
|
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實例名稱和eureka服務地址
|
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/ |
編寫一個 rest 服務 調用服務提供者的 “/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); }} |
在傳統模式中，我們通常會用apache中的httpclient來調用 rest 服務,在這里我們使用 spring 提供調用 rest 服務的組件 resttemplate。 resttemplate 本身并不具備調用分布式服務的能力，但是resttemplate的bean被@loadbalanced注解修飾后，這個resttemplate實例就具有訪問分布式服務的能力，這得益于 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 控制臺可以看到服務調用者已經在 eureka 中注冊
之后在瀏覽器訪問服務調用者的 “invoke” 接口 返回如下
總結
eureka 服務器 通過心跳鏈接來維護最新的注冊信息，這些注冊信息都保存在內存中。
eureka 服務提供者 主要進行：
- 向 eureka 服務器注冊服務
- 發送心跳到 eureka服務器，使 eureka 服務器注冊信息保持最新
- 向服務器獲取最新的注冊列表，通常 eureka 客戶端既是服務提供者也是服務調用者，但其主要職責為服務提供。
eureka 服務調用者 主要進行：
- 向 eureka 服務器注冊服務
- 發送心跳到 eureka服務器，使 eureka 服務器注冊信息保持最新
- 向服務器獲取最新的注冊列表，通常 eureka 客戶端既是服務提供者也是服務調用者，但其主要職責為發現與調用。
源碼地址：https://github.com/xc564864894/springcloud/tree/master/eureka(%e4%b8%80)
以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持服務器之家。
原文鏈接：https://my.oschina.net/u/3444403/blog/1627531
