配置

上一篇我们先学习了极限网关的安装和启动，今天学习配置。

读写分离

现在我们遇到读写分离的需求，用网关该怎么做呢？ 假设服务端现在从 http://127.0.0.1:8000 写入数据，从 http://127.0.0.1:9000 读取数据，怎么设计呢？

首先查看文档配置文档

我们在 gateway.yml 中定义两个 entry，分别绑定不同的端口，配置不同的 router

entry:
  - name: write_es
    enabled: true
    router: write_router
    network:
      binding: 0.0.0.0:8000
  - name: read_es
    enabled: true
    router: read_router
    network:
      binding: 0.0.0.0:9000

router:
  - name: write_router
    default_flow: default_flow
    tracing_flow: logging
  - name: read_router
    default_flow: default_flow
    tracing_flow: logging

为了演示效果，只配置一个 Elasticsearch

elasticsearch:
- name: dev
  enabled: true
  schema: http
  hosts:
    - 192.168.3.188:9206

启动项目

我们从 http://127.0.0.1:8000 写入一条数据，再从 http://127.0.0.1:9000 读取该条数据

添加接口

返回字符串

我们想自定义添加一个接口，怎么在不写代码的情况下通过配置实现返回字符串

flow:
  - name: hello_flow
    filter:
      - echo:
          message: "hello flow"

router:
  - name: read_router
    default_flow: hello_flow

修改配置后启动

返回 json 数据

返回字符串不符合标准的 restful 接口规范，怎么返回给调用方标准 json 数据？

filter:
  - set_response:
      content_type: application/json
      body: '{"message":"hello world"}'

修改配置后启动

修改路由

我们已经新加了接口，返回 json 数据，但是接口是直接定义在 http://127.0.0.1:9000 中，之前网关的接口就无法使用，所以我们需要单独为自定义的接口指定单独的路由

router:
  - name: read_router
    default_flow: default_flow
    tracing_flow: logging
    rules:
      - method:
          - GET
        pattern:
          - "/hello"
        flow:
          - hello_flow

default_flow: 默认的处理流，也就是业务处理的主流程，请求转发、过滤、缓存等操作都在这里面进行

tracing_flow：用于追踪请求状态的流，用于记录请求日志、统计等

如果我们有过开发经验，了解 MVC 模式，flow 就类似 MVC 中的 Controller，rules 中类似路由规则，当请求匹配到配置中的路由规则时，由配置的 flow 处理业务逻辑。

数据整体流向，从服务端发到网关，网关为每个 Elasticsearch 绑定不同的 IP 地址，每个 Elasticsearch 都有唯一一个 router 和它对应，根据请求的 method 和 path 匹配到 router 中的一个 flow，flow 中包含多个 filter 处理对数据进行流式处理。

如下图所示

流式处理是什么，假设水从一个管子里面流出来，管子旁边每一段依次站了几个人，第一个人往水里放点鱼，鱼和水到了第二个人，第二个人往水里放点草，鱼、水和草到了第三人等等，每个人对水做一定的操作，水经过这些操作后最后到达水池里。

我们可以把数据当成水，filter 是管子旁边的人，水池就是 Elasticsearch

总结

在学习了router/flow/filter后，我们已经对极限网关的配置有了初步的了解，后续开发的时候直接查阅文档。

产品介绍

极限网关（INFINI Gateway）是一个面向 Elasticsearch 的高性能应用网关。特性丰富，使用简单。

它和其他业务型网关最大的区别是业务网关把请求转发给各个底层微服务，而它把请求转发给 Elasticsearch，更多是类似 Mycat 的中间件的作用。

没有使用网关之前，服务端请求多个节点

使用网关后

下载地址

打开 下载地址，根据操作系统版本选择。

Windows 安装和启动

安装

下载 gateway-1.6.0_SNAPSHOT-597-windows-amd64.zip，解压如下。 gateway-windows-amd64.exe 是启动文件，gateway.yml 是默认配置文件。

