Linux to build swoole implementation php message push method

class WebSocketService { private static $instance = NULL; public $tagindex = 0; public $server = null; public $office_cache = null; public $timer_arr = []; // This variable holds all timer task ids. Each client can run $timer_arr[client ID] to obtain all timers created by the client. public $conf = ['host' => '0.0.0.0', 'port' => 9999, // Port used by the service 'worker_num' => 2, // Number of worker processes started 'task_worker_num' => 8, // Number of task processes started 'is_daemonize' => 0, // Whether it is running in the background: 0 - no, 1 - yes' log_file '= >'/TMP/swoole_webSocket_server. Log ', / / log file path '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); } // static method that returns a unique instance of this class public static function getInstance(){if(empty(self::$instance)){echo "instance \n"; self::$instance=new WebSocketService(); } return self::$instance; } /** * Entry for running webSocket on the server */ 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'], ] ); / / registration method list $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()); }} /** * When establishing a socket link, Execute method * @param $server * @param $request */ public function open($server, $request) { $data = [ 'client_id' => $request->fd, 'request' => $request ]; echo 'open<<'.$data['client_id']; $this->doOpen($data); } /** * When sending a message, execute method * @param $server * @param $frame */ public function message($server, $frame) {echo "GET_mesage\n"; $data = [ 'client_id' => $frame->fd, 'data' => $frame->data, 'frame' => $frame, ]; $this->doMessage($data); } /** * Executing a task * @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); } /** * Task result processing * @param $server server object * @param $taskId Task process ID * @param $data */ public function finish($server, $taskId, $data) { $data['task_id'] = $taskId; $this->doFinish($data); } /** * close link * @param $server server object * @param $client_id Unique Identifier of a client */ public function close($server, $client_id) { $data = [ 'client_id' => $client_id ]; $this->doClose($data); } /** * When the client successfully connects to the server, Triggers the method * subclass to override the method on demand * @param $data * [* 'client_id', // client unique identification * 'data', // some request data * 'frame', //swoole data *]; */ public function doOpen($data) {echo "Connection established successfully "; } /** * get Swoole Websocket Server ** @return null|\swoole_websocket_server */ public function getServer() {return $this->server; } /** * Received a message from the client, Triggers the method * subclass to override the method on demand * @param $data * [* 'client_id', // client unique identification * 'data', // client sent message (data) * 'frame', //swoole data *]; */ public function doMessage($data) { $info = json_decode($data['data'],true); $officeid = $info['officeid']; $client_id = $data['client_id']; echo"<<<<".$officeid.">>>>".$client_id."\r\n"; if ($officeid == 1) {$this->sendMsgToClient('2',array('msg' =>' I am site 1 to send you data ')); } else {$this->sendMsgToClient('1',array('msg' =>' I am site 3 to send you data ')); }} /** * Specific job tasks. Need to pass $this->doJob() to trigger * subclasses to override this method on demand * @param $data * [* 'client_id', // client unique identifier *]; */ public function doTask($data) {} /** ** Result processing of work. * Subclasses override this method on demand * @param $data * [* 'client_id', // client unique identifier *]; */ public function doFinish($data) {} /** ** This method is triggered automatically when the client disconnection * Subclasses override this method on demand * @param $data * [* 'client_id', // Client unique identifier *]; */ public function doClose($data) {} /** * Send task * @param $data must be an array, $data['client_id'] */ public function doJob($data) {$this->server->task($data); } public function finishJob($data) { $this->server->finish($data); } /** * Send a message to the client * @param $client_id * @param $msg */ public function sendMsgToClient($client_id, $MSG) {echo "send a message to the client: {$client_id} | {$MSG [' action '] [' name ']} |". The date (' Y -m - dH: I: s'). "\ r \ n"; $this->server->push($client_id, json_encode($msg)); } /** * close the client link * @param $client_id */ public function closeClient($client_id) {$this->server->close($client_id); } /** * Add timer * @param $client_id * @param $tick_time */ public function addTimer($client_id, $tick_time) {// Not implemented yet, use swoole native notation} /** ** to clear timer * @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]); }}

The $(document). Ready (function () {varwsurl = "ws: / / 182.92.101.206:9999 /"; console.log(wsurl); varwebsocket = new WebSocket(wsurl); Websocket. onopen= function(evt){console.log('Server: opens WebSocket connection '); }; Websocket. onclose= function(evt){console.log('Server: close WebSocket connection '); }; websocket.onmessage= function(evt){ varres = JSON.parse(evt.data); console.log('Server: received message (from: '+res+' request)'); console.log(res); }; websocket.οnerrοr= function(evt){console.log('Server: error '); console.log(evt.data); } functiondoSend(msg){console.log('Client: send message '+ msg); websocket.send(msg); }});

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