TCPserver in C#

[Martin (Gast)]

Hallo,

ich versuche mich an einem TCP-Server in C#, der Daten von einem 
TCP-Client in C empfängt. Das Problem ist, dass der Server nach einer 
willkürlichen Anzahl von Empfangvorgängen nichts mehr empfängt, der 
Client jedoch weiterarbeitet.

 mythread = new Thread(new ThreadStart(listen_tcp));
 mythread.start();

 private void listen_tcp()
        {
            string tmp = null;
            IPAddress ipAddress = IPAddress.Any;
            listener = new TcpListener(ipAddress, 12345);
            listener.Start();
            Console.WriteLine("Server is running");
            Console.WriteLine("Listening on port " + 12345);
            Console.WriteLine("Waiting for connections...");       
            s = listener.AcceptSocket();
            Console.WriteLine("Connection accepted from " + s.RemoteEndPoint);
            while (s.Connected == true) 
            {

                byte[] b = new byte[100];
                char[] c = new char[100];
                int k = s.Receive(b);
                //Console.WriteLine("Received:");
                for (int i = 0; i < k; i++)
                {
                    Console.Write(Convert.ToChar(b[i]));
                    c[i] = Convert.ToChar(b[i]);
                }
                tmp = new string(c);
                convert_vs(tmp);
                tmp = null;
                ASCIIEncoding enc = new ASCIIEncoding();
                s.Send(enc.GetBytes("Server responded"));
                //Console.WriteLine("\nSent Response");
                if (s.Connected == false) s.Close();
                if (shut_down == true)
                {
                    s.Close();
                    mythread.Abort();
                    Console.WriteLine("Mythread wurde beendet");
                }

            }
        }

Teilweise kommt die Meldung: Der Thread xx hat mit Fehlercode 0x00 
geendet.
Kennt jemand das Problem bzw. hat sogar eine Lösung dafür?
Viele Grüße,
Martin

[Peter II (Gast)]

Martin schrieb:
> Der Thread xx hat mit Fehlercode 0x00 geendet.
man könnte ja auch mal eine Fehlerbehandlung einbauen.

Try Catch ist das stichwort.

[Marcus B. (raketenfred)]

Martin schrieb:
> Teilweise kommt die Meldung: Der Thread xx hat mit Fehlercode 0x00
> geendet.

.Net wirft eigentlich aussagen kräftigere Fehlermeldungen.

Ansonsten umschließe den Bereich mal mit try-catch und lass die 
Fehlermeldung entweder protokollieren oder aufpoppen.

Dein Threading arbeitet aber etwas komisch

Generell gibt es einen Thread, der den Port offen hält, und wenn dann 
sich jemand auf den Port verbindet, leitet der erste Thread, das ganze 
weiter und spawnt einen neuen Thread, der sich nur um diese eine 
Verbindung kümmert.

Wenn das C-Programm irgendwann die Verbindung schließt, dann endet auch 
dein Thread, d.h. es kann sich noch nichtmals neustarten.

[Läubi .. (laeubi)]

Martin schrieb:
> s = listener.AcceptSocket();

An der stelle musst du/solltest du einen eigenen Thread aufmachen.

Martin schrieb:
> mythread.Abort();

Was soll das? Ein einfaches break reicht völlig aus.

Martin schrieb:
> if (s.Connected == false) s.Close();

Das schließen sollte immer hinter dem while block passieren und nicht 
nur manchmal wenn die Verbindung weshalb auch immer nicht mehr connected 
ist...

Martin schrieb:
> if (shut_down == true)

gehört in die while Bedingung.

Martin schrieb:
> Kennt jemand das Problem bzw. hat sogar eine Lösung dafür?

Überdenke deinen Programmfluss da geht einiges durcheinander...

[Martin (Gast)]

Danke für die ganzen Hinweise, ich bin in C# leider ziemlicher 
Anfänger... ich habe versucht etwas davon umzusetzen, es klappt immer 
noch nicht.

namespace TCPServer
{
    public partial class Form1 : Form
    {
        public Socket s;
        public Thread mythread = null;
        public TcpListener listener = null;
        public Thread cl_thread;
        
        public Form1()
        {
            InitializeComponent();
            mythread = new Thread(new ThreadStart(listen_tcp));
            mythread.Start();
        }

