如何定制協(xié)議
實(shí)際上制定自己的協(xié)議是比較簡(jiǎn)單的事情。簡(jiǎn)單的協(xié)議一般包含兩部分:
- 區(qū)分?jǐn)?shù)據(jù)邊界的標(biāo)識(shí)
- 數(shù)據(jù)格式定義
一個(gè)例子
協(xié)議定義
這里假設(shè)區(qū)分?jǐn)?shù)據(jù)邊界的標(biāo)識(shí)為換行符"\n"（注意請(qǐng)求數(shù)據(jù)本身內(nèi)部不能包含換行符），數(shù)據(jù)格式為Json，例如下面是一個(gè)符合這個(gè)規(guī)則的請(qǐng)求包。
{"type":"message","content":"hello"}
注意上面的請(qǐng)求數(shù)據(jù)末尾有一個(gè)換行字符(在PHP中用雙引號(hào)字符串"\n"表示)，代表一個(gè)請(qǐng)求的結(jié)束。
實(shí)現(xiàn)步驟
在Workerman中如果要實(shí)現(xiàn)上面的協(xié)議，假設(shè)協(xié)議的名字叫JsonNL，所在項(xiàng)目為MyApp，則需要以下步驟
1、協(xié)議文件放到項(xiàng)目的Protocols文件夾，例如文件MyApp/Protocols/JsonNL.php
2、實(shí)現(xiàn)JsonNL類(lèi)，以namespace Protocols;為命名空間，必須實(shí)現(xiàn)三個(gè)靜態(tài)方法分別為 input、encode、decode
注意：workerman會(huì)自動(dòng)調(diào)用這三個(gè)靜態(tài)方法，用來(lái)實(shí)現(xiàn)分包、解包、打包。具體流程參考下面執(zhí)行流程說(shuō)明。
workerman與協(xié)議類(lèi)交互流程
1、假設(shè)客戶端發(fā)送一個(gè)數(shù)據(jù)包給服務(wù)端，服務(wù)端收到數(shù)據(jù)(可能是部分?jǐn)?shù)據(jù))后會(huì)立刻調(diào)用協(xié)議的input方法，用來(lái)檢測(cè)這包的長(zhǎng)度，input方法返回長(zhǎng)度值$length給workerman框架。
2、workerman框架得到這個(gè)$length值后判斷當(dāng)前數(shù)據(jù)緩沖區(qū)中是否已經(jīng)接收到$length長(zhǎng)度的數(shù)據(jù)，如果沒(méi)有就會(huì)繼續(xù)等待數(shù)據(jù)，直到緩沖區(qū)中的數(shù)據(jù)長(zhǎng)度不小于$length。
4、緩沖區(qū)的數(shù)據(jù)長(zhǎng)度足夠后，workerman就會(huì)從緩沖區(qū)截取出$length長(zhǎng)度的數(shù)據(jù)(即分包)，并調(diào)用協(xié)議的decode方法解包，解包后的數(shù)據(jù)為$data。
3、解包后workerman將數(shù)據(jù)$data以回調(diào)onMessage($connection, $data)的形式傳遞給業(yè)務(wù)，業(yè)務(wù)在onMessage里就可以使用$data變量得到客戶端發(fā)來(lái)的完整并且已經(jīng)解包的數(shù)據(jù)了。
4、當(dāng)onMessage里業(yè)務(wù)需要通過(guò)調(diào)用$connection->send($buffer)方法給客戶端發(fā)送數(shù)據(jù)時(shí)，workerman會(huì)自動(dòng)利用協(xié)議的encode方法將$buffer打包后再發(fā)給客戶端。
具體實(shí)現(xiàn)
MyApp/Protocols/JsonNL.php的實(shí)現(xiàn)
namespace Protocols;
class JsonNL
{
/**
* 檢查包的完整性
* 如果能夠得到包長(zhǎng)，則返回包的在buffer中的長(zhǎng)度，否則返回0繼續(xù)等待數(shù)據(jù)
* 如果協(xié)議有問(wèn)題，則可以返回-1，當(dāng)前客戶端連接會(huì)因此斷開(kāi)
* @param string $buffer
* @return int
*/
public static function input($buffer)
{
// 獲得換行字符"\n"位置
$pos = strpos($buffer, "\n");
// 沒(méi)有換行符，無(wú)法得知包長(zhǎng)，返回0繼續(xù)等待數(shù)據(jù)
if($pos === false)
{
return 0;
}
// 有換行符，返回當(dāng)前包長(zhǎng)（包含換行符）
return $pos+1;
}
/**
* 打包，當(dāng)向客戶端發(fā)送數(shù)據(jù)的時(shí)候會(huì)自動(dòng)調(diào)用
* @param string $buffer
* @return string
*/
public static function encode($buffer)
{
// json序列化，并加上換行符作為請(qǐng)求結(jié)束的標(biāo)記
return json_encode($buffer)."\n";
}
/**
* 解包，當(dāng)接收到的數(shù)據(jù)字節(jié)數(shù)等于input返回的值（大于0的值）自動(dòng)調(diào)用
* 并傳遞給onMessage回調(diào)函數(shù)的$data參數(shù)
* @param string $buffer
* @return string
*/
public static function decode($buffer)
{
// 去掉換行，還原成數(shù)組
return json_decode(trim($buffer), true);
}
}至此，JsonNL協(xié)議實(shí)現(xiàn)完畢，可以在MyApp項(xiàng)目中使用，使用方法例如下面
文件：MyApp\start.php
use Workerman\Worker;
use Workerman\Connection\TcpConnection;
require_once __DIR__ . '/vendor/autoload.php';
$json_worker = new Worker('JsonNL://0.0.0.0:1234');
$json_worker->onMessage = function(TcpConnection $connection, $data) {
// $data就是客戶端傳來(lái)的數(shù)據(jù)，數(shù)據(jù)已經(jīng)經(jīng)過(guò)JsonNL::decode處理過(guò)
echo $data;
// $connection->send的數(shù)據(jù)會(huì)自動(dòng)調(diào)用JsonNL::encode方法打包，然后發(fā)往客戶端
$connection->send(array('code'=>0, 'msg'=>'ok'));
};
Worker::runAll();
...提示
workerman會(huì)嘗試加載Protocols命名空間下的協(xié)議，例如new Worker('JsonNL://0.0.0.0:1234')會(huì)嘗試加載Protocols\JsonNL協(xié)議。
如果報(bào)錯(cuò)Class 'Protocols\JsonNL' not found，請(qǐng)參考自動(dòng)加載實(shí)現(xiàn)自動(dòng)加載。
協(xié)議接口說(shuō)明
在Workerman中開(kāi)發(fā)的協(xié)議類(lèi)必須實(shí)現(xiàn)三個(gè)靜態(tài)方法，input、encode、decode，協(xié)議接口說(shuō)明見(jiàn)Workerman/Protocols/ProtocolInterface.php，定義如下：
namespace Workerman\Protocols;
use \Workerman\Connection\ConnectionInterface;
/**
* Protocol interface
* @author walkor <walkor@workerman.net>
*/
interface ProtocolInterface
{
/**
* 用于在接收到的recv_buffer中分包
*
* 如果可以在$recv_buffer中得到請(qǐng)求包的長(zhǎng)度則返回整個(gè)包的長(zhǎng)度
* 否則返回0，表示需要更多的數(shù)據(jù)才能得到當(dāng)前請(qǐng)求包的長(zhǎng)度
* 如果返回-1，則代表錯(cuò)誤的請(qǐng)求，則連接會(huì)斷開(kāi)
*
* @param ConnectionInterface $connection
* @param string $recv_buffer
* @return int
*/
public static function input($recv_buffer, ConnectionInterface $connection);
/**
* 用于請(qǐng)求解包
*
* input返回值大于0，并且Workerman收到了足夠的數(shù)據(jù)，則自動(dòng)調(diào)用decode
* 然后觸發(fā)onMessage回調(diào)，并將decode解碼后的數(shù)據(jù)傳遞給onMessage回調(diào)的第二個(gè)參數(shù)
* 也就是說(shuō)當(dāng)收到完整的客戶端請(qǐng)求時(shí)，會(huì)自動(dòng)調(diào)用decode解碼，無(wú)需業(yè)務(wù)代碼中手動(dòng)調(diào)用
* @param ConnectionInterface $connection
* @param string $recv_buffer
*/
public static function decode($recv_buffer, ConnectionInterface $connection);
/**
* 用于請(qǐng)求打包
*
* 當(dāng)需要向客戶端發(fā)送數(shù)據(jù)即調(diào)用$connection->send($data);時(shí)
* 會(huì)自動(dòng)把$data用encode打包一次，變成符合協(xié)議的數(shù)據(jù)格式，然后再發(fā)送給客戶端
* 也就是說(shuō)發(fā)送給客戶端的數(shù)據(jù)會(huì)自動(dòng)encode打包，無(wú)需業(yè)務(wù)代碼中手動(dòng)調(diào)用
* @param ConnectionInterface $connection
* @param mixed $data
*/
public static function encode($data, ConnectionInterface $connection);
}注意：
Workerman中沒(méi)有嚴(yán)格要求協(xié)議類(lèi)必須基于ProtocolInterface實(shí)現(xiàn)，實(shí)際上協(xié)議類(lèi)只要類(lèi)包含了input、encode、decode三個(gè)靜態(tài)方法即可。
