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:88483、在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-xxxx
profiles:
# 环境配置
active: dev
cloud:
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: true
transport:
# 控制台地址
dashboard: 127.0.0.1:87183.下载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.jar5.访问：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: 8080
spring:
application:
name: ruoyi-gateway
cloud:
gateway:
routes:
# 系统模块
- id: ruoyi-system
uri: http://localhost:9201/
predicates:
- Path=/system/**
filters:
- StripPrefix=13.网关启动类
@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\bin2.运行elasticsearch-service.bat文件来启动服务
elasticsearch-service.bat install3.启动服务
elasticsearch.bat4.启动成功，访问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);
@Override
public RemoteRecruitService create(Throwable throwable)
{
log.error("招募服务调用失败:{}", throwable.getMessage());
return new RemoteRecruitService()
{
@Override
public AjaxResult cancelCollect(RecruitSwCollect recruitSwCollect, String inner) {
return AjaxResult.error("recruit服务cancelCollect接口API调用失败:" + throwable.getMessage());
}
};
}
}