首頁 > php框架 > Swoole > 主體

swoole json不完整怎麼辦

藏色散人
發布: 2020-04-09 10:16:49
原創
2499 人瀏覽過

swoole json不完整怎麼辦

swoole json不完整怎麼辦?

swoole客戶端與服務端收發資料完整性問題解決

一、下面這個實例,啟動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');
    }   
}
登入後複製

直接new Server啟動服務端。

二、啟動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的Server和非同步Client都是在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部分組成。包頭由一個字段指定了包體或整個包的長度,長度一般是使用2字節/4字節整數來表示。伺服器收到包頭後,可以根據長度值來精確控制需要再接收多少資料就時完整的資料包。 Swoole的配置可以很好的支援這種協議,可以靈活地設定4項參數來應對所有情況。

Swoole的Server和非同步Client都是在onReceive回呼函數中處理資料包,當設定了協定處理後,只有收到完整資料包時才會觸發onReceive事件。同步客戶端在設定了協定處理後,呼叫 $client->recv() 不再需要傳入長度,recv函數在收到完整資料包或發生錯誤後傳回。

以上是swoole json不完整怎麼辦的詳細內容。更多資訊請關注PHP中文網其他相關文章!

相關標籤:
來源:php.cn
本網站聲明
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn
熱門教學
更多>
最新下載
更多>
網站特效
網站源碼
網站素材
前端模板