Linux下搭建swoole服务的基本步骤

class WebSocketService {
 
 private static $instance = NULL;
 public $tagindex = 0;
 public $server = null;
 public $office_cache = null;
 public $timer_arr = []; //该变量保存所有的定时器任务ID，每一个客户端可以通过$timer_arr[客户端ID]
 得到该客户端建立的所有定时器
 public $conf = [
 'host' => '0.0.0.0',
 'port' => 9999, //服务使用端口
 'worker_num' => 2, //启动worker进程数
 'task_worker_num' => 8, //启动task进程数
 'is_daemonize' => 0, //是否后台运行：0-否，1-是
 'log_file' =>'/tmp/swoole_webSocket_server.log', //日志文件路径
 'abc' =>0,
 ];
 
 public function getTagIndex() {
 return $this->conf['abc'];
 }
 
 public function setSetTagIndex($index) {
 $this->conf['abc'] = 100;
 echo $this->getTagIndex();
 }
 
 public function __construct($config = []) {
 $this->office_cache = array('1' => '1', '3'=>'2');
 $this->conf = array_merge($this->conf, (array)$config);
 }
 
 //静态方法，返回此类唯一实例 
 public static function getInstance(){
 if(empty(self::$instance)){ 
 echo "instance 
";
 self::$instance=new WebSocketService(); 
 } 
 return self::$instance; 
 }
 
 /**
 * 服务器端运行webSocket的入口
 */
 public function run() {
 try {
 $this->server = new swoole_websocket_server($this->conf['host'],$this->conf['port']);
 $this->server->set(
 [
 'worker_num' => $this->conf['worker_num'],
 'task_worker_num' =>$this->conf['task_worker_num'],
 'daemonize' => $this->conf['is_daemonize'],
 'log_file' => $this->conf['log_file'],
 ]
 );
 
 //注册方法列表
 $this->server->on('open', [$this, 'open']);
 $this->server->on('message', [$this, 'message']);
 $this->server->on('task', [$this, 'task']);
 $this->server->on('finish', [$this, 'finish']);
 $this->server->on('close', [$this, 'close']);
 
 $this->server->start();
 } catch (Exception $e) {
 var_dump($e->getCode() . ':' . $e->getMessage());
 }
 
 }
 
 /**
 * 建立socket链接时，执行方法
 * @param $server
 * @param $request
 */
 public function open($server, $request) {
 $data = [
 'client_id' => $request->fd,
 'request' => $request
 ];
 echo 'open<<'.$data['client_id'];
 $this->doOpen($data);
 }
 
 /**
 * 发送消息时，执行方法
 * @param $server
 * @param $frame
 */
 public function message($server, $frame) {
 echo "GET_mesage
";
 $data = [
 'client_id' => $frame->fd,
 'data' => $frame->data,
 'frame' => $frame,
 ];
 $this->doMessage($data);
 }
 
 /**
 * 执行具体任务
 * @param $server
 * @param $task_id
 * @param $from_id
 * @param $data
 */
 public function task($server, $task_id, $from_id, $data) {
 $data['task_id'] = $task_id;
 $data['from_id'] = $from_id;
 $this->doTask($data);
 }
 
 /**
 * 任务结果处理
 * @param $server 服务器对象
 * @param $taskId 任务进程ID
 * @param $data
 */
 public function finish($server, $taskId, $data) {
 $data['task_id'] = $taskId;
 $this->doFinish($data);
 }
 
 /**
 * 关闭链接
 * @param $server 服务器对象
 * @param $client_id 客户端唯一标识
 */
 public function close($server, $client_id) {
 $data = [
 'client_id' => $client_id
 ];
 $this->doClose($data);
 }
 
 /**
 * 客户端成功连接到服务器时，会触发该方法
 * 子类根据需求重写该方法
 * @param $data
 * [
 * 'client_id', //客户端唯一标识
 * 'data', //一些请求数据
 * 'frame', //swoole的数据
 * ];
 */
 public function doOpen($data) {
 echo "建立连接成功";
 
 }
 