        private void Form1_Load(object sender, EventArgs e)
        {

        }

        private void client_thread()
        {
            Console.WriteLine("Test " + s.RemoteEndPoint);
            string tmp = null;
            while (s.Connected == true)
            {
                byte[] b = new byte[100];
                char[] c = new char[100];
                int k = s.Receive(b);
                //Console.WriteLine("Received:");
                for (int i = 0; i < k; i++)
                {
                    Console.Write(Convert.ToChar(b[i]));
                    c[i] = Convert.ToChar(b[i]);
                }
                tmp = new string(c);
                //convert_vs(tmp);
                tmp = null;
                ASCIIEncoding enc = new ASCIIEncoding();
            }
            Console.WriteLine("Verbindung beendet");
        }

        private void listen_tcp()
        {      
            IPAddress ipAddress = IPAddress.Any;
            listener = new TcpListener(ipAddress, 12345);
            listener.Start();
            Console.WriteLine("Server is running");
            Console.WriteLine("Listening on port " + 12345);
            Console.WriteLine("Waiting for connections...");
            while (true)
            {
                s = listener.AcceptSocket();
                cl_thread = new Thread(new ThreadStart(client_thread));
                cl_thread.Start();
            }
           
        } 
    }
}

Nach einer Weile kommt nichts mehr beim Server an. Beende ich dann das 
Client Programm und starte es neu, kann ich mich laut Client erfolgreich 
verbinden, die Bestätigung im Server Programm bleibt aber aus.

[Peter II (Gast)]

du muss deinen Thread auch den socket übergeben! du machst es jetzt mit 
einen Globalen variabel in der Klasse das geht aber nciht, weil du nur 
eine Variabel hast aber jeder client braucht seinen eigenen socket.

Ich denke du solltest etwas einfacher anfangen, lerne erstmal die 
Sprache bevor du mit Client-Server verbindungen anfängst.

[Olek (Gast)]

Tu Dir und mir einen Gefallen und kommentiere mal jede Zeile mit dem was 
du da eigentlich machst. Es ist nicht besonders einfach deinem 
Gedankengang da zu folgen.

Um so früher Du damit anfängst um so besser, den am Ende machst Du das 
dann doch nicht... kenne ich leider von mir all zu gut :)

[Martin (Gast)]

public partial class Form1 : Form
    {
        public Thread mythread = null;
        public TcpListener listener = null;
        public Thread cl_thread;
        
        public Form1()
        {
            InitializeComponent();
            mythread = new Thread(new ThreadStart(listen_tcp));
            mythread.Start();
        }

        private void Form1_Load(object sender, EventArgs e)
        {

        }

        private void client_thread(Socket s)
        {
            Console.WriteLine("Test " + s.RemoteEndPoint);
            string tmp = null;
            while (s.Connected == true)
            {
                byte[] b = new byte[100];
                char[] c = new char[100];
                int k = s.Receive(b);
                //Console.WriteLine("Received:");
                for (int i = 0; i < k; i++)
                {
                    Console.Write(Convert.ToChar(b[i]));
                    c[i] = Convert.ToChar(b[i]);
                }
                tmp = new string(c);
                //convert_vs(tmp);
                tmp = null;
                ASCIIEncoding enc = new ASCIIEncoding();
            }
            Console.WriteLine("Verbindung beendet");
        }

        private void listen_tcp()
        {      
            IPAddress ipAddress = IPAddress.Any;
            listener = new TcpListener(ipAddress, 12345);
            listener.Start();
            Console.WriteLine("Server is running");
            Console.WriteLine("Listening on port " + 12345);
            Console.WriteLine("Waiting for connections...");
            while (true)
            {
                Socket cl_socket = listener.AcceptSocket();
                cl_thread = new Thread(new ThreadStart(client_thread(cl_socket)));
                cl_thread.Start();
            }
           
        } 
    }

Funkioniert so leider auch nicht, das übergeben des cl_socket nimmt er 
so nicht hin. Ich habe schon recht viel aussen rum gebaut und würde das 
jetzt ungern alles wegschmeissen, wär super wenn mir da jemand einen 
konkreten Tip geben könnte.

[Arc N. (arc)]

Es gibt ThreadStart und ParameterizedThreadStart

