use lua_shared_dict for cache instead

nginx/conf/nginx.conf

@@ -31,14 +31,14 @@ http {
     #keepalive_timeout  0;
     keepalive_timeout  65;
 
-
-
     lua_code_cache on;
 
     lua_package_path "/Users/zhoush/openresty/nginx/lua/?.lua;;";
     init_by_lua_file "lua/luainit/init.lua";
     init_worker_by_lua_file "lua/luabiz/settle.lua";
 
+    # shared_dict 缓存
+    lua_shared_dict dns_cache 128m;
 
     #gzip  on;
     server {
@@ -98,10 +98,14 @@ http {
             }
         }
 
+        location /csv {
+            content_by_lua_file "lua/luabiz/doftp.lua";
+        }
+
         location /get_addr {
             content_by_lua_block {
                 local zx_base = _G.zx_base or loadmod("luabiz.zx_base")
-                local host = zx_base:_get_addr("www.baidu.com")
+                local host = zx_base:_get_addr("baidu.com")
                 ngx.say(host)
                 }
         }

nginx/lua/luabiz/doftp.lua

+local json = require('cjson')
+
+local function GetLines(filename)
+
+  local file = io.input(filename)
+  local res = {}
+  for line in file:lines() do
+    table.insert(res, line)
+  end
+
+  return res --returns number of lines and line table
+end
+
+local function getValues(str)
+  local idx = 0
+  local res = {}
+  if str ~= nil then
+    while string.find(str, ",") ~= nil do
+      local i, j =string.find(str, ",");
+      idx        =idx + 1;
+      res[idx]   = string.sub(str, 1, j-1);
+      str        = string.sub(str, j+1, string.len(str))
+    end
+    idx = idx + 1
+    res[idx] = str
+  end
+  return idx, res
+end
+
+local function doLines(lines)
+  local vals = {}
+  for i = 1, #lines do
+    local _, val = getValues(lines[i])
+    table.insert(vals, val)
+  end
+  return vals
+end
+
+local function parseBasis(vals)
+  local res = {}
+  for i=1, #vals do
+    local line = {
+      user_sn            =vals[i][1],
+      user_name          = vals[i][2],
+      last_name          = vals[i][3],
+      first_name         = vals[i][4],
+      cmbc_hire_date     = vals[i][5],
+      name_pinin         = vals[i][6],
+      sex                = vals[i][7],
+      cmbc_oa_name       = vals[i][8],
+      birth_date         = vals[i][9],
+      folk               = vals[i][10],
+      user_email         = vals[i][11],
+      birth_country_code = vals[i][12],
+      mobile             = vals[i][13],
+      telephone_number   = vals[i][14],
+      address            = vals[i][15],
+      city               = vals[i][16],
+      state              = vals[i][17],
+      address_postal     = vals[i][18],
+      dept_id            = vals[i][19],
+      id_info            = vals[i][20],
+      cmbc_user_status   = vals[i][21],
+      manageType         = vals[i][22],
+      user_type_id       = vals[i][23],
+      psn_jobinfo_order  = vals[i][24],
+      job_order          = vals[i][25]
+    }
+    res[i] = line
+  end
+  return res
+end
+
+local function parseHR_Org(vals)
+  local res = {}
+  for i=1, #vals do
+    local line = {
+      setid           = vals[i][1],
+      deptid          = vals[i][2],
+      org_name        = vals[i][3],
+      org_short_name  = vals[i][4],
+      effdt           = vals[i][5],
+      eff_status      = vals[i][6],
+      cmbc_dept_type  = vals[i][7],
+      parent_node_num = vals[i][8],
+      parent_set_num  = vals[i][9],
+      company         = vals[i][10],
+      tree_level_num  = vals[i][11],
+      manageType      = vals[i][12],
+      org_order       = vals[i][13]
+    }
+    res[i] = line
+  end
+  return res
+end
+
+local function parseHR_job(vals)
+  local res = {}
+  for i=1, #vals do
+    local line = {
+      hr_position_code = vals[i][1],
+      hr_position_name = vals[i][2],
+      hr_position_short_name = vals[i][3],
+      hr_position_job_code = vals[i][4],
+      hr_position_set_id = vals[i][5],
+      hr_position_dept_id = vals[i][6],
+      hr_position_status = vals[i][7],
+      hr_position_eff_date = vals[i][8],
+      hr_position_eff_status = vals[i][9],
+      manageType = vals[i][10]
+    }
+    res[i] = line
+  end
+  return res
+end
+
+local function doftp()
+  local lines = GetLines("/tmp/test.csv")
+  local vals = doLines(lines)
+
+  ngx.say(json.encode(vals))
+end
+
+doftp()

nginx/lua/luabiz/zx_base.lua

@@ -80,12 +80,11 @@ function ZX_BASE.date2time(self, date)
 end
 
 
-
+-- DNS Resolver
 local require = require
 local ngx_re_find = ngx.re.find
-local lrucache = require "resty.lrucache"
 local resolver = require "resty.dns.resolver"
-local cache_storage = lrucache.new(200)
+local dns_cache = ngx.shared.dns_cache
 
 local function _is_addr(hostname)
   return ngx_re_find(hostname, [[\d+?\.\d+?\.\d+?\.\d+$]], "jo")
@@ -98,8 +97,7 @@ function ZX_BASE._get_addr(self,hostname)
     return hostname, hostname
   end
 
-  local addr = cache_storage:get(hostname)
-
+  local addr = dns_cache:get(hostname)
   if addr then
     return addr, hostname
   end
@@ -115,14 +113,13 @@ function ZX_BASE._get_addr(self,hostname)
   end
 
   local answers, err = r:query(hostname, {qtype = r.TYPE_A})
-
   if not answers or answers.errcode then
     return nil, hostname
   end
 
   for i, ans in ipairs(answers) do
     if ans.address then
-      cache_storage:set(hostname, ans.address, 300)
+      dns_cache:set(hostname, ans.address, 300)
       return ans.address, hostname
     end
   end

nginx/lua/luainit/db_conf.lua

@@ -29,6 +29,14 @@ if hostname == "zzd-mer01" then -- 生产
         database = "tk_biz",
         timeout  = 30
       }
+    },
+    cmbc_card = {
+      host = "115.29.241.68",
+      user = "root",
+      password = "xingdata",
+      port     = 3306,
+      database = "cmbc_card",
+      timeout  = 30
     }
   }
 else

nginx/lua/luainit/init.lua

 --- 定义NULL常量
 _G.NULL = ngx.null
 
+
+
+-- Get DNS Servers
 local pcall = pcall
 local io_open = io.open
 local ngx_re_gmatch = ngx.re.gmatch