c 如何在libuv中實現tcp伺服器

2022-09-25 05:00:22 字數 4491 閱讀 7279

libuv 中實現 tcp server 的步驟和原生 socket 步驟類似,回憶一下 linux 下原生 socket 實現 tcp server 的步驟:

libuv 和原生 socket 程式設計類似,步驟和api與原生 socket 程式設計步驟類似,但是使用卻變得簡單了,處處使用**函式使得程式設計變得簡單了。

libuv 對於 tcp 訊息的處理,同樣是基於 stream 的,步驟如下:

附錄是整個 tcp server 的源**,其中涉及到的一些 api 如下:

初始化 tcp 物件

uv_tcp_t server;

uv_tcp_init(loop, &server);//初始化tcp server物件

struct sockaddr_in addr;

uv_ip4_addr("0.0.0.0", default_port, &addr);

將www.cppcns.com給定的ip位址和埠轉換成sockaddr_in結程式設計客棧構體,原生程式設計的時候,設定ip和埠需要至少五行,用這個方法可以簡化操作

等同於原生api的 bind() 方法

uv_tcp_bind(&server, (const struct sockaddr *) &addr, 0);

uv_tcp_bind() 的第三個引數 flag 一般是0,如果想使用ip6,可以使用 uv_tcp_ipv6only

enum uv_tcp_flags ;

uv_listen((uv_stream_t *) &server, 128, on_new_connection);

類似 listen() ,開始監聽

第二個引數表明核心的排隊數,最後指定有新連線時的**函式

當有新的連線進來時,就會觸發 on_new_connection **

uv_connection_cb 是 uv_listen 的**函式,其宣告如下:

typedef void (*uv_connection_cb)(uv_stream_t* server, int status);

server 引數為伺服器控制代碼

status 表示狀態,小於0表示新連線有誤

新連線觸發**函式之後,按照一般流程,需要使用 accept() 方法獲取客戶端控制代碼,libuv 中使用 uv_accept(),其宣告如下:

int uv_accept(uv_stream_t* server, uv_stream_t* client)

在呼叫之前,client 引數必須被初始化

返回值 <0 表示有誤

示例:uv_tcp_t *client = (uv_tcp_t *) malloc(sizeof(uv_tcp_t));//為tcp client申請資源

uv_tcp_init(loop, client);//初始化tcp client控制代碼

if (uv_accept(server, (uv_stream_t *) client) == 0)

libuv 中使用 uv_read_start() 方法從傳入的 stream 中讀取資料,宣告如下:

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

read_cb 會被多次呼叫,直到資料讀完,或者主動呼叫 uv_read_stop() 方法停止

該函式有兩個**函式,alloc_cb 用於為新來的資料申請空間,申請的資源需要在 read_cb 中釋放

這兩個**的宣告如下:

typedef void (*uv_alloc_cb)(uv_handle_t* handle, size_t suggested_size, uv_buf_t* buf);

typedef void (*uv_read_cb)(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf);

示例**:

//負責為新來的訊息申請空間

void alloc_buffer(uv_handle_t *handle, size_t suggested_size, uv_buf_t *buf)

/** * @brief: 負責處理新來的訊息

* @param: client

* @param: nread>0表示有資料就緒,nread<0表示異常,nread是有可能為0的,但是這並不是異常或者結束

*/void read_cb(uv_stream_t *client, ssize_t nread, const uv_buf_t *buf)

}uv_read_start((uv_stream_t *) client, alloc_buffer, read_cb);

uv_buf_t 是libuv 中的一種特殊的資料型別,和 redis 的 sds 有一點相似度,宣告如下:

typedef struct uv_buf_t uv_buf_t;

uv_buf_t 可以使用 uv_buf_init 初始化

示例:uv_buf_t uvbuf = uv_buf_init(buf->base, nread);//初始化write的uv_buf_t

libuv 中使用 uv_close() 方法關閉控制代碼,宣告如下:

void uv_close(uv_handle_t* handle, uv_close_cb close_cb)

close_cb 為關閉之後的**,宣告如下:

typedef void (*uv_close_cb)(uv_handle_t* handle);

**示例:

void on_close(uv_handle_t *handle)

...uv_close((uv_handle_t *) client, on_close);

libuv 中使用 uv_write() 方法傳送資料,宣告如下:

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 表示需要傳送的陣列元素個數,一般小於等於 bufs 的大小

有些函式會有錯誤碼,使用 uv_strerror() 方法獲取錯誤碼對應的描述

源**如下:

#include

#include

#include

uv_loop_t *loop;

#define default_port 7000

//連線佇列最大長度

#define default_backlog 128

//負責為新來的訊息申請空間

void alloc_buffer(uv_handle_t *handle, size_t suggested_size, uv_buf_t *buf)

void on_close(uv_handle_t *handle)

void echo_write(uv_write_t *req, int status)

free(req程式設計客棧);

}/**

* @brief: 負責處理新來的訊息

* @param: client

* @param: nread>0表示有資料就緒,nread<0表示異常,nread是有可能為0的,但是這並不是異常或者結束

* @author: sherlock

*/void read_cb(uv_stream_t *client, ssize_t nread, const uv_buf_t *buf) else if (nread < 0) else

uv_close((uv_handle_t *) client, on_close);

} //釋放之前申請的資源

www.cppcns.com if (buf->base != null)

}/**

* * @param: server libuv的tcp server物件

* @param: status 狀態,小於0表示新連線有誤

* @author: sherlock

*/void on_new_connection(uv_stream_t *server, int status)

uv_tcp_t *client = (uv_tcp_t *) malloc(sizeof(uv_tcp_t));//為tcp client申請資源

uv_tcp_init(loop, client);//初始化tcp client控制代碼

//判斷accept是否成功

if (uv_accept(server, (uv_stream_t *) client) == 0) else

}int main(int argc, char **ar**)

return uv_run(loop, uv_run_default);

}

如何在socket程式設計的Tcp連線中實現心跳協議

跳包之所以叫心跳包是因為 它像心跳一樣每隔固定時間發一次,以此來告訴伺服器,這個客戶端還活著。事實上這是為了保持長連線,至於這個包的內容,是沒有什麼特別規定的,不過一般都是很小的包,或者只包含包頭的乙個空包。在tcp的機制裡面,本身是存在有心跳包的機制的,也就是tcp的選項 so keepalive...

如何在C 中呼叫C程式

c 和c是兩種完全不同的編譯鏈結處理方式,如果直接在c 裡面呼叫c函式,會找不到函式體,報鏈結錯誤。要解決這個問題,就要在 c 檔案裡面顯示宣告一下哪些函式是c寫的,要用c的方式來處理。1.引用標頭檔案前需要加上 extern c 如果引用多個,那麼就如下所示 extern c 然後在呼叫這些函式之...

如何在C 中呼叫C程式?

c 和c是兩種完全不同的編譯鏈結處理方式,如果直接在c 裡面呼叫c函式,會找不到函式體,報鏈結錯誤。要解決這個問題,就要在 c 檔案裡面顯示宣告一下哪些函式是c寫的,要用c的方式來處理。1.引用標頭檔案前需要加上 extern c 如果引用多個,那麼就如下所示 extern c 然後在呼叫這些函式之...