liwei_3d/dfbattle
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

上传客户端代码 关闭日志

Browse Source
This commit is contained in:
liwei 2023-09-19 10:43:09 +08:00
parent 1111a1a444
commit 39dbab6e22
1 changed files with 17 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
Client.cs
View File

@ -35,8 +35,8 @@ namespace BattleServer
private void doBinary(byte[] message) private void doBinary(byte[] message)
{ {
BattleRpcMessage msg = ProtoDeSerialize<BattleRpcMessage>(message); BattleRpcMessage msg = ProtoDeSerialize<BattleRpcMessage>(message);
if (msg.method != "Heartbeat") // if (msg.method != "Heartbeat")
Console.WriteLine("接收到消息 {0}", msg.method); // Console.WriteLine("接收到消息 {0}", msg.method);
// Pb.BattleRpcMessage msg = Deserialize<Pb.BattleRpcMessage>(message); // Pb.BattleRpcMessage msg = Deserialize<Pb.BattleRpcMessage>(message);
Task t = Task.Run(() => Task t = Task.Run(() =>
{ {
@ -79,7 +79,7 @@ namespace BattleServer
socket.Send(_msg); socket.Send(_msg);
break; break;
case "GetInfo": //创建战斗场景 case "GetInfo": //创建战斗场景
Console.WriteLine("处理GetInfoPVP !"); // Console.WriteLine("处理GetInfoPVP !");
BattleGetInfoReq req = ProtoDeSerialize<BattleGetInfoReq>(msg.data.value); BattleGetInfoReq req = ProtoDeSerialize<BattleGetInfoReq>(msg.data.value);
BattleStateInfo info = HotUpdateScripts.FightRunnerMgr.Instance.GetPvpStateInfo(req.battleid); BattleStateInfo info = HotUpdateScripts.FightRunnerMgr.Instance.GetPvpStateInfo(req.battleid);
msg.data = new Google.Protobuf.WellKnownTypes.Any msg.data = new Google.Protobuf.WellKnownTypes.Any
@ -89,10 +89,10 @@ namespace BattleServer
}; };
_msg = ProtoSerialize(msg); _msg = ProtoSerialize(msg);
socket.Send(_msg); socket.Send(_msg);
Console.WriteLine("处理GetInfo end !"); // Console.WriteLine("处理GetInfo end !");
break; break;
case "Create": //创建战斗场景 case "Create": //创建战斗场景
Console.WriteLine("处理CreatePVP !"); // Console.WriteLine("处理CreatePVP !");
BattleCreateServerReq CreateReq = ProtoDeSerialize<BattleCreateServerReq>(msg.data.value); BattleCreateServerReq CreateReq = ProtoDeSerialize<BattleCreateServerReq>(msg.data.value);
HotUpdateScripts.FightRunnerMgr.Instance.StartPvp(CreateReq.info, this.OnOutCmd, this.OnFinish, (issucc) => HotUpdateScripts.FightRunnerMgr.Instance.StartPvp(CreateReq.info, this.OnOutCmd, this.OnFinish, (issucc) =>
{ {
@ -103,15 +103,15 @@ namespace BattleServer
}; };
_msg = ProtoSerialize(msg); _msg = ProtoSerialize(msg);
socket.Send(_msg); socket.Send(_msg);
Console.WriteLine("处理CreatePVP end !"); // Console.WriteLine("处理CreatePVP end !");
}); });
break; break;
case "InCmd": //向战斗场景输入指令 case "InCmd": //向战斗场景输入指令
Console.WriteLine("处理InCmd !"); // Console.WriteLine("处理InCmd !");
BattleInCmdReq InCmdReq = ProtoDeSerialize<BattleInCmdReq>(msg.data.value); BattleInCmdReq InCmdReq = ProtoDeSerialize<BattleInCmdReq>(msg.data.value);
HotUpdateScripts.FightRunnerMgr.Instance.PvpInput(InCmdReq.battleid, InCmdReq.side, InCmdReq.@in, (issucc) => HotUpdateScripts.FightRunnerMgr.Instance.PvpInput(InCmdReq.battleid, InCmdReq.side, InCmdReq.@in, (issucc) =>
{ {
Console.WriteLine("处理InCmd 1------- end !"); // Console.WriteLine("处理InCmd 1------- end !");
msg.data = new Google.Protobuf.WellKnownTypes.Any msg.data = new Google.Protobuf.WellKnownTypes.Any
{ {
type_url = "type.googleapis.com/BattleInCmdResp", type_url = "type.googleapis.com/BattleInCmdResp",
@ -119,12 +119,12 @@ namespace BattleServer
}; };
_msg = ProtoSerialize(msg); _msg = ProtoSerialize(msg);
socket.Send(_msg); socket.Send(_msg);
Console.WriteLine("处理InCmd 1------- end !"); // Console.WriteLine("处理InCmd 1------- end !");
}); });
break; break;
case "Concede": //向战斗场景输入指令 case "Concede": //向战斗场景输入指令
Console.WriteLine("处理 Concede !"); // Console.WriteLine("处理 Concede !");
BattleConcedeReq ConcedeReq = ProtoDeSerialize<BattleConcedeReq>(msg.data.value); BattleConcedeReq ConcedeReq = ProtoDeSerialize<BattleConcedeReq>(msg.data.value);
HotUpdateScripts.FightRunnerMgr.Instance.InitiativeFail(ConcedeReq.battleid, ConcedeReq.side, (issucc) => HotUpdateScripts.FightRunnerMgr.Instance.InitiativeFail(ConcedeReq.battleid, ConcedeReq.side, (issucc) =>
{ {
@ -135,7 +135,7 @@ namespace BattleServer
}; };
_msg = ProtoSerialize(msg); _msg = ProtoSerialize(msg);
socket.Send(_msg); socket.Send(_msg);
Console.WriteLine("处理 Concede end !"); // Console.WriteLine("处理 Concede end !");
}); });
break; break;
@ -146,10 +146,10 @@ namespace BattleServer
private void OnOutCmd(string bid, List<BattleCmd> cmd) private void OnOutCmd(string bid, List<BattleCmd> cmd)
{ {
// Console.WriteLine("----------------------OnOutCmd {0}:{1}", bid, cmd.cmdtype); // Console.WriteLine("----------------------OnOutCmd {0}:{1}", bid, cmd.cmdtype);
foreach (var item in cmd) // foreach (var item in cmd)
{ // {
Console.WriteLine("----------------------OnOutCmd {0}:{1}", bid, item.cmdtype); // Console.WriteLine("----------------------OnOutCmd {0}:{1}", bid, item.cmdtype);
} // }
BattleRpcMessage msg = new BattleRpcMessage(); BattleRpcMessage msg = new BattleRpcMessage();
msg.method = "BattleOutCmd"; msg.method = "BattleOutCmd";
@ -166,7 +166,7 @@ namespace BattleServer
{ {
ComEndFight _cmd = HotUpdateScripts.FightCmdUtil.PasreCmd(cmd) as ComEndFight; ComEndFight _cmd = HotUpdateScripts.FightCmdUtil.PasreCmd(cmd) as ComEndFight;
Console.WriteLine("----------------------OnFinish {0}", _cmd.fightId); // Console.WriteLine("----------------------OnFinish {0}", _cmd.fightId);
BattleRpcMessage msg = new BattleRpcMessage(); BattleRpcMessage msg = new BattleRpcMessage();
msg.method = "BattleFished"; msg.method = "BattleFished";
msg.data = new Google.Protobuf.WellKnownTypes.Any msg.data = new Google.Protobuf.WellKnownTypes.Any
@ -185,7 +185,7 @@ namespace BattleServer
t.ContinueWith(r => t.ContinueWith(r =>
{ {
string Exception = Convert.ToString(t.Exception); string Exception = Convert.ToString(t.Exception);
Console.WriteLine("OnFinish 异常处理:" + Exception); // Console.WriteLine("OnFinish 异常处理:" + Exception);
}, TaskContinuationOptions.OnlyOnFaulted); }, TaskContinuationOptions.OnlyOnFaulted);