本文使用的開(kāi)發(fā)環(huán)境是vs2017及dotnet4.0,寫(xiě)此隨筆的目的是給自己及新開(kāi)發(fā)人員作為參考,
本例子比較簡(jiǎn)單,使用的是控制臺(tái)程序開(kāi)發(fā),若需要使用該軟件作為演示,必須先運(yùn)行服務(wù)端,再運(yùn)行客戶端。
因?yàn)槭鞘状谓佑|該方面的知識(shí),寫(xiě)得比較簡(jiǎn)陋,如有更好的建議,請(qǐng)?zhí)岢?,謝謝!
一、編寫(xiě)服務(wù)器端代碼,如下:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
|
using system; using system.text; using system.net; using system.net.sockets; using system.threading.tasks; namespace chatserver { class program { static void main(string[] args) { bool cancel = false; byte[] buffer = new byte[1024]; string message; byte[] messagebytes; int count = 0; tcplistener tcplistener = new tcplistener(new ipendpoint(ipaddress.any, 13000)); tcplistener.start(); console.writeline("waiting for a connection... "); tcpclient tcpclient = tcplistener.accepttcpclient(); console.writeline("connected."); networkstream stream = tcpclient.getstream(); task.factory.startnew(() => { while ((count = stream.read(buffer, 0, buffer.length)) != 0) { console.writeline($"{datetime.now:yyyy-mm-dd hh:mm:ss fff} reply from server {tcpclient.client.localendpoint.tostring()}:{encoding.utf8.getstring(buffer, 0, count)}"); } }); task t = task.factory.startnew(() => { while(!cancel) { message = console.readline(); if (message.toupper() == "y") { cancel = true; return; } messagebytes = encoding.utf8.getbytes(message); stream.write(messagebytes, 0, messagebytes.length); } }); if (cancel) tcpclient.close(); while (true) { if (t != null && t.iscompleted) break; } } } } |
二、編寫(xiě)客戶端代碼,如下:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
|
using system; using system.linq; using system.text; using system.net; using system.net.sockets; using system.threading; using system.threading.tasks; namespace chatclient { class program { static void main(string[] args) { bool cancel = false; byte[] buffer = new byte[1024]; string message; byte[] messagebytes; int count = 0; try { tcpclient tcpclient = new tcpclient(new ipendpoint(dns.gethostentry(dns.gethostname()).addresslist.where(p => p.addressfamily == addressfamily.internetwork).first(), 14000)); tcpclient.connect(new ipendpoint(ipaddress.parse("192.168.94.26"), 13000)); networkstream stream = tcpclient.getstream(); task.factory.startnew(() => { while ((count = stream.read(buffer, 0, buffer.length)) != 0) { console.writeline($"{datetime.now:yyyy-mm-dd hh:mm:ss fff} reply from client {tcpclient.client.localendpoint.tostring()}:{encoding.utf8.getstring(buffer, 0, count)}"); } }); task t = task.factory.startnew(() => { while (!cancel) { message = console.readline(); if (message.toupper() == "y") { cancel = true; return; } messagebytes = encoding.utf8.getbytes(message); stream.write(messagebytes, 0, messagebytes.length); thread.sleep(10); } }); if (cancel) tcpclient.close(); while (true) { if (t != null && t.iscompleted) break; } } catch(exception ex) { console.writeline(ex.message); console.readkey(); } } } } |
三、先運(yùn)行服務(wù)端代碼,后再另外一臺(tái)電腦運(yùn)行客戶端代碼,效果圖如下:
以上這篇c#使用tcplistener及tcpclient開(kāi)發(fā)一個(gè)簡(jiǎn)單的chat工具實(shí)例就是小編分享給大家的全部?jī)?nèi)容了,希望能給大家一個(gè)參考,也希望大家多多支持服務(wù)器之家。
原文鏈接:http://www.cnblogs.com/cncc/p/7891728.html