networking-demo

Program.cs (1957B)

---

 using System;
 using System.Net;
 
 using NetworkingDemo.Packets;
 
 namespace NetworkingDemo {
 	internal class Program {
 		// hosting the server at 127.0.0.1:12345 for sake of demo
 		static readonly IPAddress Addr = IPAddress.Loopback;
 		const int Port = 12345;
 
 		static void Main(string[] args) {
 			// server demo, wait for clients and handle them
 			Server server = new Server(Addr, Port);
 
 			// setup all server-side packet handlers
 			server.On(PacketType.Ping, (buffer, conn) => {
 				PingPacket packet = new PingPacket();
 
 				if (!packet.TryDeserializeFrom(buffer)) {
 					return ConnectionResult.CloseConnection;
 				}
 
 				conn.Send(new PongPacket(packet.Value));
 
 				return ConnectionResult.ReceivePackets;
 			});
 
 			// start listening for incoming client connections
 			server.Start();
 
 
 			// client demo, send and receive multiple packets
 			Client client = new Client();
 			Connection connection = client.ConnectTo(Addr, Port);
 
 			// setup all client-side packet handlers
 			connection.On(PacketType.Welcome, (buffer, conn) => {
 				WelcomePacket packet = new WelcomePacket();
 
 				if (!packet.TryDeserializeFrom(buffer)) {
 					return ConnectionResult.CloseConnection;
 				}
 
 				Console.WriteLine($"[server->client] Welcome: {packet.Msg}");
 
 				return ConnectionResult.ReceivePackets;
 			});
 
 			connection.On(PacketType.Pong, OnPongPacket);
 
 			// start listening for incoming packets
 			connection.BeginRecv();
 
 			for (int i = 0; i < 10; i++) {
 				Console.WriteLine($"[client->server] Ping: {i}");
 				connection.Send(new PingPacket(i));
 			}
 
 
 			// wait for demo to end
 			Console.ReadLine();
 		}
 
 		static ConnectionResult OnPongPacket(Memory<byte> buffer, Connection conn) {
 			PongPacket packet = new PongPacket();
 
 			if (!packet.TryDeserializeFrom(buffer)) {
 				return ConnectionResult.CloseConnection;
 			}
 
 			Console.WriteLine($"[server->client] Pong: {packet.Value}");
 
 			return ConnectionResult.ReceivePackets;
 		}
 	}
 }