Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- /// SERVER
- namespace TcpServer
- {
- using System;
- using System.Net;
- using System.Net.Sockets;
- using System.Text;
- using System.Threading;
- class Program
- {
- public static void Main(string[] args)
- {
- var server = new TcpListener(IPAddress.Parse("127.0.0.1"), 6112);
- server.Start();
- Console.WriteLine("Server has started on 127.0.0.1:6112.");
- Console.WriteLine("Waiting for a connection...");
- Thread.Sleep(3000);
- var client = server.AcceptTcpClient();
- Console.WriteLine("A client has connected.");
- Thread.Sleep(3000);
- var serverToClientStream = client.GetStream();
- while (!serverToClientStream.DataAvailable) { /* wait, do nothing */ };
- var buffer = new byte[1024];
- for (int i = 0; i < buffer.Length && serverToClientStream.DataAvailable; i++)
- {
- const int bytesToReadCount = 1;
- serverToClientStream.Read(buffer, i, bytesToReadCount);
- }
- var message = Encoding.UTF8.GetString(buffer);
- Console.WriteLine($"Received message from client: {message}");
- Console.WriteLine("Press any key to continue...");
- Console.ReadLine();
- }
- }
- }
- /// CLIENT
- namespace TcpClient
- {
- using System;
- using System.Net.Sockets;
- using System.Text;
- using System.Threading;
- class Program
- {
- static void Main(string[] args)
- {
- Thread.Sleep(3000);
- using (var client = new TcpClient("127.0.0.1", 6112))
- {
- Console.WriteLine("Connected");
- var clientToServerStream = client.GetStream();
- Thread.Sleep(3000);
- var message = "Message from client";
- byte[] messageBuffer = Encoding.UTF8.GetBytes(message);
- clientToServerStream.Write(messageBuffer, 0, messageBuffer.Length);
- Console.WriteLine($"Sent to server: {message}");
- }
- Console.WriteLine("Press any key to continue...");
- Console.ReadLine();
- }
- }
- }
- /////
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement