Komunikacja TCP - zapętlenie komunikacji

Witam

Piszę program który ma komunikować się z terminalem wagowym za pomocą klienta TCP. Już kilka "częściowych" postów z nim związanych pojawiło się na forum i uzyskałem Waszą pomoc - teraz trochę bardziej "globalnie" o programie i problemie.
Wysyłam komunikaty (np sprawdzające status) i na podstawie odpowiedzi wykonuję odpowiednie czynności.
Na początek trochę kodu.
Połączenie z wagą:

 
public static void PolaczZWaga(string IP, int port)
        {
            IP = IP.Replace(" ", "");
            KlientTCP = new TcpClient();
            KlientTCP.Connect(IPAddress.Parse(IP), port);
        }

Wysłanie zapytania (np o status wagi):

public static string OdczytDanychZWagi(byte[] WysylaneZapytanie)
        {
            // Wysyłka komunikatu do podłączonego serwera TCP
            byte[] GotoweZapytanie = KomunikatyWspolne.PoczatekKomunikacji.Concat(WysylaneZapytanie).Concat(KomunikatyWspolne.KoniecKumunikacji).ToArray();
            NetworkStream stream = KlientTCP.GetStream();
            stream.Write(GotoweZapytanie, 0, GotoweZapytanie.Length);

            // Otrzymanie odpowiedzi

            // Buffor na odpowiedz
            byte[] odpowiedz = new Byte[256];

            // String do przechowywania odpowiedzi w ASCII
            String responseData = String.Empty;

            // Odczyt danych z serwera
            Int32 bytes = stream.Read(odpowiedz, 0, odpowiedz.Length);
            responseData = System.Text.Encoding.ASCII.GetString(odpowiedz, 0, bytes);
            return responseData;
        }

Po otwarciu Form1 mamy nawiązanie połączenia i sprawdzenie statusu:

