構(gòu)建服務(wù)治理——Eureka

簡(jiǎn)單微服務(wù)架構(gòu)如下：

簡(jiǎn)單微服務(wù)架構(gòu)

服務(wù)治理的工程也是一個(gè)典型的Spring Boot應(yīng)用：

首先構(gòu)建一個(gè)parent工程，具體是為了將一些通用的依賴在一個(gè)地方引入，和普通的maven工程用法一樣，

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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <!--因?yàn)槭腔赟pring boot進(jìn)行開發(fā)，所以這里繼承了Spring boot的pom-->
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.5.0</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <!--parent的group、版本定義-->
    <groupId>com.jyswm</groupId>
    <artifactId>common-parent</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>common-parent</name>
    <!--注意打包文件格式是pom-->
    <packaging>pom</packaging>
    <description>Demo project for Spring Boot</description>
    <!--通用屬性、JDK版本及通用依賴包版本定義-->
    <properties>
        <java.version>1.8</java.version>
        <spring-cloud.version>2020.0.3</spring-cloud.version>
        <guava.version>20.0</guava.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter</artifactId>
        </dependency>

        <!--Guava工具包-->
        <dependency>
            <groupId>com.google.guava</groupId>
            <artifactId>guava</artifactId>
            <version>${guava.version}</version>
        </dependency>
        <!--lombok-->
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.18.10</version>
        </dependency>
        <!--fastjson-->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>1.2.58</version>
        </dependency>
       <!--commons-lang3-->
        <dependency>
            <groupId>org.apache.commons</groupId>
            <artifactId>commons-lang3</artifactId>
            <version>3.7</version>
        </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>${spring-cloud.version}</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>

接下來(lái)構(gòu)建服務(wù)治理eureka工程

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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <!--將parent指定為common-parent-->
    <parent>
        <groupId>com.jyswm</groupId>
        <artifactId>common-parent</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <artifactId>demo-eureka</artifactId>
    <name>demo-eureka</name>
    <description>Demo project for Spring Boot</description>

    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>
    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

啟動(dòng)類代碼如下：

//通過(guò)@EnableEurekaServer注解，SpringBoot在啟動(dòng)應(yīng)用的時(shí)候就會(huì)自動(dòng)構(gòu)建一個(gè)默認(rèn)的服務(wù)治理服務(wù)器。
@EnableEurekaServer
@SpringBootApplication
public class DemoEurekaApplication {

    public static void main(String[] args) {
        SpringApplication.run(DemoEurekaApplication.class, args);
    }

}

配置文件如下(application.yml)：

server:
  port: 8110
eureka:
  client:
    #啟動(dòng)服務(wù)完成后是否將該服務(wù)注冊(cè)到服務(wù)治理服務(wù)器上
    register-with-eureka: false
    #表示應(yīng)用啟動(dòng)后不需要從服務(wù)治理服務(wù)器中同步已注冊(cè)的服務(wù)注冊(cè)列表數(shù)據(jù)到本地
    fetch-registry: false
  server:
    wait-time-in-ms-when-sync-empty: 5

應(yīng)用第一次與服務(wù)治理服務(wù)器同步注冊(cè)服務(wù)列表數(shù)據(jù)后，默認(rèn)以每30秒的頻率與治理服務(wù)器進(jìn)行同步。在配置中，可以通過(guò)屬性eureka.client.registry-fetch-interval-seconds重新指定同步的時(shí)間間隔。

啟動(dòng)服務(wù)，瀏覽器訪問(wèn)，控制臺(tái)界面如下：

Eureka服務(wù)器控制臺(tái)

然后構(gòu)建一個(gè)用戶服務(wù)，注冊(cè)到eureka中

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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <!--將parent指定為common-parent-->
    <parent>
        <groupId>com.jyswm</groupId>
        <artifactId>common-parent</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <artifactId>demo-user</artifactId>
    <name>demo-user</name>
    <description>Demo project for Spring Boot</description>

    <dependencies>
        <dependency>
            <groupId>com.jyswm</groupId>
            <artifactId>demo-service</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </dependency>
        <!--數(shù)據(jù)源連接池-->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid-spring-boot-starter</artifactId>
            <version>1.2.3</version>
        </dependency>
        <!--mysql驅(qū)動(dòng)-->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>8.0.25</version>
        </dependency>
        <!--JPA依賴-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-jpa</artifactId>
        </dependency>
        <!--依賴eureka-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
        <!--這是一個(gè)web類型項(xiàng)目-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
        </dependency>

    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

用戶服務(wù)啟動(dòng)類如下：

//@EnableDiscoveryClient注解表示這是一個(gè)Eureka客戶端，通過(guò)該注解，在Spring Boot啟動(dòng)完畢之后，
// 就會(huì)根據(jù)配置中的信息嘗試與服務(wù)治理服務(wù)器進(jìn)行連接，連接成功之后進(jìn)行服務(wù)注冊(cè)或者服務(wù)注冊(cè)信息的同步。
@EnableDiscoveryClient
@SpringBootApplication
public class DemoUserApplication {

    public static void main(String[] args) {
        SpringApplication.run(DemoUserApplication.class, args);
    }

}

配置文件如下(application.yml)：

server:
  port: 2110
spring:
  application:
    name: demo-user

  datasource:
    name: test
    url: jdbc:mysql:// xxxxxx
      GMT%2B8
    username: xxxx
    password: xxxxxx
    type: com.alibaba.druid.pool.DruidDataSource
    driver-class-name: com.mysql.cj.jdbc.Driver

