listen()函數
是換換內容得時候了。假如你不希望與遠程的一個地址相連,或者說, 僅僅是將它踢開,那你就需要等待接入請求并且用各種方法處理它們。處 理過程分兩步:首先,你聽--listen(),然后,你接受--accept() (請看下面的 內容)。
除了要一點解釋外,系統調用 listen 也相當簡單。
int listen(int sockfd, int backlog);
sockfd 是調用 socket() 返回的套接字文件描述符。backlog 是在進入 隊列中允許的連接數目。什么意思呢? 進入的連接是在隊列中一直等待直 到你接受 (accept() 請看下面的文章)連接。它們的數目限制于隊列的允許。 大多數系統的允許數目是20,你也可以設置為5到10。
和別的函數一樣,在發生錯誤的時候返回-1,并設置全局錯誤變量 errno。
你可能想象到了,在你調用 listen() 前你或者要調用 bind() 或者讓內 核隨便選擇一個端口。如果你想偵聽進入的連接,那么系統調用的順序可 能是這樣的:
socket();
bind();
listen();
/* accept() 應該在這 */
因為它相當的明了,我將在這里不給出例子了。(在 accept() 那一章的 代碼將更加完全。)真正麻煩的部分在 accept()。
--------------------------------------------------------------------------------
accept()函數
準備好了,系統調用 accept() 會有點古怪的地方的!你可以想象發生 這樣的事情:有人從很遠的地方通過一個你在偵聽 (listen()) 的端口連接 (connect()) 到你的機器。它的連接將加入到等待接受 (accept()) 的隊列 中。你調用 accept() 告訴它你有空閑的連接。它將返回一個新的套接字文 件描述符!這樣你就有兩個套接字了,原來的一個還在偵聽你的那個端口, 新的在準備發送 (send()) 和接收 ( recv()) 數據。這就是這個過程!
函數是這樣定義的:
#include
int accept(int sockfd, void *addr, int *addrlen);
sockfd 相當簡單,是和 listen() 中一樣的套接字描述符。addr 是個指 向局部的數據結構 sockaddr_in 的指針。這是要求接入的信息所要去的地 方(你可以測定那個地址在那個端口呼叫你)。在它的地址傳遞給 accept 之 前,addrlen 是個局部的整形變量,設置為 sizeof(struct sockaddr_in)。 accept 將不會將多余的字節給 addr。如果你放入的少些,那么它會通過改
變 addrlen 的值反映出來。
同樣,在錯誤時返回-1,并設置全局錯誤變量 errno。
現在是你應該熟悉的代碼片段。
#include
#include
#include
#define MYPORT 3490 /*用戶接入端口*/
#define BACKLOG 10 /* 多少等待連接控制*/
main()
{
int sockfd, new_fd; /* listen on sock_fd, new connection on new_fd */
struct sockaddr_in my_addr; /* 地址信息 */
struct sockaddr_in their_addr; /* connector's address information */
int sin_size;
sockfd = socket(AF_INET, SOCK_STREAM, 0); /* 錯誤檢查*/
my_addr.sin_family = AF_INET; /* host byte order */
my_addr.sin_port = htons(MYPORT); /* short, network byte order */
my_addr.sin_addr.s_addr = INADDR_ANY; /* auto-fill with my IP */
bzero(&(my_addr.sin_zero),; /* zero the rest of the struct */
/* don't forget your error checking for these calls: */
bind(sockfd, (struct sockaddr *)&my_addr, sizeof(struct sockaddr));
listen(sockfd, BACKLOG);
sin_size = sizeof(struct sockaddr_in);
new_fd = accept(sockfd, &their_addr, &sin_size);
.
.
.
注意,在系統調用 send() 和 recv() 中你應該使用新的套接字描述符 new_fd。如果你只想讓一個連接進來,那么你可以使用 close() 去關閉原 來的文件描述符 sockfd 來避免同一個端口更多的連接。
--------------------------------------------------------------------------------
send() and recv()函數
這兩個函數用于流式套接字或者數據報套接字的通訊。如果你喜歡使 用無連接的數據報套接字,你應該看一看下面關于sendto() 和 recvfrom() 的章節。
send() 是這樣的:
int send(int sockfd, const void *msg, int len, int flags);
sockfd 是你想發送數據的套接字描述符(或者是調用 socket() 或者是 accept() 返回的。)msg 是指向你想發送的數據的指針。len 是數據的長度。 把 flags 設置為 0 就可以了。(詳細的資料請看 send() 的 man page)。
這里是一些可能的例子:
char *msg = "Beej was here!";
int len, bytes_sent;
.
.
len = strlen(msg);
bytes_sent = send(sockfd, msg, len, 0);
.
.
.
send() 返回實際發送的數據的字節數--它可能小于你要求發送的數 目! 注意,有時候你告訴它要發送一堆數據可是它不能處理成功。它只是 發送它可能發送的數據,然后希望你能夠發送其它的數據。記住,如果 send() 返回的數據和 len 不匹配,你就應該發送其它的數據。但是這里也 有個好消息:如果你要發送的包很小(小于大約 1K),它可能處理讓數據一 次發送完。最后要說得就是,它在錯誤的時候返回-1,并設置 errno。
recv() 函數很相似:
int recv(int sockfd, void *buf, int len, unsigned int flags);
sockfd 是要讀的套接字描述符。buf 是要讀的信息的緩沖。len 是緩 沖的最大長度。flags 可以設置為0。(請參考recv() 的 man page。) recv() 返回實際讀入緩沖的數據的字節數。或者在錯誤的時候返回-1, 同時設置 errno。
很簡單,不是嗎? 你現在可以在流式套接字上發送數據和接收數據了。 你現在是 Unix 網絡程序員了!