Форум программистов [Powered by Invision Power Board]

Код

using System;
using System.Net.Sockets;
using System.Threading;
using System.Net;
using System.Text;

namespace TCPTesting
{
    class TCPServer
    {
        private TcpListener tcpListner;
        private Thread listnerThread;
        public TCPTestingForm Form;

        public void TerminateServer()
        {
            this.tcpListner.Stop();
            this.listnerThread.Suspend();
        }

        public void Server() 
        {
            
            this.tcpListner = new TcpListener(IPAddress.Any, 3000);
            this.listnerThread = new Thread(new ThreadStart(ListenForClients));
            this.listnerThread.Start();
            this.Form.eOutput.Text += "Server start! ";
        }

        private void ListenForClients()
        {
            this.tcpListner.Start();
            while (true)
            {
                TcpClient client = this.tcpListner.AcceptTcpClient();
                Thread clientThread = new Thread(new ParameterizedThreadStart(HandleClientComm));
                clientThread.Start(client);
            }
        }

        private void HandleClientComm(object client)
        {
            TcpClient tcpClient = (TcpClient)client;
            NetworkStream clientStream = tcpClient.GetStream();

            byte[] message = new byte[4096];
            int bytesRead;

            while (true)
            {
                bytesRead = 0;

                try
                {
                    //blocks until a client sends a message
                    bytesRead = clientStream.Read(message, 0, 4096);
                }
                catch
                {
                    //a socket error has occured
                    break;
                }

                if (bytesRead == 0)
                {
                    //the client has disconnected from the server
                    break;
                }

                //message has successfully been received
                ASCIIEncoding encoder = new ASCIIEncoding();

                Form.eOutput.Text += encoder.GetString(message, 0, bytesRead) + " ";
                //System.Diagnostics.Debug.WriteLine(encoder.GetString(message, 0, bytesRead));
            }

            tcpClient.Close();
        }
    }
}