当前位置：首页 > news >正文

微服务常用的基础知识

news 来源：原创 2025/6/27 11:15:11

1.微服务介绍

1.1 产生背景

随着互联网的发展，网站应用的规模不断扩大，传统单体架构逐渐难以应对大型网站高并发、高扩展性等需求，于是分布式系统架构应运而生。Spring Cloud 就是在这种背景下诞生的，它利用 Spring Boot 的开发便利性，简化了分布式系统的开发。

1.2 主要功能

1.服务发现与注册：在分布式系统中，各个微服务需要相互调用，服务发现与注册功能可以动态地发现和注册服务的地址，使得服务之间能够方便地进行通信。例如，Eureka 是 Spring Cloud 中常用的服务发现与注册组件，它提供了一个服务注册中心，各个微服务启动时会向注册中心注册自己的信息，当其他服务需要调用它时，通过查询注册中心就可以获取到其地址进行通信。
2.配置中心：集中管理应用程序的配置信息，方便统一修改和管理配置。Config 是 Spring Cloud 的配置中心组件，它支持配置信息存储在多种后端，如本地文件系统、数据库、Git 仓库等。当配置信息发生变化时，可以及时通知各个微服务进行更新。
3.熔断器：在分布式系统中，某些服务可能会因为各种原因出现故障或响应缓慢，熔断器可以快速熔断故障服务的调用，避免故障蔓延，提高系统的稳定性和可用性。Hystrix 是 Spring Cloud 常用的熔断器组件，它能够实时监控服务调用的健康状况，当故障率达到一定程度时，自动熔断后续的调用请求，并可以设置熔断后的降级策略。
4.API 网关：作为系统的统一入口，对外提供 API 接口的路由转发、负载均衡、鉴权认证等功能。Zuul 是 Spring Cloud 的 API 网关组件，它可以对进入系统的请求进行过滤、路由和转发，根据不同的条件将请求分发到不同的后端微服务，并且可以实现一些安全控制和流量控制等功能。

1.3 架构优势

1.微服务架构支持：Spring Cloud 完全契合微服务架构理念，能够帮助开发者快速构建松耦合、易扩展的微服务应用，使得各个服务可以独立开发、部署和扩展。
2.开发便捷性：基于 Spring Boot 的自动配置特性，Spring Cloud 大大简化了分布式系统开发的复杂性，开发者可以使用简单的注解和配置快速搭建和集成各个功能组件。
3.良好的扩展性：Spring Cloud 的各个组件相互独立又可以协同工作，开发者可以根据项目需求灵活选择和组合不同的组件，方便地对系统进行扩展和升级。

2.常用中间件

2.1 Nacos

2.1.1 Nacos功能

1.服务发现与服务健康检查

2.动态配置管理

3.动态DNS服务

4.服务与元数据管理

2.1.2 Nacos注册中心原理

Nacos注册中心分为server与client，server采用Java编写，为client提供注册发现服务与配置服务。而client可以用多语言实现，client与微服务嵌套在一起，nacos提供sdk和openApi，如果没有sdk也可以根据openApi手动写服务注册与发现和配置拉取的逻辑

Nacos注册概括来说有6个步骤：

1、服务容器负责启动，加载，运行服务提供者。

2、服务提供者在启动时，向注册中心注册自己提供的服务。

3、服务消费者在启动时，向注册中心订阅自己所需的服务。

4、注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给消费者。

5、服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，如果调用失败，再选另一台调用。

6、服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心。

Nacos 服务注册与订阅的完整流程

Nacos 客户端进行服务注册有两个部分组成，一个是将服务信息注册到服务端，另一个是像服务端发送心跳包，这两个操作都是通过 NamingProxy 和服务端进行数据交互的。

Nacos 客户端进行服务订阅时也有两部分组成，一个是不断从服务端查询可用服务实例的定时任务，另一个是不断从已变服务队列中取出服务并通知 EventListener 持有者的定时任务。

2.1.3 Nacos配置中心原理

Nacos的注册发现是一种三层模型: 即服务--集群--实例

Nacos服务领域模型主要分为命名空间、集群、服务。在服务级别，保存了健康检查开关、元数据、路由机制、保护阈值等设置，而集群保存了健康检查模式、元数据、同步机制等数据，实例保存了该实例的ip、端口、权重、健康检查状态、下线状态、元数据、响应时间。

