Linux下建置swoole服務的基本步驟-Swoole-PHP中文網

首頁

php框架

Swoole

Linux下建置swoole服務的基本步驟

爱喝马黛茶的安东尼

Nov 22, 2019 pm 04:15 PM

linux swoole 搭建服務

Linux下建置swoole服務的基本步驟

一、安裝swoole服務

1.下載swoole原始碼，下載位址：https://github.com/swoole/swoole-src/releases

2.將tar包上傳到/usr/local/src/swoole下面，這裡面儲存安裝原始檔。

3.解壓縮來源文件，tar –xvfswoole.tar

4.進入到剛解壓縮的目錄下輸入命令phpize

5.注意：phpize是php-devel中的東西，它可以為PHP動態添加擴展，所以，請確保你的機器上安裝了php-devel軟體包。

6.接著，依序輸入以下指令：./configure，執行編譯偵測make，編譯swoole

7.缺少pcre和pcre-devel相關軟體包，安裝上即可。

8.sudo make install

9.php.ini一般在etc下面編譯安裝成功後，我們還需要修改php.ini，在其中加入swoole.so擴充：

10.extension=swoole.so

11.輸入php -m中能查看到swoole說明擴充功能安裝成功。

二、安裝apache啟動swoole服務

（1）測試是否安裝正確啟動swoole Php服務

（2）在apache中新增server.php文件，和client .php文件。一般目錄在var/www/html下面

（3）打開兩個終端在這兩個文件所在的目錄下面打開這兩個文件，可以實現socket長連接服務。

安裝lsof：yum -y install lsof

三、設定Server端

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

登入後複製

四、設定html前端

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

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

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

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

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

登入後複製

五、啟動start.php文件，cd到指定目錄下，然後PHP-CLI運行php start.php。這種方式是沒有啟用執行緒保護的關掉後程式結束執行緒還在佔用。

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

登入後複製

PHP中文網，大量的免費swoole入門教學，歡迎線上學習！

以上是Linux下建置swoole服務的基本步驟的詳細內容。更多資訊請關注PHP中文網其他相關文章！

本網站聲明

本文內容由網友自願投稿，版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容，請聯絡admin@php.cn