Swoole 與 ThinkPHP5 相結合，編寫牛B的代碼技术頭條網

Swoole 與 ThinkPHP5 相結合，編寫牛B的代碼

2018-12-02 17:04:05 i人工智能

Linux 操作系統的 PHP 環境，強烈推薦使用 Vagrant 來搭建開發環境

安裝 Swoole PECL 拓展

可以通過 pecl 命令或者通過源碼包編譯安裝，本文采用 pecl 命令來安裝 Swoole在命令行輸入

$ > pecl install swoole

安裝 Swoole PECL 拓展，執行命令後通過php -m命令來檢查 Swoole 是否安裝成功，如果返回的拓展列表中包含swoole則表明已經安裝成功，也可以通過phpinfo來檢查 Swoole 是否安裝成功。

安裝 ThinkPHP5 框架

1.安裝 Composer

如果已經安裝了 Composer 可以跳過本步驟，但是請確定通過composer self-update命令來確保已經使用了最新版本的 Composer 使用以下命令可以直接通過 Composer 官網下載 Composer.phar 並自動安裝到/usr/local/bin/目錄下

$ > php -r "readfile('https://getcomposer.org/installer');" | php -- --install-dir=/usr/local/bin/ --filename=composer

$ > composer self-update

如果以上安裝過程極慢的話，可以嘗試用以下方式通過 Composer 國內鏡像來安裝。

$ > php -r "readfile('http://install.phpcomposer.com/installer');" | php -- --install-dir=/usr/local/bin/ --filename=composer

$ > composer config -g repo.packagist composer https://packagist.phpcomposer.com

$ > composer self-update

2.安裝 ThinkPHP5 框架

使用以下命令把最新版本的 ThinkPHP5 框架安裝到當前目錄下的 thinkSwooleFirst 文件夾中

$ > composer create-project topthink/think thinkSwooleFirst --prefer-dist

安裝 think-swoole Composer 包

把命令行目錄切換到 thinkSwooleFirst 目錄，通過 Composer 安裝 think-swoole

$ > composer require topthink/think-swoole

安裝 think-swoole Composer 包之前必須先安裝好 Swoole PECL 拓展

HelloSwoole

當環境全部搭建完成後，我們在application/index/controller目錄下建立Demon.php文件，用來書寫 Swoole 與 ThinkPHP5 的 TCP 服務器的 Hello World

namespace app\index\controller;
// 必須 use 並繼承 \think\swoole\Server 類
use think\swoole\Server;
class Demon extends Server
{
 // 監聽所有地址
 protected $host = '0.0.0.0';
 // 監聽 9501 端口
 protected $port = 9501;
 // 指定運行模式為多進程
 protected $mode = SWOOLE_PROCESS;
 // 指定 socket 的類型為 ipv4 的 tcp socket
 protected $sockType = SWOOLE_SOCK_TCP;
 // 配置項
 protected $option = [
 /** 
 * 設置啟動的worker進程數
 * 業務代碼是全異步非阻塞的，這裡設置為CPU的1-4倍最合理
 * 業務代碼為同步阻塞，需要根據請求響應時間和系統負載來調整 

 */
 'worker_num' => 4,
 // 守護進程化
 'daemonize' => true,
 // 監聽隊列的長度
 'backlog' => 128
 ];
 /**
 * 收到信息時回調函數
 * @param \swoole_server $serv swoole_server對象
 * @param $fd TCP客戶端連接的文件描述符
 * @param $from_id TCP連接所在的Reactor線程ID
 * @param $data 收到的數據內容
 */
 public function onReceive(\swoole_server $server, $fd, $from_id, $data)
 {
 $server->send($fd, 'onReceive: ' . $data);
 }
}