Swoole 实例四(心跳检测)

服务器端 server.php

<?php
/*
Swoole已经内置了心跳检测功能，能自动close掉长时间没有数据来往的连接。
而开启心跳检测功能，只需要设置heartbeat_check_interval和heartbeat_idle_time即可。如下：
$this->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‘,
			‘heartbeat_check_interval‘ => 5,
			‘heartbeat_idle_time‘ => 8, //默认是heartbeat_check_interval的2倍,超过此设置客户端没有回应则强制断开链接
		));

		//设置监听
		$this->serv->on(‘Start‘, array($this, ‘onStart‘));
		$this->serv->on(‘Connect‘, array($this, ‘onConnect‘));
		$this->serv->on("Receive", array($this, ‘onReceive‘));
		$this->serv->on("Close", array($this, ‘onClose‘));
		//开启
		$this->serv->start();
	}

	public function onStart($serv) {
		echo SWOOLE_VERSION . " onStart\n";
	}

	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";
	}

}

$server = new server();

客户端 client.php

<?php
class Client
{
    private $client;

    public function __construct() {
        $this->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

php client.php