在nginx中使用lua直接访问mysql和memcaced达到数据接口的统一

偏执的太偏执、 2022-07-14 13:18 151阅读 0赞

让nginx 中的nginx\_lua\_module支持[MySQL][] 和memcache  
下载  
[https://github.com/agentzh/lua-resty-memcached][https_github.com_agentzh_lua-resty-memcached]  
[https://github.com/agentzh/lua-resty-mysql][https_github.com_agentzh_lua-resty-mysql]

对于访问接口的统一有很多的处理方式，这里介绍使用nginx lua 访问mysql并用memcache缓存起来。

配置如下：

**\[plain\]**  [view plain][]   [copy][view plain]

[print][view plain] [?][view plain] [![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  ...  
2.  location /getinfo \{  
3.      default\_type 'text/plain';  
4.      content\_by\_lua '  
5.    
6.          local args = ngx.req.get\_uri\_args()  
7.    
8.          if args\["appleid"\] == nil then  
9.              ngx.say("param appleid is nil")  
10.             return  
11.         end  
12.   
13.         local memcached = require "memcached"  
14.         local memc, err = memcached:new()  
15.         if not memc then  
16.             ngx.say("failed to instantiate memc: ", err)  
17.             return  
18.         end  
19.   
20.   
21.         memc:set\_timeout(1000) -- 1 sec  
22.   
23.         local ok, err = memc:connect("172.16.18.114", 11211)  
24.         if not ok then  
25.             ngx.say("failed to connect: ", err)  
26.             return  
27.         end  
28.   
29.         local res, flags, err = memc:get(args\["appleid"\])  
30.         if err then  
31.             ngx.say("failed to get memc: ", err)  
32.             return  
33.         end  
34.   
35.         if not res then  
36.   
37.             local mysql = require "mysql"  
38.             local db, err = mysql:new()  
39.             if not db then  
40.                 ngx.say("failed to instantiate mysql: ", err)  
41.                 return  
42.             end  
43.   
44.             db:set\_timeout(1000) -- 1 sec  
45.   
46.             local ok, err, errno, sqlstate = db:connect\{  
47.                 host = "172.16.18.162",  
48.                 port = 3306,  
49.                 database = "test",  
50.                 user = "root",  
51.                 password = "cpyf",  
52.                 max\_packet\_size = 1024 \* 1024  
53.             \}  
54.   
55.             if not ok then  
56.                 ngx.say("failed to connect: ", err, ": ", errno, " ", sqlstate)  
57.                 return  
58.             end  
59.   
60.             -- ngx.say("connected to mysql.")  
61.   
62.             sql = "select \* from tagval where tag = \\'" .. args\["appleid"\] .. "\\'"  
63.   
64.             res, err, errno, sqlstate = db:query(sql)  
65.             if not res then  
66.                 ngx.say("bad result: ", err, ": ", errno, ": ", sqlstate, ".")  
67.                 return  
68.             end  
69.   
70.             local json = require "json"  
71.             ngx.say("mysql found")  
72.             ngx.say(json.encode(res))  
73.   
74.             local ok, err = memc:set(args\["appleid"\], json.encode(res))  
75.             if not ok then  
76.                 ngx.say("failed to set memc: ", err)  
77.                 return  
78.             end  
79.   
80.             local ok, err = db:set\_keepalive(0, 100)  
81.             if not ok then  
82.                 ngx.say("failed to set keepalive: ", err)  
83.                 return  
84.             end  
85.   
86.             return  
87.   
88.         end  
89.   
90.         ngx.say("memc found")  
91.         ngx.say(res)  
92.   
93.         memc:set\_keepalive(0, 100)  
94.   
95.     ';  
96. \}  
97. ...

第二次运行：

curl --get [http://app.ca-sim.com/getinfo?appleid=jfy][http_app.ca-sim.com_getinfo_appleid_jfy]

mysql found
    [{"val":"123","tag":"jfy"}]

第二次后运行：

curl --get [http://app.ca-sim.com/getinfo?appleid=jfy][http_app.ca-sim.com_getinfo_appleid_jfy]

memc found
    [{"val":"123","tag":"jfy"}]

结果已被缓存

[MySQL]: http://lib.csdn.net/base/mysql
[https_github.com_agentzh_lua-resty-memcached]: https://github.com/agentzh/lua-resty-memcached
[https_github.com_agentzh_lua-resty-mysql]: https://github.com/agentzh/lua-resty-mysql
[view plain]: http://blog.csdn.net/jiao_fuyou/article/details/36645033#
[CODE]: https://code.csdn.net/assets/CODE_ico.png
[CODE_CODE]: https://code.csdn.net/snippets/415197
[ico_fork.svg]: https://code.csdn.net/assets/ico_fork.svg
[ico_fork.svg 1]: https://code.csdn.net/snippets/415197/fork
[http_app.ca-sim.com_getinfo_appleid_jfy]: http://app.ca-sim.com/getinfo?appleid=jfy