IPAddress ipAddress = IPAddress.Parse("127.0.0.1");
IPEndPoint ipEndPoint = new IPEndPoint(ipAddress, 5555);
using Socket listener = new Socket(ipEndPoint.AddressFamily, SocketType.Stream, ProtocolType.Tcp);
listener.Bind(ipEndPoint);
listener.Listen(100);
Console.WriteLine("Serveur démarré, en attente du client...");
var handler = await listener.AcceptAsync(); // Connexion du client
Console.WriteLine($"Client : \"{ipAddress.MapToIPv4()}\" sur le port : \"{ipEndPoint.Port}\" connecté au serveur.");
MemoryStream memoryStream = new MemoryStream();
var buffer = new byte[1024];
while (true)
{
int byteReceived = await handler.ReceiveAsync(buffer, SocketFlags.None);
if(byteReceived > 0)
{
memoryStream.Write(buffer, 0, byteReceived);
}
else
{
break;
}
BinaryReader reader = new BinaryReader(memoryStream);
- short hiheader = reader.ReadInt16(); // HiHeader (2octets) = packetId (8bits) + lenType (6bits)
short packetId = ((short)(hiheader >> 2));
short lenType = ((short)(hiheader & 3));
IPAddress ipAddress = IPAddress.Parse("127.0.0.1");
IPEndPoint ipEndPoint = new IPEndPoint(ipAddress, 5555);
using Socket listener = new Socket(ipEndPoint.AddressFamily, SocketType.Stream, ProtocolType.Tcp);
listener.Bind(ipEndPoint);
listener.Listen(100);
Console.WriteLine("Serveur démarré, en attente du client...");
var handler = await listener.AcceptAsync(); // Connexion du client
Console.WriteLine($"Client : \"{ipAddress.MapToIPv4()}\" sur le port : \"{ipEndPoint.Port}\" connecté au serveur.");
MemoryStream memoryStream = new MemoryStream();
var buffer = new byte[1024];
while (true)
{
int byteReceived = await handler.ReceiveAsync(buffer, SocketFlags.None);
if(byteReceived > 0)
{
memoryStream.Write(buffer, 0, byteReceived);
}
else
{
break;
}
BinaryReader reader = new BinaryReader(memoryStream);
- short hiheader = reader.ReadInt16(); // HiHeader (2octets) = packetId (8bits) + lenType (6bits)
short packetId = ((short)(hiheader >> 2));
short lenType = ((short)(hiheader & 3));