swoole jsonが不完全な場合の対処方法

swoole json が不完全な場合はどうすればよいですか?

swooleクライアントとサーバー間のデータ送受信の整合性問題の解決策

1. 次の例では、swoole サービスを開始した後、 、9501 ポートをリッスンし、クライアントから送信されたデータは変更されずに返されます。

class Server
{
    private $serv;
    public function __construct() {
        $this->serv = new swoole_server("127.0.0.1", 9501);
        $this->serv->set(array(
            'worker_num'     => 4,   //一般设置为服务器CPU数的1-4倍
            'daemonize'      => 1,  //以守护进程执行
            'max_request'     => 2000,
            'dispatch_mode'    => 2,//进程数据包分配模式 1平均分配，2按FD取摸固定分配，3抢占式分配
            'task_worker_num'   => 8,  //task进程的数量
            "task_ipc_mode "   => 3 ,  //使用消息队列通信，并设置为争抢模式
            "log_file"      => "./log/taskqueueu.log" ,//日志
        ));
        $this->serv->on('Receive', array($this,'onReceive'));//接收到数据时回调此函数
        $this->serv->start();
    }
    public function onReceive(swoole_server $serv, $fd, $from_id, $data ) {
                $serv->send($fd, $data);
                        usleep(500); //不加延时的话，经常两条数据被合并成一条返回了。
                        $serv->close($fd);
    }   
    public function onClose(swoole_server $serv, $fd) {
                $serv->send($fd, 'CLOSED');
    }   
}

新しいサーバーでサーバーを直接起動します。

2. swoole クライアントを起動し、サーバーにデータを送信し、戻り値を受け取ります。

$client = new swoole_client(SWOOLE_SOCK_TCP);
if (!$client->connect('127.0.0.1', 9501, -1))
{
    exit("connect failed. Error: {$client->errCode}\n");
}
$data=[
        'type'=>1, 
        'data'=>array(
                'PlatformCode'=>'...........很长的数据.',
            )
   ];
$sender=$client->send(json_encode($data)."\r\n\r\n");
while($result = $client->recv()){
    if($result=='CLOSED'){
            echo "任务结束。byebye~\r\n";
            break;
    }else{
      echo $result;
  }
}
$client->close();

比較的大きなデータ パケットを送信する場合、受信した json パケットが不完全であることがわかりますが、これはサーバーでの設定などの EOF プロトコルの処理方法を使用することで解決できます:

    $serv->set(
        array('open_eof_split' => TRUE, 'package_eof' => "\r\n\r\n")
    );

このようにして、「\r\n\r\n」が EOF プロトコルの終了文字になります。

データ パケットを送信するときは、パケットの最後に「\r\n\r\n」を追加します。インターフェイス データが検出されたときにこの文字が検出された場合、データは送信されたものとみなされます。受信されるため、データの整合性が保証されます。

注: '\r\n\r\n' 文字をデータ パケットに含めることはできません。そうしないと、サブパッケージ化エラーが発生します。

Swoole のサーバーと非同期クライアントは両方とも onReceive コールバック関数でデータ パケットを処理します。プロトコル処理が設定されている場合、onReceive イベントは完全なデータ パケットが受信された場合にのみトリガーされます。

別の方法として、次のように、送信するパケットの長さを事前に設定することもできます。

$server->set(array(
        'open_length_check' => true,
        'package_max_length' => 81920,
        'package_length_type' => 'n', //see php pack()
        'package_length_offset' => 0,
        'package_body_offset' => 2,
));

パケットの長さを固定して、データの整合性を確保できます。公式コメントは次のとおりです。

固定ヘッダーのプロトコルは非常に一般的で、BAT サーバー プログラムでよく見られます。このプロトコルの特徴は、データ パケットが必ずパケット ヘッダーとパケット ボディで構成されることです。パケットヘッダにはパケットボディまたはパケット全体の長さを指定するフィールドがあり、通常は2バイト/4バイトの整数で表されます。サーバーはパケット ヘッダーを受信した後、完全なデータ パケットを実現するために長さの値に基づいてさらにどのくらいのデータを受信する必要があるかを正確に制御できます。 Swoole の構成はこのプロトコルを非常によくサポートしており、あらゆる状況に対処するために 4 つのパラメーターを柔軟に設定できます。

Swoole のサーバーと非同期クライアントは両方とも onReceive コールバック関数でデータ パケットを処理します。プロトコル処理が設定されている場合、onReceive イベントは完全なデータ パケットが受信された場合にのみトリガーされます。同期クライアントがプロトコル処理を設定した後、$client->recv() を呼び出すときに長さを渡す必要はなくなりました。recv 関数は、完全なパケットを受信した後に戻ります。そうでない場合は、エラーが発生します。

以上がswoole jsonが不完全な場合の対処方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。