启动失败

当 gateway.yml 的 elasticsearch 选项中的 hosts 不能正常响应请求的时候，启动界面如下。

为什么 elasticsearch 不能访问的时候，网关还要继续提供服务呢，为什么不像业务接口启动时在基础业务组件如 MySQL/Redis 不能正常响应就直接 panic？

一方面网关作为 elasticsearch 抵挡流量冲击的城墙，在 elasticsearch 不能提供服务的时候，对之前成功的请求缓存结果，继续提供有限度的服务，为 elasticsearch 修复后上线争取时间。

另一方面业务接口和基础组件是强耦合关系，没有基础组件就完全无法对外提供数据读写服务，而网关与 elasticsearch 是松耦合关系，网关在没有 elasticsearch 的情况下也能对外提供有限度的服务。

在 gateway.yml 的 elasticsearch 选项中的 hosts 改成能够正常响应的 elasticsearch 请求地址。

启动成功

双击 gateway-windows-amd64.exe 文件，启动成功界面如下

访问

API 访问

由启动后终端显示可知，网关的 API 接口地址是 http://localhost:2900

[api.go:262] api listen at: http://0.0.0.0:2900

打开浏览器输入 http://localhost:2900，显示所有可以对外提供的 API 接口

我们选择其中一个，在浏览器中输入 http://localhost:2900/_framework/api/_version 从路由上看该接口是查询产品的版本信息，显示如下

gateway.yml 中可以看到有被注释掉的一段配置，看起来应该是配置 api 地址的地方。

#api:
#  enabled: true
#  network:
#    binding: 127.0.0.1:2900

把注释去掉后尝试把端口改成 2901。

api:
  enabled: true
  network:
    binding: 127.0.0.1:2901

改完后启动 打开浏览器先输入 http://localhost:2900，无法正常响应请求，再输入 http://localhost:2901，可以正常响应，界面和修改配置前访问 http://localhost:2900 的界面一样，说明 API 请求地址成功修改

Elasticsearch 访问

启动日志中显示监听 8000 端口，猜测应该是 elasticsearch 请求地址，打开浏览器输入 http://127.0.0.1:8000/

 entry [my_es_entry] listen at: http://0.0.0.0:8000

gateway.yml 中可以看到 my_es_entry 的 network 绑定 8000 端口，显而易见的这部分就是配置代理转发给 elasticsearch 的地址，所以安装后只需要把以前请求 elasticsearch 的地址修改为该地址。

entry:
  - name: my_es_entry
    enabled: true
    router: my_router
    max_concurrency: 10000
    network:
      binding: 0.0.0.0:8000

总结

我们成功安装和启动极限网关，接下来我们学习怎么根据需求修改配置。

课程定价：5500元（不含考试费） 上课方式：全程直播 开课时间：2022年6月11日、12日、18日、19日、25日，周六日直播上课，每天9:00~12:00，14:00~18:00

咨询方式：

孟老师 电话：18811088238 微信二维码：

课程简介

首先，分别介绍：Elasticsearch、ECE认证：

• Elasticsearch 是一个分布式的免费开源搜索和分析引擎，适用于包括文本、数字、地理空间、结构化和非结构化数据等在内的所有类型的数据。Elasticsearch 在 Apache Lucene 的基础上开发而成，由 Elasticsearch N.V.（即现在的 Elastic）于 2010 年首次发布。Elasticsearch 以其简单的 REST 风格 API、分布式特性、速度和可扩展性而闻名，是 Elastic Stack 的核心组件；Elastic Stack 是一套适用于数据采集、扩充、存储、分析和可视化的免费开源工具。人们通常将 Elastic Stack 称为 ELK Stack（代指 Elasticsearch、Logstash 和 Kibana），目前 Elastic Stack 包括一系列丰富的轻量型数据采集代理，这些代理统称为 Beats，可用来向 Elasticsearch 发送数据。
• 管理员认证计划ECE（Elastic Certifled Engineer），通过 ECE认证的工程师说明已经满足对Elasticsearch进行管理的能力，可胜任Elasticsearch相关工作，同时也是Elasticsearch工作道路上的敲门砖。

  课程特色：少有的生产落地实践

