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頁面可以看到調用成功了。

