TCP / IP-Listener-in-windows-Dienst

Ich versuche, einen windows-Dienst erstellen, muss im hintergrund laufen und eingehende Datenverkehr (eine normale und regelmäßige TCP-listener)

mein code ist:

private TcpListener server;

public void startServer()
    {
       //EventLog.WriteEntry(source, "connected on: " + ipAddress.ToString() + " port: " + Service1.Port.ToString());

        server = new TcpListener(IPAddress.Parse("127.0.0.1"), Service1.Port);

         server.Start();
        while (true)
        {
          var client = server.AcceptTcpClient();


            new Thread(work).Start(client);

        }

 public void work(object client)
    {
        string msg = null;
        var clientLocal = (TcpClient)client;


            using (NetworkStream ns = clientLocal.GetStream())
            using (StreamReader sr = new StreamReader(ns))
            {
            byte[] msgFullArray = new UTF8Encoding(true).GetBytes(msg);
            fs.Write(msgFullArray, 0, msg.Length);
            }

nun, wenn Sie schauen Sie nicht auf die Methode an alle, wie immer, wenn ich beginne meinen Dienst, es friert immer, wenn ich versuche, starten Sie es auf meine :

 var client = server.AcceptTcpClient();

Bedeutung mein Dienst wird nie auf den Thread oder meine Methoden zu Arbeiten..
ich kann sehen, aus früheren Anmeldung, es geht meiner while-Schleife und dann nur mal den service

Nicht klar ist, was Aufruf startServer. Wenn es direkt aufgerufen, durch Ihre OnStart Methode, das ist ein problem. Als Sie beobachtet habe, AcceptTcpClient blockiert, bis ein client wird angezeigt, aber der thread, der OnStart genannt wird, auf der gehört nicht zu Ihnen, und Sie sollten nicht es zu blockieren.
gut, Sie sind richtig, dass meine onstart-Methode ist der Aufruf "server.startServer();" aber ich bin mir nicht sicher, ob ich verstehe, wie es zu beheben dann?

InformationsquelleAutor Pilsneren | 2016-08-23

  1. 4

    In Ihrem OnStart Methode, die Sie haben zu instanziieren server-Klasse.

    protected override void OnStart(string[] args)
{
  //Create the Server Object ans Start it.
  server = new TCPServer();
  server.StartServer();
}

    verantwortlich ist zu behandeln, die verbindungen zum server durch erstellen einer neuen Thread (so, dass es eine nicht-blockierende Verfahren)

    public void StartServer()
{
  if (m_server!=null)
  {
    //Create a ArrayList for storing SocketListeners before
    //starting the server.
    m_socketListenersList = new ArrayList();

    //Start the Server and start the thread to listen client 
    //requests.
    m_server.Start();
    m_serverThread = new Thread(new ThreadStart(ServerThreadStart));
    m_serverThread.Start();

    //Create a low priority thread that checks and deletes client
    //SocktConnection objcts that are marked for deletion.
    m_purgingThread = new Thread(new ThreadStart(PurgingThreadStart));
    m_purgingThread.Priority=ThreadPriority.Lowest;
    m_purgingThread.Start();
  }
}

    für jeden socket, die es hören, die von einem TCPListener.

    private void ServerThreadStart()
{
  //Client Socket variable;
  Socket clientSocket = null;
  TCPSocketListener socketListener = null;
  while(!m_stopServer)
  {
    try
    {
      //Wait for any client requests and if there is any 
      //request from any client accept it (Wait indefinitely).
      clientSocket = m_server.AcceptSocket();

      //Create a SocketListener object for the client.
      socketListener = new TCPSocketListener(clientSocket);

      //Add the socket listener to an array list in a thread 
      //safe fashon.
      //Monitor.Enter(m_socketListenersList);
      lock(m_socketListenersList)
      {
        m_socketListenersList.Add(socketListener);
      }
      //Monitor.Exit(m_socketListenersList);

      //Start a communicating with the client in a different
      //thread.
      socketListener.StartSocketListener();
    }
    catch (SocketException se)
    {
      m_stopServer = true;
    }
  }
}

    Hier ist es die volle Projekt Artikel.

    InformationsquelleAutor

Schreibe einen Kommentar