mirror of
https://github.com/cloudwu/skynet.git
synced 2026-07-22 11:03:12 +00:00
79 lines
1.6 KiB
Lua
79 lines
1.6 KiB
Lua
package.cpath = "luaclib/?.so"
|
|
|
|
local socket = require "clientsocket"
|
|
local cjson = require "cjson"
|
|
local bit32 = require "bit32"
|
|
|
|
local fd = assert(socket.connect("127.0.0.1", 8888))
|
|
|
|
local function send_package(fd, pack)
|
|
local size = #pack
|
|
local package = string.char(bit32.extract(size,8,8)) ..
|
|
string.char(bit32.extract(size,0,8))..
|
|
pack
|
|
|
|
socket.send(fd, package)
|
|
end
|
|
|
|
local function unpack_package(text)
|
|
local size = #text
|
|
if size < 2 then
|
|
return nil, text
|
|
end
|
|
local s = text:byte(1) * 256 + text:byte(2)
|
|
if size < s+2 then
|
|
return nil, text
|
|
end
|
|
|
|
return text:sub(3,2+s), text:sub(3+s)
|
|
end
|
|
|
|
local function recv_package(last)
|
|
local result
|
|
result, last = unpack_package(last)
|
|
if result then
|
|
return result, last
|
|
end
|
|
local r = socket.recv(fd)
|
|
if not r then
|
|
return nil, last
|
|
end
|
|
if r == "" then
|
|
error "Server closed"
|
|
end
|
|
return unpack_package(last .. r)
|
|
end
|
|
|
|
local session = 0
|
|
|
|
local function send_request(v)
|
|
session = session + 1
|
|
local str = string.format("%d+%s",session, cjson.encode(v))
|
|
send_package(fd, str)
|
|
print("Request:", session)
|
|
end
|
|
|
|
local last = ""
|
|
|
|
while true do
|
|
while true do
|
|
local v
|
|
v, last = recv_package(last)
|
|
if not v then
|
|
break
|
|
end
|
|
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
|
|
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 |