在Nacos中管理微服务的配置文件，需要在Nacos控制台创建配置项，指定命名空间和分组，定义配置内容，并通过Nacos客户端在微服务中动态获取和监听配置更新。

2.1.4 注册中心基本使用

1、添加依赖

<!-- springcloud alibaba nacos discovery -->
<dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency><!-- springcloud loadbalancer -->
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-loadbalancer</artifactId>
</dependency><!-- SpringBoot Web -->
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId>
</dependency>

2.添加Nacos配置

# Spring
spring: application:# 应用名称name: ruoyi-xxxx cloud:nacos:discovery:# 服务注册地址server-addr: 127.0.0.1:8848

3、在Application启动类加入注解@SpringBootApplication。

@SpringBootApplication
public class RuoYiXxxxApplication
{public static void main(String[] args){SpringApplication.run(RuoYiXxxxApplication.class, args);System.out.println("(♥◠‿◠)ﾉﾞ  Xxxx启动成功   ლ(´ڡ`ლ)ﾞ  \n" +" .-------.       ____     __        \n" +" |  _ _   \\      \\   \\   /  /    \n" +" | ( ' )  |       \\  _. /  '       \n" +" |(_ o _) /        _( )_ .'         \n" +" | (_,_).' __  ___(_ o _)'          \n" +" |  |\\ \\  |  ||   |(_,_)'         \n" +" |  | \\ `'   /|   `-'  /           \n" +" |  |  \\    /  \\      /           \n" +" ''-'   `'-'    `-..-'              ");}
}

4.启动服务，查看Nacos控制台的服务列表

2.1.5 配置中心基本使用

1.添加依赖

<!-- springcloud alibaba nacos config -->
<dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
</dependency><!-- SpringBoot Web -->
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId>
</dependency>

2、在bootstrap.yml添加Nacos配置

# Spring
spring: application:# 应用名称name: ruoyi-xxxxprofiles:# 环境配置active: devcloud:nacos:config:# 配置中心地址server-addr: 127.0.0.1:8848# 配置文件格式file-extension: yml# 共享配置shared-configs:- application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}

3、在Application启动类加入注解@SpringBootApplication。

@SpringBootApplication
public class RuoYiXxxxApplication
{public static void main(String[] args){SpringApplication.run(RuoYiXxxxApplication.class, args);System.out.println("(♥◠‿◠)ﾉﾞ  Xxxx启动成功   ლ(´ڡ`ლ)ﾞ  \n" +" .-------.       ____     __        \n" +" |  _ _   \\      \\   \\   /  /    \n" +" | ( ' )  |       \\  _. /  '       \n" +" |(_ o _) /        _( )_ .'         \n" +" | (_,_).' __  ___(_ o _)'          \n" +" |  |\\ \\  |  ||   |(_,_)'         \n" +" |  | \\ `'   /|   `-'  /           \n" +" |  |  \\    /  \\      /           \n" +" ''-'   `'-'    `-..-'              ");}
}

2.2 Sentinel

2.2.1 基本介绍

Sentinel是阿里巴巴开源的一款面向分布式服务架构的流量控制、熔断降级组件。它以流量为切入点，从流量控制、熔断降级、系统负载保护等多个维度帮助用户保障微服务的稳定性。

2.2.2 Sentinel的使用

Sentinel 的使用可以分为两个部分:

控制台（Dashboard）：控制台主要负责管理推送规则、监控、集群限流分配管理、机器发现等。
核心库（Java 客户端）：不依赖任何框架/库，能够运行于 Java 7 及以上的版本的运行时环境，同时对 Dubbo / Spring Cloud 等框架也有较好的支持。

1.添加依赖

<!-- springcloud alibaba sentinel -->
<dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
</dependency><!-- SpringBoot Web -->
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId>
</dependency>

2.添加sentinel配置

spring: application:# 应用名称name: ruoyi-xxxx cloud:sentinel:# 取消控制台懒加载eager: truetransport:# 控制台地址dashboard: 127.0.0.1:8718

3.下载sentinel客户端jar包

4.在jar目录下输入终端命令

