dbproxy.lua 566 B

123456789101112131415161718192021222324
  1. local skynet = require "skynet"
  2. require "skynet.manager"
  3. local settings = require "run_config"
  4. local skynet_node_name = ...
  5. local CMD = {}
  6. local function start()
  7. local conf = settings.db_cnf[skynet_node_name]
  8. for _, proxy in ipairs(conf.dbproxy) do
  9. skynet.uniqueservice(proxy .. "pool", skynet_node_name)
  10. end
  11. end
  12. skynet.start(function()
  13. start()
  14. skynet.dispatch("lua", function(_, _, cmd, ...)
  15. local f = assert(CMD[cmd], cmd .. "not found")
  16. skynet.retpack(f(...))
  17. end)
  18. skynet.register('.' .. SERVICE_NAME)
  19. end)