Клиент TcpListener остается подключенным, отправляя несколько сообщений, но сервер только получает или обрабатывает первое сообщение

Question

Я настраиваю сервер для чтения некоторых сетевых клиентов, используя TcpListener. Клиент отправляет некоторые данные, которые я проверяю, и отправляю ответ на эти данные, клиент остается подключенным и отправляет второй ответ, и я проверяю эти данные и отправляю ответ обратно, как если бы я дважды заходил на сервер. Первый логин отправляется обратно клиенту просто отлично, но во второй раз, когда клиент отвечает, сервер не показывает, что он получил больше данных от клиента.

Я проверил это, настроив фиктивного клиента (реальный клиент - ODB2 на основе сотового телефона). С установленным фиктивным клиентом я проверил, что первое рукопожатие происходит, но когда клиент отправляет второй набор текста, он не отображается на сервере.

class Program
{
    static private TcpListener listener = null;
    static private TcpClient client = null;
    static private NetworkStream stream = null;
    static private int iCount = 0;
    static Int32 port = 8090;
    static IPAddress localAddr = IPAddress.Parse("192.168.1.17");
    static void Main(string[] args)
    {
        listener = new TcpListener(localAddr, port);
        listener.Start();
        while (true)
        {
            try
            {
                client = listener.AcceptTcpClient();
                ThreadPool.QueueUserWorkItem(ThreadProc, client);
            }
            catch (IOException ioex)
            {
                RestartStream();
            }
        }
    }
        private static void ThreadProc(object obj)
        {

        var client = (TcpClient)obj;
        Byte[] bytes = new Byte[client.ReceiveBufferSize];
        stream = client.GetStream();
        try
        {
            int bytesRead = stream.Read(bytes, 0, (int)client.ReceiveBufferSize);
            string returndata = Encoding.ASCII.GetString(bytes, 0, bytesRead).Replace("-", "");
            byte[] sendBytes;
            if (returndata.ToLower().StartsWith("7e") && returndata.ToLower().EndsWith("7e"))
            {
             //… do stuff with the data and send it back to the client 
             sendBytes = Encoding.Default.GetBytes(login1);
             stream.Write(sendBytes, 0, sendBytes.Length);
             stream.Flush();
                              }
                              else
                {
                    SaveStream(returndata);
                }
            }
        catch (Exception ex)
        {
                      Console.WriteLine(ex.ToString());
        }
    } 

Тестовый код клиента:

 //---data to send to the server---
        string textToSend = "7E010000360141850000080000000000000000000000000000000000000000000000000000000000000035303030303038003131313131313131313131313131313131F67E";

        //---create a TCPClient object at the IP and port no.---
        TcpClient client = new TcpClient(SERVER_IP, PORT_NO);
        NetworkStream nwStream = client.GetStream();
        byte[] bytesToSend = ASCIIEncoding.ASCII.GetBytes(textToSend);

        //---send the text---
        Console.WriteLine("Sending : " + textToSend);
        nwStream.Write(bytesToSend, 0, bytesToSend.Length);

        //---read back the text---
        byte[] bytesToRead = new byte[client.ReceiveBufferSize];
        int bytesRead = nwStream.Read(bytesToRead, 0, client.ReceiveBufferSize);
        Console.WriteLine("Received : " + Encoding.ASCII.GetString(bytesToRead, 0, bytesRead));

        string Text2 = "7E0100003601418535303030303038003131313131313131313131313131313131F67E";
        Console.WriteLine("Sending : " + Text2);
        byte[] bytesToSend2 = ASCIIEncoding.ASCII.GetBytes(Text2);
        nwStream.Write(bytesToSend2, 0, bytesToSend2.Length);
        client.Close();
        Console.ReadLine();

Что мне нужно, так это то, что я понимаю, что клиент постоянно подключен и отправляет данные снова и снова, моя система, кажется, принимает их один раз, а затем перестает их получать, мне нужно, чтобы он продолжал получать данные клиента и обработайте это.

Answer 1

Хорошо, так что я разобрался, должен быть второй цикл while в стороне от потока.

static void Main(string[] args)
    {
        listener = new TcpListener(localAddr, port);
        var clientSocket = default(TcpClient);
        listener.Start();
        var counter = 0;
        while (true)
        {
            clientSocket = listener.AcceptTcpClient();
            var client = new ConnectedDevice();
            client.startClient(clientSocket, counter.ToString(), sqlConnString);
        }
    }

Класс ConnectedDevice:

class ConnectedDevice
{
    private TcpClient _clientSocket;
    private string _clientNumber;
    private string _sqlConnString;

    public void startClient(TcpClient clientSocket, string clientNumber, string sqlConnString)
    {
        _clientSocket = clientSocket;
        _clientNumber = clientNumber;
        _sqlConnString = sqlConnString;

        var ctThread = new Thread(ProcessClient);
        ctThread.Start();
    }
    private void ProcessClient()
    {
        while (_clientSocket.Connected)
        {
            try
            {
                Byte[] bytes = new Byte[_clientSocket.ReceiveBufferSize];
                var networkStream = _clientSocket.GetStream();
                networkStream.ReadTimeout = 10000;
                int i;
                while ((i = networkStream.Read(bytes, 0, bytes.Length)) != 0)
                {
                    var data = System.Text.Encoding.ASCII.GetString(bytes, 0, i).Replace("-", "");
                    byte[] sendBytes;
                    Console.WriteLine(data);
                    string sLogin1 = "7E81000013014185000008000000000054523230313731303138303930303137497E";
                    sendBytes = Encoding.ASCII.GetBytes(sLogin1);
                    networkStream.Write(sendBytes, 0, sendBytes.Length);
                    networkStream.Flush();
                }
            }
            catch (Exception ex)
            {

            }
        }
    }
}