Spring Cloud:第二章:eureka服務(wù)發(fā)現(xiàn)

服務(wù)注冊(cè)中心 :eureka-server

新建一個(gè)springboot項(xiàng)目:eureka-server,其pom.xml配置如下:

  <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.cloud</groupId>
              <artifactId>spring-cloud-starter-eureka-server</artifactId>
         </dependency>
     </dependencies>
     <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>

想要實(shí)現(xiàn)一個(gè)服務(wù)注冊(cè)中心的功能非常簡(jiǎn)單,只需要在項(xiàng)目的啟動(dòng)類EurekaServerApplication上使用@EnableEurekaServer注解即可

1 @EnableEurekaServer
2 @SpringBootApplication
3 public class EurekaServerApplication{
4 
5     public static void main(String[] args) {
6         new SpringApplicationBuilder(EurekaServerApplication.class)
7                     .web(true).run(args);
8     }
9 }

默認(rèn)情況下,該服務(wù)注冊(cè)中心也會(huì)將自己作為客戶端來(lái)嘗試注冊(cè)它自己,所以我們需要禁用它的客戶端注冊(cè)行為,只需要在application.properties配置文件中增加如下信息:

1 spring.application.name=eureka-server
2 server.port=1001
3 eureka.instance.hostname=localhost
4 eureka.client.register-with-eureka=false
5 eureka.client.fetch-registry=false

啟動(dòng)EurekaServerApplication,訪問(wèn) http://localhost:9001/可以看到Eureka的頁(yè)面,從紅框的位置可以看到?jīng)]有任務(wù)服務(wù)實(shí)例注冊(cè)到當(dāng)前的服務(wù)注冊(cè)中心
在這里插入圖片描述

服務(wù)提供方 :eureka-client

每一個(gè)實(shí)例注冊(cè)之后需要向注冊(cè)中心發(fā)送心跳,當(dāng)client向server注冊(cè)時(shí),它會(huì)提供一些元數(shù)據(jù),例如主機(jī)和端口,URL,主頁(yè)等。Eureka server 從每個(gè)client實(shí)例接收心跳消息。 如果心跳超時(shí),則通常將該實(shí)例從注冊(cè)server中刪除。

新建一個(gè)springboot項(xiàng)目:eureka-client,其pom.xml配置如下:

<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.cloud</groupId>
                  <artifactId>spring-cloud-starter-eureka</artifactId>
             </dependency>
             <dependency>
                 <groupId>org.springframework.boot</groupId>
                 <artifactId>spring-boot-starter-web</artifactId>
             </dependency>
         </dependencies>
         <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>

想要實(shí)現(xiàn)一個(gè)服務(wù)提供方也很簡(jiǎn)單,只要在項(xiàng)目的啟動(dòng)類EurekaClientApplication上使用@EnableEurekaClient注解即可

 1 @EnableEurekaClient
 2 @SpringBootApplication
 3 public class EurekaClientApplication {
 4 
 5      public static void main(String[] args) {
 6             new SpringApplicationBuilder(
 7                     EurekaClientApplication.class)
 8                 .web(true).run(args);
 9         }
10 }

在application.properties中進(jìn)行如下配置

spring.application.name=eureka-client
server.port=9002
eureka.client.serviceUrl.defaultZone=http://localhost:9001/eureka/

通過(guò)spring.application.name屬性,我們可以指定微服務(wù)的名稱后續(xù)在調(diào)用的時(shí)候只需要使用該名稱就可以進(jìn)行服務(wù)的訪問(wèn)。

eureka.client.serviceUrl.defaultZone屬性對(duì)應(yīng)服務(wù)注冊(cè)中心的配置內(nèi)容,指定服務(wù)注冊(cè)中心的位置。

使用server.port屬性設(shè)置不同的端口。

啟動(dòng)EurekaClientApplication類

刷新 http://localhost:9001/,可以看到咱們的服務(wù)提供方已經(jīng)注冊(cè)到了服務(wù)注冊(cè)中心

在這里插入圖片描述

在新建一個(gè)DiscoveryController

使用discoveryClient.getServices()獲取已經(jīng)注冊(cè)的服務(wù)名,使用@value將配置文件中的信息賦值到ip

@RestController
public class DiscoveryController {
    
    @Autowired
    private DiscoveryClient discoveryClient;
    @Value("${server.port}")
    private String ip;
    
    @GetMapping("/client")
    public String client() {
        String services = "Services: " + discoveryClient.getServices()+" ip :"+ip;
        
        System.out.println(services);
        return services;
    }
}

訪問(wèn):http://localhost:9002/client

在這里插入圖片描述










最后說(shuō)明一下@EnableEurekaClient 與@EnableDiscoveryClient這兩個(gè)注解

首先這個(gè)兩個(gè)注解都可以實(shí)現(xiàn)服務(wù)發(fā)現(xiàn)的功能,在spring cloud中discovery service有許多種實(shí)現(xiàn)(eureka、consul、zookeeper等等)

@EnableEurekaClient基于spring-cloud-netflix。服務(wù)采用eureka作為注冊(cè)中心,使用場(chǎng)景較為單一。

@EnableDiscoveryClient基于spring-cloud-commons。服務(wù)采用其他注冊(cè)中心。