java -jar sentinel-dashboard-1.8.6.jar --server.port=8081
or
java -Dserver.port=8081 -Dcsp.sentinel.dashboard.server=localhost:8081 -Dproject.name=sentinel-dashboard -Dcsp.sentinel.api.port=8082 -jar "C:\project\xinlingzhitong2javacloud\sentinel-dashboard-1.8.6.jar"
or
java  -Dserver.port=38718 -Dcsp.sentinel.dashboard.server=localhost:38718 -Dproject.name=sentinel-dashboard -Dfile.encoding=utf-8 -Xms256m -Xmx512m -XX:MetaspaceSize=512m -XX:MaxMetaspaceSize=512m  -jar sentinel-dashboard-1.8.6.jar

5.访问：http://localhost:8081/#/dashboard

2.3 Seata

2.3.1 Seata简介

Seata 是一款开源的分布式事务解决方案，致力于提供高性能和简单易用的分布式事务服务。Seata 将为用户提供了 AT、TCC、SAGA 和 XA 事务模式，为用户打造一站式的分布式解决方案。

2.3.2 Seata基本架构

TC (Transaction Coordinator) - 事务协调者；维护全局和分支事务的状态，驱动全局事务提交或回滚。
TM (Transaction Manager) - 事务管理器；定义全局事务的范围：开始全局事务、提交或回滚全局事务。
RM (Resource Manager) - 资源管理器；管理分支事务处理的资源，与TC交谈以注册分支事务和报告分支事务的状态，并驱动分支事务提交或回滚。

2.3.3 分布式事务解决方案

XA模式：强一致性分阶段事务模式，牺牲了一定的可用性，无业务侵入。
TCC模式：最终一致的分阶段事务模式，有业务侵入。
AT模式：最终一致的分阶段事务模式，无业务侵入，也是Seata的默认模式。
SAGA模式：长事务模式，有业务侵入。

2.4 RabbitMQ

2.4.1 RabbitMQ的基本概念

RabbitMQ中的一些角色：

publisher：生产者(发布者)

consumer：消费者

exchange：交换机，负责消息路由

queue：队列，存储消息

virtualHost：虚拟主机，隔离不同租户的exchange、queue、消息的隔离

channel：表示通道，操作MQ的工具。是消息发布者和交换机之间的连接通道，也是消息消费者连接队列的通道

将以上的RabbitMQ基本结构归纳为以下四点：

1.消息的发布者(publisher)将消息投递到交换机(exchange)

2.交换机(exchange)将消息转发到与之绑定的队列(queue)

3.消息消费者(consumer)监听队列(queue)，获取队列(queue)中的消息

4.将不同的队列(queue)和交换机(exchange)划分成一组，称为虚拟主机(virtualHost)

2.4.2 官方示例

1.基本消息队列

P（producer/ publisher）：生产者，一个发送消息的用户应用程序。我们自己书写代码发送。

C（consumer）：消费者，消费和接收有类似的意思，消费者是一个主要用来等待接收消息的用户应用程序。我们自己书写代码接收。

队列（红色区域）：存在于rabbitmq内部。许多生产者可以发送消息到一个队列，许多消费者可以尝试从一个队列接收数据。

2.工作消息队列

工作消息队列是基本消息队列的增强版，具有多个消费者消费队列的消息。假设消息队列中积压了多个消息，那么此时可以使用多个消费者来消费队列中的消息。效率要比基本消息队列模型高。

3.发布订阅

将消息交给所有绑定到交换机的队列,生产者发送的消息，只能发送到交换机，交换机来决定要发给哪个队列，生产者无法决定。交换机把消息发送给绑定过的所有队列.队列的消费者都能拿到消息。实现一条消息被多个消费者消费.

4.路由

1.在广播模式中，生产者发布消息，所有消费者都可以获取所有消息。

2.在某些场景下，我们希望不同的消息被不同的队列消费。这时就要用到Direct类型的Exchange。在Direct模型下，队列与交换机的绑定，不能是任意绑定了，而是要指定一个RoutingKey（路由key）.消息的发送方在向Exchange发送消息时，也必须指定消息的routing key。

3.P：生产者，向Exchange发送消息，发送消息时，会指定一个routing key。

4.X：Exchange（交换机），接收生产者的消息，然后把消息递交给与routing key完全匹配的队列

