基本信息

---

下载

   友情提示：（无需注册或充值，赞助后即可获取资源下载链接）

---

     嘿，亲！知识可是无价之宝呢，但咱这精心整理的资料也耗费了不少心血呀。小小地破费一下，绝对物超所值哦！如有下载和支付问题，请联系我们QQ(微信同号)：813200300

本次赞助数额为： 2 元　

支付宝支付

微信支付

   源码介绍

---

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();
            }
        }
    }