30 lines
1.0 KiB
C#
30 lines
1.0 KiB
C#
|
using TcpDotNet;
|
|||
|
|
using TcpDotNet.Protocol;
|
|||
|
|
using TcpDotNet.Protocol.Packets.ClientBound;
|
|||
|
|
using TcpDotNet.Protocol.Packets.ServerBound;
|
|||
|
|
|
|||
|
|
var listener = new ProtocolListener();
|
|||
|
|
listener.Started += (_, _) =>
|
|||
|
|
Console.WriteLine($"Listener started on {listener.LocalEndPoint}");
|
|||
|
|
|
|||
|
|
listener.ClientConnected += (_, e) =>
|
|||
|
|
Console.WriteLine($"Client connected from {e.Client.RemoteEndPoint} with session {e.Client.SessionId}");
|
|||
|
|
|
|||
|
|
listener.ClientDisconnected += (_, e) =>
|
|||
|
|
Console.WriteLine($"Client {e.Client.SessionId} disconnected ({e.DisconnectReason})");
|
|||
|
|
|
|||
|
|
listener.RegisterPacketHandler(new PingPacketHandler());
|
|||
|
|
listener.Start(1234);
|
|||
|
|
|
|||
|
|
await Task.Delay(-1);
|
|||
|
|
|
|||
|
|
internal sealed class PingPacketHandler : PacketHandler<PingPacket>
|
|||
|
|
{
|
|||
|
|
public override async Task HandleAsync(BaseClientNode recipient, PingPacket packet)
|
|||
|
|
{
|
|||
|
|
Console.WriteLine($"Client {recipient.SessionId} sent ping with payload {BitConverter.ToString(packet.Payload)}");
|
|||
|
|
var pong = new PongPacket(packet.Payload);
|
|||
|
|
await recipient.SendPacketAsync(pong);
|
|||
|
|
}
|
|||
|
|
}
|