5.主题

1.Topic类型的Exchange与Direct相比，都是可以根据RoutingKey把消息路由到不同的队列。只不过Topic类型Exchange可以让队列在绑定Routing key 的时候使用通配符！

2.Routingkey 一般都是有一个或多个单词组成，多个单词之间以”.”分割，例如： item.insert

3.通配符规则：

#：匹配一个或多个词

*：匹配恰好1个词

2.5 SpringCloud Gateway

2.5.1 基本介绍

服务网关

API Gateway（APIGW / API 网关），顾名思义，是系统对外的唯一入口。API网关封装了系统内部架构，为每个客户端提供定制的API。近几年来移动应用与企业间互联需求的兴起。从以前单一的Web应用，扩展到多种使用场景，且每种使用场景对后台服务的要求都不尽相同。这不仅增加了后台服务的响应量，还增加了后台服务的复杂性。随着微服务架构概念的提出，API网关成为了微服务架构的一个标配组件。

why use？

微服务的应用可能部署在不同机房，不同地区，不同域名下。此时客户端（浏览器/手机/软件工具）想要请求对应的服务，都需要知道机器的具体 IP 或者域名 URL，当微服务实例众多时，这是非常难以记忆的，对于客户端来说也太复杂难以维护。此时就有了网关，客户端相关的请求直接发送到网关，由网关根据请求标识解析判断出具体的微服务地址，再把请求转发到微服务实例。这其中的记忆功能就全部交由网关来操作了。

核心概念

路由（Route）：路由是网关最基础的部分，路由信息由 ID、目标 URI、一组断言和一组过滤器组成。如果断言路由为真，则说明请求的 URI 和配置匹配。
断言（Predicate）：Java8 中的断言函数。Spring Cloud Gateway 中的断言函数输入类型是 Spring 5.0 框架中的 ServerWebExchange。Spring Cloud Gateway 中的断言函数允许开发者去定义匹配来自于 Http Request 中的任何信息，比如请求头和参数等。
过滤器（Filter）：一个标准的 Spring Web Filter。Spring Cloud Gateway 中的 Filter 分为两种类型，分别是 Gateway Filter 和 Global Filter。过滤器将会对请求和响应进行处理。

2.5.2 使用网关

1.添加依赖

<!-- spring cloud gateway 依赖 -->
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-gateway</artifactId>
</dependency>

2.resources/application.yml配置文件

server:port: 8080spring: application:name: ruoyi-gatewaycloud:gateway:routes:# 系统模块- id: ruoyi-systemuri: http://localhost:9201/predicates:- Path=/system/**filters:- StripPrefix=1

3.网关启动类

@SpringBootApplication
public class RuoYiGatewayApplication
{public static void main(String[] args){SpringApplication.run(RuoYiGatewayApplication.class, args);System.out.println("(♥◠‿◠)ﾉﾞ  若依网关启动成功   ლ(´ڡ`ლ)ﾞ  \n" +" .-------.       ____     __        \n" +" |  _ _   \\      \\   \\   /  /    \n" +" | ( ' )  |       \\  _. /  '       \n" +" |(_ o _) /        _( )_ .'         \n" +" | (_,_).' __  ___(_ o _)'          \n" +" |  |\\ \\  |  ||   |(_,_)'         \n" +" |  | \\ `'   /|   `-'  /           \n" +" |  |  \\    /  \\      /           \n" +" ''-'   `'-'    `-..-'              ");}
}

2.6 MongoDB

2.6.1 简单介绍

MongoDB是一个基于分布式文件存储的数据库

由C++语言编写，旨在为WEB应用提供可扩展的高性能数据存储解决方案。

MongoDB是一个介于关系数据库和非关系数据库之间的产品，是非关系数据库当中功能最丰富，最像关系数据库的。

它支持的数据结构非常松散，是类似json的bson格式，因此可以存储比较复杂的数据类型。

Mongo最大的特点是它支持的查询语言非常强大，其语法有点类似于面向对象的查询语言，几乎可以实现类似关系数据库单表查询的绝大部分功能，而且还支持对数据建立索引

2.6.2 使用场景

传统的关系型数据库(如MySQL)，在数据操作的三高需求以及应对Web2.0的网站需求面前，显得力不从心，而 MongoDB可应对“三高“需求。

