protocol

package

v0.0.0-...-b988991 Latest Latest Go to latest Published: Apr 16, 2024 License: MIT Imports: 10 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/wubo0067/calmwu-go

Links

Open Source Insights

Documentation ¶

Overview ¶

Package protocol is a generated protocol buffer package.

import "google/protobuf/descriptor.proto";

It is generated from these files:

proto_hs.proto

It has these top-level messages:

ProtoSyn
ProtoAsyn
ProtoAck
ProtoHeartBeat

Index ¶

Constants
Variables
func FlodPayloadData(rawData []byte, cipherBlock cipher.Block) ([]byte, error)
func PackAckMsg(msgId uint32, protoAck *ProtoAck) ([]byte, error)
func PackAsynMsg(msgId uint32, protoAsyn *ProtoAsyn) ([]byte, error)
func PackHeartBeat(msgId uint32, unix int64) ([]byte, error)
func PackSynMsg(msgId uint32, protoSyn *ProtoSyn) ([]byte, error)
func PackTransferData(msgId uint32, payLoad []byte) ([]byte, error)
func UnFlodPayloadData(cipherData []byte, cipherBlock cipher.Block) ([]byte, error)
type ProtoAck
- func (*ProtoAck) Descriptor() ([]byte, []int)
- func (m *ProtoAck) GetCipherText() []byte
- func (*ProtoAck) ProtoMessage()
- func (m *ProtoAck) Reset()
- func (m *ProtoAck) String() string
type ProtoAsyn
- func (*ProtoAsyn) Descriptor() ([]byte, []int)
- func (m *ProtoAsyn) GetDHServerPubKey() []byte
- func (*ProtoAsyn) ProtoMessage()
- func (m *ProtoAsyn) Reset()
- func (m *ProtoAsyn) String() string
type ProtoC2SCmd
- func (i ProtoC2SCmd) String() string
type ProtoC2SHead
- func UnPackProtoHead(data []byte) (*ProtoC2SHead, error)
type ProtoHeartBeat
- func (*ProtoHeartBeat) Descriptor() ([]byte, []int)
- func (m *ProtoHeartBeat) GetTimestamp() int64
- func (*ProtoHeartBeat) ProtoMessage()
- func (m *ProtoHeartBeat) Reset()
- func (m *ProtoHeartBeat) String() string
type ProtoSyn
- func (*ProtoSyn) Descriptor() ([]byte, []int)
- func (m *ProtoSyn) GetDHClientPubKey() []byte
- func (m *ProtoSyn) GetVerifyBuf() []byte
- func (*ProtoSyn) ProtoMessage()
- func (m *ProtoSyn) Reset()
- func (m *ProtoSyn) String() string

Constants ¶

View Source

const (
	ProtoC2SMagic = uint32(0x98651210)
	//ProtoC2SHeadSize = int(unsafe.Sizeof(head_82732831712))  这里无法使用sizeof，应为有align，可序列化时是pack 1的
	ProtoC2SHeadSize int = 14
)

Variables ¶

View Source

var (
	ErrUnPackProtoHead = errors.New("unpackprotohead failed")
	ErrPackProtoSyn    = errors.New("pack ProtoSyn failed")
	ErrPackProtoAsyn   = errors.New("pack ProtoAsyn failed")
	ErrPackProtoAck    = errors.New("pack ProtoAck failed")
)

Functions ¶

func FlodPayloadData ¶

func FlodPayloadData(rawData []byte, cipherBlock cipher.Block) ([]byte, error)

压缩--->CRC校验--->加密

func PackAckMsg ¶

func PackAckMsg(msgId uint32, protoAck *ProtoAck) ([]byte, error)

func PackAsynMsg ¶

func PackAsynMsg(msgId uint32, protoAsyn *ProtoAsyn) ([]byte, error)

func PackHeartBeat ¶

func PackHeartBeat(msgId uint32, unix int64) ([]byte, error)

func PackSynMsg ¶

func PackSynMsg(msgId uint32, protoSyn *ProtoSyn) ([]byte, error)

func PackTransferData ¶

func PackTransferData(msgId uint32, payLoad []byte) ([]byte, error)

func UnFlodPayloadData ¶

func UnFlodPayloadData(cipherData []byte, cipherBlock cipher.Block) ([]byte, error)

