using System;

using System.Collections.Generic;

using System.ComponentModel;

using System.Data;

using System.Diagnostics;

using System.Linq;

using System.ServiceProcess;

using System.Text;

using System.Threading;

​

namespace WindowsService1

{

    partial class TestService : ServiceBase

    {

        Thread workerThread;

        public TestService()

        {

            InitializeComponent();

        }

​

        protected override void OnStart(string[] args)

        {

            try

            {

                TcpListenerSample.isEnabled = true;

                workerThread =  new Thread(new ThreadStart(TcpListenerSample.Listen));

                workerThread.Start();

            }

            catch (Exception ex)

            {

                using (EventLog eventLog = new EventLog("Application"))

                {

                    eventLog.Source = "Application";

                    eventLog.WriteEntry("ex", EventLogEntryType.Information, 101, 1);

                }

            }

        }

​

        protected override void OnStop()

        {

            TcpListenerSample.isEnabled = false;

            workerThread.Join();

            base.OnStop();

            // TODO: Add code here to perform any tear-down necessary to stop your service.

        }

    }

}

​

​

​

​

using System;

using System.Text;

using System.IO;

using System.Net;

using System.Net.Sockets;

using System.Threading;

using System.Runtime.Serialization;

using System.Runtime.Serialization.Formatters.Binary;

using WindowsService1;

​

public class TcpListenerSample

{

​

    public static volatile bool isEnabled;

    public static void Listen()

    {

        try

        {

            // set the TcpListener on port 13000

            int port = 4000;

            TcpListener server = new TcpListener(IPAddress.Any, port);

​

            // Start listening for client requests

            server.Start();

​

​

            // Buffer for reading data

            byte[] bytes = null;

            string data = null;

​

            //Enter the listening loop

            while (true && isEnabled)

            {

                // check for pending connections.                

                if (server.Pending())

                {

                    TcpClient client = server.AcceptTcpClient();

                    NetworkStream inputStream = client.GetStream();

                    while (!inputStream.DataAvailable) ;

​

​

                    int i;

​

                    // read data

                    bytes = new byte[client.Available];

                    i = inputStream.Read(bytes, 0, bytes.Length);

                    Thread.Sleep(10000);

                    data = System.Text.Encoding.ASCII.GetString(bytes, 0, i);

                    MatrixValidationRequest matrixValidation = Deserialize<MatrixValidationRequest>(data);

                    byte[] msg = System.Text.Encoding.ASCII.GetBytes(matrixValidation.SourceName.ToUpper());

                    if(IsSocketConnected(client.Client))// Send back a response.                    

                        inputStream.Write(msg, 0, msg.Length);

​

                    // Shutdown and end connection

                    client.Close();

                }

            }

        }

        catch (Exception e)

        {

        }

    }

​

    public static T Deserialize<T>(string input) where T : class

    {

        System.Xml.Serialization.XmlSerializer ser = new System.Xml.Serialization.XmlSerializer(typeof(T));

​

        using (StringReader sr = new StringReader(input))

        {

            return (T)ser.Deserialize(sr);

        }

    }

    private static bool IsSocketConnected(Socket socket)

    {

        try

        {

            return !(socket.Poll(1, SelectMode.SelectRead) && socket.Available == 0);

        }

        catch (SocketException) { return false; }

    }

​

}

​