mirror of
https://github.com/cloudwu/skynet.git
synced 2026-07-22 11:03:12 +00:00
39 lines
762 B
Lua
39 lines
762 B
Lua
local skynet = require "skynet"
|
|
local db = {}
|
|
|
|
local command = {}
|
|
|
|
function command.GET(key)
|
|
skynet.ret(db[key])
|
|
end
|
|
|
|
function command.SET(key, value)
|
|
local last = db[key]
|
|
db[key] = value
|
|
skynet.ret(last)
|
|
end
|
|
|
|
local trace_cache = {}
|
|
|
|
skynet.trace_callback(function(handle, ti)
|
|
print("TRACE",trace_cache[handle],ti)
|
|
trace_cache[handle] = nil
|
|
end)
|
|
|
|
skynet.start(function()
|
|
skynet.dispatch("text", function(session, address, message)
|
|
trace_cache[skynet.trace()] = message
|
|
print("simpledb",message, skynet.address(address), session)
|
|
local cmd, key , value = string.match(message, "(%w+) (%w+) ?(.*)")
|
|
local f = command[cmd]
|
|
if f then
|
|
f(key,value)
|
|
else
|
|
skynet.ret("Invalid command : "..message)
|
|
end
|
|
end)
|
|
skynet.register "SIMPLEDB"
|
|
end)
|
|
|
|
|