 /**
 * 得到Swoole Websocket Server
 *
 * @return null|swoole_websocket_server
 */
 public function getServer()
 {
 return $this->server;
 }
 
 /**
 * 收到客户端发来的消息，会触发该方法
 * 子类根据需求重写该方法
 * @param $data
 * [
 * 'client_id', //客户端唯一标识
 * 'data', //客户端发送过来的消息(数据)
 * 'frame', //swoole的数据
 * ];
 */
 public function doMessage($data) {
 $info = json_decode($data['data'],true);
 $officeid = $info['officeid'];
 $client_id = $data['client_id'];
 echo"<<<<".$officeid.">>>>".$client_id."
";
 if ($officeid == 1) {
 $this->sendMsgToClient('2',array('msg' =>'我是1号场地发送给你数据'));
 } else {
 $this->sendMsgToClient('1',array('msg' =>'我是3号场地发送给你数据'));
 }
 }
 
 /**
 * 具体的工作任务。需要通过 $this->doJob()来触发
 * 子类根据需求重写该方法
 * @param $data
 * [
 * 'client_id', //客户端唯一标识
 * ];
 */
 public function doTask($data) {
 }
 
 /**
 * 工作的结果处理。
 * 子类根据需求重写该方法
 * @param $data
 * [
 * 'client_id', //客户端唯一标识
 * ];
 */
 public function doFinish($data) {
 }
 
 /**
 * 客户端断开时会自动触发该方法
 * 子类根据需求重写该方法
 * @param $data
 * [
 * 'client_id', //客户端唯一标识
 * ];
 */
 public function doClose($data) {
 }
 
 
 /**
 * 发送任务
 * @param $data 必须是数组，且要有$data['client_id']
 */
 public function doJob($data) {
 $this->server->task($data);
 }
 
 public function finishJob($data) {
 $this->server->finish($data);
 }
 
 /**
 * 发送消息到客户端
 * @param $client_id
 * @param $msg
 */
 public function sendMsgToClient($client_id, $msg) {
 echo "发送信息给客户端：{$client_id} | {$msg['action']['name']} | " . date('Y-m-dH:i:s') . "
";
 $this->server->push($client_id, json_encode($msg));
 }
 
 /**
 * 关闭客户端链接
 * @param $client_id
 */
 public function closeClient($client_id) {
 $this->server->close($client_id);
 }
 
 /**
 * 添加定时器
 * @param $client_id
 * @param $tick_time
 */
 public function addTimer($client_id, $tick_time) {
 //暂未实现,先使用swoole原生写法
 }
 
 /**
 * 清除定时器
 * @param $client_id
 * @param $arr
 */
 public function clearTimer($client_id, &$arr) {
 if (is_array($arr)) {
 foreach ($arr[$client_id] as $val) {
 if (is_array($val)) {
 foreach ($val as $v) {
 swoole_timer_clear($v);
 }
 } else {
 swoole_timer_clear($val);
 }
 }
 }
 unset($arr[$client_id]);
 }
}

$(document).ready(function(){
 varwsurl = "ws://182.92.101.206:9999/";
 console.log(wsurl);
 varwebsocket = new WebSocket(wsurl);
 websocket.onopen= function(evt){
 console.log('Server: 打开WebSocket连接');
 };

 websocket.onclose= function(evt){
 console.log('Server: 关闭WebSocket连接');
 };

 websocket.onmessage= function(evt){
 varres = JSON.parse(evt.data);
 console.log('Server: 收到消息(来自：'+res+'请求)');
 console.log(res);
 };

 websocket.οnerrοr= function(evt){
 console.log('Server: 出现错误');
 console.log(evt.data);
 }

 functiondoSend(msg){
 console.log('Client:发送消息 ' + msg);
 websocket.send(msg);
 }
});

require'src/WebSocketSwoole/WebSocketService.php';
// require './WebSocketService.php';
session_start();
// $demoService = newWebSocketSwooleWebSocketService();
$demoService =WebSocketSwooleWebSocketService::getInstance();
$demoService->run();