http://msdn.microsoft.com/de-de/library/system.threading.threadstart(v=vs.80).aspx
http://msdn.microsoft.com/de-de/library/system.threading.parameterizedthreadstart(v=vs.80).aspx

oder die Fehlermeldungen beachten und die richtigen Typen verwenden bzw. 
den Thread und die Parameter kapseln.
http://msdn.microsoft.com/de-de/library/ts553s52(v=vs.80).aspx

[Läubi .. (laeubi)]

Martin schrieb:
> wär super wenn mir da jemand einen
> konkreten Tip geben könnte.

Teil Das Problem auf: Eine Klasse welche einen Socket im Konstruktor 
übernimmt, einen Thread startet und von dem Socket liest/schreibt.
In der Serverklasse erzeugst du bei jedem Accept einfach eine neue 
Instanz der neuen Klasse.

Das ist nicht nur universeller sondern auch weniger Fehleranfällig.

[Martin (Gast)]

Läubi ich habe versucht deinen Vorschlag umzusetzen:

namespace TCPServer
{
    public class My_server
    {
        public My_server(Socket mysocket)
        {
            this.mysocket = mysocket;
            mythread = new Thread(new ThreadStart(client_thread));
            mythread.Start();
        }

        public Socket mysocket;
        public Thread mythread;

        public void client_thread()
        {
            Console.WriteLine("Test " + mysocket.RemoteEndPoint);
            string tmp = null;
            while (mysocket.Connected == true)
            {
                byte[] b = new byte[200];
                char[] c = new char[200];
                int k = mysocket.Receive(b);
                for (int i = 0; i < k; i++)
                {
                    Console.Write(Convert.ToChar(b[i]));
                    c[i] = Convert.ToChar(b[i]);
                }
                tmp = new string(c);
                //convert_vs(tmp);
                tmp = null;
                ASCIIEncoding enc = new ASCIIEncoding();
            }
            Console.WriteLine("Verbindung beendet");
        }
    }
    
    public partial class Form1 : Form
    {
        public Thread mythread = null;
        public TcpListener listener = null;
        public Thread cl_thread;
        Socket s;

        public Form1()
        {
            InitializeComponent();
            mythread = new Thread(new ThreadStart(listen_tcp));
            mythread.Start();
        }

        private void Form1_Load(object sender, EventArgs e)
        {

        }

        private void listen_tcp()
        {      
            IPAddress ipAddress = IPAddress.Any;
            listener = new TcpListener(ipAddress, 12345);
            listener.Start();
            Console.WriteLine("Server is running");
            Console.WriteLine("Listening on port " + 12345);
            Console.WriteLine("Waiting for connections...");
            while (true)
            {
               s = listener.AcceptSocket();
               My_server my = new My_server(s);
            }
           
        } 
    }
}

Leider bleibt das Problem bestehen. Ist vllt in der Empfangsroutine an 
sich ein Fehler, eine Variable die überläuft etc?

[Martin (Gast)]

Hier noch eine Variante bei der jedesmal eine neue Instanz der My_server 
Klasse erstellt wird. Kommen keine Werte mehr an und ich connecte 
erneut, erhalte ich allerdings gleich von Anfang an keine Werte.

namespace TCPServer
{
    public class My_server
    {
        public My_server(Socket mysocket)
        {
            this.mysocket = mysocket;
            mythread = new Thread(new ThreadStart(client_thread));
            mythread.Start();
        }

        public Socket mysocket;
        public Thread mythread;

        public void client_thread()
        {
            Console.WriteLine("Test " + mysocket.RemoteEndPoint);
            string tmp = null;
      
            while (mysocket.Connected == true)
            {
                byte[] b = new byte[200];
                char[] c = new char[200];
                int k = mysocket.Receive(b);
                for (int i = 0; i < k; i++)
                {
                    Console.Write(Convert.ToChar(b[i]));
                    c[i] = Convert.ToChar(b[i]);
                }
                tmp = new string(c);
                //convert_vs(tmp);
                tmp = null;
                ASCIIEncoding enc = new ASCIIEncoding();
            }
            Console.WriteLine("Verbindung beendet");
        }
    }
    
