PHP 在之前的某一段時間里是被認為無法處理好協議層面的,但是隨著Workerman,Swoole 以及目前風頭正上的 MEEPOPS 的出現,徹底打破了這一局面,讓很多人發現原來 PHP 能做的事越來越多。
接下來本章將詳細介紹如何用 swoole_websocket_server 和 ThinkPHP5 的命令行來建立 websocket 服務器。
本章沒有使用think-swoole Composer 包。
創建 ThinkPHP5 自定義命令行
在 ThinkPHP5 中推薦使用命令行工具來管理運行不需要外部訪問的程序,如 http 服務器啟動程序,websocket 服務器啟動程序,crontab(計劃任務/定時器)等
1.創建命令行類
-
- 創建application/console/WebSocket.php文件
```php
<?php
namespace app\Console;
use think\console\Command;
use think\console\Input;
use think\console\Output;
class WebSocket extends Command
{
// 命令行配置函數
protected function configure()
{
// setName 設置命令行名稱
// setDescription 設置命令行描述
$this->setName('websocket:start')->setDescription('Start Web Socket Server!');
}
// 設置命令返回信息
protected function execute(Input $input, Output $output)
{
$output->writeln("WebSocket: Start.\n");
}
}
```
- 2.修改配置文件
文件所在 application/command.php
~~~
<?php
return [
'app\console\WebSocket',
];
~~~
這時在項目根目錄輸入命令行就可以看到已經配置好的命令行類及描述
編寫 Web Socket 邏輯代碼
接下來我們就可以正式編寫 web socket 服務器的代碼了,Swoole 幫我們內置了 web socket 服務器支持,通過幾行 PHP 代碼就可以寫出一個異步非阻塞多進程的 web scoket 服務器。
在application/console/WebSocket.php文件中繼續編寫代碼
```php
<?php
namespace app\Console;
use think\console\Command;
use think\console\Input;
use think\console\Output;
class WebSocket extends Command
{
// Server 實例
protected $server;
protected function configure()
{
$this->setName('websocket:start')->setDescription('Start Web Socket Server!');
}
protected function execute(Input $input, Output $output)
{
// 監聽所有地址,監聽 10000 端口
$this->server = new \swoole_websocket_server('0.0.0.0', 10000);
// 設置 server 運行前各項參數
// 調試的時候把守護進程關閉,部署到生產環境時再把注釋取消
// $this->server->set([
// 'daemonize' => true,
// ]);
// 設置回調函數
$this->server->on('Open', [$this, 'onOpen']);
$this->server->on('Message', [$this, 'onMessage']);
$this->server->on('Close', [$this, 'onClose']);
$this->server->start();
// $output->writeln("WebSocket: Start.\n");
}
// 建立連接時回調函數
public function onOpen(\swoole_websocket_server $server, \swoole_http_request $request)
{
echo "server: handshake success with fd{$request->fd}\n";
}
// 收到數據時回調函數
public function onMessage(\swoole_websocket_server $server, \swoole_websocket_frame $frame)
{
echo "receive from {$frame->fd}:{$frame->data},opcode:{$frame->opcode},fin:{$frame->finish}\n";
$server->push($frame->fd, "this is server");
}
// 連接關閉時回調函數
public function onClose($server, $fd)
{
echo "client {$fd} closed\n";
}
}
```
在命令行輸入
~~~
php think websocket:start
~~~
啟動 web socket 服務器
接下來我們使用 JavaScript 代碼來測試 Web Socket 服務器是否正常運行,推薦使用 Chrome 來進行調試
~~~
<script>
var websocket = new WebSocket('ws://localhost:10000');
websocket.onopen = function (evt) { onOpen(evt) };
websocket.onclose = function (evt) { onClose(evt) };
websocket.onmessage = function (evt) { onMessage(evt) };
websocket.onerror = function (evt) { onError(evt) };
function onOpen(evt) {
console.log("Connected to WebSocket server.");
}
function onClose(evt) {
console.log("Disconnected");
}
function onMessage(evt) {
console.log('Retrieved data from server: ' + evt.data);
}
function onError(evt) {
console.log('Error occured: ' + evt.data);
}
</script>
~~~

