libuv库的最基本使用方法

1. libuv的使用：
   
2. //（1）创建                        uv_async_t async;
   
3. //                                        uv_loop_t* loop = uv_default_loop();
   
4. //（2）开启主线程        uv_async_init(loop, &async, uv_asynccb);---》（void uv_asynccb(uv_async_t* handle)）
   
5. //（3）激活持有async的队列        uv_async_send(&async);
   
6. //（4）循环队列                uv_run(loop, UV_RUN_DEFAULT);
   
7. //（5）清楚指针                uv_loop_close(uv_default_loop());
   
8. 
   
9. //线程使用：
   
10. //（1）创建句柄                uv_thread_t thread;
    
11. //（2）创建线程                uv_thread_create(&thread, sub_thread, (void *)&async);
    
12. //（3）回收                        uv_thread_join(&thread)
    
13. 
    
14. //工作队列使用
    
15. //（1）创建句柄                uv_work_t req;
    
16. //（2）创建工作                uv_queue_work(loop, &req, callback, finishcallback)
    
17. 
    
18. //定时器使用
    
19. //（1）创建句柄                uv_timer_t m_timer;
    
20. //（2）创建定时器回掉 uv_timer_start(&m_timer, handle, timeout, repalce);
    
21. //（3）回收                        uv_timer_stop(&m_timer)
    
22. 
    
23. //DNS查询
    
24. //（1）创建句柄                uv_getaddrinfo_t resolver
    
25. //（2）解析   int r = uv_getaddrinfo(loop, &resolver, on_resolved, "irc.freenode.net", "6667", struct addrinfo*);
    
26. //回掉void on_resolved(uv_getaddrinfo_t *resolver, int status, struct addrinfo *res)--》你可以在struct addrinfo(s) 结构的链表中任取一个 IP
    
27. //（3）返回值        返回非0解析出错，回掉不会调用，所有参数回值返回后释放

复制代码

直接从代码的角度讲解
（1）uv_async_init队列进程

1. void uv_asynccb(uv_async_t* handle)
   
2. {
   
3.         printf("async_cb called!\n");
   
4.         uv_thread_t id = uv_thread_self();
   
5.         printf("thread id:%lu.\n", id);
   
6. uv_close((uv_handle_t*)handle, NULL);//从队列中删除本任务，程序会直接退出
   
7.         //uv_async_send(handle);//若不删除任务，再次激活程序会陷入循环
   
8. }
   
9. int main(int argc, char* argv[])
   
10. {
    
11.         uv_async_t async;//创建句柄
    
12.         uv_loop_t* loop = uv_default_loop();
    
13.         uv_thread_t id = uv_thread_self();
    
14.         printf("thread id:%lu.\n", id);//得到自身TID
    
15. 
    
16.         uv_async_init(loop, &async, uv_asynccb);//投入队列

复制代码

执行结果：

1. thread id:0
   
2. thread id:0

复制代码

可见uv_async_init并不会创建线程，程序还是同一个线程


（2）线程使用：

1. void sub_thread(void* arg)
   
2. {
   
3.         uv_thread_t id = uv_thread_self();
   
4.         printf("sub thread id:%lu.\n", id);
   
5. }
   
6. 
   
7. int _tmain(int argc, _TCHAR* argv[])
   
8. {
   
9.         uv_thread_t thread;
   
10.         uv_loop_t* loop = uv_default_loop();
    
11.        
    
12.         uv_thread_t id = uv_thread_self();
    
13.         printf("thread id:%lu.\n", id);
    
14. 
    
15.         //创建子线程(子线程不等于队列，线程thread_t是不一样的)
    
16.         uv_thread_create(&thread, sub_thread, NULL);
    
17.         uv_run(loop, UV_RUN_DEFAULT);
    
18.         uv_loop_close(uv_default_loop());
    
19.         return 0;
    
20. }

复制代码

执行结果

1. thread id:0
   
2. sub thread id:456

复制代码

tid不同，创建了线程，且程序直接返回

（3）定时器

1. int _tmain(int argc, _TCHAR* argv[])
   
2. {
   
3.         uv_timer_t m_timer;
   
4.        
   
5.         uv_thread_t id = uv_thread_self();
   
6.         printf("thread id:%lu.\n", id);

复制代码

执行结果

1. thread id:0
   
2. thread id:453
   
3. thread id:453
   
4. thread id:453
   
5. 。。。

复制代码

定时器也为线程运行，代码中

1. [](uv_timer_t* handle)
   
2. {
   
3. printf("======TIME========!\n");
   
4. uv_thread_t id = uv_thread_self();
   
5. printf("thread id:%lu.\n", id);
   
6. }

复制代码

上述写法是在调用时对函数进行实现
（4）工作队列

1. int _tmain(int argc, _TCHAR* argv[])
   
2. {
   
3.         uv_async_t async;
   
4.         uv_work_t req;
   
5.         uv_loop_t* loop = uv_default_loop();
   
6.        
   
7.         uv_thread_t id = uv_thread_self();
   
8.         printf("thread id:%lu.\n", id);
   
9. 
   
10.         uv_queue_work(loop, &req, [](uv_work_t* handle)
    
11.                                                 {
    
12.                                                         printf("async_cb called2!\n");
    
13.                                                         uv_thread_t id = uv_thread_self();
    
14.                                                         printf("thread id:%lu.\n", id);
    
15.                                                 }
    
16.                                         , NULL);
    
17.         uv_run(loop, UV_RUN_DEFAULT);
    
18.         uv_loop_close(uv_default_loop());
    
19.         return 0;
    
20. }

复制代码

执行结果同定时器

DNS解析

1. #include <iostream>
   
2. #include <string>
   
3. #include <uv.h>
   
4. using namespace std;
   
5. 
   
6. //回掉函数
   
7. void callback(uv_getaddrinfo_t* req, int status, struct addrinfo* res){
   
8.         cout << "status: " << status << endl;
   
9.         while (res)
   
10.         {
    
11.                 struct sockaddr_in* addr = (struct sockaddr_in*)res->ai_addr;//从res得到解析结果
    
12.                 cout << "addr: " << inet_ntoa(addr->sin_addr) << " : " << ntohs(addr->sin_port) << endl;//打印端口和IP
    
13.                 res= res->ai_next;
    
14.         }
    
15.         uv_freeaddrinfo(res);//必须释放
    
16. }
    
17. 
    
18. int main(int argc, char* argv[])
    
19. {
    
20.         uv_loop_t* loop = uv_default_loop();
    
21.         uv_getaddrinfo_t uv_req;//创建句柄
    
22. 
    
23.         int r = uv_getaddrinfo(uv_default_loop(), &uv_req, callback, "www.baidu.com", NULL, NULL);//解析DNS
    
24.         if (r) {
    
25.                 cout << "dns:error" << endl;
    
26.                 return 1;
    
27.         }
    
28.         uv_run(loop, UV_RUN_DEFAULT);
    
29.         uv_loop_close(uv_default_loop());
    
30.         return 0;
    
31. }

复制代码

执行结果

1. status: 0
   
2. addr: 180.97.33.108 : 0
   
3. addr: 180.97.33.108 : 0
   
4. addr: 180.97.33.108 : 0
   
5. addr: 180.97.33.107 : 0
   
6. addr: 180.97.33.107 : 0
   
7. addr: 180.97.33.107 : 0
   

复制代码