C#建立简单的服务端和客户端通信

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
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
 /// <summary>
    ///     最简单的服务端通讯
    /// </summary>
    public class NormalServerSocket
    {
        //端口和IP
        private int port = 6000;
        private string hostIp = "10.100.1.64";

        /// <summary>
        ///     创建服务套接字
        /// </summary>
        private Socket serverSocket = null;

        /// <summary>
        ///     这个连接 是服务接收到客户端连接 新建的连接
        /// </summary>
        private Socket clientSocket = null;

        /// <summary>
        ///     两个客户端连接作为实例
        /// </summary>
        private static Socket socketA = null;
        private static Socket socketB = null;


        string recStr = string.Empty;
        byte[] receiveByte = new byte[1024*100];

        /// <summary>
        ///     通信
        /// </summary>
        public　void ServerCommunicate()
        {
            //创建一个服务端套接字
            IPAddress ip = IPAddress.Parse(hostIp);
            IPEndPoint ipe = new IPEndPoint(ip, port);
            //创建服务端连接
            serverSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            //绑定套接字
            serverSocket.Bind(ipe);
            //监听，最大挂起连接队列
            serverSocket.Listen(1);

            //开始连接 接收数据 应答
            Thread myThread = new Thread(listenClientConnect);
            myThread.Start();

        }
        
        /// <summary>
        ///     客户端连接 接收数据
        /// </summary>
        private void listenClientConnect()
        {
            while (true)
            {
                clientSocket = serverSocket.Accept();
                //连接上后，应答
                clientSocket.Send(Encoding.Default.GetBytes("hello"));

                if (socketA == null)
                {
                    socketA = clientSocket;
                }
                else if(socketB == null)
                {
                    socketB = clientSocket;
                }
                else
                {
                    //其中一个断开
                    if(socketB.IsBound)
                    {
                        socketA = socketB;
                        socketB = clientSocket;
                    }
                    else
                    {
                        socketB = socketA;
                        socketA = clientSocket;
                    }
                }
                Thread recieveThread = new Thread(ReceiveMessage);
                recieveThread.Start(clientSocket);

            }
        }

        /// <summary>
        ///     接收数据
        /// </summary>
        /// <param name="clientSocket"></param>
        private void ReceiveMessage(object clientSocket)
        {
            Socket myClientSocket = (Socket)clientSocket;
            while(true)
            {
                //接收数据到缓冲区
                int bytes = myClientSocket.Receive(receiveByte, receiveByte.Length, 0);
                //缓冲区的数据打印
                recStr += Encoding.Default.GetString(receiveByte, 0, bytes);
                try
                {
                    if (myClientSocket == socketA)
                    {
                        Console.Write("receive from A");
                        if (socketA != null && socketA.IsBound)
                        {
                            socketA.Send(receiveByte, 0, bytes, SocketFlags.None);
                        }
                        else
                        {
                            myClientSocket.Send(Encoding.ASCII.GetBytes("A is  not Connect Server!"));
                            Console.WriteLine("The ClientA dose not Connect to The Server");
                        }
                    }
                    else
                    {
                        Console.Write("receive from B");
                        if(socketB != null && socketB.IsBound)
                        {
                            socketB.Send(receiveByte, 0, bytes, SocketFlags.None);
                        }
                        else
                        {
                            myClientSocket.Send(Encoding.ASCII.GetBytes("B is  not Connect Server!"));
                            Console.WriteLine("The ClientB dose not Connect to The Server");
                        }
                    }
                }
                catch (Exception)
                {

                    throw;
                }
            }
        }
    }

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
70
71
72
73
74
/// <summary>
///     客户端通信
/// </summary>
public class ClientComm
{
    //端口和IP
    private int port = 6000;
    private string hostIp = "10.100.1.64";

    private static Socket clientSocket = null;

    private static byte[] recData = new byte[1024 * 8];

    /// <summary>
    ///     客户端通讯
    /// </summary>
    public void ClientCommunicate()
    {
        IPAddress ip = IPAddress.Parse(hostIp);
        clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

        //连接服务端
        try
        {
            clientSocket.Connect(ip, port);
            Console.WriteLine("连接成功！");
        }
        catch (Exception)
        {
            Console.WriteLine("连接失败！");
            return;
        }
        Thread th1 = new Thread(listenServer);
        th1.Start();
        Send();

    }

    /// <summary>
    ///     接收数据
    /// </summary>
    private void listenServer()
    {
        while(true)
        {
            int recLength = clientSocket.Receive(recData);
            Console.WriteLine("接收字节长度：" + recLength);
        }
    }

    /// <summary>
    ///     发送数据
    /// </summary>
    private void Send()
    {
        while (true)
        {
            try
            {
                Thread.Sleep(10000);
                string message = "你好，我测试客户端";
                byte[] mesByte = Encoding.Default.GetBytes(message);
                clientSocket.Send(mesByte);
            }
            catch (Exception ex)
            {
                clientSocket.Shutdown(SocketShutdown.Both);
                clientSocket.Close();
                break;
            }
        }
    }
}

1
2
3
4

`