放假了.同學都回家了,我是更情愿留久點在學校,一來學校安靜,二來免得火車太擠.? 這臨走前的幾天,放下了erlang,寫了一下c. 其實只是對比下erlang 寫socket服務器,和c寫socket服務器的異同.

說一下libev:? 點擊打開鏈接
Libev是一個event loop：向libev注冊感興趣的events，比如Socket可讀事件，libev會對所注冊的事件的源進行管理，并在事件發生時觸發相應的程序。 ? 對比另外一個更加出名的libevent,這個更加先進. 小巧輕量.? 源碼解讀就不獻丑了,一堆堆宏.我功力不夠去深層切入libev.官網有文檔,弄成pdf了,可以下載: http://d.yun.io/Y9ziuo

說一下環境: ubuntu 11.10 ,gcc4.4.6 ,libev 4.11,? code:block(vim,emacs黨...莫要黑,我用CB好久了,莫要離間!!!)

官方文檔是有個鍵盤輸入的demo,網上也有幾個用libev寫echo sever的,感覺都寫得很不錯,很全面.? 我還是參考他們寫個簡單,簡陋的試一下吧.

main.c 只有一個文件..呵呵

[cpp] view plain copy

#include?<stdio.h>??

#include?<netinet/in.h>??

#include?<ev.h>??

??

#define?PORT?9999??

#define?BUFFER_SIZE?1024??

??

??

void?accept_cb(struct?ev_loop?*loop,?struct?ev_io?*watcher,?int?revents);??

??

??

void?read_cb(struct?ev_loop?*loop,?struct?ev_io?*watcher,?int?revents);??

??

int?main()??

{??

struct?ev_loop?*loop?=?ev_default_loop(0);??

int?sd;??

struct?sockaddr_in?addr;??

int?addr_len?=?sizeof(addr);??

struct?ev_io?socket_accept;??

??

//?創建socket的寫法,這里簡單處理,用INADDR_ANY?,匹配任何客戶端請求.這里寫法都一樣,沒什么特別的,直接copy都可以用??

if(?(sd?=?socket(PF_INET,?SOCK_STREAM,?0))?<?0?)??

{??

??printf("socket?error");??

??return?-1;??

}??

bzero(&addr,?sizeof(addr));??

addr.sin_family?=?AF_INET;??

addr.sin_port?=?htons(PORT);??

addr.sin_addr.s_addr?=?INADDR_ANY;??

if?(bind(sd,?(struct?sockaddr*)?&addr,?sizeof(addr))?!=?0)??

{??

??printf("bind?error");??

}??

if?(listen(sd,?2)?<?0)??

{??

??printf("listen?error");??

??return?-1;??

}??

??

??

??

//?初始化,這里監聽了io事件,寫法參考官方文檔的??

ev_io_init(&socket_accept,?accept_cb,?sd,?EV_READ);??

ev_io_start(loop,?&socket_accept);??

??

??

while?(1)??

{??

??ev_loop(loop,?0);??

}??

??

return?0;??

}??

??

??

??

//accept事件?的回調塊??

void?accept_cb(struct?ev_loop?*loop,?struct?ev_io?*watcher,?int?revents)??

{??

struct?sockaddr_in?client_addr;??

socklen_t?client_len?=?sizeof(client_addr);??

int?client_sd;??

??

//分派客戶端的ev?io結構??

struct?ev_io?*w_client?=?(struct?ev_io*)?malloc?(sizeof(struct?ev_io));??

??

//libev的錯誤處理??

if(EV_ERROR?&?revents)??

{??

??printf("error?event?in?accept");??

??return;??

}??

??

//accept,普通寫法??

client_sd?=?accept(watcher->fd,?(struct?sockaddr?*)&client_addr,?&client_len);??

if?(client_sd?<?0)??

{??

??printf("accept?error");??

??return;??

}??

??

printf("someone?connected.\n");??

??

//開始監聽讀事件了,有客戶端信息就會被監聽到??

ev_io_init(w_client,?read_cb,?client_sd,?EV_READ);??

ev_io_start(loop,?w_client);??

}??

??

//read?數據事件的回調快??

void?read_cb(struct?ev_loop?*loop,?struct?ev_io?*watcher,?int?revents){??

char?buffer[BUFFER_SIZE];??

ssize_t?read;??

??

if(EV_ERROR?&?revents)??

{??

??printf("error?event?in?read");??

??return;??

}??

??

//recv普通socket寫法??

read?=?recv(watcher->fd,?buffer,?BUFFER_SIZE,?0);??

??

if(read?<?0)??

{??

??printf("read?error");??

??return;??

}??

??

//斷開鏈接的處理,停掉evnet就可以,同時記得釋放客戶端的結構體!??

if(read?==?0)??

{??

??printf("someone?disconnected.\n");??

??ev_io_stop(loop,watcher);??

??free(watcher);??

??return;??

}??

else??

{??

??printf("get?the?message:%s\n",buffer);??

}??

??

//原信息返回,也可以自己寫信息,都一樣.最后記得置零??

send(watcher->fd,?buffer,?read,?0);??

bzero(buffer,?read);??

}??

編譯后,運行. 然后打開teminal ,?? telnet 127.0.0.1 9999? 就可以發送信息了.

入手c的網絡編程,將來,對比下erlang的底層網絡通訊是怎么弄的

~~by dp

總結

以上是生活随笔為你收集整理的[c语言 ] 用libev 写个echo服务器的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。