High performance：对数据库高并发读写的需求

Huge Storage：对海量数据的高效率存储和访问的需求

High Scalability && High Availability：对数据库的高可扩展性和高可用性的需求

具体应用场景：

社交场景，使用 MongoDB存储存储用户信息，以及用户发表的朋友圈信息，通过地理位置索引实现附近的人、地点等功能。

游戏场景，使用 MongoDB存储游戏用户信息，用户的装备、积分等直接以内嵌文档的形式存储，方便查询、高效率存储和访问。

物流场景，使用 MongoDB存储订单信息，订单状态在运送过程中会不断更新，以 MongoDB内嵌数组的形式来存储，一次查询就能将订单所有的变更读取出来

物联网场景，使用 MongoDB存储所有接入的智能设备信息，以及设备汇报的日志信息，并对这些信息进行多维度的分析。

视频直播，使用 MongoDB存储用户信息、点赞互动信息等。

这些应用场景中，数据操作方面的共同特点是：

（1）数据量大

（2）写入操作频繁（读写都很频繁）

（3）价值较低的数据，对事务性要求不高

对于这样的数据，我们更适合使用 MongoDB来实现数据的存储。

2.6.3 数据类型

MongoDB的最小存储单位就是文档document对象。文档document对象对应于关系型数据库的行。数据在MongoDB中以BSON（Binary-JSON）文档的格式存储在磁盘上。

BSON（Binary Serialized Document Format）是一种类json的一种二进制形式的存储格式，简称 Binary JSON；BSON和JSON一样，支持内嵌的文档对象和数组对象，但是BSON有JSON没有的一些数据类型，如Date和Bin Data类型。

BSON采用了类似于C语言结构体的名称、对表示方法，支持内嵌的文档对象和数组对象，具有轻量性、可遍历性、高效性的三个特点，可以有效描述非结构化数据和结构化数据。这种格式的优点是灵活性高，但它的缺点是空间利用率不是很理想。

BSON中，除了基本JSON类型： string，integer，boolean，double，null，array和object，mongo还使用了特殊的数据类型。这些类型包括 date， object id， binary data， regular expression和code。每一个驱动都以特定语言的方式实现了这些类型，查看你的驱动的文档来获取详细信息。

2.6.4 基本常用命令

增：插入文档
db.集合名.insert(json数据)
集合存在则直接插入数据，不存在则隐式创建集合并插入数据
json数据格式要求key得加""，但这里为了方便查看，对象的key统一不加""；查看集合数据时系统会自动给key加""
mongodb会自动给每条数据创建全球唯一的_id键（我们也可以自定义_id的值，只要给插入的json数据增加_id键即可覆盖，但是不推荐这样做）

插入测试

删：删除数据
db.集合名.remove(条件 [,是否删除一条])# 是否删除一条
- false删除多条,即全部删除(默认)
- true删除一条

改：修改数据
db.集合名.update(条件, 新数据 [,是否新增, 是否修改多条])
# 新数据
- 默认是对原数据进行替换
- 若要进行修改,格式为 {修改器:{key:value}}# 是否新增
- 条件匹配不到数据时是否插入: true插入,false不插入(默认)# 是否修改多条
- 条件匹配成功的数据是否都修改: true都修改,false只修改一条(默认)

查：查询数据
db.集合名.find(条件 [,查询的列])
db.集合名.find(条件 [,查询的列]).pretty()	#格式化查看# 条件
- 查询所有数据	{}或不写
- 查询指定要求数据	{key:value}或{key:{运算符:value}}# 查询的列(可选参数)
- 不写则查询全部列
- {key:1}	只显示key列
- {key:0}	除了key列都显示
- 注意:_id列都会存在

2.7 RBAC模型

2.7.1 RABC

RBAC（Role-Based Access Control）是一种通过角色（Role）关联用户（User）和权限（Permission）的访问控制模型，核心思想是：用户→角色→权限。

用户（User）：系统的实际使用者，拥有唯一标识。

角色（Role）：一组权限的集合，代表用户在系统中的职责（如管理员、普通用户）。

权限（Permission）：对系统资源的操作许可（如 “用户查看”、“订单删除”）。

关联关系：

