106 lines
3.7 KiB
C#
106 lines
3.7 KiB
C#
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 =>
|
|
{
|
|
//Thread.Sleep(3000);
|
|
string Exception = Convert.ToString(t.Exception);
|
|
Console.WriteLine("消息处理异常:" + Exception);
|
|
}, TaskContinuationOptions.OnlyOnFaulted);
|
|
}
|
|
|
|
/// <summary>
|
|
/// 处理远程请求
|
|
/// </summary>
|
|
/// <param name="msg"></param>
|
|
private void handle(BattleRpcMessage 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);
|
|
bool ischeck = 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=ischeck}),
|
|
};
|
|
byte[] _msg = ProtoSerialize(msg);
|
|
ts = (DateTime.Now.ToUniversalTime().Ticks - 621355968000000000) / 10000;
|
|
Console.WriteLine("接收到战斗消息 4 |{0}",ts);
|
|
socket.Send(_msg);
|
|
break;
|
|
}
|
|
|
|
}
|
|
|
|
/// <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;
|
|
}
|
|
}
|
|
}
|
|
} |