From 56807123968ac765600bbf2acab964cdf7bc6b04 Mon Sep 17 00:00:00 2001 From: duanhf2012 Date: Mon, 24 Feb 2020 17:18:03 +0800 Subject: [PATCH] =?UTF-8?q?=E5=90=8C=E6=AD=A5=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- sysservice/tcpsocketpbservice.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/sysservice/tcpsocketpbservice.go b/sysservice/tcpsocketpbservice.go index 03dd93e..9e77158 100644 --- a/sysservice/tcpsocketpbservice.go +++ b/sysservice/tcpsocketpbservice.go @@ -110,21 +110,21 @@ func (slf *TcpSocketPbService) OnExceptMsg (pClient *network.SClient,pPack *netw }else{ pClient.Close() //记录日志 - service.GetLogger().Printf(service.LEVER_WARN, "OnExceptMsg packtype %d,error %+v",pPack.PackType(),err) + service.GetLogger().Printf(service.LEVER_WARN, "OnExceptMsg packtype %d,error %+v",pPack.PackType,err) } } func (slf *TcpSocketPbService) OnRecvMsg(pClient *network.SClient, pPack *network.MsgBasePack){ - if info, ok := slf.mapMsg[pPack.PackType()]; ok { + if info, ok := slf.mapMsg[pPack.PackType]; ok { msg := reflect.New(info.msgType.Elem()).Interface() tmp := msg.(proto.Message) - err := proto.Unmarshal(pPack.Body(), tmp) + err := proto.Unmarshal(pPack.Body, tmp) if err != nil { slf.OnExceptMsg(pClient,pPack,err) return } - info.msgHandler(pClient.GetId(),pPack.PackType(), msg.(proto.Message)) + info.msgHandler(pClient.GetId(),pPack.PackType, msg.(proto.Message)) return }