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

69

private void btnListen_Click(object sender, EventArgs e)

{

    IPEndPoint point = new IPEndPoint(IPAddress.Any, 13000);//IPAddress.Any本机任何网卡IP。本机端口查看netstat -an

    //服务端Socket定义

    Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

    socket.Bind(point); //绑定IP

    socket.Listen(10);//启动监听。最大监听数,同一个时间点过来10个客户端，排队

    ShowMsg("服务器开始监听");

    Thread thread = new Thread(AcceptInfo);

    thread.Start(socket);

}

//记录通信用的Socket

Dictionary<string, Socket> dic = new Dictionary<string, Socket>();

// private Socket client;

void AcceptInfo(object o)

{

    Socket socket = o as Socket;

    while (true)

    {

        //通信用socket

        try

        {

            Socket clientSocket = socket.Accept();//如果客户端有请求，生成一个新的Socket

            string point = clientSocket.RemoteEndPoint.ToString();

            ShowMsg(point + "连接客户端成功！");

            dic.Add(point, clientSocket);

            //接收消息

            Thread th = new Thread(ReceiveMsg);

            th.Start(clientSocket);

        }

        catch (Exception ex)

        {

            break;

        }

    }

    socket.Close();

}

//接收消息

void ReceiveMsg(object socket)

{

    Socket clientSocket = socket as Socket;

    while (true)

    {

        //接收客户端发送过来的数据

        try

        {

            //定义byte数组存放从客户端接收过来的数据

            byte[] buffer = new byte[1024 * 1024];

           int n = clientSocket.Receive(buffer);//将接收过来的数据放到buffer中，并返回实际接受数据的长度

            //将字节转换成字符串

            string words = Encoding.Unicode.GetString(buffer, 0, n);

            Console.WriteLine(clientSocket.RemoteEndPoint.ToString() + ":" + words);

            byte[] msg = Encoding.Unicode.GetBytes(words);

            clientSocket.Send(msg);//发送数据，字节数组

        }

        catch (Exception ex)

        {

            break;

        }

    }

    clientSocket.Shutdown(SocketShutdown.Both);//禁止发送和接受数据

    clientSocket.Close();//关闭socket,释放资源

}

1

2

3

4

5

6

7

8

9

10

11

12

Socket clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

IPEndPoint point = new IPEndPoint("127.0.0.1", 13000));//连接到的服务端IP

clientSocket.Connect(point);//连接到服务器

ShowMsg("连接成功");

ShowMsg("服务器" + client.RemoteEndPoint.ToString());

ShowMsg("客户端:" + client.LocalEndPoint.ToString());

Thread th = new Thread(ReceiveMsg);//连接成功后，就可以接收服务器发送的信息了

th.IsBackground = true;

th.Start();

clientSocket.Shutdown(SocketShutdown.Both);//禁止发送和接受数据

clientSocket.Close();//关闭socket,释放资源