using System;

using System.IO;

using System.Linq;

using System.Net;

using System.Net.Sockets;

using System.Runtime.Serialization.Formatters.Binary;

using System.Threading;

using System.Threading.Tasks;

​

namespace StackOverflow2

{

    internal class Program

    {

        private static void Main(string[] args)

        {

            Console.WriteLine("Hello World!");

            var srv = Task.Factory.StartNew(() => { new Server().Start(); });

            var cl = Task.Factory.StartNew(() => { new Client().Start(); });

            Task.WaitAll(srv, cl);

        }

    }

​

    public class Connection

    {

        private Socket socket;

​

        public Connection(Socket socket)

        {

            this.socket = socket;

            Console.WriteLine($"Connected to client: {socket.RemoteEndPoint}");

            Task.Factory.StartNew(() => Execute(socket));

        }

​

        private void Execute(Socket socket)

        {

            while (true)

            {

                var buffer = new byte[2048];

                var bytesCount = socket.Receive(buffer);

                if (bytesCount != 0)

                {

                    var msgReceived = (Message) Serializer.FromStream(new MemoryStream(buffer, 0, buffer.Length));

                    Console.WriteLine($"Received msg: {msgReceived.Content}");

                }

                /* var msg = new Message { Content = "Hello World2!" };

                 Console.WriteLine($"Sending msg with content: {msg.Content}");

                 MemoryStream stream = Serializer.ToStream(msg);

                 var bytesSent = socket.Send(stream.GetBuffer());*/

​

                Console.WriteLine("Trying again");

                Thread.Sleep(500);

            }

        }

    }

​

    public class Serializer

    {

        public static MemoryStream ToStream(object obj)

        {

            var stream = new MemoryStream();

            var formatter = new BinaryFormatter();

            formatter.Serialize(stream, obj);

            return stream;

        }

​

        public static object FromStream(MemoryStream stream)

        {

            Console.WriteLine("Starting from stream");

            var formatter = new BinaryFormatter();

            stream.Seek(0, SeekOrigin.Begin);

            var rez = formatter.Deserialize(stream); //NEVER GOES OVER THIS

            Console.WriteLine("Starting deserialization" + rez);

            return rez;

        }

    }

​

    [Serializable]

    public class Message

    {

        public string Content { get; set; }

    }

​

    public class Client

    {

        public void Start()

        {

            var host = Dns.GetHostEntry("localhost");

            var ipAddress = host.AddressList.First();

            var serverEndpoint = new IPEndPoint(ipAddress, 9000);

​

            var serverSocket = new Socket(ipAddress.AddressFamily, SocketType.Stream, ProtocolType.Tcp);

            serverSocket.Connect(serverEndpoint);

​

            Console.WriteLine($"Successfully connected to server on: {serverSocket.RemoteEndPoint}");

​

            while (true)

            {

                var msg = new Message {Content = "Hello World!"};

                Console.WriteLine($"Sending msg with content: {msg.Content}");

                var stream = Serializer.ToStream(msg);

                var bytesSent = serverSocket.Send(stream.GetBuffer());

                Console.WriteLine("Waiting to receive");

​

                var buffer = new byte[2048];

                var bytesReceived = serverSocket.Receive(buffer);

                if (bytesReceived != 0)

                {

                    var receivedMessage = (Message) Serializer.FromStream(new MemoryStream(buffer));

                    Console.WriteLine($"Received message: {receivedMessage.Content}");

                }

​

                Console.WriteLine("Received done");

            }

        }

    }

​

    public class Server

    {

        public void Start()

        {

            var host = Dns.GetHostEntry("localhost");

            var ipAddress = host.AddressList.First();

            var localEndPoint = new IPEndPoint(ipAddress, 9000);

            var serverSocket = new Socket(ipAddress.AddressFamily, SocketType.Stream, ProtocolType.Tcp);

            serverSocket.Bind(localEndPoint);

            serverSocket.Listen(1);

​

            while (true)

            {

                Console.WriteLine("Waiting for client");

                var clientSocket = serverSocket.Accept();

                var connection = new Connection(clientSocket);

            }

        }

    }

}