// 啟動服務(wù)器
    // 根據(jù)博客中協(xié)議的設(shè)計(jì)部分
    // 客戶端先向服務(wù)器發(fā)送登錄請求，然后通過服務(wù)器返回的端口號
    // 再與服務(wù)器建立連接
    // 所以啟動服務(wù)按鈕事件中有兩個套接字：一個是接收客戶端信息套接字和
    // 監(jiān)聽客戶端連接套接字
    private void btnStart_Click(object sender, EventArgs e)
    {
      // 創(chuàng)建接收套接字
      serverIp = IPAddress.Parse(txbServerIP.Text);
      serverIPEndPoint = new IPEndPoint(serverIp, int.Parse(txbServerport.Text));
      receiveUdpClient = new UdpClient(serverIPEndPoint);
      // 啟動接收線程
      Thread receiveThread = new Thread(ReceiveMessage);
      receiveThread.Start();
      btnStart.Enabled = false;
      btnStop.Enabled = true;

      // 隨機(jī)指定監(jiān)聽端口
      Random random = new Random();
      tcpPort = random.Next(port + 1, 65536);

      // 創(chuàng)建監(jiān)聽套接字
      tcpListener = new TcpListener(serverIp, tcpPort);
      tcpListener.Start();

      // 啟動監(jiān)聽線程
      Thread listenThread = new Thread(ListenClientConnect);
      listenThread.Start();
      AddItemToListBox(string.Format("服務(wù)器線程{0}啟動，監(jiān)聽端口{1}",serverIPEndPoint,tcpPort));
    }

    // 接收客戶端發(fā)來的信息
    private void ReceiveMessage()
    {
      IPEndPoint remoteIPEndPoint = new IPEndPoint(IPAddress.Any, 0);
      while (true)
      {
        try
        {
          // 關(guān)閉receiveUdpClient時下面一行代碼會產(chǎn)生異常
          byte[] receiveBytes = receiveUdpClient.Receive(ref remoteIPEndPoint);
          string message = Encoding.Unicode.GetString(receiveBytes, 0, receiveBytes.Length);

          // 顯示消息內(nèi)容
          AddItemToListBox(string.Format("{0}:{1}",remoteIPEndPoint,message));

          // 處理消息數(shù)據(jù)
          // 根據(jù)協(xié)議的設(shè)計(jì)部分，從客戶端發(fā)送來的消息是具有一定格式的
          // 服務(wù)器接收消息后要對消息做處理
          string[] splitstring = message.Split(',');
          // 解析用戶端地址
          string[] splitsubstring = splitstring[2].Split(':');
          IPEndPoint clientIPEndPoint = new IPEndPoint(IPAddress.Parse(splitsubstring[0]), int.Parse(splitsubstring[1]));
          switch (splitstring[0])
          {
            // 如果是登錄信息，向客戶端發(fā)送應(yīng)答消息和廣播有新用戶登錄消息
            case "login":
              User user = new User(splitstring[1], clientIPEndPoint);
              // 往在線的用戶列表添加新成員
              userList.Add(user);
              AddItemToListBox(string.Format("用戶{0}({1})加入", user.GetName(), user.GetIPEndPoint()));
              string sendString = "Accept," + tcpPort.ToString();
              // 向客戶端發(fā)送應(yīng)答消息
              SendtoClient(user, sendString);
              AddItemToListBox(string.Format("向{0}({1})發(fā)出：[{2}]", user.GetName(), user.GetIPEndPoint(), sendString));
              for (int i = 0; i < userList.Count; i++)
              {
                if (userList[i].GetName() != user.GetName())
                {
                  // 給在線的其他用戶發(fā)送廣播消息
                  // 通知有新用戶加入
                  SendtoClient(userList[i], message);
                }
              }

              AddItemToListBox(string.Format("廣播：[{0}]", message));
              break;
            case "logout":
              for (int i = 0; i < userList.Count; i++)
              {
                if (userList[i].GetName() == splitstring[1])
                {
                  AddItemToListBox(string.Format("用戶{0}({1})退出",userList[i].GetName(),userList[i].GetIPEndPoint()));
                  userList.RemoveAt(i); // 移除用戶
                }
              }
              for (int i = 0; i < userList.Count; i++)
              {
                // 廣播注銷消息
                SendtoClient(userList[i], message);
              }
              AddItemToListBox(string.Format("廣播:[{0}]", message));
              break;
          }
        }
        catch
        {
          // 發(fā)送異常退出循環(huán)
          break;
        }
      }
      AddItemToListBox(string.Format("服務(wù)線程{0}終止", serverIPEndPoint));
    }

    // 向客戶端發(fā)送消息
    private void SendtoClient(User user, string message)
    {
      // 匿名方式發(fā)送
      sendUdpClient = new UdpClient(0);
      byte[] sendBytes = Encoding.Unicode.GetBytes(message);
      IPEndPoint remoteIPEndPoint =user.GetIPEndPoint();
      sendUdpClient.Send(sendBytes,sendBytes.Length,remoteIPEndPoint);
      sendUdpClient.Close();
    }
    
    // 接受客戶端的連接
    private void ListenClientConnect()
    {
      TcpClient newClient = null;
      while (true)
      {
        try
        {
          newClient = tcpListener.AcceptTcpClient();
          AddItemToListBox(string.Format("接受客戶端{(lán)0}的TCP請求",newClient.Client.RemoteEndPoint));
        }
        catch
        {
          AddItemToListBox(string.Format("監(jiān)聽線程({0}:{1})", serverIp, tcpPort));
          break;
        }

        Thread sendThread = new Thread(SendData);
        sendThread.Start(newClient);
      }
    }

    // 向客戶端發(fā)送在線用戶列表信息
    // 服務(wù)器通過TCP連接把在線用戶列表信息發(fā)送給客戶端
    private void SendData(object userClient)
    {
      TcpClient newUserClient = (TcpClient)userClient;
      userListstring = null;
      for (int i = 0; i < userList.Count; i++)
      {
        userListstring += userList[i].GetName() + ","
          + userList[i].GetIPEndPoint().ToString() + ";";
      }

      userListstring += "end";
      networkStream = newUserClient.GetStream();
      binaryWriter = new BinaryWriter(networkStream);
      binaryWriter.Write(userListstring);
      binaryWriter.Flush();
      AddItemToListBox(string.Format("向{0}發(fā)送[{1}]", newUserClient.Client.RemoteEndPoint, userListstring));
      binaryWriter.Close();
      newUserClient.Close();
    }