string odp = KomunikacjaSieciowa.OdczytDanychZWagi(OdczytZWagi.Kom_RejestrStatusu);
                char status = odp[0];

            
                switch(status)
                {
                    case 'B':
                        KomunikacjaSieciowa.WysylkaDoWyswietlaczaWagi_4linie(WysylkaDoWyswietlacza_Komunikaty.LogWitaj, WysylkaDoWyswietlacza_Komunikaty.LogZaloguj, WysylkaDoWyswietlacza_Komunikaty.PustaLinia, WysylkaDoWyswietlacza_Komunikaty.LogNrOperatora);
                        string NrOperatora = KomunikacjaSieciowa.OdczytDanychZWagi(OdczytZWagi.Kom_ZatwierdzoneF1);
                        //int NrOperatora_int = Convert.ToInt32(NrOperatora);
                        break;
// tutaj dalsza część przypadków

Tutaj pojawia się mój problem - komunikacja z wagą odbywa się tylko raz a operacja wymaga wprowadzenia danych na terminalu. Zanim operator wprowadzi dane to program kończy już swoje działanie.
Jak zmienić kod/zapętlić/dodać timer żeby komunikacja powtarzała się do osiągnięcia pewnego statusu?
Dokładniej jak w tym fragmencie:

case 'B':
                        KomunikacjaSieciowa.WysylkaDoWyswietlaczaWagi_4linie(WysylkaDoWyswietlacza_Komunikaty.LogWitaj, WysylkaDoWyswietlacza_Komunikaty.LogZaloguj, WysylkaDoWyswietlacza_Komunikaty.PustaLinia, WysylkaDoWyswietlacza_Komunikaty.LogNrOperatora);
                        string NrOperatora = KomunikacjaSieciowa.OdczytDanychZWagi(OdczytZWagi.Kom_ZatwierdzoneF1);

powtarzać "string NrOperatora" w zależności od zwracanych danych??
Czy wykorzystać wątek?? W którym momencie najlepiej "zapętlić"??

Jakaś szansa żeby ktoś z kolegów/koleżanek coś pomógł w temacie??

Wszystko zalezy od tego w ktorym momecie operator musi wprowadzic dane a kiedy powinna nastapic komunikacja. Z twojego opisu ciezko to wylapac.
Napisz krótki opis jak wyglada sekwencja ewentualnie co chcialhys zapętlić

Już opisuje jak to ma wyglądać z założenia.

Pokrótce na temat samej wagi/terminala. Terminal wagowy z 4 liniowym wyświetlaczem, klawiaturą numeryczną, 5 klawiszami funkcyjnymi.

Jak ma działać program:

• nawiązanie połączenia z wagą (ta część działa)
• sprawdzenie statusu wagi i wysłanie informacji do wyświetlacza wagi (ta część działa)
• wprowadzanie danych przez operatora na terminalu (tutaj utknąłem).

Po nawiązaniu komunikacji system sprawdzi jaki jest status i wysyła do wyświetlacza "menu" programu. Np wysyła opis "F1 - zaloguj się" i tutaj powinno być oczekiwanie na konkretną odpowiedź czyli powinna być pętla sprawdzająca czy zostało wybrane F1, wprowadzone dane i zatwierdzone enterem. Jeśli tak to idziemy krok dalej czyli np "F2 - podaj pin" - tutaj oczekiwanie na kod wprowadzony z klawiatury po wcześniejszym wybraniu F2. Jeśli wybrano to przejście do sprawdzenia czy dane zgadzają się z danymi w tabeli (nr użytkownika i pin) - jeśli tak to sprawdzenie poziomu uprawnień i kolejne menu i znów oczekiwanie na kolejne klawisze (od F1 do F5).
Oczywiście waga w zależności od wprowadzonych danych zwraca odpowiednie statusy.
W tej chwili mam tak że wysyłam dane do wyświetlacza i od razu odczytuję odpowiedź z wagi (jedna wspólna metoda) a jest to nierealne żeby użytkownik zdążył cokolwiek wprowadzić na terminalu.
Przypuszczam że powinienem to rozdzielić czyli wysłać dane do terminala na wyświetlacz a w osobnej metodzie oczekiwać na konkretną odpowiedź? Jak zapętlić sprawdzanie odpowiedzi aż do otrzymania konkretnego statusu?

Czyli jak rozumiem problem tkwi w linijce stream.Read. Program powinien w niej oczekiwać aż nadejdą jakieś dane. Na ile pamiętam jeszcze z >NET 1.1 następującej to wtedy kiedy w TCP otrzymana zostanie flaga PUSH, FIN lub rozmiar danych osiągnie zdefiniowany bufor. Metoda Read na buforze jest synchroniczna (czyli wychodzi się z niej kiedy skończy się odczyt).

Dlaczego u Ciebie wychodzi ciężko mi stwierdzić. Może terminal zamyka połączenie (widać w kodzie łączenie rozkazów i tam jest "KoniecKomunikacji"
Jednak jeżeli jest to komunikacja tekstowa nad TCP/IP sugeruje użyć SteramReader http://msdn.microsoft.com/en-us/library/system.io.streamreader.aspx (do odczytywania danych nadchodzących z terminala i StreamWriter do wysyłania skrócisz sobie zapis. Bp odczytanie jednej linii tekstu wglada tak. ReadLine czeka do przesłania znaku końca lini.
using (reader = new StreamReader(stream))
{
string line = reader.ReadLine()
}
reader ma też właściwość EndOfFile, którą mozna sprawdzić czy nastąpił koniec strumienia (druga strona połączenia zamknęła je)

Nadal jest to trochę zgadywanka co może być przyczyną. W debug sprawdź sobie stan klienta TCP po wysłaniu rozkazu i po odczycie.

dubcio napisał(a):

Czyli jak rozumiem problem tkwi w linijce stream.Read. Program powinien w niej oczekiwać aż nadejdą jakieś dane

Problem polega na tym że terminal zawsze zwraca dane informujące o statusie wagi. Nie ma takiej sytuacji żeby stream.Read nic nie zwrócił w zapytaniu o status. Ja muszę zapętlić odczyt tak żeby przejście dalej było dopiero w momencie jak ten status będzie miał odpowiednią treść. U mnie teraz stream.Read wykonuje się raz - nie oczekuje na konkretny status.

Może terminal zamyka połączenie (widać w kodzie łączenie rozkazów i tam jest "KoniecKomunikacji"
Nie ma to związku - to moje nazewnictwo i tutaj akurat oznacza byte zamykający komunikat wysyłany do terminala - nie kończy to komunikacji.

Tak najprościej to użyć pętli. np do {...} while (...), bazując na twoim kodzie:
do
{
Int32 bytes = stream.Read(odpowiedz, 0, odpowiedz.Length);
responseData = System.Text.Encoding.ASCII.GetString(odpowiedz, 0, bytes);
} while (!responseData.Contains("to co poiwinna zawierac odpowiedz aby i wyjsc"))

Spróbuj stworzyć po stronie serwera jakiś kumaty format odpowiedzi (mogą być struktury). Potem serializuj to na format binarny i deserializuj na struktury po stronie klienta i lepiej zorganizuj kod, bo to, co tutaj masz, jest tragiczne w rozczytywaniu :/

Nie mam wpływu na to co wysyła serwer :( To gotowy "firmware" terminala wagowego. Mam dokumentację do tego (co jak gdzie i kiedy).
Co do kodu - dzięki za uwagę - zaczynam dopiero programowanie i czytelnego "układania" kodu też się uczę :) Powiem tylko że już i tak jest lepiej niż było na początku :)

Będę robił testy z pętlą do while jak mi poradzono.
Spotkałem się też z opinią żeby zastosować stream.BeginRead oraz były również sugestie użycia wątku. Czy ktoś z kolegów jest w temacie i może coś podpowiedzieć czy może lepiej skupić się na tych rozwiązaniach??
Mam jeszcze wiele pytań co do aplikacji ale z czasem jak będę brnął dalej to pewnie zadam je na forum :)