Libuv api介绍

libuv socket api介绍

int uv_ip4_addr(const char* ip, int port, struct sockaddr_in* addr);
int uv_ip6_addr(const char* ip, int port, struct sockaddr_in6* addr);

使用uv_ip4_addr根据ip地址以及端口号来填充sockaddr_in或sockaddr_in6结构

int uv_udp_init(uv_loop_t* loop, uv_udp_t* handle);
int uv_tcp_init(uv_loop_t* loop, uv_tcp_t* handle);

该函数的作用为初始化TCP或UDP服务器对象,并绑定到对应的事件循环当中
初始化udp和tcp对象
参数loop为绑定的循环
参数handle为udp或udp 句柄,使用new uv_udp_t()或者new uv_tcp_t()即可实例化

int uv_udp_bind(uv_udp_t* handle,
                const struct sockaddr* addr,
                unsigned int flags);

int uv_tcp_bind(uv_tcp_t* handle,
                const struct sockaddr* addr,
                unsigned int flags);

该函数的作用为绑定IP和端口
参数flags,当为IPV6时使用 flags |= UV_UDP_IPV6ONLY或 flags |= UV_TCP_IPV6ONLY
参数addr可通过uv_ip4_addr函数初始化的sockaddr_in结构体中获取
参数handle为句柄,在uv_udp_init或uv_tcp_init中被初始化

int uv_listen(uv_stream_t* stream, int backlog, uv_connection_cb cb);

该函数仅TCP通信使用,作用是建立对端口的监听
参数stream为要监听的对象,可以使用reinterpret_cast<uv_stream_t*>(handle)

参数backlog表示最大长度的待处理的请求连接队列。

参数cb为传入的回调函数,在回调函数内进行uv_accept、uv_read_start等操作。

int uv_udp_recv_start(uv_udp_t* handle,
                      uv_alloc_cb alloc_cb,
                      uv_udp_recv_cb recv_cb) ;

开始接收数据,需要传入alloc_cb和recv_cb回调函数
alloc_cb用于接收数据时申请接收buffer内存
recv_cb用于接收数据回调

int uv_udp_send(uv_udp_send_t* req,
                uv_udp_t* handle,
                const uv_buf_t bufs[],
                unsigned int nbufs,
                const struct sockaddr* addr,
                uv_udp_send_cb send_cb);

该函数用于udp发送数据
参数req:在发送数据时为封装一个uv_udp_send_t结构,其中包含数据域,以及uv_udp_t域还有发送状态回调函数
bufs:为要发送的数据,指向req的data部分,可以使用uv_buf_init对其进行初始化
addr
send_cb用于回调发送状态

libuv pipe api介绍

int uv_read_start(uv_stream_t* stream,
                  uv_alloc_cb alloc_cb,
                  uv_read_cb read_cb)

参数stream:要监控的对象可以是uv_pipe_t、uv_udp_t、uv_tcp_t等。
参数alloc_cb:回调函数，用于申请存储读到的内容的空间;
参数read_cb:回调函数，用于消息处理
该函数的功能为开始输入流的监控

int uv_write(uv_write_t* req,
             uv_stream_t* handle,
             const uv_buf_t bufs[],
             unsigned int nbufs,
             uv_write_cb cb)

参数req:写文件流对象;
参数handle：要写的目标对象；
参数bufs[]：已经初始化完成的指向uv_buf_t结构体的指针；
参数nbufs：一般为1；
参数cb：写数据完成后的回调函数
该函数的功能为往输入流写内容

int uv_pipe_init(uv_loop_t* loop, uv_pipe_t* handle, int ipc)

参数loop：event-loop
参数handle：与管道关联的对象
参数ipc：一般写为0，具体作用在后面进行介绍
该函数用于初始化管道

int uv_pipe_open(uv_pipe_t* pipe, uv_file file)

参数pipe：与管道关联的对象；
参数file：文件描述符。
该函数为打开管道关联文件描述符句柄

void uv_close(uv_handle_t* handle, uv_close_cb close_cb)

参数handle：流对象，可以是uv_pipe_t、uv_udp_t、uv_tcp_t等。

参数close_cb：回调函数，一般为NULL(uv_close、uv_fs_close等函数都可认为是同步的)

最后编辑于：2020.05.24 11:54:08