tcplistener.cs

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

namespace Hl7v2MLLP
{
    public class TcpServer : IDisposable
    {
        private readonly TcpListener _tcpListener;

        public TcpServer(string ipAddress = "127.0.0.1", int port = 4321)
        {
            try
            {
                _tcpListener = new TcpListener(IPAddress.Parse(ipAddress), port);
                _tcpListener.Start();

                Console.WriteLine("TcpListener started");
            }
            catch (Exception e)
            {
                Console.WriteLine(e);
                throw;
            }
        }

        public async Task Listen()
        {
            try
            {
                while (true)
                {
                    var incomingTcpClientConnection = await _tcpListener.AcceptTcpClientAsync();

                    Console.WriteLine($"Accepting incoming connection");

                    var clientProcessingThread = new Thread(ProcessClientConnection);

                    clientProcessingThread.Start(incomingTcpClientConnection);
                }
            }
            catch (Exception e)
            {
                Console.WriteLine(e);
                throw;
            }
        }

        private void ProcessClientConnection(object args)
        {
            var tcpClient = (TcpClient) args;

            var buffer = new byte[200];
            var netStream = tcpClient.GetStream();

            var readData = String.Empty;

            try
            {
                int bytesReceived;

                while ((bytesReceived = netStream.Read(buffer, 0, buffer.Length)) > 0)
                {
                    Console.WriteLine($"Bytes received: {bytesReceived}");
                    readData += Encoding.UTF8.GetString(buffer, 0, bytesReceived);
                }

                System.Diagnostics.Debugger.Launch();
                Console.WriteLine($"Data: {readData}");

            }
            catch (Exception e)
            {
                Console.WriteLine(e);
                throw;
            }
            finally
            {
                netStream.Close();
                netStream.Dispose();
                tcpClient.Close();
            }
        }

        public void Dispose()
        {
            _tcpListener.Stop();
        }
    }
}