• 讲师更加权威：具有多年的云原生与Elastic的售前架构设计与项目落地经验，并具备云原生与Elastic相关认证。
• 实践落地为先：课程包含了ECE（Elastic Certifled Engineer）认证与Elastic多种应用场景在项目中的架构设计与落地。 适配岗位

适合人群

本次课程适用从事技术实施工程师、开发人员、运维工程师，课程学完后可以掌握Elastic在企业中的项目落地与最佳实践，如：日志搜集与全观测、全文搜索、数据库加速技术场景的掌握。帮助学员快速掌握Elastic的理论知识和专业技能，从容面对Elastic认证考试以及在Elastic领域的职业挑战。

课程大纲

第一阶段 Elasticsearch环境搭建

第一课 初识Elasticsearch

• Elasticsearch发展史
• Elasticsearch应用场景
• Elasticsearch核心概念讲解  

  第二课 节点类型

• 节点类型介绍
• 节点类型配置   

  第三课 ElasticSearch集群搭建和kibana可视化界面部署

• 基础环境配置
• 配置文件讲解   

  第二阶段 ElasticSearch数据建模

  第四课 index & document

• 倒排索引介绍
• index创建与删除
• index关闭与开启
• 数据更新  

  第五课 Reindex

• Reindex概述
• Reindex实践   

  第六课 Mapping

• 动态映射（dynamic mapping）
• 显示映射（Explicit mapping）
• Runtime fields
• 常用字段数据类型
• 元数据字段讲解
• 常用映射参数讲解

第七课 Analysis

• Character filter
• Tokenizer
• TokenFilter
• 自定义文本分词器

第八课 索引模板（index template）与索引别名（Alias）

• 索引模板的创建与使用
• 索引别名的创建与使用

第九课 索引声明周期管理（ILM）

• ILM概述
• ILM创建及使用
• ILM常用管理操作

第十课 Data stream（数据流）

• 设置数据流
• 使用数据流
• 更改数据流的映射和设置

第十一课 Ingest pipline

• Ingest pipline 概述
• Ingest pipline 使用案例
• 常见processors

第三阶段 ElasticSearch数据查询

第十二课 Full text query（全文查询）

• Match查询
• Match phrase查询
• Multi match多字段查询
• Query string 字符串查询
• Simple querystring 简单字符串查询

第十三课 Compound query（复合查询）

• Boolean 布尔查询
• Boosting 加权查询
• Constant score 固定分值查询
• Disjunction max 单字符串多字段查询
• Function score 优化算分查询

第十四课 joining query

• Nested 嵌套
• 文档父子关联关系

第十五课 Aggregation（聚和分析）

• Bucket聚和查询
• Metrics 聚和查询
• Pipline 聚和分析

第十六课 Search your data

• 高量显示
• 分页查询
• 对查询结果进行排序
• 跨集群搜索与复制
• 搜索模板

第四阶段 集群管理

第十七课 User & Role

• Security 安全认证配置
• 创建用户角色
• 创建用户

第十八课 快照与恢复

• 创建快照
• 恢复快照
• 删除快照

第十九课 生产集群落地

• 节点角色规划
• 节点资源规划
• 集群升级
• 集群扩容
• 集群性能调优

第二十课 常见运维操作

• 常见问题及解决方案

第二十一课 多集群监控管理实战

• 使用prometheus实现ElasticSearch多集群监控
• 使用极限平台实现ElasticSearch多集群监控

第二十二课：kibana

• kibana概述
• Kibana高可用部署架构与dashboard管理

第四阶段 项目实战

日志搜集项目实战

数据库加速项目实战

第五阶段 ECE认证

• 如何报名考试
• 参加考试注意事项
• 考前模拟练习