打開 Chrome 瀏覽器的調試工具,切換到 Console 選項卡下看到如下圖結果,表示 web socket 連接成功
同時服務器端命令行下應該看到如下回執消息
`server: handshake success with fd1`

- PHP7新特性
- 優雅的寫代碼
- 常見的代碼優化
- 常用的工具類
- PHP原生生成EXCEL
- PHP地理位置計算
- PHP獲取服務器狀態
- 駝峰轉下劃線
- 百度地圖兩點坐標距離計算
- 判斷是否是url
- PHP常見header頭
- 郵件發送類
- 阿拉伯數字轉化為大寫
- 獲取漢字首個拼音
- 根據身份證號獲取星座
- 生成驗證碼類
- 生成唯一ID
- 身份證驗證類
- PHP中文轉拼音
- Nginx配置文件
- curl獲取網頁內容
- 快遞查詢api
- 上傳圖片類
- 股票類
- 找回密碼類
- 字符串助手函數
- 校驗數據規則
- PHP獲取收集相關信息
- 字符串截取助手函數
- 網頁中提取關鍵字
- 檢測瀏覽器語言
- 微信相關類
- 微信獲取access_token
- 獲取用戶基本信息
- 代碼規范
- 編程規范(psr-1,2)
- 編程規范(原作者的建議)
- 經驗
- 常用函數地址
- 函數集合
- 一些常識
- MYSQL相關知識
- 常用sql
- mysql事務隔離級別
- Read uncommitted
- Read committed
- Repeatable read
- Serializable
- 高性能MYSQL讀書筆記
- 第一章MYSQL的架構
- mysql邏輯架構
- redis相關知識
- 1.安裝redis
- 3.php操作redis
- 隊列
- 悲觀鎖
- 樂觀鎖
- 發布
- 訂閱
- redis實戰-文章投票
- 設計模式
- 創建模型實例
- 單例模式
- 工廠模式
- AnimalInterface.php
- Chicken.php
- Factory.php
- Farm.php
- Pig
- SampleFactory.php
- Zoo
- 抽象工廠模式
- AnimalFactory
- Factory
- FarmInterface
- Income
- PandaZoo
- PeonyZoo
- PigFarm
- PlantFactory
- RiceFarm
- ZooInterface
- 原型模式
- 建造者模式
- 結構型模式實例
- 橋接模式
- 享元模式
- 外觀模式
- 適配器模式
- 裝飾器模式
- 組合模式
- 代理模式哦
- 過濾器模式
- 行為型模式實例
- 模板模式
- 策略模式
- 狀態模式
- 觀察者模式
- 責任鏈模式
- 訪問者模式
- 解釋器模式
- 空對象模式
- 中介者模式
- 迭代器模式
- 命令模式
- 備忘錄模式
- 網絡知識
- 互聯網協議概述
- nginx簡易交互過程
- HTTP知識
- LINUX相關知識
- swoole學習
- 1.初識swoole
- 2.WebSocket PHP 即時通訊開發
- 3.異步多進程的 CURL
- 4.異步非阻塞多進程的 Http 服務器
- 5.TCP 服務器
- 5.1同步 TCP 客戶端
- 5.2異步 TCP 客戶端
- 6.UDP 服務器
- 7.異步多任務處理
- 8.毫秒定時器
- 9.高并發投票
- ThinkPHP5學習
- 命令行操作
- 所有命令行中用到的基類
- 1.base
- 2.WorkerBase
- 3.TimeWorkerBase
- 4.CycleWorkerBase
- 5.WorkerCommandBase
- 6.WorkerHookBase
- 1.基礎命令實現
- 2.建立Linux上的守護源碼
- 3.發送模板消息
- 4.基于命令行實現自己的隊列模式
- 5.發送定時短信
- thinkphp5使用sentry
- sentry通知,記錄日志
- 高級查詢
- Kafka相關
- 1.安裝
- 2.為php打擴展
- 3.kafka實現
- 一些工具搭建
- sentry日志收集系統搭建
- walle搭建
- php實現定時任務
- 檢測文件變化