用户与角色：多对多（一个用户可拥有多个角色，一个角色可分配给多个用户）。

角色与权限：多对多（一个角色可包含多个权限，一个权限可被多个角色拥有）。

优点：

简化权限管理：通过角色统一管理权限，避免直接对用户逐个授权。

灵活性：新增角色或修改角色权限时，无需逐个调整用户，只需关联角色即可。

职责分离：符合现实中组织架构的职责划分（如财务角色、研发角色）。

2.7.2 RBAC - 1

RBAC - 1 在基本 RBAC 模型的基础上引入了角色层次结构的概念。即一个角色可以继承另一个角色的权限，形成类似于树状或有向无环图（DAG）的结构。例如，“高级管理员” 角色可能继承 “普通管理员” 角色的所有权限，并且还拥有额外的权限。这种层次结构使得权限管理更加灵活和高效，能够更好地反映现实组织中的职责和权力关系。

优势

当一个新角色需要继承已有角色的大部分权限时，只需将其置于角色层次结构中合适的位置，而无需重新分配所有权限。
角色层次结构可以确保权限的分配遵循一定的规则和逻辑，减少了权限分配的混乱和错误。
能够准确地反映组织中不同职位之间的上下级关系和权限继承关系。

2.7.3 RBAC - 2（约束型 RBAC）

RBAC - 2 在基本 RBAC 模型基础上，添加了各种约束条件，以增强系统的安全性和合规性。这些约束可以限制用户、角色和权限之间的关系，防止不合理的权限分配和使用。

常见约束类型：

互斥角色约束：某些角色不能同时被一个用户拥有。例如，在财务系统中，“审计员” 和 “财务管理员” 角色是互斥的，因为一个人不能同时既负责审计又负责财务管理，以防止利益冲突和欺诈行为。

基数约束：对用户可拥有的角色数量、角色可分配的用户数量或权限可分配的角色数量进行限制。例如，规定每个项目只能有一个 “项目经理” 角色。

先决条件约束：一个角色必须在用户拥有另一个角色之后才能被分配。比如，用户必须先拥有 “普通员工” 角色，才能被分配 “部门主管” 角色。

优势

增强安全性：约束条件可以有效防止用户滥用权限，减少内部人员违规操作的风险。

满足合规要求：许多行业有严格的法规和合规要求，RBAC - 2 的约束机制有助于系统满足这些要求，如金融行业的监管要求。

提高系统可靠性：通过约束条件，可以避免不合理的权限分配导致的系统故障和数据不一致问题。

2.8 Elasticsearch

2.8.1 简介

Elasticsearch是一个基于Lucene的搜索服务器。它提供了一个分布式多用户能力的全文搜索引擎，基于RESTful web接口。Elasticsearch是用Java语言开发的，并作为Apache许可条款下的开放源码发布，是一种流行的企业级搜索引擎。Elasticsearch用于云计算中，能够达到实时搜索，稳定，可靠，快速，安装使用方便。官方客户端在Java、.NET（C#）、PHP、Python、Apache Groovy、Ruby和许多其他语言中都是可用的。根据DB-Engines的排名显示，Elasticsearch是最受欢迎的企业搜索引擎，其次是Apache Solr，也是基于Lucene。

2.8.2 安装

1.下载注意选择的版本需要和你的jdk版本适配

Past Releases of Elastic Stack Software | Elastic

2.修改配置（config下的elasticsearch.yml）


cluster.name: xuecheng   #配置elasticsearch的集群名称，默认是elasticsearch。建议修改成一个有意义的名称。
node.name: xc_node_1  #节点名，通常一台物理服务器就是一个节点，es会默认随机指定一个名字，建议指定一个有意义的名称，方便管理
network.host: 0.0.0.0  #绑定ip地址 ，这个位置改为127.0.0.1，否则报错
http.port: 19200  #暴露的http端口
transport.tcp.port: 19300  #内部端口
node.master: true  #主节点
node.data: true  #数据节点
discovery.zen.ping.unicast.hosts: ["0.0.0.0:19300", "0.0.0.0:19301", "0.0.0.0:19302"]  #设置集群中master节点的初始列表
discovery.zen.minimum_master_nodes: 1  #主结点数量的最少值 ,此值的公式为：(master_eligible_nodes / 2) + 1 ，比如：有3个符合要求的主结点，那么这里要设置为2。
bootstrap.memory_lock: false  #内存的锁定只给es用
node.max_local_storage_nodes: 1 #单机允许的最大存储结点数，通常单机启动一个结点建议设置为1，开发环境如果单机启动多个节点可设置大于1
path.data: C:\elasticsearch-6.2.1\data  #索引目录
path.logs: C:\elasticsearch-6.2.1\logs    #日志
http.cors.enabled: true #  跨域设置
http.cors.allow-origin: “*” #设置跨域

