1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
|
import("core.base.bytes")
import("core.base.socket")
import("core.base.scheduler")
function _session(addr, port, data)
local buff = bytes(8192)
local sock = socket.udp()
local send = sock:sendto(data or "hello xmake!", addr, port, {block = true})
print("%s: send to %s:%d %d bytes!", sock, addr, port, send)
local recv, data, peer_addr, peer_port = sock:recvfrom(buff, 8112, {block = true})
if recv > 0 then
print("%s: recv %d bytes from %s:%d", sock, recv, peer_addr, peer_port)
data:dump()
end
sock:close()
end
function main(data)
scheduler.co_start(_session, "127.0.0.1", 9091, data)
end
|
