xzr0736
/
ascnet
forked from PGR/ascnet
1
0
Fork 0
Code Pull Requests Activity

now fixed, happy handling

This commit is contained in:
rfi 2023-10-10 17:10:29 +07:00
parent 8c53541d7f
commit 42e69df9cb
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
AscNet.GameServer/Session.cs
View File

@ -12,7 +12,7 @@ namespace AscNet.GameServer
public readonly TcpClient client; public readonly TcpClient client;
public readonly Logger c; public readonly Logger c;
private long lastPacketTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds(); private long lastPacketTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
private ushort packetNo = 0; private ushort packetNo = 1;
private readonly MessagePackSerializerOptions lz4Options = MessagePackSerializerOptions.Standard.WithCompression(MessagePackCompression.Lz4Block); private readonly MessagePackSerializerOptions lz4Options = MessagePackSerializerOptions.Standard.WithCompression(MessagePackCompression.Lz4Block);
public Session(string id, TcpClient tcpClient) public Session(string id, TcpClient tcpClient)
@ -126,7 +126,7 @@ namespace AscNet.GameServer
{ {
Packet.Response packet = new() Packet.Response packet = new()
{ {
Id = 0, Id = 1,
Name = typeof(T).Name, Name = typeof(T).Name,
Content = MessagePackSerializer.Serialize(response) Content = MessagePackSerializer.Serialize(response)
}; };
@ -144,12 +144,13 @@ namespace AscNet.GameServer
private void Send(Packet packet) private void Send(Packet packet)
{ {
byte[] serializedPacket = MessagePackSerializer.Serialize(packet, lz4Options); byte[] serializedPacket = MessagePackSerializer.Serialize(packet, lz4Options);
Crypto.HaruCrypt.Encrypt(serializedPacket);
byte[] sendBytes = GC.AllocateUninitializedArray<byte>(serializedPacket.Length + 4); byte[] sendBytes = GC.AllocateUninitializedArray<byte>(serializedPacket.Length + 4);
BinaryPrimitives.WriteInt32LittleEndian(sendBytes, serializedPacket.Length); BinaryPrimitives.WriteInt32LittleEndian(sendBytes.AsSpan()[0..4], serializedPacket.Length);
Array.Copy(serializedPacket, 0, sendBytes, 4, serializedPacket.Length); Array.Copy(serializedPacket, 0, sendBytes, 4, serializedPacket.Length);
Crypto.HaruCrypt.Encrypt(sendBytes);
client.GetStream().Write(sendBytes); client.GetStream().Write(sendBytes);
} }