TCP/IP na przykładzie .NET

Pierwszy podstawowy program



Uruchamiamy Visual Studio



Zakładamy nowy projekt (ctrl+shift+n)

Pierwszy podstawowy program



Z zakładki „tools” wybieramy odpowiednie kontrolki i
układamy na formatce

Pierwszy podstawowy program



We właściwościach zmieniamy następujące parametry

•Minimum size: 300;300
•Name: textBoxAdres
•Name: textBoxPort
•Name: buttonPolacz
•Name: buttonSerwuj
•Name: richTextBoxOdbior
•Name: textBoxKomunikat
•Name: buttonWyslij
•Anchor: Top, Left, Right
•Anchor: Top
•Anchor: Top, Bottom, Left, Right
•Anchor: Bottom, Left, Right

Pierwszy podstawowy program



Używamy dodatkowej przestrzeni nazw:

using

System.Net.Sockets;

using

System.Net;



W klasie Form1 dodajemy zmienne

private

TcpListener tcpLsn;

private

Encoding ASCII = Encoding.ASCII;

//kodowanie

Socket s;

Pierwszy podstawowy program



Dodajemy obsługę guzika „Serwuj”

private void

buttonSerwuj_Click

(object

sender

,

EventArgs

e)

{

tcpLsn =

new

TcpListener(IPAddress.Parse(textBoxAdres.Text),

int.

Parse(textBoxPort.Text));

//zainicjiuj listenera na podanym

porcie i adresie

tcpLsn.Start();

Socket

sckt = tcpLsn.AcceptSocket();

//funkcja blokująca do czasu

nadejścia połączenia

Byte

[] odebraneBajty =

new

Byte

[100];

int

ret = sckt.Receive(odebraneBajty, odebraneBajty.Length, 0);

string

tmp =

null

;

tmp = System.Text.

Encoding

.ASCII.GetString(odebraneBajty);

if

(tmp.Length > 0)

{
richTextBoxOdbior.AppendText(tmp);
}
tcpLsn.Stop();
}

Pierwszy podstawowy program



Dodajemy obsługę guzika „Połącz” oraz „Wyślij”

private void

buttonPolacz_Click(

object

sender,

EventArgs e

)

{
s =

new

Socket

(

AddressFamily

.InterNetwork,

SocketType

.Stream,

ProtocolType

.Tcp);

IPAddress

hostadd

= IPAddress

.Parse(textBoxAdres.Text);

int

port =

Int32

.Parse(textBoxPort.Text);

IPEndPoint

EPhost =

new

IPEndPoint

(hostadd, port);

s.Connect(EPhost);
}

private void

buttonWyslij_Click(

object

sender,

EventArgs e

)

{

string

str = textBoxKomunikat.Text;

Byte

[] byteData = ASCII.GetBytes(str.ToCharArray());

s.Send(byteData, byteData.Length, 0);
}

Pierwszy podstawowy program



Pierwsza działająca wersja ale ma poważne wady:



Usługa zadziała tylko raz (przydałaby się pętla)



Jest kilka blokujących funkcji przez co tracimy kontrolę
w głównej formatce (przydałby się osobny wątek)



Brak obsługi błędów



Brak możliwości wielokrotnego podłączania się i
odłączania



Brak uodpornienia interfejsu na głupie zachowania

2 wersja programu część powyższych ma wyeliminowane

Drugi program



We właściwościach zmieniamy dodatkowo następujące
parametry:

•Text: 127.0.01
•Text: 2222
•ReadOnly: true
•Enabled: false

Drugi program

public delegate void

DodajKolorowyTekst

(

RichTextBox

RichTextBox,

string

Text,

Color

kolor);

private void

DodajKolorowyTekstFn(

RichTextBox

rtb,

string

tekst,

Color

kolor)

{

var

StartIndex = rtb.TextLength;

rtb.AppendText(tekst);

var

EndIndex = rtb.TextLength;

rtb.Select(StartIndex, EndIndex - StartIndex);
rtb.SelectionColor = kolor;
}

private void

AppendColoredText(

RichTextBox

RTB,

string

Text,

Color

kolor)

{

if

(RTB.InvokeRequired)

{
RTB.Invoke(

new

DodajKolorowyTekst

(DodajKolorowyTekstFn), RTB, Text, kolor);

}

else

{
DodajKolorowyTekstFn(RTB, Text, kolor);
}
}

private

Encoding

ASCII =

Encoding

.ASCII;

//kodowanie

private

TcpListener

tcpLsn;

Socket

s;

Thread

tcpThd;

Drugi program

private void

buttonSerwuj_Click(

object

sender,

EventArgs

e)

