C#通过socket套接字数据传输,QQ：1009714648

【实例简介】

C#通过socket 套接字进行客户端与服务器数据传输；

【实例截图】

【核心代码】

 static void SendMessage()
        {
            try
            {
                while (true)
                {
                    Console.WriteLine("等待发送信息，回车->发送，close->断开连接");
                    string s = Console.ReadLine();
                    foreach (Socket client in clients.Values)
                    {
                        client.Send(Encoding.Default.GetBytes(s));
                    }
                    Console.WriteLine("发送成功！\n");
                    if (s == "close")
                    {
                        client.Close();
                        break;
                    }
                }
            }
            catch (Exception e)
            {
                Console.WriteLine(e.Message);
            }
        }
        static void CreateServer()
        {
            server = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            IPAddress iPAddress = IPAddress.Any;
            int port = 9003;
            EndPoint endPoint = new IPEndPoint(iPAddress, port);
            server.Bind(endPoint);
            server.Listen(8);

            Console.WriteLine("tcp端口已经打开,192.144.215.243:9003");
            DisplayAllClients();

        }

        static void Accept(Object obj)
        {
            Socket socket = (Socket)obj;
            while (true)
            {
                client = socket.Accept();
                string ip = client.RemoteEndPoint.ToString();
                if (!clients.ContainsKey(ip))
                {
                    clients.Add(ip, client);
                    Console.WriteLine(ip "已连接");
                    DisplayAllClients();
                }
                new Thread(() =>
                {
                    try
                    {
                        Recieve(client);
                    }
                    catch (Exception e)
                    {
                        Console.WriteLine(e.Message);
                        clients.Remove(ip);
                    }
                })
                { IsBackground = true }.Start();
            }
        }

        static void Recieve(Object obj)
        {
            Socket client = (Socket)obj;
            while (true)
            {
                try
                {
                    byte[] buffer = new byte[1024 * 1024 * 8];
                    int length = client.Receive(buffer);

                    string message = Encoding.Default.GetString(buffer, 0, length);
                    Console.WriteLine(client.RemoteEndPoint.ToString() ":" message);
                    if (message == null || message.Length == 0 || message == "close")
                    {
                        string ip = client.RemoteEndPoint.ToString();
                        Console.WriteLine(ip "连接断开！");
                        clients.Remove(ip);
                        DisplayAllClients();
                        break;
                    }
                }
                catch (Exception e)
                {
                    Console.WriteLine(e.Message);
                    clients.Remove(client.RemoteEndPoint.ToString());
                    DisplayAllClients();
                    break;
                }
            }
        }
        ///显示所有连接客户端
        static void DisplayAllClients()
        {
            if (clients.Values.Count == 0)
            {
                Console.WriteLine("目前无连接");
                Console.WriteLine("等待新的连接");
            }
            else
            {
                Console.WriteLine("目前所有连接");
                Console.WriteLine(" ========== ");
                foreach (Socket client in clients.Values)
                {
                    Console.WriteLine(client.RemoteEndPoint.ToString());
                }
                Console.WriteLine(" ========== ");
                Console.WriteLine();
            }
        }
    }

     ///发送消息
        static void SendMessage()
        {
            try
            {
                while (true)
                {
                    Console.WriteLine("等待发送信息，回车->发送，close->断开连接");
                    string s = Console.ReadLine();
                    client.Send(Encoding.Default.GetBytes(s));
                    Console.WriteLine("发送成功！\n");
                    if (s == "close")
                    {
                        client.Close();
                        break;
                    }
                }
            }
            catch (Exception e)
            {
                Console.WriteLine(e.Message);
            }
        }
        ///接收消息
        static void ReceiveMessage()
        {
            try
            {
                while (true)
                {
                    byte[] buffer = new byte[1024 * 1024 * 8];
                    int length = client.Receive(buffer);
                    string msg = Encoding.Default.GetString(buffer, 0, length);
                    if (buffer.Length > 0)
                    {
                        Console.WriteLine("服务器:" msg);
                    }
                    else
                    {
                        Console.WriteLine("断开连接");
                        break;
                    }
                    Thread.Sleep(100);
                }
            }
            catch (Exception e)
            {
                Console.WriteLine(e.Message);
            }
        }
    }