libuv在windows的简单使用

libuv的官网：http:///。

关于libuv的介绍网上都有，大家可以去搜一下。

而如何在windows上安装libuv，我这边是使用vcpkg安装的，学习的时候极力推荐使用这种方式安装，关于vcpkg的使用可以参考这篇博客：https://blog.csdn.net/cjmqas/article/details/79282847。

libuv底层在windows使用的是IOCP机制，IOCP是个神器，但是学起来是真的难，学好了，用起来也就容易了，但是学好谈何容易。关于IOCP的介绍可以看这篇博客：https://blog.csdn.net/piggyxp/article/details/6922277。

综上所述，我就想在windows下试试使用libuv编写一个简单的服务器软件来测试测试libuv的性能，代码如下：

1. #include <iostream>
2. #include <uv.h>
3. #include <uv/errno.h>
4. #include <spdlog/spdlog.h>
6. // 客户端关闭socket时回调函数
7. void OnClose(uv_handle_t* handle)
8. {
9. free(handle);
10. }
12. // 接收socket数据前分配缓冲区函数回调函数
13. void ClientAlloc(uv_handle_t* handle, size_t suggested_size, uv_buf_t* buf)
14. {
15. buf->base = reinterpret_cast<char*>(malloc(suggested_size));
16. buf->len = suggested_size;
17. }
19. //
20. void ClientRead(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf)
21. {
22. sockaddr_in streamAddr;
23. int nameLen = sizeof(sockaddr_in);
25. // 当数据大于0时为接收数据，小于0时是客户端断开连接
26. if (nread > 0)
27. {
28. char szIpAdderss[17] = { 0, };
29. uv_tcp_getpeername(reinterpret_cast<uv_tcp_t*>(stream), reinterpret_cast<sockaddr*>(&streamAddr), &nameLen);
30. uv_ip4_name(&streamAddr, szIpAdderss, 17);
32. buf->base[nread] = '\0';
33. spdlog::info('ip {0}, port {1}, data length {2}, data {3}', szIpAdderss, ntohs(streamAddr.sin_port), nread, buf->base);
34. }
35. else if (nread < 0)
36. {
37. if (nread != UV_EOF)
38. {
39. spdlog::error('ClientRead fail, {0}', uv_strerror(nread));
40. }
41. else
42. {
43. sockaddr_in streamAddr;
44. int nameLen = sizeof(sockaddr_in);
45. char szIpAdderss[17] = { 0, };
46. uv_tcp_getpeername(reinterpret_cast<uv_tcp_t*>(stream), reinterpret_cast<sockaddr*>(&streamAddr), &nameLen);
47. uv_ip4_name(&streamAddr, szIpAdderss, 17);
49. spdlog::info('ip {0}, port {1} disconnect', szIpAdderss, ntohs(streamAddr.sin_port));
50. // 注册断开连接回调函数
51. uv_close(reinterpret_cast<uv_handle_t*>(stream), OnClose);
52. }
53. }
55. free(buf->base);
56. }
58. // 监听回调函数
59. void OnConnect(uv_stream_t* server, int status)
60. {
61. if (status == -1)
62. {
63. return;
64. }
66. // 分配客户端对象
67. uv_tcp_t *pClient = reinterpret_cast<uv_tcp_t*>(malloc(sizeof(uv_tcp_t)));
69. // 为客户端对象绑定libuv循环
70. int retValue = uv_tcp_init(uv_default_loop(), pClient);;
71. if (retValue != 0)
72. {
73. spdlog::error('uv_tcp_init fail, {0}', uv_strerror(retValue));
74. uv_close(reinterpret_cast<uv_handle_t*>(pClient), OnClose);
75. }
76. else
77. {
78. // 接收客户端连接
79. int retValue = uv_accept(server, reinterpret_cast<uv_stream_t*>(pClient));
80. if (retValue != 0)
81. {
82. spdlog::error('uv_accept fail, {0}', uv_strerror(retValue));
83. uv_close(reinterpret_cast<uv_handle_t*>(pClient), OnClose);
84. }
85. else
86. {
87. // 绑定客户端读分配内存和读回调函数
88. uv_read_start(reinterpret_cast<uv_stream_t*>(pClient), ClientAlloc, ClientRead);
89. }
90. }
91. }
93. int main()
94. {
95. // 初始化libuv循环
96. auto pLoop = uv_default_loop();
98. // 初始化libuv服务器
99. uv_tcp_t server;
100. uv_tcp_init(pLoop, &server);
102. sockaddr_in bindAddr;
103. int retValue = uv_ip4_addr('0.0.0.0', 43000, &bindAddr);
104. if (retValue != 0)
105. {
106. spdlog::error('uv_ip4_addr fail, {0}', uv_strerror(retValue));
107. return -1;
108. }
110. // 绑定地址和端口
111. retValue = uv_tcp_bind(&server, reinterpret_cast<sockaddr*>(&bindAddr), 0);
112. if (retValue != 0)
113. {
114. spdlog::error('uv_tcp_bind fail, {0}', uv_strerror(retValue));
115. return -2;
116. }
118. // 开始监听
119. retValue = uv_listen(reinterpret_cast<uv_stream_t*>(&server), 128, OnConnect);
120. if (retValue != 0)
121. {
122. spdlog::error('uv_listen fail, {0}', uv_strerror(retValue));
123. return -3;
124. }
126. // 开启libuv循环
127. return uv_run(pLoop, UV_RUN_DEFAULT);
128. }

测试的时候使用的是上面介绍IOCP的博客所提供的客户端，目的是对比使用IOCP写的服务器和使用libuv写的服务器之间的差异，结果看来是没多大差别的。

以上就是本博客的全文，本人限于能力，上文中难免有错误的地方，若读者发现上文的错误，请于评论区中指出，本人看到之后会立即修改的，谢谢。