// 登錄服務(wù)器
    private void btnlogin_Click(object sender, EventArgs e)
    {
      // 創(chuàng)建接受套接字
      IPAddress clientIP = IPAddress.Parse(txtLocalIP.Text);
      clientIPEndPoint = new IPEndPoint(clientIP, int.Parse(txtlocalport.Text));
      receiveUdpClient = new UdpClient(clientIPEndPoint);
      // 啟動接收線程
      Thread receiveThread = new Thread(ReceiveMessage);
      receiveThread.Start();

      // 匿名發(fā)送
      sendUdpClient = new UdpClient(0);
      // 啟動發(fā)送線程
      Thread sendThread = new Thread(SendMessage);
      sendThread.Start(string.Format("login,{0},{1}", txtusername.Text, clientIPEndPoint));

      btnlogin.Enabled = false;
      btnLogout.Enabled = true;
      this.Text = txtusername.Text;
    }

    // 客戶端接受服務(wù)器回應(yīng)消息 
    private void ReceiveMessage()
    {
      IPEndPoint remoteIPEndPoint = new IPEndPoint(IPAddress.Any,0);
      while (true)
      {
        try
        {
          // 關(guān)閉receiveUdpClient時會產(chǎn)生異常
          byte[] receiveBytes = receiveUdpClient.Receive(ref remoteIPEndPoint);
          string message = Encoding.Unicode.GetString(receiveBytes,0,receiveBytes.Length);

          // 處理消息
          string[] splitstring = message.Split(',');

          switch (splitstring[0])
          {
            case "Accept":
              try
              {
                tcpClient = new TcpClient();
                tcpClient.Connect(remoteIPEndPoint.Address, int.Parse(splitstring[1]));
                if (tcpClient != null)
                {
                  // 表示連接成功
                  networkStream = tcpClient.GetStream();
                  binaryReader = new BinaryReader(networkStream);
                }
              }
              catch
              {
                MessageBox.Show("連接失敗", "異常");
              }

              Thread getUserListThread = new Thread(GetUserList);
              getUserListThread.Start();
              break;
            case "login":
              string userItem = splitstring[1] + "," + splitstring[2];
              AddItemToListView(userItem);
              break;
            case "logout":
              RemoveItemFromListView(splitstring[1]);
              break;
            case "talk":
              for (int i = 0; i < chatFormList.Count; i++)
              {
                if (chatFormList[i].Text == splitstring[2])
                {
                  chatFormList[i].ShowTalkInfo(splitstring[2], splitstring[1], splitstring[3]);
                }
              }

              break;
          }
        }
        catch
        {
          break;
        }
      }
    }

    // 從服務(wù)器獲取在線用戶列表
    private void GetUserList()
    {
      while (true)
      {
        userListstring = null;
        try
        {
          userListstring = binaryReader.ReadString();
          if (userListstring.EndsWith("end"))
          {
            string[] splitstring = userListstring.Split(';');
            for (int i = 0; i < splitstring.Length - 1; i++)
            {
              AddItemToListView(splitstring[i]);
            }

            binaryReader.Close();
            tcpClient.Close();
            break;
          }
        }
        catch
        {
          break;
        }
      }
    }
  // 發(fā)送登錄請求
    private void SendMessage(object obj)
    {
      string message = (string)obj;
      byte[] sendbytes = Encoding.Unicode.GetBytes(message);
      IPAddress remoteIp = IPAddress.Parse(txtserverIP.Text);
      IPEndPoint remoteIPEndPoint = new IPEndPoint(remoteIp, int.Parse(txtServerport.Text));
      sendUdpClient.Send(sendbytes, sendbytes.Length, remoteIPEndPoint);
      sendUdpClient.Close();
    }