解密--->crc校验--->解压缩

Types ¶

type ProtoAck ¶

type ProtoAck struct {
	CipherText []byte `protobuf:"bytes,1,opt,name=CipherText,proto3" json:"CipherText,omitempty"`
}

func (*ProtoAck) Descriptor ¶

func (*ProtoAck) Descriptor() ([]byte, []int)

func (*ProtoAck) GetCipherText ¶

func (m *ProtoAck) GetCipherText() []byte

func (*ProtoAck) ProtoMessage ¶

func (*ProtoAck) ProtoMessage()

func (*ProtoAck) Reset ¶

func (m *ProtoAck) Reset()

func (*ProtoAck) String ¶

func (m *ProtoAck) String() string

type ProtoAsyn ¶

type ProtoAsyn struct {
	DHServerPubKey []byte `protobuf:"bytes,1,opt,name=DHServerPubKey,proto3" json:"DHServerPubKey,omitempty"`
}

func (*ProtoAsyn) Descriptor ¶

func (*ProtoAsyn) Descriptor() ([]byte, []int)

func (*ProtoAsyn) GetDHServerPubKey ¶

func (m *ProtoAsyn) GetDHServerPubKey() []byte

func (*ProtoAsyn) ProtoMessage ¶

func (*ProtoAsyn) ProtoMessage()

func (*ProtoAsyn) Reset ¶

func (m *ProtoAsyn) Reset()

func (*ProtoAsyn) String ¶

func (m *ProtoAsyn) String() string

type ProtoC2SCmd ¶

type ProtoC2SCmd int16

const (
	E_C2S_CMD_SYN ProtoC2SCmd = iota
	E_S2C_CMD_ASYN
	E_C2S_CMD_ACK // 握手协议，主要用来交换密钥，验证加密用
	E_TRANSFER    // 业务传输
	E_HEARTBEAT
)

func (ProtoC2SCmd) String ¶

func (i ProtoC2SCmd) String() string

type ProtoC2SHead ¶

type ProtoC2SHead struct {
	MagicValue uint32      // 魔术字
	MsgId      uint32      // 消息序号
	Cmd        ProtoC2SCmd //
	DataLen    int32       // 数据长度
}

这里的数据类型不能是int，必须明确位宽，否则binary操作会报错

func UnPackProtoHead ¶

func UnPackProtoHead(data []byte) (*ProtoC2SHead, error)

type ProtoHeartBeat ¶

type ProtoHeartBeat struct {
	Timestamp int64 `protobuf:"fixed64,1,opt,name=Timestamp" json:"Timestamp,omitempty"`
}

func (*ProtoHeartBeat) Descriptor ¶

func (*ProtoHeartBeat) Descriptor() ([]byte, []int)

func (*ProtoHeartBeat) GetTimestamp ¶

func (m *ProtoHeartBeat) GetTimestamp() int64

func (*ProtoHeartBeat) ProtoMessage ¶

func (*ProtoHeartBeat) ProtoMessage()

func (*ProtoHeartBeat) Reset ¶

func (m *ProtoHeartBeat) Reset()

func (*ProtoHeartBeat) String ¶

func (m *ProtoHeartBeat) String() string

type ProtoSyn ¶

type ProtoSyn struct {
	VerifyBuf      []byte `protobuf:"bytes,1,opt,name=VerifyBuf,proto3" json:"VerifyBuf,omitempty"`
	DHClientPubKey []byte `protobuf:"bytes,2,opt,name=DHClientPubKey,proto3" json:"DHClientPubKey,omitempty"`
}

func (*ProtoSyn) Descriptor ¶

func (*ProtoSyn) Descriptor() ([]byte, []int)

func (*ProtoSyn) GetDHClientPubKey ¶

func (m *ProtoSyn) GetDHClientPubKey() []byte

func (*ProtoSyn) GetVerifyBuf ¶

func (m *ProtoSyn) GetVerifyBuf() []byte

func (*ProtoSyn) ProtoMessage ¶

func (*ProtoSyn) ProtoMessage()

func (*ProtoSyn) Reset ¶

func (m *ProtoSyn) Reset()

func (*ProtoSyn) String ¶

func (m *ProtoSyn) String() string

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL