放假了.同學都回家了,我是更情願留久點在學校,一來學校安靜,二來免得火車太擠.  這臨走前的幾天,放下了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 只有一個檔案..呵呵

#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);
}
 

入手c的網路程式設計,將來,對比下erlang的底層網路通訊是怎麼弄的

~~by dp