    public partial class Form1 : Form
    {
        public Thread mythread = null;
        public TcpListener listener = null;
        public Thread cl_thread;
        Socket s;
        int count = 0;

        public Form1()
        {
            InitializeComponent();
            mythread = new Thread(new ThreadStart(listen_tcp));
            mythread.Start();
        }

        private void Form1_Load(object sender, EventArgs e)
        {

        }

        private void listen_tcp()
        {      
            IPAddress ipAddress = IPAddress.Any;
            listener = new TcpListener(ipAddress, 12345);
            listener.Start();
            My_server[] my = new My_server[10];
            Console.WriteLine("Server is running");
            Console.WriteLine("Listening on port " + 12345);
            Console.WriteLine("Waiting for connections...");
            while (true)
            {
               s = listener.AcceptSocket();
               my[count] = new My_server(s);
               count++;
            }
           
        } 
    }
}

[Läubi .. (laeubi)]

Martin schrieb:
> tmp = null;
> ASCIIEncoding enc = new ASCIIEncoding();
Was soll das bewirken?

Martin schrieb:
> my[count] = new My_server(s);
> count++;
AUA was soll sowas? Bitte nicht solche Konstrukte in einer Schleife 
ohne Boundcheck und was soll das überhaupt?
 1) C# kennt Listen welche sich um das Speichermanagment kümmern
 2) du verwendest die Referenz nie also wozu aufheben?

Martin schrieb:
> Kommen keine Werte mehr an und ich connecte
> erneut, erhalte ich allerdings gleich von Anfang an keine Werte

Zeig doch mal deinen Clientcode.... der Server sieht (bis auf die 
Anmerkungen) ganz okay aus.

[Martin (Gast)]

Hallo Läubi, hier der Client:

int main()
{
  WSADATA wsa;
  SOCKET mysocket;
  SOCKADDR_IN addr;
  long rc;
  char mystring[100] = "";
  int i = 0;

  if(WSAStartup(MAKEWORD(2,0),&wsa)!=0) 
    printf("Winsock konnte nicht gestartet werden\n");
  else
    printf("Winsock gestartet\n");

  mysocket=socket(AF_INET,SOCK_STREAM,0);

  if(mysocket==INVALID_SOCKET)
  {
    printf("Fehler: Der Socket konnte nicht erstellt werden, fehler code: %d\n",WSAGetLastError());
    return 1;
  }
  else
  {
    printf("Socket erstellt!\n");
  }
  memset(&addr,0,sizeof(SOCKADDR_IN));
  addr.sin_family=AF_INET;
  addr.sin_port=htons(12345); // wir verwenden mal port 12345
  addr.sin_addr.s_addr=inet_addr("127.0.0.1"); // zielrechner ist unser eigener
  rc=connect(mysocket,(SOCKADDR*)&addr,sizeof(SOCKADDR));
  if(rc==SOCKET_ERROR)
  {
    printf("Fehler: connect gescheitert, fehler code: %d\n",WSAGetLastError());
    return 1;
  }
  else
  {
    printf("Verbunden mit 127.0.0.1..\n");
  }
  send(mysocket,mystring,sizeof(mystring),0);
  strcpy(mystring,"Verbunden\n");
  send(mysocket,mystring,9,0);
  
  while(1)
  {
    i++;
    sprintf(mystring, "%d\n",i);
    send(mysocket,mystring,sizeof(mystring),0);
    printf("%d",i);
    Sleep(500);
  }
  return 0;
}

Was meinst du genau mit Boundcheck?
> ASCIIEncoding enc = new ASCIIEncoding(); hat keine Funktion hier, hab ich 
vergessen rauszuschmeissen. Grüße Martin

[Finchi (Gast)]

Schreib den Server nochmal ordentlich neu, benenne Variablen richtig, 
benutze Klassen und kommentiere deinen Code. Beachte dabei folgende 
Seiten:

http://msdn.microsoft.com/de-de/library/system.net.sockets.tcplistener.aspx

http://msdn.microsoft.com/de-de/library/system.net.sockets.tcpclient.aspx

http://www.vb-paradise.de/allgemeines/tipps-tricks-und-tutorials/internet-lan/16242-ausfuehrliches-tcp-und-udp-tutorial/#post94565 
(Ist zwar VB.NET aber trotzdem gut erklärt)

MFG