using System;
using System.Collections.Generic;
using System.Linq;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using System.Threading.Tasks;

namespace LAB02
{
    class Program
    {

        private static void ThreadServer(object info)
        {
            TcpListener server = new TcpListener(IPAddress.Any, 2048);
            server.Start();

            while (true)
            {
                TcpClient client = server.AcceptTcpClient();
                byte[] buffer = new byte[2048];
                while (client.Connected)
                {
                    int l = client.GetStream().Read(buffer, 0, 2048);
                    client.GetStream().Write(buffer, 0, l);
                }
                client.Close();
            }
        }

        private static void ThreadClient(object info)
        {
            TcpClient client = new TcpClient();
            client.Connect(new IPEndPoint(IPAddress.Parse("127.0.0.1"), 2048));
            int counter = 5;

            for (int i = 0; i < counter; i++)
            {
                byte[] message = new ASCIIEncoding().GetBytes("wiadomosc");
                client.GetStream().Write(message, 0, message.Length);
                NetworkStream stream = client.GetStream();
                message = new byte[2048];
                int l = stream.Read(message, 0, 2048);
                string result = System.Text.Encoding.UTF8.GetString(message,0,l);
                Console.WriteLine(result);
            }
        }


        static void Main(string[] args)
        {
            ThreadPool.QueueUserWorkItem(ThreadServer);
            ThreadPool.QueueUserWorkItem(ThreadClient);
            ThreadPool.QueueUserWorkItem(ThreadClient);

            Console.ReadKey();
        }
    }
}