server.php

     serv->set(    array(        'heartbeat_check_interval' => 60,        'heartbeat_idle_time' => 600,    ));其中heartbeat_idle_time的默认值是heartbeat_check_interval的两倍。 在设置这两个选项后，swoole会在内部启动一个线程每隔heartbeat_check_interval秒后遍历一次全部连接，检查最近一次发送数据的时间和当前时间的差如果这个差值大于heartbeat_idle_time，则会强制关闭这个连接，并通过回调onClose通知Server进程。 小技巧： 结合之前的Timer功能，如果我们想维持连接，就设置一个略小于如果这个差值大于heartbeat_idle_time的定时器，在定时器内向所有连接发送一个心跳包。如果收到心跳回应，则判断连接正常，如果没有收到，则关闭这个连接或者再次尝试发送。*/class server{	private $serv;	/**	 * [__construct description]	 * 构造方法中,初始化 $serv 服务	 */	public function __construct() {		$this->serv = new swoole_server('0.0.0.0', 9801);		//初始化swoole服务		$this->serv->set(array(			'worker_num'  => 8,			'daemonize'   => 0, //是否作为守护进程,此配置一般配合log_file使用			'max_request' => 1000,			'dispatch_mode' => 2,			'debug_mode' => 1,			'log_file'    => './swoole.log',		));		//设置监听		$this->serv->on('Start', array($this, 'onStart'));		$this->serv->on('WorkerStart', array($this, 'onWorkerStart'));		$this->serv->on('Connect', array($this, 'onConnect'));		$this->serv->on("Receive", array($this, 'onReceive'));		$this->serv->on("Close", array($this, 'onClose'));		// bind callback        $this->serv->on('Timer', array($this, 'onTimer'));		//开启		$this->serv->start();	}		public function onStart($serv) {		echo SWOOLE_VERSION . " onStart\n";	}	public function onWorkerStart( $serv , $worker_id) {		// 在Worker进程开启时绑定定时器        echo $worker_id ." onWorkerStart \n";        // 只有当worker_id为0时才添加定时器,避免重复添加        if( $worker_id == 0 ) {        	$serv->addtimer(1000);//毫秒数	        $serv->addtimer(3000);            $serv->addtimer(10000);        }    }	public function onConnect($serv, $fd) {		echo $fd."Client Connect.\n";	}	public function onReceive($serv, $fd, $from_id, $data) {		echo "Get Message From Client {$fd}:{$data}\n";		// send a task to task worker.        $param = array(            'fd' => $fd        );              $serv->send($fd, 'Swoole: '.$data);	}	public function onClose($serv, $fd) {		echo $fd."Client Close.\n";	}	public function onTimer($serv, $interval) {    	switch( $interval ) {    		case 1000: {	//     			echo "Do Thing A at interval 500\n";    			break;    		}    		case 3000:{    			echo "Do Thing B at interval 3000\n";    			break;    		}    		case 10000:{    			echo "Do Thing C at interval 10000\n";    			break;    		}    	}    }}$server = new server();

client.php

     client = new swoole_client(SWOOLE_SOCK_TCP, SWOOLE_SOCK_ASYNC);        $this->client->on('Connect', array($this, 'onConnect'));        $this->client->on('Receive', array($this, 'onReceive'));        $this->client->on('Close', array($this, 'onClose'));        $this->client->on('Error', array($this, 'onError'));    }    public function connect() {        if(!$fp = $this->client->connect("127.0.0.1", 9801 , 1)) {            echo "Error: {$fp->errMsg}[{$fp->errCode}]\n";            return;        }    }    //connect之后,会调用onConnect方法    public function onConnect($cli) {        fwrite(STDOUT, "Enter Msg:");        swoole_event_add(STDIN,function(){            fwrite(STDOUT, "Enter Msg:");            $msg = trim(fgets(STDIN));            $this->client->send($msg);        });    }	public function onReceive($cli, $data) {		echo "Received: ".$data."\n";	}    public function onClose($cli) {        echo "Client close connection\n";    }    public function onError() {    }    public function send($data) {        $this->client->send($data);    }    public function isConnected() {        return $this->client->isConnected();    }}$client = new Client();$client->connect();

运行:

php server.php

可以看到结果: