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