refactor(pack): 重构组包逻辑
- 移除 common/core/pack.go 文件 - 在 TomeeHeader 结构体中添加 Pack 方法实现组包功能 - 更新 Player 结构体和相关方法，使用 Conn 包装 gnet.Conn - 修改控制器和服务中的组包调用，使用新的 Pack 方法 - 优化部分代码结构，提高可维护性
This commit is contained in:
@@ -1,65 +0,0 @@
|
||||
package core
|
||||
|
||||
import (
|
||||
"blazing/common/serialize/bytearray"
|
||||
"blazing/common/socket/handler"
|
||||
"bytes"
|
||||
"fmt"
|
||||
"reflect"
|
||||
|
||||
"github.com/lunixbochs/struc"
|
||||
)
|
||||
|
||||
func Pack(header1 handler.TomeeHeader, data any) []byte { //组包
|
||||
header := header1
|
||||
//t := reflect.TypeOf(data)
|
||||
tv := reflect.ValueOf(data)
|
||||
var datar []byte
|
||||
|
||||
// 处理指针类型
|
||||
if tv.Kind() == reflect.Ptr {
|
||||
//tv = t.Elem() // 获取指针指向的类型
|
||||
tv = tv.Elem() // 获取指针指向的值
|
||||
}
|
||||
//.Println(t.Kind())
|
||||
//t1 := tv.Interface()
|
||||
//fmt.Println(t1)
|
||||
switch tv.Kind() {
|
||||
|
||||
case reflect.Slice:
|
||||
datar = data.([]byte)
|
||||
//p.Conn.Write(p.pack(cmd, data.([]byte))) //写入数据
|
||||
|
||||
case reflect.Struct:
|
||||
var data1 bytes.Buffer
|
||||
err := struc.Pack(&data1, data)
|
||||
if err != nil {
|
||||
fmt.Println(err)
|
||||
}
|
||||
|
||||
datar = data1.Bytes()
|
||||
|
||||
default:
|
||||
datar = []byte{}
|
||||
// fmt.Println(err, datar)
|
||||
// p.Conn.Write(p.pack(cmd, data))
|
||||
|
||||
}
|
||||
header.Len = uint32(len(datar) + 17)
|
||||
|
||||
// if iserror != 0 { //如果存在错误码
|
||||
// head1.Data = nil
|
||||
// }
|
||||
//var data1 bytes.Buffer
|
||||
//.Pack(&data1, &head1)
|
||||
by := bytearray.CreateByteArray()
|
||||
by.WriteUInt32(header.Len)
|
||||
by.WriteString(header.Version)
|
||||
by.WriteUInt32(uint32(header.CMD))
|
||||
by.WriteUInt32(header.UserID)
|
||||
by.WriteUInt32(header.Result)
|
||||
by.Write(datar)
|
||||
|
||||
return by.Bytes()
|
||||
|
||||
}
|
||||
32
common/data/entity/conn.go
Normal file
32
common/data/entity/conn.go
Normal file
@@ -0,0 +1,32 @@
|
||||
package entity
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
|
||||
"github.com/gobwas/ws"
|
||||
"github.com/gobwas/ws/wsutil"
|
||||
"github.com/panjf2000/gnet/v2"
|
||||
"github.com/panjf2000/gnet/v2/pkg/logging"
|
||||
)
|
||||
|
||||
type Conn struct {
|
||||
MainConn gnet.Conn `struc:"[0]pad"` //TODO 不序列化,,序列化下面的作为blob存数据库
|
||||
}
|
||||
|
||||
func (c *Conn) SendPack(bytes []byte) error {
|
||||
if c.MainConn.Context().(*ClientData).Getwsmsg().Upgraded {
|
||||
// This is the echo server
|
||||
err := wsutil.WriteServerMessage(c.MainConn, ws.OpBinary, bytes)
|
||||
if err != nil {
|
||||
logging.Infof("conn[%v] [err=%v]", c.MainConn.RemoteAddr().String(), err.Error())
|
||||
return err
|
||||
}
|
||||
} else {
|
||||
|
||||
_, err := c.MainConn.Write(bytes)
|
||||
if err != nil {
|
||||
fmt.Println(err)
|
||||
}
|
||||
}
|
||||
return nil
|
||||
}
|
||||
@@ -7,9 +7,9 @@ import (
|
||||
)
|
||||
|
||||
type Player struct {
|
||||
MainConn gnet.Conn `struc:"[0]pad"` //TODO 不序列化,,序列化下面的作为blob存数据库
|
||||
UserID uint32 //用户ID
|
||||
IsLogin bool //是否登录 //TODO 待实现登录包为第一个包,后续再发其他的包
|
||||
MainConn Conn
|
||||
UserID uint32 //用户ID
|
||||
IsLogin bool //是否登录 //TODO 待实现登录包为第一个包,后续再发其他的包
|
||||
|
||||
}
|
||||
|
||||
@@ -22,9 +22,9 @@ func WithUserID(userID uint32) PlayerOption {
|
||||
p.UserID = userID
|
||||
}
|
||||
}
|
||||
func WithConn(Conn gnet.Conn) PlayerOption {
|
||||
func WithConn(c gnet.Conn) PlayerOption {
|
||||
return func(p *Player) {
|
||||
p.MainConn = Conn
|
||||
p.MainConn = Conn{MainConn: c}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -42,7 +42,7 @@ func (p *Player) GetUserID() uint32 {
|
||||
}
|
||||
|
||||
func (p *Player) SendPack(b []byte) error {
|
||||
_, err := p.MainConn.Write(b)
|
||||
err := p.MainConn.SendPack(b)
|
||||
return err
|
||||
}
|
||||
|
||||
|
||||
@@ -3,7 +3,11 @@ package handler
|
||||
import (
|
||||
"blazing/common/serialize/bytearray"
|
||||
"blazing/common/socket/cmd"
|
||||
"bytes"
|
||||
"fmt"
|
||||
"reflect"
|
||||
|
||||
"github.com/lunixbochs/struc"
|
||||
"github.com/panjf2000/gnet/v2"
|
||||
)
|
||||
|
||||
@@ -55,3 +59,51 @@ func (h *TomeeHandler) Handle(c gnet.Conn, data []byte) { //处理接收到的
|
||||
h.Callback(c, header)
|
||||
//return header
|
||||
}
|
||||
func (h *TomeeHeader) Pack(data any) []byte { //组包
|
||||
|
||||
//t := reflect.TypeOf(data)
|
||||
tv := reflect.ValueOf(data)
|
||||
var datar []byte
|
||||
|
||||
// 处理指针类型
|
||||
if tv.Kind() == reflect.Ptr {
|
||||
//tv = t.Elem() // 获取指针指向的类型
|
||||
tv = tv.Elem() // 获取指针指向的值
|
||||
}
|
||||
//.Println(t.Kind())
|
||||
//t1 := tv.Interface()
|
||||
//fmt.Println(t1)
|
||||
switch tv.Kind() {
|
||||
|
||||
case reflect.Slice:
|
||||
datar = data.([]byte)
|
||||
//p.Conn.Write(p.pack(cmd, data.([]byte))) //写入数据
|
||||
|
||||
case reflect.Struct:
|
||||
var data1 bytes.Buffer
|
||||
err := struc.Pack(&data1, data)
|
||||
if err != nil {
|
||||
fmt.Println(err)
|
||||
}
|
||||
|
||||
datar = data1.Bytes()
|
||||
|
||||
default:
|
||||
datar = []byte{}
|
||||
// fmt.Println(err, datar)
|
||||
// p.Conn.Write(p.pack(cmd, data))
|
||||
|
||||
}
|
||||
h.Len = uint32(len(datar) + 17)
|
||||
|
||||
by := bytearray.CreateByteArray()
|
||||
by.WriteUInt32(h.Len)
|
||||
by.WriteString(h.Version)
|
||||
by.WriteUInt32(uint32(h.CMD))
|
||||
by.WriteUInt32(h.UserID)
|
||||
by.WriteUInt32(h.Result)
|
||||
by.Write(datar)
|
||||
|
||||
return by.Bytes()
|
||||
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user