构建服务治理——Eureka

简单微服务架构如下：

简单微服务架构

服务治理的工程也是一个典型的Spring Boot应用：

首先构建一个parent工程，具体是为了将一些通用的依赖在一个地方引入，和普通的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>
    <!--因为是基于Spring boot进行开发，所以这里继承了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>

接下来构建服务治理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>

启动类代码如下：

//通过@EnableEurekaServer注解，SpringBoot在启动应用的时候就会自动构建一个默认的服务治理服务器。
@EnableEurekaServer
@SpringBootApplication
public class DemoEurekaApplication {

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

}

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

server:
  port: 8110
eureka:
  client:
    #启动服务完成后是否将该服务注册到服务治理服务器上
    register-with-eureka: false
    #表示应用启动后不需要从服务治理服务器中同步已注册的服务注册列表数据到本地
    fetch-registry: false
  server:
    wait-time-in-ms-when-sync-empty: 5

应用第一次与服务治理服务器同步注册服务列表数据后，默认以每30秒的频率与治理服务器进行同步。在配置中，可以通过属性eureka.client.registry-fetch-interval-seconds重新指定同步的时间间隔。

启动服务，浏览器访问，控制台界面如下：

Eureka服务器控制台

然后构建一个用户服务，注册到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>
        <!--数据源连接池-->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid-spring-boot-starter</artifactId>
            <version>1.2.3</version>
        </dependency>
        <!--mysql驱动-->
        <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>
        <!--这是一个web类型项目-->
        <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>

用户服务启动类如下：

//@EnableDiscoveryClient注解表示这是一个Eureka客户端，通过该注解，在Spring Boot启动完毕之后，
// 就会根据配置中的信息尝试与服务治理服务器进行连接，连接成功之后进行服务注册或者服务注册信息的同步。
@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相关配置
eureka:
  instance:
    prefer-ip-address: true
  client:
    register-with-eureka: true
    fetch-registry: true
    service-url:
      defaultZone: http://localhost:8110/eureka

启动用户服务，查看eureka控制台如下：

用户服务已经注册到了注册中心

注意：一个服务实例注册到Eureka服务器时大概需要30秒才能够在控制台中查看到该服务。这是因为，Eureka要求服务提供者必须发送3次心跳（默认每次心跳间隔为10秒）后才认为该服务实例已经准备好，可以对外提供服务了。因此，当启动完一个服务实例时，在Eureka控制台中没有立即显示是一种正常现象。

对于每一个需要注册到Eureka服务器的服务都需要提供以下两个ID:

application.name：即应用的ID，用来对服务进行分组，相同的ID表示这些服务实例所提供的服务是相同的。当使用Spring Boot构建微服务时，该ID将使用spring. application.name属性所设置的值
instanceId：也就是微服务实例ID，用来标识每一个注册到Eureka服务器中的服务实例。默认情况下该值是由：服务宿主机器名称+服务名称+端口号构成。

最后构建一个商品服务来调用用户服务

pom.xml和上面用户服务的pom.xml相同，启动类也相同

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

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

启动商品服务，注册中心控制台如下：

注册中心控制台

调用用户微服务

在Spring Cloud中提供了多种实现方式，下面先来一个最直接的方式，通过RestTemplate来调用。

商品服务API代码如下：

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

    private final RestTemplate restTemplate;

    /**
     * 根据用户ID获取用户
     *
     * @param id 用户ID
     * @return
     */
    @GetMapping(value = "/getUser/{id}")
    public BaseResult<UserVo> getUser(@PathVariable("id") String id) {
        try {
            log.debug("获取用户 入参id: {}", 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("请求异常");
        }
    }

商品服务启动类稍作修改，如下：

@EnableDiscoveryClient
@SpringBootApplication
public class DemoProductApplication {
    
    //创建一个RestTemplate Bean
    @Bean(value = "restTemplate")
    @LoadBalanced
    RestTemplate restTemplate() {
        return new RestTemplate();
    }

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

}

用户服务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;
    }
}

一切准备就绪，发起调用，如下:

服务调用

然后通过Postman请求商品服务的获取用户接口：http://localhost:2120/product/getUser/123，如上图所示得到了用户信息，说明商品服务已经能够正确地通过Eureka访问到用户微服务了。

最后编辑于：2021.06.13 01:15:33

人面猴
序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
沈念sama阅读 217,542评论 6赞 504
死咒
序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
沈念sama阅读 92,822评论 3赞 394
救了他两次的神仙让他今天三更去死
文/潘晓璐我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
开封第一讲书人阅读 163,912评论 0赞 354
道士缉凶录：失踪的卖姜人
文/不坏的土叔我叫张陵，是天一观的道长。经常有香客问我，道长，这世上最难降的妖魔是什么？我笑而不...
开封第一讲书人阅读 58,449评论 1赞 293
港岛之恋（遗憾婚礼）
正文为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
茶点故事阅读 67,500评论 6赞 392
恶毒庶女顶嫁案：这布局不是一般人想出来的
文/花漫我一把揭开白布。她就那样静静地躺着，像睡着了一般。火红的嫁衣衬着肌肤如雪。梳的纹丝不乱的头发上，一...
开封第一讲书人阅读 51,370评论 1赞 302
城市分裂传说
那天，我揣着相机与录音，去河边找鬼。笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。我是一名探鬼主播，决...
沈念sama阅读 40,193评论 3赞 418
双鸳鸯连环套：你想象不到人心有多黑
文/苍兰香墨我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
开封第一讲书人阅读 39,074评论 0赞 276
万荣杀人案实录
序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
沈念sama阅读 45,505评论 1赞 314
护林员之死
正文独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋以下内容为张勋视角年9月15日...
茶点故事阅读 37,722评论 3赞 335
白月光启示录
正文我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
茶点故事阅读 39,841评论 1赞 348
活死人
序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
沈念sama阅读 35,569评论 5赞 345
日本核电站爆炸内幕
正文年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
茶点故事阅读 41,168评论 3赞 328
男人毒药：我在死后第九天来索命
文/蒙蒙一、第九天我趴在偏房一处隐蔽的房顶上张望。院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
开封第一讲书人阅读 31,783评论 0赞 22
一桩弑父案，背后竟有这般阴谋
文/苍兰香墨我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。一阵脚步声响...
开封第一讲书人阅读 32,918评论 1赞 269
情欲美人皮
我被黑心中介骗来泰国打工，没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。一个月前我还...
沈念sama阅读 47,962评论 2赞 370
代替公主和亲
正文我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
茶点故事阅读 44,781评论 2赞 354

构建服务治理——Eureka

推荐阅读更多精彩内容