listen()函數(shù)
是換換內(nèi)容得時候了。假如你不希望與遠程的一個地址相連,或者說, 僅僅是將它踢開,那你就需要等待接入請求并且用各種方法處理它們。處 理過程分兩步:首先,你聽--listen(),然后,你接受--accept() (請看下面的 內(nèi)容)。
除了要一點解釋外,系統(tǒng)調(diào)用 listen 也相當(dāng)簡單。
int listen(int sockfd, int backlog);
sockfd 是調(diào)用 socket() 返回的套接字文件描述符。backlog 是在進入 隊列中允許的連接數(shù)目。什么意思呢? 進入的連接是在隊列中一直等待直 到你接受 (accept() 請看下面的文章)連接。它們的數(shù)目限制于隊列的允許。 大多數(shù)系統(tǒng)的允許數(shù)目是20,你也可以設(shè)置為5到10。
和別的函數(shù)一樣,在發(fā)生錯誤的時候返回-1,并設(shè)置全局錯誤變量 errno。
你可能想象到了,在你調(diào)用 listen() 前你或者要調(diào)用 bind() 或者讓內(nèi) 核隨便選擇一個端口。如果你想偵聽進入的連接,那么系統(tǒng)調(diào)用的順序可 能是這樣的:
socket();
bind();
listen();
/* accept() 應(yīng)該在這 */
因為它相當(dāng)?shù)拿髁耍覍⒃谶@里不給出例子了。(在 accept() 那一章的 代碼將更加完全。)真正麻煩的部分在 accept()。
--------------------------------------------------------------------------------
accept()函數(shù)
準(zhǔn)備好了,系統(tǒng)調(diào)用 accept() 會有點古怪的地方的!你可以想象發(fā)生 這樣的事情:有人從很遠的地方通過一個你在偵聽 (listen()) 的端口連接 (connect()) 到你的機器。它的連接將加入到等待接受 (accept()) 的隊列 中。你調(diào)用 accept() 告訴它你有空閑的連接。它將返回一個新的套接字文 件描述符!這樣你就有兩個套接字了,原來的一個還在偵聽你的那個端口, 新的在準(zhǔn)備發(fā)送 (send()) 和接收 ( recv()) 數(shù)據(jù)。這就是這個過程!
函數(shù)是這樣定義的:
#include
int accept(int sockfd, void *addr, int *addrlen);
sockfd 相當(dāng)簡單,是和 listen() 中一樣的套接字描述符。addr 是個指 向局部的數(shù)據(jù)結(jié)構(gòu) sockaddr_in 的指針。這是要求接入的信息所要去的地 方(你可以測定那個地址在那個端口呼叫你)。在它的地址傳遞給 accept 之 前,addrlen 是個局部的整形變量,設(shè)置為 sizeof(struct sockaddr_in)。 accept 將不會將多余的字節(jié)給 addr。如果你放入的少些,那么它會通過改
變 addrlen 的值反映出來。
同樣,在錯誤時返回-1,并設(shè)置全局錯誤變量 errno。
現(xiàn)在是你應(yīng)該熟悉的代碼片段。
#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);
.
.
.
注意,在系統(tǒng)調(diào)用 send() 和 recv() 中你應(yīng)該使用新的套接字描述符 new_fd。如果你只想讓一個連接進來,那么你可以使用 close() 去關(guān)閉原 來的文件描述符 sockfd 來避免同一個端口更多的連接。
--------------------------------------------------------------------------------
send() and recv()函數(shù)
這兩個函數(shù)用于流式套接字或者數(shù)據(jù)報套接字的通訊。如果你喜歡使 用無連接的數(shù)據(jù)報套接字,你應(yīng)該看一看下面關(guān)于sendto() 和 recvfrom() 的章節(jié)。
send() 是這樣的:
int send(int sockfd, const void *msg, int len, int flags);
sockfd 是你想發(fā)送數(shù)據(jù)的套接字描述符(或者是調(diào)用 socket() 或者是 accept() 返回的。)msg 是指向你想發(fā)送的數(shù)據(jù)的指針。len 是數(shù)據(jù)的長度。 把 flags 設(shè)置為 0 就可以了。(詳細的資料請看 send() 的 man page)。
這里是一些可能的例子:
char *msg = "Beej was here!";
int len, bytes_sent;
.
.
len = strlen(msg);
bytes_sent = send(sockfd, msg, len, 0);
.
.
.
send() 返回實際發(fā)送的數(shù)據(jù)的字節(jié)數(shù)--它可能小于你要求發(fā)送的數(shù) 目! 注意,有時候你告訴它要發(fā)送一堆數(shù)據(jù)可是它不能處理成功。它只是 發(fā)送它可能發(fā)送的數(shù)據(jù),然后希望你能夠發(fā)送其它的數(shù)據(jù)。記住,如果 send() 返回的數(shù)據(jù)和 len 不匹配,你就應(yīng)該發(fā)送其它的數(shù)據(jù)。但是這里也 有個好消息:如果你要發(fā)送的包很小(小于大約 1K),它可能處理讓數(shù)據(jù)一 次發(fā)送完。最后要說得就是,它在錯誤的時候返回-1,并設(shè)置 errno。
recv() 函數(shù)很相似:
int recv(int sockfd, void *buf, int len, unsigned int flags);
sockfd 是要讀的套接字描述符。buf 是要讀的信息的緩沖。len 是緩 沖的最大長度。flags 可以設(shè)置為0。(請參考recv() 的 man page。) recv() 返回實際讀入緩沖的數(shù)據(jù)的字節(jié)數(shù)。或者在錯誤的時候返回-1, 同時設(shè)置 errno。
很簡單,不是嗎? 你現(xiàn)在可以在流式套接字上發(fā)送數(shù)據(jù)和接收數(shù)據(jù)了。 你現(xiàn)在是 Unix 網(wǎng)絡(luò)程序員了!