client 客户端

<?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() {$fp = $this->client->connect("127.0.0.1", 9501 , 1);if( !$fp ) {echo "Error: {$fp->errMsg}[{$fp->errCode}]\n";return;}}public function onReceive( $cli, $data ) {echo "Get Message From Server: {$data}\n";}public function onConnect( $cli) {$msg_eof = "This is a Msg\r\n";//      $msg_length = pack("N" , strlen($msg_normal) ). $msg_normal;//  $msg_length = pack("N" , strlen($msg_eof) ). $msg_eof;$i = 0;while(1){if( $i < 100 ) { //有可能会分几次发 因为一次可能处理不完//            $this->client->send( $msg_length );$this->client->send( $msg_eof );$i ++;}else{break; //这里一定加个else 不然的话 无法收到返回信息 会被while(1) 始终阻塞在那里}}}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();}
}
$cli = new Client();
$cli->connect();

下面运行客户端