【nginx+lua高性能web应用开发（二）：开发评论模块（ssi+mysql）】

墨蓝 2023-10-17 14:13 8阅读 0赞

开发这个模块，是为了解决项目中的实际问题，思考设计的 。

本文原文连接: http://blog.csdn[.NET][]/freewebsys/article/details/16944917 转载请注明出处！

### 前言： ###

参考了下ngx\_lua，Node.js，PHP三个进行的压测对比。  
[http://bluehua.org/demo/php.node.lua.html][http_bluehua.org_demo_php.node.lua.html]  
  
ngx\_lua Time per request: 3.065 \[ms\]  
Node.js Time per request: 3.205 \[ms\]  
PHP   Time per request: 5.747 \[ms\]  
  
  
  
从各种性能测试来说ngx\_lua似乎在CPU和内存上更胜一筹，同时  
ngx\_lua出奇的资源消耗比较稳定，不像php那样波动比较大。  
ngx\_lua和Node.js几乎比php快接近1倍。  
同时ngx\_lua模型也是单线程的异步的事件驱动的，工作原理和nodejs相同，  
代码甚至比nodejs的异步回调更好写一些。  
对于ngx的运维和配置相对比nodejs来说更加熟悉和有经验。

### 1，总体设计思路 ###

完全基于nginx层实现，nginx要开启ssi。  
（Server Side Includes： [http://wiki.nginx.org/HttpSsiModule][http_wiki.nginx.org_HttpSsiModule] ）  
以最快的速度展示页面，使用ssi直接读取数据，不是ajax返回。  
服务端使用lua读取数据库内容并显示。  
  
  
  
  
对应用的评论，使用mysql分区，按照itme\_id进行hash。  
设置成1024个分区，以后方便进行拆库。保证每一个表的数据都不是很大。  
（1024）是mysql能设置的最大分区数量。  
  
  
流程：  
  
ningx 请求 /blog/201311/127.html（博客内容已经静态化了。）  
  
 ↓  
  
使用ssi将url里面的参数获得调用lua评论模块

↓  
  
**lua评论模块，读取[数据库][Link 1]。（如果压力大，可以进行拆库，做cache）**

### 2，主要代码 ###

1.  local mysql= require("resty.mysql") 
2.  \--评论查询. 
3.  local **function** query\_mysql(sql) 
4.   local db = mysql:**new**() 
5.   db:connect\{ 
6.   host = "127.0.0.1", 
7.   port = 3306, 
8.   database = "test", 
9.   user = "root", 
10.  password = "root"
11.  \} 
12.  local res, err, errno, sqlstate = db:query(sql) 
13.  \--使用数据库连接池。保持连接. 
14.  db:set\_keepalive(0, 100) 
15. **return** res 
16. end 
17. 
18. local comment\_li = \[\[ 
19. 
20. <li id="cmt\_"**class**="row\_1"> 
21.  <table width=""><tr> 
22.  <td **class**="portrait"> 
23.  <a href="" name="rpl\_277051035"**class**="ShowUserOutline"><img src="http://www.oschina.net/img/portrait.gif"></a> 
24.  </td> 
25.  <td **class**="body"> 
26.  <div **class**="r\_title"> 
27.  %s楼：<b>%s</b> 发表于%s 
28.  </div> 
29.  <div **class**="r\_content TextContent">%s</div> 
30.  </td></tr> 
31.  </table> 
32. </li> 
33. 
34. \]\] 
35. 
36. \--设置顶部内容. 
37. local comment\_html = \[\[ 
38. 
39. <div **class**="Comments" id="userComments"> 
40. <h2> 
41.  <a name="comments" href="\#"**class**="more">回到顶部</a> 
42.  <a href="\#CommentForm"**class**="more" style="margin-right:10px;color:\#ff3;">发表评论</a> 
43.  网友评论，共 %s条 
44. </h2> 
45. <ul> 
46. %s 
47. </ul> 
48.  <ul **class**="pager"> 
49.  %s 
50.  </ul> 
51. </div> 
52. 
53. \]\] 
54. 
55. \--设置循环li 
56. local page\_li = \[\[ 
57. <li **class**="page %s"><a href="?start=%s\#comments">%s</a></li> 
58. \]\] 
59. \--输入参数 count start limit ，总数，开始，分页限制 
60. local **function** page(count,start,limit) 
61.  \--print(count,start,limit) 
62.  local page = math.ceil(count/limit) 
63.  local current\_page = math.floor(start/limit) + 1 
64.  \--判断当前页面不超出分页范围. 
65.  current\_page = math.min(current\_page,page) 
66.  current\_page = math.max(current\_page,1) 
67.  local is\_first = ( current\_page == 1 ) 
68.  local is\_last = ( current\_page == page ) 
69.  \--打印页数，开始，结束. 
70.  local page\_offset = 3 
71.  local start\_page = math.max(current\_page - page\_offset ,1) 
72.  local end\_page = math.min(current\_page + page\_offset ,page) 
73.  local page\_html = ""
74. **if** not is\_first then 
75.  page\_html = page\_html..\[\[<li **class**="page prev"><a href="?start=\]\] 
76.  page\_html = page\_html..(current\_page-2)\*limit 
77.  page\_html = page\_html..\[\[\#comments"><</a></li> 
78.  \]\] 
79.  end 
80. **for** i = start\_page , end\_page **do**
81.  local tmp\_current = ""
82. **if** current\_page == i then 
83.  tmp\_current = "current"
84.  end 
85.  local tmp\_div = string.format(page\_li,tmp\_current,(i-1)\*limit,i) 
86.  page\_html = page\_html..tmp\_div 
87.  end 
88. **if** not is\_last then 
89.  page\_html = page\_html..\[\[<li **class**="page next"><a href="?start=\]\] 
90.  page\_html = page\_html..current\_page\*limit 
91.  page\_html = page\_html..\[\[\#comments">></a></li> 
92.  \]\] 
93.  end 
94. **return** page\_html 
95. end 
96. 
97. \--接收参数。 
98. local uri = ngx.**var**.arg\_uri 
99. \--使用正则过滤url中的参数。 
100. local year,item\_id = string.match(uri,"/blog/(%d+)/(%d+).html") 
101. local start = string.match(uri,"start=(%d+)") or "0"
102. 
103. start = tonumber(start)--将字符串转换成数字。 
104. local limit = 10 
105. \--拼接sql。 
106. 
107. local count\_sql = " select count(\*) as count from comment where item\_id = "..item\_id 
108. local count = query\_mysql(count\_sql) 
109. 
110. **if** count and \#count > 0 then 
111.  \--对数据进行赋值. 
112.  count = count\[1\].count 
113. **else**
114.  count = "0"
115. end 
116. count = tonumber(count)--将字符串转换成数字。 
117. 
118. local sql = " select id,uid,content,create\_time from comment where item\_id = "..item\_id.." limit "..start..","..limit 
119. local res = query\_mysql(sql) 
120. 
121. local comment\_lis = ""
122. **for** key,val **in** pairs(res) **do**
123.  local id = val\["id"\] 
124.  local uid = val\["uid"\] 
125.  local content = val\["content"\] 
126.  local create\_time = val\["create\_time"\] 
127.  \--拼接字符串. 
128.  comment\_lis = comment\_lis..string.format(comment\_li,key,uid,create\_time,content) 
129. end 
130. 
131. local page\_lis = page(count,start,limit) 
132. local html = string.format(comment\_html,count,comment\_lis,page\_lis) 
133. ngx.say(html)

代码将功能实现了。后续可以拆分成多个模块。其中生成分页部分比较复杂。

运行效果：使用了oschina的页面样式。

**其中/blog/201311/127.html是静态html页面。**

**速度超级快。**

![SouthEast][]

### 3，nginx配置 ###

参考：  
[http://wiki.nginx.org/HttpSsiModule][http_wiki.nginx.org_HttpSsiModule]  
[http://wiki.nginx.org/HttpCoreModule][http_wiki.nginx.org_HttpCoreModule]

1.   gzip on; 
2.   ssi on; 
3.   root /data/comment; 
4.  location /blog/list\_comment \{ 
5.  default\_type 'text/html'; 
6.  content\_by\_lua\_file '/data/comment/list\_comment.lua'; 
7.   \} 
8.  location /blog/save\_comment \{ 
9.  default\_type 'text/html'; 
10. content\_by\_lua\_file '/data/comment/save\_comment.lua'; 
11.  \}

在静态页面中增加ssi代码，这样就可以把uri当做参数传递了。

### 4，mysql修改打开文件数 ###

因为开启了分区，所以读取文件数量肯定会多。  
用ulimit -n查看打开文件数量。如果是1024，修改配置：

**/etc/security/limits.conf 然后重启系统**  
\*soft noproc 65536  
\*hard noproc 65536  
\*soft nofile 65536  
\*hard nofile 65536

**然后修改my.conf配置文件：**  
vi /etc/my.cnf  
  
\[mysqld\]  
datadir=/var/lib/[MySQL][Link 1]  
socket=/var/lib/[mysql][Link 1]/mysql.sock  
user=mysql  
symbolic-links=0  
**open\_files\_limit=65536**  
  
  
重启mysql生效，查看参数：  
mysql> show variables like 'open%';  
\+------------------+-------+  
| Variable\_name | Value |  
\+------------------+-------+  
| open\_files\_limit | 65536 |  
\+------------------+-------+  
1 row in set (0.00 sec)  
  
**数据库表，按照设计成分区表。将数据分散。**

1.  **CREATE****TABLE** \`comment\` ( 
2.   \`id\` **int**(11) NOTNULL auto\_increment COMMENT '主键', 
3.   \`item\_id\` **int**(11) NOTNULL COMMENT '评论项id', 
4.   \`uid\` **int**(11) NOTNULL**default**'0' COMMENT '评论用户', 
5.   \`content\` text NOTNULL COMMENT '内容', 
6.   \`create\_time\` datetime NOTNULL COMMENT '创建时间', 
7.  **PRIMARY****KEY** (\`item\_id\`,\`id\`) 
8.  ) ENGINE=MyISAM **DEFAULT** CHARSET=utf8 
9.  PARTITION **BY** HASH (\`item\_id\`) 
10. PARTITIONS 1024;

插入测试数据：  
insert into comment(\`item\_id\`,content,create\_time) values(127,CONCAT("conent test ",RAND()\*1000),now());  
  
源代码放到github上了。

[https://github.com/luapkg/comment/][https_github.com_luapkg_comment]

继续完善评论模块。

本文原文连接: http://blog.csdn[.net][.NET]/freewebsys/article/details/16944917 转载请注明出处！

来源:http://blog.csdn.net/freewebsys/article/details/16944917

[.NET]: http://lib.csdn.net/base/dotnet
[http_bluehua.org_demo_php.node.lua.html]: http://bluehua.org/demo/php.node.lua.html
[http_wiki.nginx.org_HttpSsiModule]: http://wiki.nginx.org/HttpSsiModule
[Link 1]: http://lib.csdn.net/base/mysql
[SouthEast]: https://img-blog.csdn.net/20131125165756390?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvZnJlZXdlYnN5cw==/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/SouthEast
[http_wiki.nginx.org_HttpCoreModule]: http://wiki.nginx.org/HttpCoreModule
[https_github.com_luapkg_comment]: https://github.com/luapkg/comment/