golang leaf调试Game、Login模块收发信息

main.go代码如下package main
import (
"flag"
"server/conf"
"server/game"
"server/gate"
"server/login"
_ "time"
_ "FenDZ/glog-master"
_ "github.com/dop251/goja" // JS 解析器
"github.com/name5566/leaf"
lconf "github.com/name5566/leaf/conf"
)
func init() {
// 初始化 日志系统
flag.Set("alsologtostderr", "true") // 日志写入文件的同时，输出到stderr
flag.Set("log_dir", "./log") // 日志文件保存目录
flag.Set("v", "3") // 配置V输出的等级。
flag.Parse()
return
}
func main() {
// 加载配置
lconf.LogLevel = conf.Server.LogLevel
lconf.LogPath = conf.Server.LogPath
lconf.LogFlag = conf.LogFlag
lconf.ConsolePort = conf.Server.ConsolePort
lconf.ProfilePath = conf.Server.ProfilePath
// 注册模块
leaf.Run(
game.Module,
gate.Module,
login.Module,
)
}知识点
   ·消息配置，实现不同功能对应不同的消息，防止数据处理混乱。文件：serveer\msg\msg.gopackage msg
import (
"github.com/name5566/leaf/network"
"github.com/name5566/leaf/network/json"
)
var Processorbak network.Processor
// 使用默认的 JSON 消息处理器（默认还提供了 protobuf 消息处理器）
var Processor = json.NewProcessor()
func init() {
// 这里我们注册了一个 JSON 消息 Test
Processor.Register(&Test{})
// 注册登陆协议
Processor.Register(&UserLogin{})
}
// 一个结构体定义了一个 JSON 消息的格式
// 消息名为 Test
type Test struct {
Name string
}
// 用户登陆的协议
type UserLogin struct {
LoginName string
LoginPW string
}   ·配置路由：实现将消息Test、UserLogin分别发给Game和Login模块。文件：server\gate\router.gopackage gate
import (
"server/game"
"server/login"
"server/msg"
)
func init() {
// 这里指定消息 Test 路由到 game 模块
// 模块间使用 ChanRPC 通讯，消息路由也不例外
msg.Processor.SetRouter(&msg.Test{}, game.ChanRPC)
// 路由分发数据到login
msg.Processor.SetRouter(&msg.UserLogin{}, login.ChanRPC)
}   ·game模块处理消息。文件位置：server\game\internal\handler.gopackage internal
import (
"reflect"
"server/msg"
"github.com/name5566/leaf/gate"
"github.com/name5566/leaf/log"
)
func init() {
// 向当前模块（game 模块）注册 Test 消息的消息处理函数 handleTest
handler(&msg.Test{}, handleTest)
}
// 异步处理
func handler(m interface{}, h interface{}) {
skeleton.RegisterChanRPC(reflect.TypeOf(m), h)
}
// 消息处理
func handleTest(args []interface{}) {
// 收到的 Test 消息
m := args[0].(*msg.Test)
// 消息的发送者
a := args[1].(gate.Agent)
// 输出收到的消息的内容
log.Debug("hello game %v", m.Name)
// 给发送者回应一个 Test 消息
a.WriteMsg(&msg.Test{
Name: "client",
})
}  ·login模块处理消息。文件位置：server\login\internal\handler.gopackage internal
import (
"reflect"
"server/msg"
"github.com/name5566/leaf/gate"
"github.com/name5566/leaf/log"
)
func handleMsg(m interface{}, h interface{}) {
skeleton.RegisterChanRPC(reflect.TypeOf(m), h)
}
func init() {
// 向当前模块（login 模块）注册 Test 消息的消息处理函数 handleTest
handleMsg(&msg.UserLogin{}, handleTest)
}
// 消息处理
func handleTest(args []interface{}) {
// 收到的 Test 消息
m := args[0].(*msg.UserLogin)
// 消息的发送者
a := args[1].(gate.Agent)
// 1 查询数据库--判断用户是不是合法
// 2 如果数据库返回查询正确--保存到缓存或者内存
// 输出收到的消息的内容
log.Debug("Test login %v", m.LoginName)
// 给发送者回应一个 Test 消息
a.WriteMsg(&msg.Test{
Name: "client"
b9bc
,
})
}  ·TCP_模拟客户端package main
import (
"encoding/binary"
"net"
)
func main() {
conn, err := net.Dial("tcp", "127.0.0.1:8888")
if err != nil {
panic(err)
}
// Test 消息（JSON 格式）
// 对应游戏服务器 Test 消息结构体
data := []byte(`{
"Test": {
"Name": "leaf"
}
}`)
// len + data
m := make([]byte, 2+len(data))
// 默认使用大端序
binary.BigEndian.PutUint16(m, uint16(len(data)))
copy(m[2:], data)
// 发送消息
conn.Write(m)
if true {
data := []byte(`{
"UserLogin": {
"LoginName": "leaf",
"LoginPW" :"sss"
}
}`)
// len + data
m := make([]byte, 2+len(data))
// 默认使用大端序
binary.BigEndian.PutUint16(m, uint16(len(data)))
copy(m[2:], data)
// 发送消息
conn.Write(m)
}
}