dfbattle/Client.cs

using Fleck;

namespace BattleServer
{
    /// <summary>
    /// 客户端链接对象
    /// </summary>
    class Client
    {
        private IWebSocketConnection socket;

        public Client(IWebSocketConnection _socket)
        {
            socket = _socket;
            socket.OnBinary = doBinary;
            socket.OnClose = close;
        }

        private void close()
        {
            Service.Instance.Shutdown(this);
        }

        /// <summary>
        /// 接收rpc数据
        /// </summary>
        /// <param name="message"></param>
        private void doBinary(byte[] message)
        {
            BattleRpcMessage msg = ProtoDeSerialize<BattleRpcMessage>(message);
            Console.WriteLine("接收到消息 {0}", msg.method);
            // Pb.BattleRpcMessage msg = Deserialize<Pb.BattleRpcMessage>(message);
            Task t = Task.Run(() =>
            {
                handle(msg);
            });

            t.ContinueWith(r =>
            {
                string Exception = Convert.ToString(t.Exception);
                Console.WriteLine("消息处理异常:" + Exception);
            }, TaskContinuationOptions.OnlyOnFaulted);
        }

        /// <summary>
        /// 处理远程请求
        /// </summary>
        /// <param name="msg"></param>
        private void handle(BattleRpcMessage msg)
        {
            bool issucc;
            byte[] _msg;
            // long ts = (DateTime.Now.ToUniversalTime().Ticks - 621355968000000000) / 10000;
            // Console.WriteLine("接收到战斗消息 1 {0}|{1}",msg.method,ts);
            switch (msg.method)
            {
                case "Check": //校验战报
                    BattleReport report = ProtoDeSerialize<BattleReport>(msg.data.value);
                    // ts = (DateTime.Now.ToUniversalTime().Ticks - 621355968000000000) / 10000;
                    // Console.WriteLine("接收到战斗消息 2 |{0}",ts);
                    issucc = HotUpdateScripts.FightRunnerMgr.Instance.VerifyOnceFight(report);
                    // ts = (DateTime.Now.ToUniversalTime().Ticks - 621355968000000000) / 10000;
                    // Console.WriteLine("接收到战斗消息 3 |{0}",ts);
                    msg.data = new Google.Protobuf.WellKnownTypes.Any
                    {
                        type_url = "type.googleapis.com/BattleCheckResults",
                        value = ProtoSerialize(new BattleCheckResults { ischeck = issucc }),
                    };
                    _msg = ProtoSerialize(msg);
                    // ts = (DateTime.Now.ToUniversalTime().Ticks - 621355968000000000) / 10000;
                    // Console.WriteLine("接收到战斗消息 4 |{0}",ts);
                    socket.Send(_msg);
                    break;
                case "Create": //创建战斗场景
                    BattleCreateServerReq CreateReq = ProtoDeSerialize<BattleCreateServerReq>(msg.data.value);
                    issucc = HotUpdateScripts.FightRunnerMgr.Instance.CreatePvP(CreateReq.info, this.OnOutCmd, this.OnFinish);
                    msg.data = new Google.Protobuf.WellKnownTypes.Any
                    {
                        type_url = "type.googleapis.com/BattleCreateServerResp",
                        value = ProtoSerialize(new BattleCreateServerResp { issucc = issucc }),
                    };
                    _msg = ProtoSerialize(msg);
                    socket.Send(_msg);
                    break;
                case "InCmd":  //向战斗场景输入指令
                    BattleInCmdReq InCmdReq = ProtoDeSerialize<BattleInCmdReq>(msg.data.value);
                    issucc = HotUpdateScripts.FightRunnerMgr.Instance.PvpInput(InCmdReq.battleid, 0, InCmdReq.@in);
                    msg.data = new Google.Protobuf.WellKnownTypes.Any
                    {
                        type_url = "type.googleapis.com/BattleCreateServerResp",
                        value = ProtoSerialize(new BattleCreateServerResp { issucc = issucc }),
                    };
                    _msg = ProtoSerialize(msg);
                    socket.Send(_msg);
                    break;
            }

        }

        private void OnOutCmd(string bid, BattleCmd cmd)
        {
            BattleRpcMessage msg = new BattleRpcMessage();
            msg.method = "BattleOutCmd";
            msg.data = new Google.Protobuf.WellKnownTypes.Any
            {
                type_url = "type.googleapis.com/BattleOutCmdPush",
                value = ProtoSerialize(new BattleOutCmdPush { battleid = bid, cmd = new List<BattleCmd>() { cmd }, }),
            };
            byte[] data = ProtoSerialize(msg);
            socket.Send(data);
        }

        private void OnFinish(BattleCmd cmd)
        {
            ComEndFight _cmd = HotUpdateScripts.FightCmdUtil.PasreCmd(cmd) as ComEndFight;
            BattleRpcMessage msg = new BattleRpcMessage();
            msg.method = "BattleFished";
            msg.data = new Google.Protobuf.WellKnownTypes.Any
            {
                type_url = "type.googleapis.com/BattleFinishPush",
                value = ProtoSerialize(new BattleFinishPush { battleid = _cmd.fightId }),
            };
            byte[] data = ProtoSerialize(msg);
            socket.Send(data);
        }

        /// <summary>
        /// 序列化并返回二进制
        /// Serialize an Object and return byte[]
        /// </summary>
        /// <param name="obj"></param>
        /// <returns></returns>
        public static byte[] ProtoSerialize<T>(T obj) where T : class
        {
            using (var stream = new MemoryStream())
            {
                ProtoBuf.Serializer.Serialize(stream, obj);
                return stream.ToArray();
            }
        }

        /// <summary>
        /// 通过二进制反序列化
        /// Deserialize with byte[]
        /// </summary>
        /// <param name="msg"></param>
        /// <typeparam name="T"></typeparam>
        /// <returns></returns>
        public static T ProtoDeSerialize<T>(byte[] msg) where T : class
        {
            msg = msg == null ? new byte[] { } : msg;
            using (var ms = new MemoryStream(msg))
            {
                var data = ProtoBuf.Serializer.Deserialize<T>(ms);
                return data;
            }
        }
    }
}