昔念
ec082db71d
feat(socket): 优化服务器事件处理逻辑并修复数据解码问题 - 移除重复的 `gnet.WithTicker(true)` 配置项 - 调整 `OnTick` 的执行间隔从 10 秒延长至 30 秒 - 更新 `NewClientData` 方法以传入连接对象，用于后续消息处理 - 将 `c.Read` 替换为 `c.Discard` 以正确丢弃已读数据 - 改进数据包处理逻辑，增强对不完整包的处理能力 - 修正 `TomeeHeader.Version` 类型由 string 转为 byte，并更新相关读写操作 - 在消息处理中增加错误日志打印
86 lines
1.8 KiB
Go
86 lines
1.8 KiB
Go
package codec
|
|
|
|
import (
|
|
"blazing/cool"
|
|
"context"
|
|
"encoding/binary"
|
|
"errors"
|
|
"io"
|
|
|
|
"github.com/panjf2000/gnet/v2"
|
|
)
|
|
|
|
var ErrIncompletePacket = errors.New("incomplete packet")
|
|
|
|
const maxBodyLen = 10 * 1024 * 1024 // 业务最大包体长度，按需调整
|
|
// TomeeSocketCodec 协议格式:
|
|
//
|
|
// * 0 4
|
|
// * +-----------+
|
|
// * | body len |
|
|
// * +-----------+
|
|
// * | |
|
|
// * + +
|
|
// * | body bytes|
|
|
// * + +
|
|
// * | ... ... |
|
|
// * +-----------+
|
|
type TomeeSocketCodec struct{}
|
|
|
|
var _ SocketCodec = (*TomeeSocketCodec)(nil)
|
|
|
|
func NewTomeeSocketCodec() *TomeeSocketCodec {
|
|
return &TomeeSocketCodec{}
|
|
|
|
}
|
|
|
|
func (codec TomeeSocketCodec) Encode(buf []byte) ([]byte, error) {
|
|
bodyLen := len(buf)
|
|
data := make([]byte, 4+bodyLen)
|
|
|
|
// 写入4字节的包长度
|
|
binary.BigEndian.PutUint32(data[:4], uint32(bodyLen))
|
|
// 写入包体
|
|
copy(data[4:], buf)
|
|
|
|
return data, nil
|
|
}
|
|
|
|
func (codec TomeeSocketCodec) Decode(c gnet.Conn) ([]byte, error) {
|
|
|
|
// handle(c)
|
|
// 先读取4字节的包长度
|
|
lenBuf, err := c.Peek(4)
|
|
|
|
if err != nil {
|
|
if errors.Is(err, io.ErrShortBuffer) {
|
|
return nil, ErrIncompletePacket
|
|
}
|
|
return nil, err
|
|
}
|
|
|
|
bodyLen := binary.BigEndian.Uint32(lenBuf)
|
|
cool.Loger.Print(context.TODO(), "lenBuf", bodyLen)
|
|
if bodyLen > maxBodyLen {
|
|
return nil, errors.New("packet body exceeds max length")
|
|
}
|
|
|
|
// 检查整个包是否完整
|
|
buf, err := c.Peek(int(bodyLen))
|
|
if err != nil {
|
|
if errors.Is(err, io.ErrShortBuffer) {
|
|
return nil, ErrIncompletePacket
|
|
}
|
|
return nil, err
|
|
}
|
|
|
|
// 提取包体
|
|
body := make([]byte, bodyLen)
|
|
copy(body, buf)
|
|
|
|
// 从缓冲区中丢弃已读取的数据
|
|
_, _ = c.Discard(int(bodyLen))
|
|
|
|
return body, nil
|
|
}
|