Spring Cloud 入门 -- 搭建 Eureka 注册中心实现服务者与消费者的服务调用

2022 年 8 月 06 日
本文字数：9524 字
阅读完需：约 31 分钟

一、什么是 Spring Cloud？

Spring Cloud provides tools for developers to quickly build some of the common patterns in distributed systems (e.g. configuration management, service discovery, circuit breakers, intelligent routing, micro-proxy, control bus, one-time tokens, global locks, leadership election, distributed sessions, cluster state). Coordination of distributed systems leads to boiler plate patterns, and using Spring Cloud developers can quickly stand up services and applications that implement those patterns. They will work well in any distributed environment, including the developer’s own laptop, bare metal data centres, and managed platforms such as Cloud Foundry.

以上翻译如下：

Spring Cloud 为开发者提供了工具来快速构建分布式系统中的一些常见模式（例如配置管理、服务发现、断路器、智能路由、微代理、控制总线、一次性令牌、全局锁、领导选举、分布式会话，集群状态）。分布式系统的协调导致了样板模式，使用 Spring Cloud 开发人员可以快速建立实现这些模式的服务和应用程序。它们在任何分布式环境中都能很好地工作，包括开发人员自己的笔记本电脑、裸机数据中心以及 Cloud Foundry 等托管平台。

大致意思就是 Spring Cloud 是一个分布式框架，基于 Spring Boot 微服务，将一个一个独立的模块聚合，达到了“ 高内聚 · 低耦合 ”

二、Spring Cloud 与 Spring Boot 的关系

Spring Boot 专注于开发方便的开发单个个体微服务；
Spring Cloud 是关注全局的微服务协调整理治理框架，它将 Spring Boot 开发的一个个单体微服务，整合并管理起来，为各个微服务之间提供：配置管理、服务发现、断路器、路由、为代理、事件总栈、全局锁、决策竞选、分布式会话等等集成服务；
Spring Boot 专注于快速、方便的开发单个个体微服务，Spring Cloud 关注全局的服务治理框架
Spring Boot 可以离开 Spring Cloud 独立运行，而 Spring Cloud 不可以离开 Spring Boot，是基于 Spring Boot 的

三、Spring Cloud 与 Dubbo 的区别

⛽服务的调用方式

Spring Cloud 采用 HTTP 的 REST 方式调用服务，Dubbo 采用 RPC 框架实现远程调用服务

⛽社区更新力度

Dubbo 活跃度较低

Spring Cloud 社区活跃度比较高

定位不同：Dubbo 的定位是一款高性能 RPC 框架，而 Spring Cloud 的目标是分布式微服务架构的一站式解决方案

两者最大的区别：Spring Cloud 抛弃了 Dubbo 的 RPC，采用了基于 HTTP 的 REST 方式

严格来说，这两种方式各有优劣。虽然从一定程度上来说，后者牺牲了服务调用的性能，但也避免了上面提到的原生 RPC 带来的问题。而且 REST 相比 RPC 更为灵活，服务提供方和调用方的依赖只依靠一纸契约，不存在代码级别的强依赖，这个优点在当下强调快速演化的微服务环境下，显得更加合适。

四、Spring Cloud 能干什么？

Distributed/versioned configuration 分布式/版本控制配置
Service registration and discovery 服务注册与发现
Routing 路由
Service-to-service calls 服务到服务的调用
Load balancing 负载均衡配置
Circuit Breakers 断路器
Distributed messaging 分布式消息管理

五、什么是 Eureka？

Netflix 在涉及 Eureka 时，遵循的就是 API 原则.

Eureka 是 Netflix 的子模块，也是核心模块之一。Eureka 是基于 REST 的服务，用于定位服务，以实现云端中间件层服务发现和故障转移，服务注册与发现对于微服务来说是非常重要的，有了服务注册与发现，只需要使用服务的标识符，就可以访问到服务，而不需要修改服务调用的配置文件了，功能类似于 Dubbo 的注册中心，比如 Zookeeper。

