PHP libevent 使用总结

在根据网上很多资料介绍 libevent 如何使用或者代码分析；不过，大多数都是C 方面一些底层介绍。

在 php 层面上介绍相关应用相对很少，不知道是否在 php 使用 libevent 组件的本身就比较少. 而且网主记载使用例子非常简单. 好啦, 我就长话短说,下面就直接上代码了。

下面为定义 libevent 监听端口以及监听IP

[code=language-php]
public function Start(){
$this->server_sock = stream_socket_server ('tcp://0.0.0.0:'.$port, $errno, $errstr);
@stream_set_blocking($this->server_sock, 0);
//设置事件监听，监听到服务器端socket可读，则有连接请求
event_set($this->server_event, $this->server_sock, EV_READ | EV_PERSIST, array($this,'ev_accept'), NULL);
event_base_set($this->server_event, $this->base_event);
event_add($this->server_event);
event_base_loop($this->base_event);
}

注意: 在设置事件监听上,第四个参数. 我使用 一个Array 来做. 在网上很多例子都是使用 function 名称. 但这样做不利于业务逻辑编写,所以,这里作出了一些修改.

下面为 ev_accept 方法的代码

[code=plain]	private function ev_accept($server_socket, $events) {

//接受连接
$accept_socket = @stream_socket_accept($server_socket);
$accept_id = (int)$accept_socket;
//增加socket timeout设定
stream_set_timeout($accept_socket, 2);
@stream_set_blocking($accept_socket , 0);

$accept_ip = @stream_socket_get_name($accept_socket, true);
//新的事件监听，监听客户端发生的事件
$client_event = event_new();
event_set($client_event, $accept_socket, EV_READ | EV_PERSIST, array($this,'ev_read'), NULL);
event_base_set($client_event,$this->base_event);
event_add($client_event); //加入事件监听组

$this->client_sock[$accept_id] = $accept_socket; //加入到服务器端上客户端socket列表
$this->client_event[$accept_id] = $client_event; //加入到服务端上,客户端socket时间监听列表
}

注: 这个部分主要都是设定服务端接收一个Socket 连接的情况下, 服务端需要处理一些必要事情.如: 监听信息流事件,监听类型以及有信息流触发的处理方法. 这些事情都是对应每个Socket 来做相关处理.

下面为 ev_read 方法的代码

[code=language-php]	private function ev_read($client_socket,$events){

$client_id = (int)$client_socket;
$read = '';
$read = fread($client_socket, 2048))
if($read !== false && $read !=''){
//这里你就可以处理你读取的信息流
}
else{
echo ' SOCKET CLOSE BY CLIENT ' ;
//服务端释放对应用户的内存块
unset($this->client_sock[$client_id],$this->client_event[$client_id]);
}
}

展示的代码相对比较简单,但跌跌碰碰用了不少时间进行摸索.总的来讲,这样构建PHP 服务端会比用纯Socket组件要稳定.