本文已收录 https://github.com/lkxiaolou/lkxiaolou 欢迎star。

OpenResty介绍

OpenResty通过汇聚各种设计精良的 Nginx模块（主要由 OpenResty 团队自主开发），从而将 Nginx 有效地变成一个强大的通用 Web 应用平台。这样，Web 开发人员和系统工程师可以使用 Lua 脚本语言调动 Nginx 支持的各种 C 以及 Lua 模块，快速构造出足以胜任 10K 乃至 1000K 以上单机并发连接的高性能 Web 应用系统。OpenResty的目标是让你的Web服务直接跑在 Nginx 服务内部，充分利用 Nginx 的非阻塞 I/O 模型，不仅仅对 HTTP 客户端请求,甚至于对远程后端诸如 MySQL、PostgreSQL、Memcached 以及 Redis 等都进行一致的高性能响应。

OpenResty安装

可参考 http://openresty.org/en/linux-packages.html

以centos为例：

• wget https://openresty.org/package/centos/openresty.repo
• mv openresty.repo /etc/yum.repos.d/
• yum check-update
• yum install openresty

hello world程序

• mkdir -p /home/roshi/opensty/conf /home/roshi/opensty/logs
• 写个输出”hello world“的配置

1worker_processes  1;
2error_log logs/error.log;
3events {
4    worker_connections 1024;
5}
6
7http {
8    server {
9        listen 6699;
10        location / {
11            default_type text/html;
12
13
14            content_by_lua_block {
15                ngx.say("HelloWorld")
16            }
17        }
18    }
19}

• 运行 用上述的安装方式，nginx会安装在/usr/local/openresty目录，执行

/usr/local/openresty/nginx/sbin/nginx -p /home/roshi/openresty -c /home/roshi/openresty/conf/nginx.conf

• 测试

curl http://127.0.0.1:6699

处理流程

OpenResty处理一个请求，它的处理流程参考如下图

实战

nginx最常用的是反向代理功能，例如通过URL上的特征将同一个域名下的请求按照规则分发给不同的后端集群，举个例子：

http://example.com/user/1和http://example.com/product/1

是同个域名下的两个请求，他们分别对应用户与商品，后端提供服务的集群很可能是拆分的，这种情况使用nginx就可以很容易地分流；

但如果这个分流的特征不在header或者URL上，比如在post请求的body体中，nginx原生就没法支持，此时可以借助OpenResty的lua脚本来实现。

我就遇到过这样一个需求，同样的请求需要路由到不同的集群处理，但特征无法通过header或者URL来区分，因为在前期的设计中，不需要区分；这个请求可以处理单个的请求，也可以处理批量的情况，现在批量的请求性能不如人意，需要一个新集群来处理，抽象为以下请求

curl -X "POST" -d '{"uids":[1,2]}' -H "Content-Type:application/json" 'http://127.0.0.1:6699/post'

期望分离当body体中uids是多个和单个的请求，当uids只有1个uid时请求路由到后端A，uids中uid数量大于1时路由到后端B

在之前的nginx.conf基础上修改

1worker_processes  1;
2error_log logs/error.log info;
3events {
4    worker_connections 1024;
5}
6
7http {
8   upstream single.uid {
9       server host.docker.internal:8888;
10   }
11   upstream multiple.uids {
12       server host.docker.internal:9999;
13   }
14
15    server {
16        listen 6699;
17        location / {
18            default_type application/json;
19            # default upstream
20            set $upstream_name 'multiple.uids';
21
22            rewrite_by_lua_block {
23
24                cjson = require 'cjson.safe'
25                ngx.req.read_body()
26                local body = ngx.req.get_body_data()
27                if body then
28                    ngx.log(ngx.INFO, "body=" .. body)
29                    local data = cjson.decode(body)
30
31                    if data and type(data) == "table" then
32                        local count = 0
33                        for k,v in pairs(data["uids"]) do
34                            count = count + 1
35                        end
36
37                        ngx.log(ngx.INFO, "count = " .. count)
38
39                        if count == 1 then
40                            ngx.var.upstream_name = "single.uid"
41                        end
42                    end
43                end
44            }
45            proxy_pass http://$upstream_name;
46        }
47    }
48}

• 第二行将日志级别调整为info，方便调试观察
• 定义两个upstream，对应不同的后端，由于我的openresty在docker容器中，后端服务在物理机中，所有这里使用了host.docker.internal代替后端ip
• 使用rewrite_by_lua_block（可以对照上文中的处理流程图）
• 使用cjson来解析body，判断uids中的数量，这段都是lua代码，注意lua代码和nginx配置的语法是不一样的，lua中获取nginx的变量使用ngx.var.upstream_name

后端代码这里也贴一下，使用golang编写，用到了echo框架

1package main
2
3import (
4   "github.com/labstack/echo/v4"
5   "github.com/labstack/echo/v4/middleware"
6   "os"
7   "strconv"
8)
9
10type Response struct {
11   Success bool `json:"success"`
12   Message string `json:"message"`
13   Port int `json:"port"`
14   Uids []int `json:"uids"`
15}
16
17type Request struct {
18   Uids []int `json:"uids"`
19}
20
21var port = 8888
22
23func main() {
24
25   e := echo.New()
26   e.Use(middleware.Logger())
27   e.Use(middleware.Recover())
28
29   e.POST("/post", post)
30
31   if len(os.Args) >= 2 {
32      p, err := strconv.Atoi(os.Args[1])
33      if err == nil {
34         port = p
35      }
36   }
37   e.Logger.Fatal(e.Start(":"+strconv.Itoa(port)))
38}
39
40func post(c echo.Context) error {
41   req := Request{}
42   err := c.Bind(&req)
43   if err != nil {
44      c.JSON(500, Response{
45         Success: false,
46         Port: port,
47         Message: "bind body error",
48      })
49      return err
50   }
51   response := Response{
52      Success: true,
53      Port: port,
54   }
55   for _, uid := range req.Uids {
56      response.Uids = append(response.Uids, uid + 100)
57   }
58   c.JSON(200, response)
59   return nil
60}

分别监听在8888和9999端口，运行后，请求6699端口（nginx监听）观察

同时，在日志/home/roshi/openresty/logs/error.log中也能看到

最后

本文从安装，基本原理上简单介绍了OpenResty，并从一个实际的例子展示了OpenResty的能力，希望看完的你也能入门OpenResty。

搜索关注微信公众号"捉虫大师"，后端技术分享，架构设计、性能优化、源码阅读、问题排查、踩坑实践。