六、Eureka 的特性及优点

Eureka 是一个基于 REST 的服务，用于定位服务，以实现云端中间层服务发现和故障转移。
Eureka 主管服务注册与发现，在微服务中，以后了这两者，只需要使用服务的标识符,就是那个在每个服务的 yml 文件中取得服务名称，就可以访问到服务，不需要修改服务调用的配置文件。
Eureka 遵循 AP 原则 高可用，分区容错性，因为使用了自我保护机制所以保证了高可用。

Eureka 两大组件：Eureka Server（提供注册服务）、 Eureka Client（JAVA 客户端，负责发送心跳）

Eureka 三大角色：

Eureka Server：提供服务注册和发现
Service Provider：服务提供方，将自身服务注册到 Eureka，从而使服务消费方能够找到
Service Consumer：服务消费方，从 Eureka 获取注册服务列表，从而能够消费服务。

七、Spring Cloud 入门案例 -- 搭建 Eureka 注册中心

✴️需求说明

基于 Spring Boot 聚合工程

使用 Spring Cloud 实现分布式应用

服务提供者，将服务注册到 Eureka 注册中心
服务消费者，从 Eureka 取出调用的服务并获取返回结果

流程图

❇️ 效果图

♻️项目结构

模块说明

spring_cloud 模块：父级模块
springcloud-api：实体类模块
springcloud-eureka：注册中心模块
springcloud-provider：服务提供者模块
springcloud-consumer：服务消费者模块

⏳核心源码

⌚父级模块

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 http://maven.apache.org/xsd/maven-4.0.0.xsd">    <modelVersion>4.0.0</modelVersion>
    <groupId>org.example</groupId>    <artifactId>spring_cloud</artifactId>    <version>1.0-SNAPSHOT</version>    <modules>        <module>springcloud-api</module>        <module>springcloud-provider</module>        <module>springcloud-eureka</module>        <module>springcloud-consumer</module>    </modules>

    <!-- 打包方式为 pom -->    <packaging>pom</packaging>
    <properties>        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>        <maven.compiler.source>1.8</maven.compiler.source>        <maven.compiler.target>1.8</maven.compiler.target>        <junit.version>4.12</junit.version>        <log4j.version>1.2.17</log4j.version>        <lombok.version>1.16.18</lombok.version>    </properties>
    <dependencyManagement>        <dependencies>            <dependency>                <groupId>org.springframework.cloud</groupId>                <artifactId>spring-cloud-alibaba-dependencies</artifactId>                <version>0.2.0.RELEASE</version>                <type>pom</type>                <scope>import</scope>            </dependency>            <!--springCloud的依赖-->            <dependency>                <groupId>org.springframework.cloud</groupId>                <artifactId>spring-cloud-dependencies</artifactId>                <version>Greenwich.SR1</version>                <type>pom</type>                <scope>import</scope>            </dependency>            <!--SpringBoot-->            <dependency>                <groupId>org.springframework.boot</groupId>                <artifactId>spring-boot-dependencies</artifactId>                <version>2.1.4.RELEASE</version>                <type>pom</type>                <scope>import</scope>            </dependency>            <!--数据库-->            <dependency>                <groupId>mysql</groupId>                <artifactId>mysql-connector-java</artifactId>                <version>5.1.47</version>            </dependency>            <dependency>                <groupId>com.alibaba</groupId>                <artifactId>druid</artifactId>                <version>1.1.10</version>            </dependency>            <!--SpringBoot 启动器-->            <dependency>                <groupId>org.mybatis.spring.boot</groupId>                <artifactId>mybatis-spring-boot-starter</artifactId>                <version>1.3.2</version>            </dependency>            <!--日志测试~-->            <dependency>                <groupId>ch.qos.logback</groupId>                <artifactId>logback-core</artifactId>                <version>1.2.3</version>            </dependency>            <dependency>                <groupId>junit</groupId>                <artifactId>junit</artifactId>                <version>${junit.version}</version>            </dependency>            <dependency>                <groupId>log4j</groupId>                <artifactId>log4j</artifactId>                <version>${log4j.version}</version>            </dependency>            <dependency>                <groupId>org.projectlombok</groupId>                <artifactId>lombok</artifactId>                <version>${lombok.version}</version>            </dependency>        </dependencies>    </dependencyManagement>
