mirror of
https://github.com/cloudwu/skynet.git
synced 2026-07-22 19:13:07 +00:00
50 lines
1.0 KiB
Lua
50 lines
1.0 KiB
Lua
package.cpath = "luaclib/?.so"
|
|
|
|
local socket = require "clientsocket"
|
|
local cjson = require "cjson"
|
|
|
|
local fd = socket.connect("127.0.0.1", 8888)
|
|
|
|
local last
|
|
local result = {}
|
|
|
|
local function dispatch()
|
|
while true do
|
|
local status
|
|
status, last = socket.recv(fd, last, result)
|
|
if status == nil then
|
|
error "Server closed"
|
|
end
|
|
if not status then
|
|
break
|
|
end
|
|
for _, v in ipairs(result) do
|
|
local session,t,str = string.match(v, "(%d+)(.)(.*)")
|
|
assert(t == '-' or t == '+')
|
|
session = tonumber(session)
|
|
local result = cjson.decode(str)
|
|
print("Response:",session, result[1], result[2])
|
|
end
|
|
end
|
|
end
|
|
|
|
local session = 0
|
|
|
|
local function send_request(v)
|
|
session = session + 1
|
|
local str = string.format("%d+%s",session, cjson.encode(v))
|
|
socket.send(fd, str)
|
|
print("Request:", session)
|
|
end
|
|
|
|
while true do
|
|
dispatch()
|
|
local cmd = socket.readstdin()
|
|
if cmd then
|
|
local args = {}
|
|
string.gsub(cmd, '[^ ]+', function(v) table.insert(args, v) end )
|
|
send_request(args)
|
|
else
|
|
socket.usleep(100)
|
|
end
|
|
end |