用openresty与nodemcu通过lua一站式开发搭建的一个一体的物联网框架(逐步更新）
结构供包含config、controller、libs、model四个目录
-
config
配置文件目录，用于app、redis、database相关的配置
- app应用相关
return { default_controller = 'home', -- 默认控制器 default_action = 'index', -- 默认方法 }
- 数据库相关
local mysql_config = { timeout = 5000, connect_config = { host = "127.0.0.1", port = 3306, database = "demo", user = "root", password = "a12345", max_packet_size = 1024 * 1024 }, pool_config = { max_idle_timeout = 20000, -- 20s pool_size = 50 -- connection pool size } }
- redis配置
return { host = "127.0.0.1", -- redis host port = 6379, -- the port max_idle_timeout = 60000, -- max idle time pool_size = 1000, -- pool size timeout = 1000, -- timeout time db_index= 2, -- database index }
-
libs目录
libs目录下面的公共的模块库，包括redis、db、request、response等
-
controller目录
这是控制器目录，里面有一个封装了一个基类Base.lua,业务控制器继承这个即可，基本的业务控制器代码如下
-- home.lua local Base = require("controller.base") local Home = Base:extend() function Home:index() self:json({data={}}) end
上面的代码就实现了一个控制器，访问路径hostname://home/index即可请求index方法,请求的url规则是hostname+controller文件夹下的文件名+/+文件中的方法名**(注意一定要继承Base模块)**
controller里面提供了几个基本属性
-
self.request获取请求相关参数，如self.request.query.xx获取get参数，self.request.body.xx获取post参数，self.request.headers.xx获取header参数等
-
self.response输出响应结果，主要有self.response:json()返回data结果，以及self.response:redirect()跳转,self.response.get_body()获取响应结果等
为了方便开发，在Base里面封装了response，提供了self:json(),self:error(code,message)两个快捷方法
self:json({data=self.redis:get("test")}) --返回结果设置data self:error(2,"获取数据失败") --返回结果设置错误码，错误消息
返回的结构包含data,code,message字段
{"data":{"data":["BBBBB","B","AAAAA","A","BBBBB","B","AAAAA","A"]},"message":"","code":"获取成功"} -
self.redis可以使用redis，包含self.redis:set,self.redis:get,self.redis:hset,self.redis:hget等等，具体可以使用的函数可以参考libs/redis.lua文件的15到72行
-
self.controller获取当前控制器名称
-
self.action获取当前action操作名称
-
-
model目录
模型相关，为了便于操作，也封装了一个Base基类，业务model只需要继承即可
-- good.lua local Base = require "model.base" local Good = Base:extend() --继承Base return Good("test",'lgid') --第一个参数表名称,第二个参数是表对应的主键(默认为id)
修改model的继承方式为一个数据库一个文件，通过table封装成一个模块
local Base = (require "model.base"):extend()
local iotservice={}
--设置区域*****************************************
iotservice.admin_user = Base("admin_user")
iotservice.all_user = Base("all_user")
iotservice.device = Base("device")
iotservice.device_type = Base("device_type")
iotservice.device_val = Base("device_val")
iotservice.device_data = Base("device_data")
---------------------------------------------------
return iotservice
使用方法
--i_code 默认与model重名
local i_code="device_type"
local Base = require("controller.base")
local iotservice = require "model.iotservice"
local l_model=iotservice[i_code]
local Home = Base:extend() Base.lua封装的基类提供了单表增删改查的方法
- create(data)添加记录
- delete(id)删除记录
- update(data,id)修改记录
- get()、all()过滤记录
- where_and()与过滤条件方法
- where_or()或过滤条件方法
- columns()设置查找哪些列的方法
- orderby()设置排序的方法
- count()查找数据总条数的方法
同时Base.lua也提供了一个方法用于自定义执行sql的方法，方便复杂查询
- query()
### 快速开始
- nginx.conf添加类似如下代码
``` shell
worker_processes 1;
#error_log logs/error.log;
error_log logs/error.log info;
events {
worker_connections 1024;
}
http {
resolver 114.114.114.114;
lua_package_path 'd:/openresty/jframe/?.lua;;';
lua_shared_dict localStorage 100m;
#配置缓存服务
upstream memcached {
server 127.0.0.1:11211;
}
upstream redis_server{ server 127.0.0.1:6379 weight=1; }
server {
charset utf-8;
listen 80;
lua_code_cache on;
location = /favicon.ico {
log_not_found off;#关闭日志
access_log on;#不记录在access.log
}
location /outapi {
internal;
set_by_lua $target 'return ngx.ctx.target_uri';
proxy_pass_request_headers off;
proxy_pass $target;
proxy_set_header Content-Type 'application/json';
}
location / {
default_type text/html;
content_by_lua_file "d:/openresty/jframe/main.lua";
add_header Access-Control-Allow-Origin *;
add_header Access-Control-Allow-Methods 'GET, POST, OPTIONS,PUT';
add_header Access-Control-Allow-Headers 'DNT,X-Mx-ReqToken,Keep-Alive,User-Agent,X-Requested-With,If-Modified-Since,Cache-Control,Content-Type,Authorization';
if ($request_method = 'OPTIONS') {
return 204;
}
}
}
server {
charset utf-8;
listen 38083;
lua_code_cache on;
location = /favicon.ico {
log_not_found off;#关闭日志
access_log on;#不记录在access.log
}
location / {
default_type text/html;
content_by_lua_file "d:/openresty/jframe/main.lua";
}
}
}
-
添加控制器
在controller目录添加user.lua
local Base = require("controller.base") local User = Base:extend() function User:index() self:json({ data={ name = "hello world" } }) end return User
-
添加model
local Base = require "model.base" local User = Base:extend() return User("sls_p_user",'suid')
-
控制器使用model
local userModel = require('model.user') function User:index() self:json({ data={ name = userModel:columns('rname'):get(1) } }) end
model后面需要增加 :newsql() 防止开启缓存导致的错误
-
添加
local data = { name = "test", pwd = 123 } local insertId = userModel:newsql():create(data)
-
删除
-
根据主键删除
local affect_rows = userModel:newsql():delete(2)
-
-
修改
-
根据主键修改
local affect_rows = userModel:newsql():update(data,2) local data = { suid = "1", -- data里面存在主键，根据主键更新 name = "hello 我的测试", } local affect_rows = userModel:newsql():update(data)
-
根据where条件修改
local affect_rows = userModel:newsql():where("name","=",3):update(data)
-
-
查找
-
查找一条记录
local info = userModel:newsql():get(1) --根据主键查找 local info = userModel:newsql():columns('suid,name'):get(1) --查找指定字段,查找字段是字符串 local info = userModel:newsql():columns({'suid','name'}):get(1) --查找指定字段,查找字段是table
-
查找多条记录
local list = userModel:newsql():columns('suid,name'):all() --查找指定字段,查找字段是字符串 local list = userModel:newsql():columns({'suid','name'}):all() --查找指定字段,查找字段是table
-
-
其它方法说明
-
查找数据条数
local count = userModel:newsql():where_and({{"name","=","json"}}):count()
-
排序
local list = userModel:newsql():where_and({{"name","=",3}}):orderby("id"):all() local list = userModel:newsql():where_and({{"name","=",3}}):orderby("name","asc"):orderby("id","desc"):all() --多个排序
-
查找指定字段(不使用指定字段，则是查找所有字段)
local list = userModel:newsql():columns('suid,name'):all() --columns里面可以是字符串，也可以是table结构
-
根据where条件查找
local list = userModel:newsql():columns('suid,rname'):where({{"suid","<","30"}}):orderby("suid"):all() local list = userModel:newsql():columns('suid,rname'):where({{"suid","<","30"}}):where("rname","like","test%"):orderby("suid"):all() -- 可以多个where -多个where组合在一个table local t={{column="id",operator="=",value="1"},{column="id",operator="=",value="1"},{column="id",operator="=",value="1"}} if t.where then list = l_model:newsql():columns(t.columns or 'id'):where_and(t.where or {{column="id",operator="=",value=""}}):orderby((t.orderby or 'id'),(t.sort or "desc")):all(t.limit or 0) end -- 可以多个where
-
自定义执行的sql
-- 关联查询 local sql = "select su.*,c.logincount from sls_p_user su join c_user c on su.suid=c.suid where su.suid=2" local result = userModel:query(sql) -- 动态参数查询 local sql = "select * from sls_p_user where suid=? and username=?" local result = userModel:query(sql,{1,"json"})
-
为了方便快速生成控制器controller,以及模型model, 特开发了命令行,命令行使用luajit编写，需要将luajit放入环境变量
./jframe -h
jframe v0.1.1, a Lua web framework based on OpenResty.
Usage: jframe COMMAND [OPTIONS]
Commands:
controller [name] Create a new controller
model [name] [table] Create a new model
version Show version of the framework
help Show help tips注意windows下命令是
luajit ./jframe -h-
生成控制器，自动生成到controller目录下
jframe controller controllerName
-
生成model，自动生成到model目录下
jframe model modelName --不指定表名称，生成的model表名称默认是给定的modelname的小写格式 jframe model modelName table--指定model名称以及表名称