</project>

复制代码

⌚实体类模块

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 http://maven.apache.org/xsd/maven-4.0.0.xsd">    <parent>        <artifactId>spring_cloud</artifactId>        <groupId>org.example</groupId>        <version>1.0-SNAPSHOT</version>    </parent>    <modelVersion>4.0.0</modelVersion>
    <artifactId>springcloud-api</artifactId>
    <properties>        <maven.compiler.source>8</maven.compiler.source>        <maven.compiler.target>8</maven.compiler.target>    </properties>
    <dependencies>        <dependency>            <groupId>org.projectlombok</groupId>            <artifactId>lombok</artifactId>        </dependency>    </dependencies>
</project>

复制代码

Dept 实体类

package com.wanshi.springcloud.entity;
import lombok.Data;import lombok.NoArgsConstructor;import lombok.experimental.Accessors;
@Data@NoArgsConstructor//支持链式编程@Accessors(chain = true)public class Dept {
    private Integer dept_noid;
    private String dept_name;
    private String db_source;}

复制代码

⌚注册中心模块

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 http://maven.apache.org/xsd/maven-4.0.0.xsd">    <parent>        <artifactId>spring_cloud</artifactId>        <groupId>org.example</groupId>        <version>1.0-SNAPSHOT</version>    </parent>    <modelVersion>4.0.0</modelVersion>
    <artifactId>springcloud-eureka</artifactId>
    <dependencies>        <!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-eureka-server -->        <dependency>            <groupId>org.springframework.cloud</groupId>            <artifactId>spring-cloud-starter-eureka-server</artifactId>            <version>1.4.6.RELEASE</version>        </dependency>        <!-- 热部署工具 -->        <dependency>            <groupId>org.springframework.boot</groupId>            <artifactId>spring-boot-devtools</artifactId>        </dependency>    </dependencies>
</project>

复制代码

application.yml

server:  port: 7001
# eureka 配置eureka:  instance:    hostname: localhost # eureka 服务端的实例名称  client:    register-with-eureka: false # 是否向 eureka 注册自己，不注册自己    fetch-registry: false # fetch-registry 如果为false，表示自己为注册中心    service-url: # 将默认的url去掉，替换为自己的，监控页面      defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/

复制代码

启动类

package com.wanshi.springcloud;
import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
@SpringBootApplication// EnableEurekaServer 启动Eureka服务@EnableEurekaServerpublic class EurekaServerMainApplication {    public static void main(String[] args) {        SpringApplication.run(EurekaServerMainApplication.class, args);    }}

复制代码

⌚服务提供者模块

pom.xml

