C#基于TCP通信协议的实现示例

1

newTcpClient(server, port)

1

AcceptTcpClient()

1

stream.Close()

1

client.Close()

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

usingSystem;

usingSystem.Net.Sockets;

usingSystem.Text;

​

namespaceTCpClient

{

internalclassProgram

{

staticvoidMain(string[] args)

{

// 定义服务器的IP地址和端口号

stringserverIp ="172.16.0.14";// 替换为实际服务器IP（本机测试可填127.0.0.1）

intserverPort = 9898;

​

TcpClient tcpClient =null;

NetworkStream networkStream =null;

​

try

{

// 1. 建立TCP连接（底层三次握手）

tcpClient =newTcpClient(serverIp, serverPort);

Console.WriteLine($"成功连接到服务器 {serverIp}:{serverPort}");

​

// 2. 获取网络流（用于数据收发）

networkStream = tcpClient.GetStream();

​

// 3. 发送数据到服务器

Console.WriteLine("请输入要发送的消息：");

stringsendMessage = Console.ReadLine();

byte[] sendData = Encoding.UTF8.GetBytes(sendMessage);

networkStream.Write(sendData, 0, sendData.Length);

Console.WriteLine($"客户端已发送：{sendMessage}");

​

// 4. 接收服务器响应

byte[] receiveBuffer =newbyte[256];// 定义缓冲区存储接收的数据

intreceiveBytes = networkStream.Read(receiveBuffer, 0, receiveBuffer.Length);

stringreceiveMessage = Encoding.UTF8.GetString(receiveBuffer, 0, receiveBytes);

Console.WriteLine($"客户端收到服务器响应：{receiveMessage}");

}

catch(Exception ex)

{

Console.WriteLine($"连接/通信异常：{ex.Message}");

}

finally

{

// 5. 释放资源（底层四次挥手）

if(networkStream !=null) networkStream.Close();

if(tcpClient !=null) tcpClient.Close();

}

​

Console.WriteLine("客户端程序结束，按任意键退出...");

Console.ReadKey();

}

}

}

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

62

63

64

65

66

67

68

usingSystem;

usingSystem.Net;

usingSystem.Net.Sockets;

usingSystem.Text;

​

namespaceTCPServer

{

internalclassProgram

{

staticvoidMain(string[] args)

{

// 定义监听端口

intlistenPort = 9898;

TcpListener tcpListener =null;

TcpClient client =null;

NetworkStream networkStream =null;

​

try

{

// 1. 初始化监听器并启动监听

tcpListener =newTcpListener(IPAddress.Any, listenPort);

tcpListener.Start();

Console.WriteLine($"服务器已启动，正在监听端口 {listenPort}...");

​

// 2. 循环等待客户端连接（单线程，仅处理一个客户端）

while(true)

{

// 阻塞等待客户端连接

client = tcpListener.AcceptTcpClient();

Console.WriteLine("有客户端成功连接！");

​

// 3. 获取网络流，处理数据交互

networkStream = client.GetStream();

byte[] receiveBuffer =newbyte[256];

intreadBytes;

​

// 循环读取客户端发送的数据（直到客户端断开）

while((readBytes = networkStream.Read(receiveBuffer, 0, receiveBuffer.Length)) != 0)

{

// 解析接收的字节数据为字符串

stringreceiveMessage = Encoding.UTF8.GetString(receiveBuffer, 0, readBytes);

Console.WriteLine($"服务器收到客户端数据：{receiveMessage}");

​

// 4. 向客户端发送响应

stringresponseMessage ="已收到客户端消息";

byte[] responseData = Encoding.UTF8.GetBytes(responseMessage);

networkStream.Write(responseData, 0, responseData.Length);

Console.WriteLine($"服务器已发送响应：{responseMessage}");

}

}

}

catch(Exception ex)

{

Console.WriteLine($"服务器异常：{ex.ToString()}");

}

finally

{

// 5. 释放资源

if(networkStream !=null) networkStream.Close();

if(client !=null) client.Close();

if(tcpListener !=null) tcpListener.Stop();

}

​

Console.WriteLine("服务器程序结束，按任意键退出...");

Console.ReadKey();

}

}

}