Workerman是一款純PHP開發的開源高性能的PHP socket 服務器框架。被廣泛的用於手機app、手游服務端、網絡游戲服務器、聊天室服務器、硬件通訊服務器、智能家居、車聯網、物聯網等領域的開發。 支持TCP長連接,支持Websocket、HTTP等協議,支持自定義協議。基於workerman開發者可以更專注於業務邏輯開發,不必再為PHP Socket底層開發而煩惱。這些都是thinkphp5開發文檔里面的資料,但是文檔里面有些事沒有寫清楚的,下面小編自身從頭到尾寫一個完整的案例。
首先通過 composer 安裝,切換到項目根目錄,輸入命令
composer require topthink/think-worker
如果需要在window下做服務端,還需要
composer require workerman/workerman-for-win
首先要明白composer之后workerman是安裝到哪去了,安裝到tp5項目下vendor目錄中
運行出現錯誤PHP Fatal error: Call to undefined function Workerman\Lib\pcntl_signal(),需要刪除vendor\workerman\workerman,防止命名覆蓋
服務端使用示例如下:
新增啟動服務文件server.php,在項目根目錄(和application同級目錄,不要放入public中)
<?php #!/usr/bin/env php define('APP_PATH', __DIR__ . '/application/'); define('BIND_MODULE','push/Worker'); // 加載框架引導文件 require __DIR__ . '/thinkphp/start.php';
關於server.php 文檔說,放到項目根目錄,其實這個文件放到哪個目錄並沒有什么關系。通過命令行訪問到這個文件,然后執行它就可以了。關鍵是要確保每一行代碼中訪問的目錄都是可以正常訪問到。不然執行中會提示找不到控制器或者模塊之類的信息。
新增服務處理類,在tp5目錄中application\push\controller\Worker.php中新建worker.php控制器,其中127.0.0.1:2346為服務器的私有ip地址和端口,查看服務器私有ip地址可以通過ifconfig來查看inet addr就是私有ip地址。
端口這塊很多人都會出錯,因為服務器再默認情況下是不會打開你要配置的2346端口的,所有為保證配置成功,你首先需要去服務器防火牆添加一個允許訪問2346的端口的規則。下面是詳細控制器代碼
<?php namespace app\push\controller; use think\worker\Server; use Workerman\Lib\Timer; class Worker extends Server{ protected $socket = 'websocket://127.0.0.1:2346'; /** * 收到信息 * @param $connection * @param $data */ public function onMessage($connection, $data) { $connection->send('我收到你的信息了'); $connection->send('你給我發送了'.$data); // $timer_id = Timer::add(1, function () use ($connection, $data, &$timer_id) { // $connection->send('timer_id=' . $timer_id); // }); } /** * 當連接建立時觸發的回調函數 * @param $connection */ public function onConnect($connection) { } /** * 當連接斷開時觸發的回調函數 * @param $connection */ public function onClose($connection) { } /** * 當客戶端的連接上發生錯誤時觸發 * @param $connection * @param $code * @param $msg */ public function onError($connection, $code, $msg) { echo "error $code $msg\n"; } /** * 每個進程啟動 * @param $worker */ public function onWorkerStart($worker) { } }
在命令行下運行,啟動監聽服務
php server.php start
開啟了服務后,如果成功的話我們可以看到,start success!
最后客戶端代碼需要注意的是127.0.0.1為你服務器的公網ip地址,這個地址就是通常域名需要解析的ip地址。搞清楚了這點以后我們再打開chrome瀏覽器,再打開項目的任一網頁(js跨域不能通訊),按F12打開調試控制台,在Console一欄輸入(我建議大家把下面代碼放入到html頁面用js運行)
<!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <title>Websocket 測試</title> </head> <body> <h1>Websocket 測試</h1> </body> <script> ws = new WebSocket("ws://127.0.0.1:2346"); ws.onopen = function() { console.log("連接成功"); ws.send('tom'); console.log("給服務端發送一個字符串:tom"); }; ws.onmessage = function(e) { console.log("收到服務端的消息:" + e.data); }; // ws.send('保持連接,發第二次信息,查看服務器回應'); </script> </html>
最后都配置成功的話,我們切換到那個有js代碼的html頁面可以看到調用成功了。