#eureka相關(guān)配置
eureka:
  instance:
    prefer-ip-address: true
  client:
    register-with-eureka: true
    fetch-registry: true
    service-url:
      defaultZone: http://localhost:8110/eureka

啟動(dòng)用戶服務(wù)，查看eureka控制臺(tái)如下：

用戶服務(wù)已經(jīng)注冊(cè)到了注冊(cè)中心

注意：一個(gè)服務(wù)實(shí)例注冊(cè)到Eureka服務(wù)器時(shí)大概需要30秒才能夠在控制臺(tái)中查看到該服務(wù)。這是因?yàn)椋?code>Eureka要求服務(wù)提供者必須發(fā)送3次心跳（默認(rèn)每次心跳間隔為10秒）后才認(rèn)為該服務(wù)實(shí)例已經(jīng)準(zhǔn)備好，可以對(duì)外提供服務(wù)了。因此，當(dāng)啟動(dòng)完一個(gè)服務(wù)實(shí)例時(shí)，在Eureka控制臺(tái)中沒有立即顯示是一種正常現(xiàn)象。

對(duì)于每一個(gè)需要注冊(cè)到Eureka服務(wù)器的服務(wù)都需要提供以下兩個(gè)ID:

  • application.name：即應(yīng)用的ID，用來(lái)對(duì)服務(wù)進(jìn)行分組，相同的ID表示這些服務(wù)實(shí)例所提供的服務(wù)是相同的。當(dāng)使用Spring Boot構(gòu)建微服務(wù)時(shí)，該ID將使用spring. application.name屬性所設(shè)置的值
  • instanceId：也就是微服務(wù)實(shí)例ID，用來(lái)標(biāo)識(shí)每一個(gè)注冊(cè)到Eureka服務(wù)器中的服務(wù)實(shí)例。默認(rèn)情況下該值是由：服務(wù)宿主機(jī)器名稱+服務(wù)名稱+端口號(hào)構(gòu)成。

最后構(gòu)建一個(gè)商品服務(wù)來(lái)調(diào)用用戶服務(wù)

pom.xml和上面用戶服務(wù)的pom.xml相同，啟動(dòng)類也相同

配置文件如下(application.yml)，也只有服務(wù)的端口不同：

 server:
  port: 2120
spring:
  application:
    name: demo-product
# 下面相同的省略

啟動(dòng)商品服務(wù)，注冊(cè)中心控制臺(tái)如下：

注冊(cè)中心控制臺(tái)

調(diào)用用戶微服務(wù)

在Spring Cloud中提供了多種實(shí)現(xiàn)方式，下面先來(lái)一個(gè)最直接的方式，通過(guò)RestTemplate來(lái)調(diào)用。

商品服務(wù)API代碼如下：

@Slf4j
@RestController
@AllArgsConstructor
@RequestMapping("/product")
public class ProductController extends BaseController {

    private final RestTemplate restTemplate;

    /**
     * 根據(jù)用戶ID獲取用戶
     *
     * @param id 用戶ID
     * @return
     */
    @GetMapping(value = "/getUser/{id}")
    public BaseResult<UserVo> getUser(@PathVariable("id") String id) {
        try {
            log.debug("獲取用戶 入?yún)d: {}", id);
            UserVo userVo = restTemplate.getForEntity(
                    "http://demo-user/user/getUser/{id}", UserVo.class, id).getBody();
            log.debug("獲取用戶到的用戶userVo: 【{}】", userVo.toString());
            return success(userVo);
        } catch (Exception e) {
            return error("請(qǐng)求異常");
        }
    }

商品服務(wù)啟動(dòng)類稍作修改，如下：

@EnableDiscoveryClient
@SpringBootApplication
public class DemoProductApplication {
    
    //創(chuàng)建一個(gè)RestTemplate Bean
    @Bean(value = "restTemplate")
    @LoadBalanced
    RestTemplate restTemplate() {
        return new RestTemplate();
    }

    public static void main(String[] args) {
        SpringApplication.run(DemoProductApplication.class, args);
    }

}

用戶服務(wù)API代碼如下：

@Slf4j
@RestController
@AllArgsConstructor
@RequestMapping("/user")
public class UserController extends BaseController {

    @GetMapping(value = "/getUser/{id}")
    public UserVo getUser(@PathVariable("id") String id) {
        UserVo userVo = new UserVo();
        userVo.setId(id);
        userVo.setName(id);
        return userVo;
    }
}

一切準(zhǔn)備就緒，發(fā)起調(diào)用，如下:

服務(wù)調(diào)用

然后通過(guò)Postman請(qǐng)求商品服務(wù)的獲取用戶接口：http://localhost:2120/product/getUser/123，如上圖所示得到了用戶信息，說(shuō)明商品服務(wù)已經(jīng)能夠正確地通過(guò)Eureka訪問(wèn)到用戶微服務(wù)了。

最后編輯于 ：
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成，瀏覽時(shí)請(qǐng)結(jié)合常識(shí)與多方信息審慎甄別。
平臺(tái)聲明：文章內(nèi)容（如有圖片或視頻亦包括在內(nèi)）由作者上傳并發(fā)布，文章內(nèi)容僅代表作者本人觀點(diǎn)，簡(jiǎn)書系信息發(fā)布平臺(tái)，僅提供信息存儲(chǔ)服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容