1. 概述

1.1 插件名称

Logging-ElasticSearch

1.2 适用场景

通过shenyu网关收集http请求日志，通过其他平台(Kibana)查询或者展示日志。

1.3 插件功能

Apache ShenYu 网关接收客户端请求，向服务端转发请求，并将服务端结果返回给客户端。网关可以记录下每次请求对应的详细信息，
列如：请求时间、请求参数、请求路径、响应结果、响应状态码、耗时、上游IP、异常信息等待.
ShenYu网关可以通过Logging-ElasticSearch插件记录访问日志并将访问日志发送到ElasticSearch数据库。

1.4 插件代码

核心模块 shenyu-plugin-logging-elasticsearch
核心类 org.apache.shenyu.plugin.logging.elasticsearch.LoggingElasticSearchPlugin
核心类 org.apache.shenyu.plugin.logging.elasticsearch.client.ElasticSearchLogCollectClient

1.5 添加自哪个shenyu版本

ShenYu 2.5.0

1.6 技术方案

架构图

2. 如何使用插件

2.1 插件使用流程图

2.2 导入pom

在shenyu-bootstrap模块的 pom.xml 文件中添加 Logging-ElasticSearch的依赖。

<!--shenyu logging-elasticsearch plugin start-->
<dependency>
    <groupId>org.apache.shenyu</groupId>
    <artifactId>shenyu-spring-boot-starter-plugin-logging-elasticsearch</artifactId>
    <version>${project.version}</version>
</dependency>
<!--shenyu logging-elasticsearch plugin end-->

2.3 启用插件

在 shenyu-admin--> 基础配置 —> 插件管理-> loggingElasticSearch ，配置ElasticSearch参数，并设置为开启。

2.4 配置插件

2.4.1 开启插件，并配置elasticsearch,配置如下：

各个配置项说明如下：

配置项	类型	说明	备注
config-item	type	description	remarks
host	String	主机名	必须
port	String	端口号	必须
sampleRate	String	采样率，范围0~1，0：关闭，0.01:采集1%，1：采集100%	可选，默认1，全部采集
compressAlg	String	压缩算法，默认不压缩，目前支持LZ4压缩	可选，默认不压缩
maxResponseBody	Ingeter	最大响应体大小，超过阈值将不采集响应体	可选，默认512KB
maxRequestBody	Ingeter	最大请求体大小，超过阈值将不采集请求体	可选，默认512KB

除了host、port其它都是可选，大部分情况下只需要配置这2项就可以了。

2.4.2 配置选择器和规则器

选择器和规则详细配置，请参考: 选择器和规则管理。另外有时候一个大网关集群对应多个应用程序（业务），不同应用程序（业务）对应不同的主题，相关隔离，这时候可以按选择器配置不同的主题(可选)和采样率(可选)，配置项的含义如上表所示。
操作如下图：

2.5 Logging信息

采集的access log的字段如下：

字段名称	含义	说明
clientIp	客户端IP
timeLocal	请求时间字符串, 格式：yyyy-MM-dd HH:mm:ss.SSS
method	请求方法(不同rpc类型不一样，http类的为:get,post等待，rpc类的为接口名称)
requestHeader	请求头(json格式)
responseHeader	响应头(json格式)
queryParams	请求查询参数
requestBody	请求Body（二进制类型的body不会采集）
requestUri	请求uri
responseBody	响应body
responseContentLength	响应body大小
rpcType	rpc类型
status	响应码
upstreamIp	上游(提供服务的程序)IP
upstreamResponseTime	上游(提供服务的程序)响应请求的耗时(毫秒ms)
userAgent	请求的用户代理
host	请求的host
module	请求的模块
path	请求的路径path
traceId	请求的链路追踪ID	需要接入链路追踪插件，如skywalking,zipkin