【正文】 = ChatServerForm。 = Form1。 += new ()。 (false)。 } endregion /// summary /// 應(yīng)用程序的主入口點(diǎn)。 /// /summary [STAThread] static void Main() { (new ChatServerForm())。 } private void Form1_Load(object sender, e) { = true。 = ()。 = 。 } private void btnStart_Click(object sender, e) { try { IPAddress ip = ()。 listener = new TcpListener(ip, port)。 //創(chuàng)建服務(wù)器套字 ()。 //開始監(jiān)聽服務(wù)器端口 (服務(wù)器已經(jīng)啟動，正在監(jiān)聽 + + : + )。 //啟動一個新的線程，執(zhí)行方法StartListen，以便在一個獨(dú)立的進(jìn)程中執(zhí)行確認(rèn)于客戶端連接的操作. Thread thread = new Thread(new ThreadStart())。 ()。 = false。 } catch(Exception ex) { ()。 } } private void StartListen() { while(true) { try { //當(dāng)接受到一個客戶端請求時,確認(rèn)與客戶端的連接 Socket socket = ()。 //用tmpSocket保存發(fā)出請求的客戶端實例 tmpSocket = socket。 if ( = MaxNum) { ()。 } else { //啟動一個新的線程,處理用戶相應(yīng)的要求 Thread clientService = new Thread(new ThreadStart())。 ()。 } } catch(Exception ex) { ()。 } } } private void ServiceClient() { //定義一個數(shù)組,用于接收從客戶端發(fā)送過來的數(shù)據(jù),每次所能接收的數(shù)據(jù)包的最大長度為1024字節(jié) byte[] buffer = new byte[1024]。 Socket clientSocket = tmpSocket。 bool keepConnect = true。 //用循環(huán)不斷地與客戶端進(jìn)行交互,直到客戶端發(fā)出Exit命令,將keepConnect設(shè)置為false //退出循環(huán),關(guān)閉連接,中止當(dāng)前線程 while(keepConnect) { //接收數(shù)據(jù)并存入buffer數(shù)組中 (buffer)。 //將字符數(shù)組轉(zhuǎn)化為字符串 string clientCommand = (buffer)。 string[] tokens = (39。|39。)。 //tokens[0]中保存了命令標(biāo)識符(CONN或CHAT或PRIV或EXIT) if (tokens[0] == CONN) // CONN|用戶名| { Client _client = new Client(tokens[1], clientSocket)。 (_client)。 (tokens[1] + has joined)。 //將剛連接的用戶名加入到當(dāng)前在線用戶列表中 (tokens[1])。 //對每一個在線用戶發(fā)送JOIN和LIST信息命令,以此來更新客戶端的在線用戶列表 for(int i=0。 i。 i++) { Client client = (Client)clients[i]。 //向客戶端發(fā)送JOIN命令,以此來提示有新的客戶進(jìn)入聊天室 SendToClient(client, JOIN| + tokens[1] + |)。 (100)。 string msgUsers = LIST| + GetUserList()。 //向客戶端發(fā)送LIST命令,以此來更新客戶端的當(dāng)前在線用戶列表 SendToClient(client, msgUsers)。 } } if (tokens[0] == CHAT) // CHAT|用戶名:內(nèi)容| { //向所有當(dāng)前在線用戶轉(zhuǎn)發(fā)此信息 for (int i=0。 i。 i++) { Client client = (Client)clients[i]。 //將發(fā)送者的用戶名:發(fā)送內(nèi)容轉(zhuǎn)發(fā)給用戶 SendToClient(client, tokens[1])。 } } if (tokens[0] == PRIV) // PRIV|發(fā)送者用戶名|接受者用戶名|發(fā)送內(nèi)容 { string sender = tokens[1]。 string receiver = tokens[2]。 string content = tokens[3]。 string message = sender + send to + receiver + : + content。 //僅把信息轉(zhuǎn)發(fā)給發(fā)送者和接收者 for (int i=0。 i。 i++) { Client client = (Client)clients[i]。 if ( == tokens[2]) { (client, message)。 } if ( == tokens[1]) { (client, message)。 } } } if (tokens[0] == EXIT) // EXIT|用戶名 { for (int i=0。 i。 i++) { Client client = (Client)clients[i]。 string message = tokens[1] + has gone!。 (client, message)。 if ( == to