PHP libevent 使用总结

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

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

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

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 方法的代码

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 方法的代码

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组件要稳定.