namespace TcpServer  //服务器
{
    class Program
    {
        public static List<Client> clientList = new List<Client>();
       
        static void Main(string[] args)
        {
            Socket tcpServer = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);//创建socket对象
            tcpServer.Bind(new IPEndPoint(IPAddress.Parse("192.168.1.145"), 8090));//绑定IP和申请端口

            tcpServer.Listen(100);//设置客户端最大连接数
            Console.WriteLine("服务器已启动，等待连接.........");
            while (true)//循环等待新客户端的连接
            {
                Socket clientSocket = tcpServer.Accept();
                Console.WriteLine((clientSocket.RemoteEndPoint as IPEndPoint).Address+"已连接");
                Client client = new Client(clientSocket);
                clientList.Add(client);
            }
        }
        public static void BroadcastMessage(string message, Client clientSocket)//这个函数用来广播接收到的客户端消息  参数1为消息，参数2为消息来源（客户端）
        {
            var onConnectedList = new List<Client>();//用来存储已断开服务器连接的客户端

            foreach (var client in clientList)//遍历已经存储的客户端
            {
                if (clientSocket == client)//如果该客户端是消息来源，则不重复发送消息给该客户端
                {
                    continue;
                }
                if (client.Connected)//判断该客户端的状态
                {
                    client.SendMessage(client.ip + ":" + message);//
                }
                else//把已断开连接的客户端放到数组中
                {
                    onConnectedList.Add(client);
                }
            }
            foreach (var temp in onConnectedList)//广播完之后从存储已连接客户端集合中移除掉已断开连接的客户端
            {
                clientList.Remove(temp);
            }
        }
    }
}

namespace TcpServer  
{
    class Client
    {
        private Socket clientSocket;
        private Thread t;
        public string ip = "";
        private byte[] data = new byte[1024];
        public Client(Socket socket)
        {
            clientSocket = socket;
            ip = (clientSocket.RemoteEndPoint as IPEndPoint).Address.ToString();//获取客户端的ip
            t = new Thread(ReceiveMessage);//开启线程执行循环接收消息
            t.Start();
        }
        private void ReceiveMessage()//接收消息
        {
            int length = 0;//初始化消息的长度
            while (true)//循环接收消息
            {
                length = clientSocket.Receive(data);//获取存放消息数据数组的长度
                if (clientSocket.Poll(10, SelectMode.SelectRead))//？？？？
                {
                    clientSocket.Close();
                    break;
                }
                if (length != 0)//判断是否有数组内是否存放消息数据
                {
                    string message = Encoding.UTF8.GetString(data, 0, length);//Byte转为string
                    Program.BroadcastMessage(message, this);//广播给其他客户端
                    Console.WriteLine("来自" + (clientSocket.RemoteEndPoint as IPEndPoint).Address + ":" + message);//输出到服务器控制台
                    length = 0;//归0
                }
            }
        }
        public void SendMessage(string message)//发送消息
        {
            byte[] data = Encoding.UTF8.GetBytes(message);
            clientSocket.Send(data);
        }
        public bool Connected//获取该客户端的状态
        {
            get { return clientSocket.Connected; }
        }
    }
}

namespace TcpClient
{
    class Program
    {
        private static Thread  t;
        private static Socket clientScoket;
        private static byte[] data= new byte[1024];
        static void Main(string[] args)
        {
            ConnectToServer();//创建scoket对象并连接到服务器
           
            while (true)
            {
                string message2 = Console.ReadLine();
                SendMessage(message2);
            }
           
            Console.ReadKey();
        }
        static void ConnectToServer()
        {
            clientScoket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
             clientScoket.Connect(new IPEndPoint(IPAddress.Parse("192.168.1.145"), 8090));
            Console.WriteLine("已连接到服务器");
            t = new Thread(ReceiveMessage);//开启线程执行循环接收消息
            t.Start();

        }
        static void SendMessage(string message)//发送消息
        {
            byte[] data = Encoding.UTF8.GetBytes(message);
            clientScoket.Send(data);
        }
        static void ReceiveMessage()//接收消息
        {
            int length = 0;
            while (true)
            {
                if (clientScoket.Connected==true)
                {
                    length = clientScoket.Receive(data);
                    if (length != 0)
                    {
                        string message = Encoding.UTF8.GetString(data, 0, length);
                         Console.WriteLine(message);
                    }
                }
            }         
        }
    }
}