Workerman のカスタムプロトコルを共有して、粘着性と解凍の問題を解決します-Workerman-php.cn

workermanカスタマイズされたプロトコルのスティッキーとアンパックを解決するにはどうすればよいですか?次の記事では、Workerman のカスタムプロトコルがスティッキーパケットとアンパックの問題をどのように解決するかを紹介します。

Workerman のカスタムプロトコルを共有して、粘着性と解凍の問題を解決します

前書き:

私は最近、workerman を使用して Unity3D オンラインゲームのサーバー側を実装しています。 TCP プロトコルを通じて直接通信することもできますが、実際のテスト中にいくつかの小さな問題が発見されました。 [関連する推奨事項: "workermanTutorial"]

たとえば、両側のデータパケットは文字列の形式ですか? また、文字列であるため、カットする必要があります。クライアントまたはサーバーがそれを受信したときにエラーが発生する場合があります。ログを出力したところ、両端で受信したパケットの形式が事前に合意されていないことが判明しました (TCP スティッキーおよびアンパック現象)。これに対する解決策は非常に簡単で、インターネット上にたくさんありますが、ここでは、私が実装したプロトコルを使用して解決したいと思います。それは後で残しておきます。

質問への答え:

インターネット上のオンラインゲームの通信データパケットの形式に関するいくつかの規則も見たことがあります。サーバーサイドスクリプトを実行するために弱い型指定の言語を使用しない場合、他の言語ではバイト配列が使用されることがよくあります。ただし、PHP がバイト配列を受け取るとき、それは実際には文字列ですが、バイト配列には特定の変換が行われないことが前提となります。 C# を例に挙げると、スティッキーパケットなどの問題を解決する場合、バイト配列の前にバイト長 (BitConverter.GetBytes (len)) が追加されます。しかし、これを PHP サーバーに渡して受信すると、最初の 4 バイトが表示されず、いくら変換しても取得できません。その後、Protobuf データメソッドを使用することも考えましたが、PHP ではデータ変換はできますが、クライアント C# に慣れていないため断念しました。

もう 1 つの問題は、実際、他のオンラインゲームサーバーで使用されるフレーム同期のほとんどは、TCP と UDP でも共有される UDP プロトコルを使用していることです。ただし、小規模なマルチプレイヤーオンラインゲームであれば、サーバーとして PHP を使用し、TCP プロトコル通信を使用することは完全に可能です。次に、workerman のカスタムプロトコルとスティッキーおよびアンパックの問題に戻りましょう。

カスタムプロトコル:

Workerman は、PHP のいくつかのソケット関数をカプセル化しました (ソケット関数に関しては、手間をかけても PHP でファイル転送関数を作成することもできます)ガジェット）は、TCP に基づいており、Http、Websocket、Frame などのいくつかのアプリケーション層プロトコルも付属しています。また、ユーザーが独自のプロトコルを定義するための交差部分も予約されています。ユーザーが必要とするのは、その ProtocolInterface インターフェイスを実装することだけです。以下は、次のインターフェイスに実装する必要があるいくつかのメソッドの簡単な紹介です。

1. 入力メソッド

このメソッドでは、サーバーが受信する前に、データパケットを解凍、パケット長のチェック、フィルタリングなどを行うことができます。 0を返す場合はデータパケットを受信側のバッファに入れて待ち続けることを意味し、指定した長さを返す場合はバッファ内の長さを取り出すことを意味します。例外が発生した場合は、false を返してクライアント接続を直接閉じることもできます。

2. エンコード方式

この方式は、データパケットをクライアントに送信する前に、サーバーによってデータパケットの形式を処理する、つまりパケットのカプセル化です。この方法は、フロントエンドとバックエンドが合意されています。

3. decode メソッド

このメソッドはアンパックでもあり、onMessage が実行される前にバッファから処理が必要な場所まで指定された長さを取得します。ロジック調整などを受け付けております。

スティッキーパケットのアンパックによって引き起こされる現象:

TCP はストリームに基づいており、トランスポート層であるため、上位層のアプリケーションはソケットを使用します (次のように理解されます)。インターフェイス）通信では、渡されたデータパケットの始まりと終わりがどこにあるのかわかりません。 TCP の一連の輻輳アルゴリズムに従って、グルーを送信するかバンドルを解除するだけです。文字通り、スティッキーパケットは一緒に送信される複数のデータパケットです。元々は 2 つのパケットがありましたが、クライアントは 1 つのパケットしか受信しませんでした。アンパッキングとは、データパケットを複数のパケットに分割することで、本来は 1 つのデータパケットを受信するはずですが、1 つのデータパケットしか受信しませんでした。したがって、これが解決されていない場合、前述したように、取り決めに従って文字列が送信されると、解凍時にエラーが報告される可能性があります。

スティッキーパケットアンパックの解決策:

1. ヘッダーにパケット長を追加します

 strlen(substr($buffer, 4))) { return 0; } return $bodyLen + 4; } /** * Decode. * * @param string $buffer * @return string */ public static function decode($buffer) { return substr($buffer, 4); } /** * Encode. * * @param string $buffer * @return string */ public static function encode($buffer) { // 对数据包长度向左补零 $bodyLen = strlen($buffer); $headerStr = str_pad($bodyLen, 4, 0, STR_PAD_LEFT); return $headerStr . $buffer; } }

ログイン後にコピー

2特定の文字のセグメンテーション

maxPackageSize) && \strlen($buffer) >= $connection->maxPackageSize) { $connection->close(); return 0; } $pos = \strpos($buffer, "#"); if ($pos === false) { return 0; } // 返回当前包长 return $pos + 1; } /** * Encode. * * @param string $buffer * @return string */ public static function encode($buffer) { return $buffer . "#"; } /** * Decode. * * @param string $buffer * @return string */ public static function decode($buffer) { return \rtrim($buffer, "#"); } }

ログイン後にコピー

スティッキーパケットのアンパッキングテスト:

ここでは、特定の文字列のセグメンテーションに対する解決策のみを示します。上記のホームページ長いパッケージにはまだ問題があります。つまり、最初にパケット長を指定せずにパケットが送信されると、その後のスティッキングまたはアンパッキングのシミュレーションはバッファーに残ります。次のデモンストレーションについては、上記のコードを参照してください。

1. サービスの起動とクライアント接続

2. 服务业务端代码

数据包格式说明一下，字符串以逗号分割，数据包以 #分割，逗号分割第一组是业务方法，如 Login 表示登陆传递，Pos 表示坐标传递，后面带的就是对应方法需要的参数了。

count = 4; $worker->onWorkerStart = function ($connection) { echo "游戏协议服务启动……"; }; // Emitted when new connection come $worker->onConnect = function ($connection) { echo "New Connection\n"; $connection->send("address: " . $connection->getRemoteIp() . " " . $connection->getRemotePort()); }; // Emitted when data received $worker->onMessage = function ($connection, $data) use ($worker, $stream) { echo "接收的数据：" . $data . "\n"; // 简单实现接口分发 $arr = explode(",", $data); if (!is_array($arr) || !count($arr)) { $connection->close("数据格式错误", true); } $func = strtoupper($arr[0]); $client = $connection->getRemoteAddress(); switch($func) { case "LOGIN": $sendData = "Login1"; break; case "POS": $positionX = $arr[1] ?? 0; $positionY = $arr[2] ?? 0; $positionZ = $arr[3] ?? 0; $sendData = "POS,$client,$positionX,$positionY,$positionZ"; break; } $connection->send($sendData); }; // Emitted when connection is closed $worker->onClose = function ($connection) { echo "Connection closed\n"; }; // 接收缓冲区溢出回调 $worker->onBufferFull = function ($connection) { echo "清理缓冲区吧"; }; Worker::runAll(); ?>

ログイン後にコピー

3. 粘包测试

只需要在客户端模拟两个数据包连在一起，但是要以 #分隔，看看服务端接收的时候是一几个包进行处理的。