<dependencies>
        <!-- Eureka -->        <!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-eureka -->        <dependency>            <groupId>org.springframework.cloud</groupId>            <artifactId>spring-cloud-starter-eureka</artifactId>            <version>1.4.6.RELEASE</version>        </dependency>
        <!-- actuator 监控中心 -->        <dependency>            <groupId>org.springframework.boot</groupId>            <artifactId>spring-boot-starter-actuator</artifactId>        </dependency>

        <!-- 引入实体类 -->        <dependency>            <groupId>org.example</groupId>            <artifactId>springcloud-api</artifactId>            <version>1.0-SNAPSHOT</version>        </dependency>        <!-- junit -->        <dependency>            <groupId>junit</groupId>            <artifactId>junit</artifactId>            <scope>test</scope>        </dependency>
        <!-- mysql -->        <dependency>            <groupId>mysql</groupId>            <artifactId>mysql-connector-java</artifactId>        </dependency>
        <dependency>            <groupId>com.alibaba</groupId>            <artifactId>druid</artifactId>        </dependency>
        <dependency>            <groupId>ch.qos.logback</groupId>            <artifactId>logback-core</artifactId>        </dependency>
        <dependency>            <groupId>org.mybatis.spring.boot</groupId>            <artifactId>mybatis-spring-boot-starter</artifactId>        </dependency>
        <!-- test -->        <dependency>            <groupId>org.springframework.boot</groupId>            <artifactId>spring-boot-test</artifactId>        </dependency>        <dependency>            <groupId>org.springframework.boot</groupId>            <artifactId>spring-boot-starter-web</artifactId>        </dependency>        <!-- jetty -->        <dependency>            <groupId>org.springframework.boot</groupId>            <artifactId>spring-boot-starter-jetty</artifactId>        </dependency>
        <!-- 热部署工具 -->        <dependency>            <groupId>org.springframework.boot</groupId>            <artifactId>spring-boot-devtools</artifactId>        </dependency>        <dependency>            <groupId>org.springframework.boot</groupId>            <artifactId>spring-boot-starter-jdbc</artifactId>        </dependency>
    </dependencies>

复制代码

application.yml

server:  port: 8001  servlet:    context-path: /springcloud-provider-dept/
spring:  application:    name: SpringCloudProviderDept  datasource:    url: jdbc:mysql://localhost:3306/db_spring_cloud01    username: root    password: 111111    driver-class-name: com.mysql.jdbc.Driver

# Eureka的配置，服务注册到那里eureka:  client:    service-url:      defaultZone: http://localhost:7001/eureka/  instance:    instance-id: springcloud-provider-dept8001 # 修改 Eureka上的默认描述信息
info:  app.name: wanshi-springcloud  company.name: blog.wanshi.com

复制代码

DeptController

package com.wanshi.springcloud.controller;
import com.wanshi.springcloud.entity.Dept;import com.wanshi.springcloud.service.DeptService;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.cloud.client.ServiceInstance;import org.springframework.cloud.client.discovery.DiscoveryClient;import org.springframework.web.bind.annotation.*;
import java.util.List;
@RestController@RequestMapping("/dept/")public class DeptController {
    @Autowired    private DeptService deptService;
    @GetMapping("list")    public List<Dept> list() {        return deptService.list();    }
    @PostMapping("insert")    public Integer insert(@RequestBody Dept param) {        return deptService.insert(param);    }
    @PostMapping("get/{id}")    public Dept get(@PathVariable("id") Integer id) {        Dept param = new Dept();        param.setDept_noid(id);       return deptService.get(param);    }
}

复制代码

⌚服务消费者模块

pom.xml

 <dependencies>
        <!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-ribbon -->        <dependency>            <groupId>org.springframework.cloud</groupId>            <artifactId>spring-cloud-starter-ribbon</artifactId>            <version>1.4.6.RELEASE</version>        </dependency>
        <!-- Eureka -->        <!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-eureka -->        <dependency>            <groupId>org.springframework.cloud</groupId>            <artifactId>spring-cloud-starter-eureka</artifactId>            <version>1.4.6.RELEASE</version>        </dependency>
        <dependency>            <groupId>org.example</groupId>            <artifactId>springcloud-api</artifactId>            <version>1.0-SNAPSHOT</version>        </dependency>
        <dependency>            <groupId>org.springframework.boot</groupId>            <artifactId>spring-boot-starter-web</artifactId>        </dependency>
        <!-- 热部署工具 -->        <dependency>            <groupId>org.springframework.boot</groupId>            <artifactId>spring-boot-devtools</artifactId>        </dependency>
    </dependencies>

复制代码

application.yml

server:  port: 80
# Eureka配置eureka:  client:    register-with-eureka: false # 不向注册中心注册自己    service-url:      defaultZone: http://localhost:7001/eureka/

复制代码

ConfigBean 配置

package com.wanshi.springcloud.config;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;import org.springframework.web.client.RestTemplate;
@Configurationpublic class ConfigBean {
    @Bean    public RestTemplate getRestTemplate() {        return new RestTemplate();    }}

