# 封装器-Pack
```php
interface IPack
{
function encode($buffer);
function decode($buffer);
function pack($data, $topic = null);
function unPack($data);
function getProbufSet();
function errorHandle($e, $fd);
}
```
需要实现6个方法
encode和decode分别是协议头的封装和解析工作，pack和unPack是协议体的序列化和反序列化工作，getProbufSet将返回swoole的set中关于协议头解析相关的配置，errorHandle是协议解析出错后的处理函数。
默认提供了几组简易配置
```php
class LenJsonPack implements IPack
{
protected $package_length_type = 'N';
protected $package_length_type_length = 4;
protected $package_length_offset = 0;
protected $package_body_offset = 0;
protected $last_data = null;
protected $last_data_result = null;
/**
* 数据包编码
* @param $buffer
* @return string
* @throws SwooleException
*/
public function encode($buffer)
{
$total_length = $this->package_length_type_length + strlen($buffer) - $this->package_body_offset;
return pack($this->package_length_type, $total_length) . $buffer;
}
/**
* @param $buffer
* @return string
*/
public function decode($buffer)
{
return substr($buffer, $this->package_length_type_length);
}
public function pack($data, $topic = null)
{
if ($this->last_data != null && $this->last_data == $data) {
return $this->last_data_result;
}
$this->last_data = $data;
$this->last_data_result = $this->encode(json_encode($data, JSON_UNESCAPED_UNICODE));
return $this->last_data_result;
}
public function unPack($data)
{
$value = json_decode($this->decode($data));
if (empty($value)) {
throw new SwooleException('json unPack 失败');
}
return $value;
}
public function getProbufSet()
{
return [
'open_length_check' => true,
'package_length_type' => $this->package_length_type,
'package_length_offset' => $this->package_length_offset, //第N个字节是包长度的值
'package_body_offset' => $this->package_body_offset, //第几个字节开始计算长度
'package_max_length' => 2000000, //协议最大长度)
];
}
public function errorHandle(\Throwable $e, $fd)
{
get_instance()->close($fd);
}
}
```
## 自定义协议举例
协议 = 包头(4字节 `msg_type` + 4字节包体长) + 包体(protobuf)
```php
<?php
namespace app\Pack;
use Server\Pack\IPack;
use Server\CoreBase\SwooleException;
use Game\Protobuf\Ping;
use Game\Protobuf\Pong;
use stdClass;
class GamePack implements IPack
{
/**
* 数据包编码
* @param $buffer
* @return string
* @throws SwooleException
*/
public function encode($buffer)
{
return substr($buffer, 0, 4) . pack('N', strlen($buffer) - 4) . substr($buffer, 4);
}
/**
* @param $buffer
* @return string
*/
public function decode($buffer)
{
return substr($buffer, 0, 4) . substr($buffer, 8);
}
// 包长还是会传递过来
public function unPack($data)
{
$msgType = unpack('N', substr($data, 0, 4))[1];
$body = substr($data, 8);
$dataMsg = new stdClass();
$dataMsg->msg_type = $msgType;
// protobuf Exception
// try {
// $to->mergeFromString($data);
// } catch (Exception $e) {
// // Handle parsing error from invalid data.
// ...
// }
if ($msgType == 1) {
$msg = new Ping();
$msg->mergeFromString($body);
$dataMsg->uid = $msg->getUid();
} else if ($msgType == 2) {
$msg = new Pong();
$dataMsg->uid = $msg->getUid();
}
return $dataMsg;
}
public function Pack($data, $topic = null)
{
$msgType = $data->msg_type;
if ($msgType == 1) {
$msg = new Ping();
$msg->setUid($data->uid);
} else if ($msgType == 2) {
$msg = new Pong();
$msg->setUid($data->uid);
}
$data = $msg->serializeToString();
return pack('N', $msgType) . pack('N', strlen($data)). $data;
}
public function getProbufSet()
{
return [
'open_length_check' => true,
'package_length_type' => 'N',
'package_length_offset' => 4, //第N个字节是包长度的值
'package_body_offset' => 8, //第几个字节开始计算长度
'package_max_length' => 2000000, //协议最大长度
];
}
public function errorHandle(\Throwable $e, $fd)
{
get_instance()->close($fd);
}
}
```
protobuf 定义如下:
```
syntax = "proto3";
package game.protobuf;
enum MsgType {
PING = 1;
PONG = 2;
};
message Ping {
uint64 uid = 1;
};
message Pong {
uint64 uid = 1;
};
```
- SD3.X简介
- 捐赠SD项目
- VIP服务
- 基础篇
- 搭建环境
- 使用Composer安装/更新SD框架
- 启动命令
- 开发注意事项
- 框架配置
- 配置文件夹
- server.php
- ports.php
- business.php
- mysql.php
- redis.php
- timerTask.php
- log.php
- consul.php
- catCache.php
- client.php
- 自定义配置
- 框架入口
- MVC架构
- 加载器-Loader
- 控制器-Controller
- 模型-Model
- 视图-View
- 同步任务-Task
- 封装器
- Swoole编程指南-EOF协议
- Swoole编程指南-固定包头协议
- 封装器-Pack
- 路由器
- TCP相关
- 绑定UID
- Send系列
- Sub/Pub
- 获取服务器信息
- Http相关
- HttpInput
- HttpOutput
- 默认路由规则
- WebSocket相关
- 使用SSL
- 公共函数
- 进阶篇
- 内核优化
- 封装器路由器原理剖析
- 对象池
- 上下文-Context
- 中间件
- 进程管理
- 创建自定义进程
- 进程间RPC
- 自定义进程如何使用连接池
- 异步连接池
- Redis
- Mysql
- Mqtt
- HttpClient
- Client
- AMQP
- RPC
- 日志工具-GrayLog
- 微服务-Consul
- Consul基础
- 搭建Consul服务器
- SD中Consul配置
- 微服务
- 选举-Leader
- Consul动态配置定时任务
- 熔断与降级
- 集群-Cluster
- 高速缓存-CatCache
- 万物-Actor
- Actor原型
- Actor的创建
- Actor间的通讯
- 消息派发-EventDispatcher
- 延迟队列-TimerCallBack
- 协程
- 订阅与发布
- MQTT简易服务器
- AMQP异步任务调度
- 自定义命令-Console
- 调试工具Channel
- 特别注意事项
- 日常问题总结
- 实践案例
- 物联网自定义协议
- Actor在游戏的应用
- Mongodb以及一些同步扩展的使用
- 自定义进程使用MQTT客户端
- 开发者工具
- SDHelper