swoole 固定包头格式

先上图

server 端

client 客户端

原文参考 https://blog.csdn.net/ldy3243942/article/details/40920743

3.固定包头类型协议

固定包头协议是在实际应用中最常用的协议。该协议的内容是规定一个固定长度的包头，在包头的固定位置有一个指定好的字段存放了后续数据的实际长度。这样，服务器端可以先读取固定长度的数据，从中提取出长度，然后再读取指定长度的数据，即可获取一段完整的数据。
在Swoole中，同样提供了固定包头的协议格式。需要注意的是，Swoole只允许二进制形式的包头，因此，需要使用pack、unpack来打包、解包。
通过设置open_length_check选项，即可打开固定包头协议解析功能。此外还有package_length_offset，package_body_offset和package_length_type三个配置项用于控制解析功能。package_length_offset规定了包头中第几个字节开始是长度字段，package_body_offset规定了包头的长度，package_length_type规定了长度字段的类型。
具体设置如下：

$this->serv->set(array(
    'package_max_length' => 8192,
    'open_length_check'=> true,
    'package_length_offset' => 0,
    'package_body_offset' => 4,
    'package_length_type' => 'N'
));

具体如何设置这些参数请参考文档
OK，废话不多讲，直接上实例：
服务器端：

public function onReceive( swoole_server $serv, $fd, $from_id, $data ) {    $length = unpack("N" , $data)[1];
    echo "Length = {$length}\n";
    $msg = substr($data,-$length);
    echo "Get Message From Client {$fd}:{$msg}\n";
}

客户端：

$msg_length = pack("N" , strlen($msg_normal) ). $msg_normal;

$i = 0;
while( $i < 100 ) {    $this->client->send( $msg_length );
    $i ++;
}

直接运行，Perfect！
点此查看完整实例

点此查看其他相关源码

下面是server代码稍作修改

<?php
class Server
{private $serv;public function __construct() {$this->serv = new swoole_server("0.0.0.0", 9501);$this->serv->set(array('worker_num' => 8,'daemonize' => false,'max_request' => 10000,'dispatch_mode' => 2,'package_max_length' => 8192,'open_length_check'=> true,'package_length_offset' => 0,'package_body_offset' => 4,'package_length_type' => 'N'));$this->serv->on('Start', array($this, 'onStart'));$this->serv->on('Connect', array($this, 'onConnect'));$this->serv->on('Receive', array($this, 'onReceive'));$this->serv->on('Close', array($this, 'onClose'));$this->serv->start();}public function onStart( $serv ) {echo "Start\n";}public function onConnect( $serv, $fd, $from_id ) {echo "Client {$fd} connect\n";}public function onReceive( swoole_server $serv, $fd, $from_id, $data ) {print($data);file_put_contents("2.txt",$data);//This is a Msgecho "\n";print_r(unpack("N",$data));/*Array([1] => 13)*/$length = unpack("N" , $data)[1];echo "Length = {$length}\n";$msg = substr($data,-$length);echo "Get Message From Client {$fd}:{$msg}\n";}public function onClose( $serv, $fd, $from_id ) {echo "Client {$fd} close connection\n";}
}
new Server();

客户端代码 client

<?php
class Client
{private $client;public function __construct() {$this->client = new swoole_client(SWOOLE_SOCK_TCP);}public function connect() {if( !$this->client->connect("127.0.0.1", 9501 , 1) ) {echo "Error: {$fp->errMsg}[{$fp->errCode}]\n";}$msg_normal = "This is a Msg";
//              $msg_eof = "This is a Msg\r\n";//      echo  pack("N" , strlen($msg_normal) );$msg_length = pack("N" , strlen($msg_normal) ). $msg_normal;file_put_contents("1.txt",$msg_length);$i = 0;while( $i < 5 ) {$this->client->send( $msg_length );$i ++;}}
}
$client = new Client();
$client->connect();~

看下1.txt 发现前面变成看不懂的也就是二进制流

到此为止就结束了 server端应该也是收到流才对

再看下server 的2.txt

server 端生成的同样也是二进制再开头的

大概就这样了

swoole 固定包头格式相关推荐

java数据存入txt_java将数据写入到txt文件中（txt有固定的格式）
java将数据写入到txt文件中,这个应该对于学过java I/O的人来说是很简单的事情了,但是如果要将数据以固定的格式写入到txt文件中,就需要一定的技巧了. 这里举个简单的例子,以供参考: 比如我 ...
如何修改固定了格式的WPS表格
很多情况下,我们可能会遇到WPS的 excel 表格的格式已经被固定为某种特定的格式,比如日期或者有下拉选框等等,而且我们往表格里面填写内容的时候,就会报错:请按照XX格式填写,例如XX,给我们带来很 ...
由freemarker毫秒级时间谈固定日期格式
需要在freemarker中呈现毫秒级时间,查了很多资料,始终不对.最后终于弄明白原因:java和c#中日期的毫秒表示是不同的.c#中的毫秒级用f表示,java中用S表示.而我将一直在java中用C# ...
js验证用户输入的座机/手机/固定电弧格式是否正确
编写方法如下 const checkTelephone = (value) => {var isMobilePhone = /^([0-9]{3,4}-)?[0-9]{7,8}$/;var is ...
bootstrap bootstraptable 固定列_1个Excel公式按条件自定义格式显示固定电话号码
点击右上角"关注",每天免费获取干货教程前面写了很多篇关于数据查询.数据统计.数据分析.公式排错的教程,今天换一个口味,写个关于自定义格式显示数据的教程. 因为工作中很多时候都需 ...
网络处理中TLV形式的不固定格式匹配
假设如果已经实现了控制平面和数据转发平面的分离,即SDN,那么网络协议就被弱化了!为何如此放狂言?还得从历史说起! 如果上面的假设不成立,那么如何实现独立的控制平面和独立的数据平面,对于控制平面,简单 ...
当SWOOLE遇上PROTOCOL
前言上回我们简单介绍了一下TCP Server的工作方式以及如何用Swoole实现一个简单的TCP Server,这次我们来聊聊信息流动中,非常重要基石之一--协议(PROTOCOL). 协议,通信 ...
PS流包格式之PS/SYS/PSM/PES头
PS流包格式 1,PS流的基本组成 PS流由很多个PS包组成. 每个PS包由如下组成: PS header + SYS header(I帧)+PSM header(I帧) +PES header+ P ...
Swoole基础知识，安装，websocket应用及各种问题详解
1. swoole基础-概述 Swoole基础课程正式推出!零基础开始,让你循环渐进的掌握swoole. 传统的phper们大部分都是用于开发web应用程序,并且大部分都是在用类似yii\larave ...

swoole 固定包头格式

3.固定包头类型协议

swoole 固定包头格式相关推荐

最新文章

热门文章