{

if

(buttonSerwuj.Text == "Stop")

{

try

{

tcpThd.Abort();

tcpLsn.Stop();
buttonSerwuj.Text =

"Serwuj"

;

buttonPolacz.Enabled =

true

;

textBoxAdres.Enabled =

true

;

textBoxPort.Enabled =

true

;

}

catch

(

Exception

ex)

{
AppendColoredText(richTextBoxOdbior, "

Bład odłączenia: \n

",

Color

.Red);

AppendColoredText(richTextBoxOdbior, ex.Message +

"\n",

Color

.Red);

}
}

Drugi program

else

{

try

{

//zainicjiuj listenera na podanym porcie i adresie

tcpLsn =

new

TcpListener

(

IPAddress

.Parse(textBoxAdres.Text),

int.

Parse(textBoxPort.Text));

tcpLsn.Start();

AppendColoredText(richTextBoxOdbior, "

Słucham na:

",

Color

.Red);

AppendColoredText(richTextBoxOdbior, tcpLsn.LocalEndpoint.ToString() + "

\n

",

Color

.Blue);

//przygotowanie wątku czekającego na połączenia

tcpThd =

new

Thread

(

new

ThreadStart

(WaitingForClient));

tcpThd.Start();

//wystartowanie wątku czekającego na połączenia

buttonSerwuj.Text =

"Stop";

//zmiana nazwy

buttonPolacz.Enabled =

false

;

//zmiany stanów

textBoxAdres.Enabled =

false

;

textBoxPort.Enabled =

false

;

}
catch

(

Exception

ex)

{
AppendColoredText(richTextBoxOdbior,

"Bład połączenia: \n"

,

Color

.Red);

AppendColoredText(richTextBoxOdbior, ex.Message +

"\n"

,

Color

.Red);

}
}
}

Drugi program

public void

WaitingForClient()

{

while

(

true

)

{

try

{

Socket

sckt = tcpLsn.AcceptSocket();

Byte

[] odebraneBajty =

new

Byte

[textBoxKomunikat.MaxLength];

AppendColoredText(richTextBoxOdbior,

"Podłączony klient z: "

,

Color

.Red);

AppendColoredText(richTextBoxOdbior, sckt.RemoteEndPoint.ToString() +

"\n"

,

Color

.Blue);

while

(sckt.Connected)

{

try

{

int

ret = sckt.Receive(odebraneBajty, odebraneBajty.Length, 0);

if

(ret > 0)

{

string

tmp =

null

;

odebraneBajty[ret] = 0;
tmp = System.Text.

Encoding

.ASCII.GetString(odebraneBajty);

if (

tmp.Length > 0)

{
AppendColoredText(richTextBoxOdbior, tmp,

Color

.Black);

AppendColoredText(richTextBoxOdbior,

"\n"

,

Color

.Black);

}
}

Drugi program

else

{
AppendColoredText(richTextBoxOdbior,

"Błąd odbioru\n"

,

Color

.Red);

break

;

}
}

catch

(

Exception

ex)

{

if

(!sckt.Connected)

{
AppendColoredText(richTextBoxOdbior,

"Połaczenie zerwane\n"

,

Color

.Red);

AppendColoredText(richTextBoxOdbior, ex.Message +

"\n"

,

Color

.Red);

break

;

}
}
}
}

catch

(

Exception

ex)

{

MessageBox

.Show("Koniec: " + ex.Message);

}
}
}

Drugi program

private void

buttonPolacz_Click(

object

sender,

EventArgs

e)

{

if

(buttonPolacz.Text ==

"Odłącz"

)

{

try

{

s.Disconnect(

false

);

textBoxKomunikat.Enabled =

false

;

buttonWyslij.Enabled =

false

;

buttonSerwuj.Enabled =

true

;

textBoxAdres.Enabled =

true

;

textBoxPort.Enabled =

true

;

buttonPolacz.Text =

"Połacz"

;

AppendColoredText(richTextBoxOdbior,

"Odłączono \n"

,

Color

.Red);

}

catch

(

Exception

ex)

{
AppendColoredText(richTextBoxOdbior,

"Błąd odłaczenia: \n"

,

Color

.Red);

AppendColoredText(richTextBoxOdbior, ex.Message +

"\n"

,

Color

.Red);

}
}

Drugi program

else

{

try

{
s =

new

Socket

(

AddressFamily

.InterNetwork,

SocketType

.Stream,

ProtocolType

.Tcp);

IPAddress

hostadd =

IPAddress

.Parse(textBoxAdres.Text);

int

port =

Int32

.Parse(textBoxPort.Text);

IPEndPoint

EPhost =

new

IPEndPoint

(hostadd, port);

s.Connect(EPhost);

if (

s.Connected)

{
textBoxKomunikat.Enabled =

true

;

buttonWyslij.Enabled =

true

;

buttonSerwuj.Enabled =

false

;

textBoxAdres.Enabled =

false

;

textBoxPort.Enabled =

false

;

buttonPolacz.Text =

"Odłącz"

;

AppendColoredText(richTextBoxOdbior,

"Podłączono \n"

,

Color

.Red);

}
}

catch

(

Exception

ex)

{
AppendColoredText(richTextBoxOdbior,

"Błąd podłaczenia: \n"

,

Color

.Red);

AppendColoredText(richTextBoxOdbior, ex.Message +

"\n"

,

Color

.Red);

}
}
}

Drugi program

private void

buttonWyslij_Click(

object

sender,

EventArgs

e)

{

if

(s != null && s.Connected)

//jeżeli jesteśmy podłączeni to wysyłamy

{

string

str = textBoxKomunikat.Text;

Byte

[] byteData = ASCII.GetBytes(str.ToCharArray());

s.Send(byteData, byteData.Length, 0);
}
}

private void

Form1_FormClosed(

object

sender,

FormClosedEventArgs e

)

{

if

(tcpThd !=

null

)

tcpThd.Abort();

if

(tcpLsn !=

null

)

tcpLsn.Stop();
}

Trzecia wersja programu



Wprowadzono następujące modyfikacje:



Obsługa wielu klientów jednocześnie (serwer
wielowątkowy)



Wydzielenie obsługi połączeń do osobnej klasy



Dzięki serializacji i deserializacji przekazywanie całych
obiektów



Informowanie za pomocą zdarzeń.