复制代码

DeptConsumerController

package com.wanshi.springcloud.controller;
import com.wanshi.springcloud.entity.Dept;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.web.bind.annotation.*;import org.springframework.web.client.RestTemplate;
import java.util.List;
@RestController@CrossOrigin@RequestMapping("/consumer/dept/")public class DeptConsumerController {
    @Autowired    private RestTemplate restTemplate;
    private static final String REST_URL_PREFIX = "http://localhost:8001/springcloud-provider-dept";
    @GetMapping("get/{id}")    public Integer get(@PathVariable("id") Integer id) {        return restTemplate.getForObject(REST_URL_PREFIX + "/dept/get/" + id, Integer.class);    }
    @GetMapping("list")    public List<Dept> list() {        return restTemplate.getForObject(REST_URL_PREFIX + "/dept/list", List.class);    }
    @PostMapping("insert")    public Integer insert(@RequestBody Dept param) {        return restTemplate.patchForObject(REST_URL_PREFIX + "/dept/insert", param, Integer.class);    }}

复制代码

启动类

package com.wanshi.springcloud;
import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
// Ribbon 和 Eureka 整合以后，客户端可以直接调用，不用关心IP地址和端口号@SpringBootApplication@EnableEurekaClientpublic class DeptConsumerApplication {
    public static void main(String[] args) {        SpringApplication.run(DeptConsumerApplication.class, args);    }}

复制代码

八、源码下载

Spring Cluod搭建Eureka注册中心实现服务者与消费者的服务调用

♨️往期精彩热文回顾

✈️ Netty进阶 -- WebSocket长连接开发✈️ Netty进阶 -- 非阻塞网络编程实现群聊+私聊+心跳检测系统

✈️ Postman测试工具调试接口详细教程【向后端发送Json数据并接收返回的Json结果】

✈️ Java面向对象 --- 吃货联盟订餐系统（完整版）✈️ 一分钟教你快速搭建Vue脚手架（Vue-Cli）项目并整合ElementUI

⛵小结

以上就是【Bug 终结者】对 Spring Cloud 搭建 Eureka 注册中心实现服务者与消费者的服务调用 简单的概述，理解代码不难，多多练习，该工程是一个分布式应用框架，注册了 Eureka 注册中心作为服务的中转站，可以多多练习去巩固自己的技术~

如果这篇【文章】有帮助到你，希望可以给【Bug 终结者】点个赞👍，创作不易，如果有对【后端技术】、【前端领域】感兴趣的小可爱，也欢迎关注❤️❤️❤️ 【Bug 终结者】❤️❤️❤️，我将会给你带来巨大的【收获与惊喜】💝💝💝！

发布于: 刚刚阅读数: 6

原文链接:【http://xie.infoq.cn/article/7078e9e919f373dc277fa096c】。文章转载请联系作者。

Bug终结者

关注

励志成为一个优秀的开发者～ 2021.12.09 加入

星星之火，可以燎原

发布

暂无评论

创作场景

Spring Cloud 入门 -- 搭建 Eureka 注册中心 实现服务者与消费者的服务调用

一、什么是 Spring Cloud？

二、Spring Cloud 与 Spring Boot 的关系

三、Spring Cloud 与 Dubbo 的区别

⛽服务的调用方式

⛽社区更新力度

四、Spring Cloud 能干什么？

五、什么是 Eureka？

六、Eureka 的特性及优点

七、Spring Cloud 入门案例 -- 搭建 Eureka 注册中心

✴️需求说明

❇️ 效果图

♻️项目结构

⏳核心源码

⌚父级模块

⌚实体类模块

⌚注册中心模块

⌚服务提供者模块

⌚服务消费者模块

八、源码下载

♨️往期精彩热文回顾

⛵小结

Bug终结者

评论

Spring Cloud 入门 -- 搭建 Eureka 注册中心实现服务者与消费者的服务调用