lbus = require("lbus");
socket_mgr = lbus.create_socket_mgr(最大句柄数);
--用户需要在主循环中调用wait函数,比如:
--其参数为最大阻塞时长(实际是传给epoll_wait之类函数),单位ms.
socket_mgr.wait(50);

--注意保持listener的生存期,一旦被gc,则端口就自动关了
--第三个参数为listen的backlog,可以不传,默认16
listener = mgr.listen("127.0.0.1", 8080, 32);

--设置accept回调
listener.on_accept = function(stream)
    stream.on_recv = function(msg, ...)
        -- ...
    end

    stream.on_error = function(err)
        -- ...
    end
end

--注意保持stream对象生存期,被gc的话,连接会自动关闭
--连接都是异步进行的,一直要stream上面触发'on_connect'事件后,连接才可用
--connect(ip, port, timeout)
stream = mgr.connect("127.0.0.1", 8080, 2000);
--设置连接事件回调:
stream.on_connect = function(result)
    --如果连接成功,result为"ok"
    --否则,result表明具体的错误
end

stream.send("on_login", acc, password);

stream.on_error = function (err)
    --发生任何错误时触发
end

stream.on_recv = function (msg, ...)
    --收到对端消息时触发.
    --通常这里是以...为参数调用msg对应的函数过程.
end

--设置nodelay属性,默认设置为true
stream.set_nodelay(true);
--设置收发缓冲区,至少应该可以容纳一条消息,默认64K
stream.set_recv_buffer_size(1024 * 64);
stream.set_send_buffer_size(1024 * 64);
stream.ip: 对端ip
stream.token: 本连接的唯一标识

--调用close即可:
stream.close();