ngx_lua操作Redis和Mysql
生活随笔
收集整理的這篇文章主要介紹了
ngx_lua操作Redis和Mysql
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
功能簡介
- 通過ngx_lua對redis進行數據的插入和取出
- ngx_lua對mysql的增刪改查
- 瀏覽器以json格式返回數據
- 將頻繁調用的cjson設置全局，一開始就加載
結果顯示
redis數據插入和取出的顯示：
mysql增刪改查的顯示：
nginx.conf的配置
#設置全部變量，一開始加載init_by_lua_block{cjson = require "cjson";}server {listen 80;server_name localhost;charset UTF-8;#access_log logs/host.access.log main;location / {root html;index index.html index.htm;}location /lua{default_type 'text/html';content_by_lua 'ngx.say("<h1>HELLO,OpenRestry</h1>")';}#lua連接redislocation /luaRedis {charset gbk;default_type "text/html";content_by_lua_block{--01 引入redislocal redis=require "resty.redis"--02 創建redis對象local redisObj=redis:new()--03 設置超時redisObj:set_timeout(1000)--04 連接local ok,errr=redisObj:connect("redis所在的IP",6379)if not ok thenngx.say("連接失敗",err)returnend--05 redis存入數據local ok,errr=redisObj:set("name","xiaoTang")if not ok thenngx.say("數據導入失敗",err)returnend--06 redis取出數據local ans,errr=redisObj:get("name")ngx.say(ans)--07 連接關閉redisObj:close()}}#lua連接mysqllocation /luaMysql {charset gbk;default_type "text/html";content_by_lua_block{local mysql = require "resty.mysql"--local cjson = require "cjson"local db = mysql:new()local ok,err = db:connect{host="IP",port=3306,user="root",password="密碼",database="nginx_db"}db:set_timeout(1000)db:send_query("select * from users")local res,err,errcode,sqlstate = db:read_result()for i,v in ipairs(res) dongx.say(v.id..","..v.username..","..v.birthday..","..v.salary)end--換行和加粗local html = [[<html><head></head><body><p><b><br />mysql中以json返回數據<br /></b></p></body></html>]]ngx.say(html);local jsonDate=cjson.encode(res);ngx.say(jsonDate);--數據庫的增刪改查--換行和加粗local html = [[<html><head></head><body><p><b><br />數據庫的增刪改查<br /></b></p></body></html>]]ngx.say(html);--mysql的增加--local sql="insert into users(id,username,birthday,salary) values(null,'xiaoTang','1996-04-26',66666.6)";--mysql的刪除--local sql="delete from users where username='xiaoTang'";--mysql的修改--local sql="update users set username='xiaoTang02' where id=3";--mysql的查找local sql="select * from users where username='xiaoTang02'";--數據庫執行語句直接用querylocal res,err,errcode,sqlstate = db:query(sql);local jsonDate=cjson.encode(res);ngx.say(jsonDate);db:close()}}相關API介紹
redis的API
lua-resty-redis提供了訪問Redis的詳細API，包括創建對接、連接、操作、數據處理等。這些API基本上與Redis的操作一一對應。 （1）redis = require "resty.redis" （2）new語法: redis,err = redis:new(),創建一個Redis對象。 （3）connect語法:ok,err=redis:connect(host,port[,options_table]),設置連接Redis的連接信息。ok:連接成功返回 1，連接失敗返回nilerr:返回對應的錯誤信息 （4）set_timeout語法: redis:set_timeout(time) ，設置請求操作Redis的超時時間。 （5）close語法: ok,err = redis:close(),關閉當前連接，成功返回1，失敗返回nil和錯誤信息 （6）redis命令對應的方法在lua-resty-redis中，所有的Redis命令都有自己的方法，方法名字和命令名字相同，只是全部為小寫。mysql的API
（1）引入"resty.mysql"模塊local mysql = require "resty.mysql" （2）new創建一個MySQL連接對象，遇到錯誤時，db為nil，err為錯誤描述信息語法: db,err = mysql:new() （3）connect嘗試連接到一個MySQL服務器語法:ok,err=db:connect(options),options是一個參數的Lua表結構，里面包含數據庫連接的相關信息host:服務器主機名或IP地址port:服務器監聽端口，默認為3306user:登錄的用戶名password:登錄密碼database:使用的數據庫名 （4）set_timeout設置子請求的超時時間(ms)，包括connect方法語法:db:set_timeout(time) （5）close關閉當前MySQL連接并返回狀態。如果成功，則返回1；如果出現任何錯誤，則將返回nil和錯誤描述。語法:db:close() （6）send_query異步向遠程MySQL發送一個查詢。如果成功則返回成功發送的字節數；如果錯誤，則返回nil和錯誤描述語法:bytes,err=db:send_query(sql) （7）read_result從MySQL服務器返回結果中讀取一行數據。res返回一個描述OK包或結果集包的Lua表,語法:res, err, errcode, sqlstate = db:read_result() res, err, errcode, sqlstate = db:read_result(rows) :rows指定返回結果集的最大值，默認為4如果是查詢，則返回一個容納多行的數組。每行是一個數據列的key-value對，如總結
以上是生活随笔為你收集整理的ngx_lua操作Redis和Mysql的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： 在PyPI上发布自己的python包
- 下一篇： 新手小白零基础搭建个人博客（一）服务器篇