2.8.3 使用

1.进入Elasticsearch的bin目录

cd C:\elasticsearch-6.2.1\bin

2.运行elasticsearch-service.bat文件来启动服务

elasticsearch-service.bat install

3.启动服务

elasticsearch.bat

4.启动成功，访问http://localhost:19200/（19200为配置的端口号）

2.9 Logstash

2.9.1 简介

作为数据收集引擎。它支持动态的从各种数据源搜集数据，并对数据进行过滤、分析、丰富、统一格式等操作，然后存储到用户指定的位置,一般会发送给 Elasticsearch。

Logstash 由 Ruby 语言编写，运行在 Java 虚拟机（JVM）上，是一款强大的数据处理工具，可以实现数据传输、格式处理、格式化输出。Logstash 具有强大的插件功能，常用于日志处理。

2.10 Kibana

2.10.1 简介

Kibana 是为 Elasticsearch设计的开源分析和可视化平台。你可以使用 Kibana 来搜索，查看存储在 Elasticsearch 索引中的数据并与之交互。你可以很容易实现高级的数据分析和可视化，以图表的形式展现出来。

2.10.2 安装

1.下载安装

到网站https://www.elastic.co/cn/downloads/kibana下载可以直接通过修改版本号来下载 https://artifacts.elastic.co/downloads/kibana/kibana-7.17.25-windows-x86_64.zip 版本号和es的一样就行了

2.修改配置文件

2.10.3 使用

启动访问：http://localhost:5601/app/kibana/

ELK架构

2.11 FeignClient

2.11.1 介绍

FeignClient是Spring Cloud的一个声明式HTTP客户端工具，简化了微服务之间的HTTP调用，通过注解和接口定义能够自动且快速发送HTTP请求。

在接触FeignClient之前，对HTTP请求更多的是在前端代码，而FeignClient是后端用来请求HTTP服务（也就是后端某个工程需要请求某个服务），它与前端请求并没有明显的差距，都包括请求url，请求方式，请求参数等，只是书写方式有区别。

2.11.2 使用

FeignClient 的使用步骤

1.引入依赖

<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>

2.启用 FeignClient

@SpringBootApplication
@EnableFeignClients
public class Application {public static void main(String[] args) {SpringApplication.run(Application.class, args);}
}

3.定义 FeignClient 接口

@FeignClient(contextId = "remoteRecruitService", value = ServiceNameConstants.RECRUIT_SERVICE, fallbackFactory = RemoteRecruitFallbackFactory.class)
public interface RemoteRecruitService {@PostMapping("/jobInfo/getJobHotCityList")AjaxResult getJobHotCityList(@RequestBody RecruitCityVo cityVo,@RequestHeader(SecurityConstants.FROM_SOURCE) String source);
}

4.调用 FeignClient

@PostMapping("/hotCityList")
public AjaxResult hotCityList(@RequestBody RecruitCityVo cityVo) {cityVo.setBeHot(1); // 热门城市return remoteRecruitService.getJobHotCityList(cityVo, SecurityConstants.INNER);
}

2.11.3 服务降级

@Component
public class RemoteRecruitFallbackFactory implements FallbackFactory<RemoteRecruitService>
{private static final Logger log = LoggerFactory.getLogger(RemoteRecruitFallbackFactory.class);@Overridepublic RemoteRecruitService create(Throwable throwable){log.error("招募服务调用失败:{}", throwable.getMessage());return new RemoteRecruitService(){@Overridepublic AjaxResult cancelCollect(RecruitSwCollect recruitSwCollect, String inner) {return AjaxResult.error("recruit服务cancelCollect接口API调用失败:" + throwable.getMessage());}};}
}