【正文】 務(wù)器端用Java實(shí)現(xiàn)C/S聊天系統(tǒng)C/S （Client/Server）結(jié)構(gòu)，即大家熟知的客戶(hù)機(jī)和服務(wù)器結(jié)構(gòu)。 由于沒(méi)能提供用戶(hù)真正期望的開(kāi)放環(huán)境，C/S結(jié)構(gòu)的軟件需要針對(duì)不同的操作系統(tǒng)系統(tǒng)開(kāi)發(fā)不同版本的軟件， 加之產(chǎn)品的更新?lián)Q代十分快，已經(jīng)很難適應(yīng)百臺(tái)電腦以上局域網(wǎng)用戶(hù)同時(shí)使用。能夠使應(yīng)用軟件相對(duì)獨(dú)立于計(jì)算機(jī)硬件和操作系統(tǒng)平臺(tái)。因此，在網(wǎng)上聊天室這個(gè)虛擬的社會(huì)中，可以結(jié)交各層次各地方的朋友，從而為自己獲取更多的知識(shí)和更多的閱歷?？蛻?hù)/服務(wù)器應(yīng)用程序負(fù)責(zé)數(shù)據(jù)的部分只需訪問(wèn)一個(gè)中間件系統(tǒng)，由中間件完成到網(wǎng)絡(luò)中找到數(shù)據(jù)源或服務(wù)，進(jìn)而傳輸客戶(hù)請(qǐng)求、重組答復(fù)信息，最后將結(jié)果送回應(yīng)用程序的任務(wù)。負(fù)責(zé)接收客戶(hù)的輸入信息，并將輸入信息發(fā)送給中間件服務(wù)器，客戶(hù)機(jī)接收來(lái)自中間件服務(wù)器的結(jié)果信息并顯示給客戶(hù)。為了進(jìn)一步提高系統(tǒng)的效率，可以將企業(yè)的業(yè)務(wù)進(jìn)行大類(lèi)分類(lèi)?！　?shù)據(jù)庫(kù)服務(wù)器的功能與C/S結(jié)構(gòu)是一樣的，只不過(guò)其結(jié)果數(shù)據(jù)是返回給中間件服務(wù)器，而不是客戶(hù)機(jī)。(2) Sybase 。首先來(lái)看一下服務(wù)器端的任務(wù)： 1．服務(wù)器端應(yīng)當(dāng)建立一個(gè)ServerSocket，并且不斷進(jìn)行偵聽(tīng)是否有客戶(hù)端連接或者斷開(kāi)連接(包括判斷沒(méi)有響應(yīng)的連接超時(shí))。 客戶(hù)端應(yīng)該完成的工作包括： 1．與服務(wù)器端建立通信通道，向服務(wù)器端發(fā)送信息。一個(gè)網(wǎng)絡(luò)聊天室的運(yùn)行，首先是要有一個(gè)完整穩(wěn)定的服務(wù)器端，并且擁有很多個(gè)服務(wù)器端。聊天室的發(fā)展 　　聊天室做為即時(shí)通訊的一種，即時(shí)通訊（Instant Messenger，簡(jiǎn)稱(chēng)IM）軟件可以說(shuō)是目前我國(guó)上網(wǎng)用戶(hù)使用率最高的軟件，無(wú)論是老牌的ICQ，還是國(guó)內(nèi)用戶(hù)量第一的騰訊，以及微軟的MSN Messenger都是大眾關(guān)注的焦點(diǎn)，它們能讓你迅速地在網(wǎng)上找到你的朋友或工作伙伴，可以實(shí)時(shí)交談和互傳信息。正是四位以色列籍的年輕人，在1996年7月成立的Mirabilis公司，并于同年11月推出了全世界第一個(gè)即時(shí)通訊軟件ICQ，取意為“我在找你”——“I Seek You”，簡(jiǎn)稱(chēng)ICQ了。Messenger雖出道較晚，但依托微軟的強(qiáng)大背景，實(shí)力也不可小視。 用戶(hù)注冊(cè)功能，實(shí)現(xiàn)用戶(hù)的登陸ID注冊(cè)和個(gè)人信息，并存入服務(wù)器數(shù)據(jù)庫(kù)中。 私聊功能，實(shí)現(xiàn)用戶(hù)和在線的其他用戶(hù)一對(duì)一的聊天方式。 顯示時(shí)鐘功能。 發(fā)送表情和設(shè)置聊天內(nèi)容字體，并可以設(shè)置字體顏色和背景色等。 發(fā)送系統(tǒng)消息數(shù)據(jù)庫(kù)在信息管理系統(tǒng)中占有非常重要的地位，其設(shè)計(jì)的好壞直接影響到整個(gè)系統(tǒng)的效率和性能。 　　接收用戶(hù)的聊天信息是由多線程技術(shù)實(shí)現(xiàn)的，因?yàn)榭蛻?hù)端必須時(shí)時(shí)關(guān)注更新服務(wù)器上是否有最新消息，在本程序中設(shè)定的是3秒刷新服務(wù)器一次，如果間隔時(shí)間太短將會(huì)增加客戶(hù)端與服務(wù)器端的通信負(fù)擔(dān)，而間隔時(shí)間長(zhǎng)就會(huì)讓人感覺(jué)沒(méi)有時(shí)效性，所以經(jīng)過(guò)權(quán)衡后認(rèn)為3秒最佳，因?yàn)槊總€(gè)用戶(hù)都不可能在3秒內(nèi)連續(xù)發(fā)送信息。服務(wù)器接收到請(qǐng)求后，啟動(dòng)單獨(dú)得線程進(jìn)行處理，首先進(jìn)行合法性檢查，確認(rèn)登錄名與系統(tǒng)中已注冊(cè)得用戶(hù)登陸名不相同后更新數(shù)據(jù)，并返回信息，客服端進(jìn)行顯示。用戶(hù)的需求具體體現(xiàn)在各種信息的提供、保存、更新和查詢(xún)。 　　，包括：用戶(hù)名，密碼，性別，年齡，電子郵箱，用戶(hù)頭象。下面是具體的步驟：一、服務(wù)器端的偵聽(tīng)。偵聽(tīng)數(shù)據(jù)庫(kù)表messages是否有未發(fā)送信息，信息包括：即時(shí)發(fā)送和定時(shí)發(fā)送，是即時(shí)發(fā)送的話就向客戶(hù)機(jī)發(fā)出連接請(qǐng)求，連接成功就把短信內(nèi)容和用戶(hù)編號(hào)發(fā)送到客戶(hù)端，是定時(shí)發(fā)送的話，再判斷定時(shí)的時(shí)間是否當(dāng)前時(shí)間，如果是，同樣發(fā)送給客戶(hù)端，如果不是當(dāng)前時(shí)間則跳過(guò)。2 Socket 向服務(wù)器端發(fā)送請(qǐng)求。如果客戶(hù)端超過(guò)一定時(shí)間不向服務(wù)器發(fā)送alive報(bào)文，則服務(wù)器端認(rèn)為用戶(hù)已經(jīng)掉線，從可用用戶(hù)列表中刪除該用戶(hù)。 　　在服務(wù)器端可以實(shí)現(xiàn)不斷的監(jiān)聽(tīng)客服的連接，并且根據(jù)客戶(hù)端發(fā)送過(guò)來(lái)的不同信息如注冊(cè)信息，登錄信息，公聊信息，私聊信息，退出信息等，服務(wù)器端要做出不同的響應(yīng)，并且要實(shí)現(xiàn)數(shù)據(jù)庫(kù)的操作，如根據(jù)用戶(hù)注冊(cè)的信息保存數(shù)據(jù)庫(kù)中，根據(jù)登錄時(shí)發(fā)送來(lái)的用戶(hù)名和密碼檢測(cè)是否合法用戶(hù)等。電腦每做的一次動(dòng)作，一個(gè)步驟，都是按照以經(jīng)用計(jì)算機(jī)語(yǔ)言編好的程序來(lái)執(zhí)行的，程序是計(jì)算機(jī)要執(zhí)行的指令的集合，而程序全部都是用我們所掌握的語(yǔ)言來(lái)編寫(xiě)的。由于客戶(hù)端需要同時(shí)能夠接收信息以及發(fā)送信息，所以也必須利用多個(gè)線程來(lái)實(shí)現(xiàn)。因特網(wǎng)發(fā)展以后，較常用的用戶(hù)端包括了如萬(wàn)維網(wǎng)使用的網(wǎng)頁(yè)瀏覽器，收寄電子郵件時(shí)的電子郵件客戶(hù)端，以及即時(shí)通訊的客戶(hù)端軟件等。具體實(shí)現(xiàn) 首先建立一個(gè)Server類(lèi)，Server類(lèi)完成一個(gè)偵聽(tīng)的工作，并為建立連接的客戶(hù)端增加線程： public class Server{ static Socket socketlist[] = new Socket[1000]。 //一旦客戶(hù)端連接進(jìn)來(lái)，就增加一個(gè)線程用于與該客戶(hù)端的通信，關(guān)鍵在于傳遞參數(shù)， //將Server類(lèi)和客戶(hù)端的sokcet都傳送到這個(gè)通信線程 new ConnectionForClient( this, socket )。 ( message )。 = socket。 //一旦接收到客戶(hù)端發(fā)送的信息，就將詳細(xì)發(fā)送者和發(fā)送的信息傳給Server類(lèi)的信息發(fā)送中心 ( message , )。 DataOutputStream dataOut。 //開(kāi)始后臺(tái)線程用于監(jiān)聽(tīng)服務(wù)器端傳送的信息 start()。 sendMessage(words)。 } //程序開(kāi)始執(zhí)行 public static void main(String args[]){ int socketport = 8765。 所有這些問(wèn)題都可以通過(guò)Client與Server類(lèi)的SendMessageCenter方法建立一個(gè)不很復(fù)雜的通信協(xié)議來(lái)完成。 一般地，這樣就制定了一個(gè)簡(jiǎn)單的通信協(xié)議。import 。 ServerFrame frame = new ServerFrame()。 // Validate frames that have preset sizes ()。 } if ( ) { (new Runnable() { ()。 }import 。import .*。import 。import .*。import 。 Socket socket = null。 Vector clients = new Vector(20)。 public ServerFrame() { } //Overridden so we can exit when window is closed }//client類(lèi)是ServerFrame類(lèi)的內(nèi)部類(lèi) socket = s。 try { String info = ()。 //讀取用:分開(kāi)的字符段//度曲第一個(gè)分段字符串 ip = ()。 } //send方法是client類(lèi)的方法，用于向客戶(hù)端發(fā)送消息 ()。 } while (true){ if(line == null){ StringBuffer message = new StringBuffer(MSG:)。 (broadcast+:)。 ((s))。 if((BROAD)){ } + + } (())。 if((name)){ (())。 ++//從clients數(shù)組中刪除客戶(hù) sendClients(new StringBuffer(QUIT+:+))。 } } //notifyRoom是ServerFrame的方法，監(jiān)視視頻聊天窗口連接變化， //不斷刷新clients數(shù)組兵刷新用戶(hù)列表信息 public void notifyRoom(){ if(() 0){ StringBuffer people = new StringBuffer(PEOPLE)。 (:+)。 } if (socket != null){ Client c = new Client(socket)。 ++ (目前已經(jīng)有:+()+用戶(hù)連接)。//監(jiān)視聊天窗口的連接變化 } else { try { (FaultName)。//睡眠400毫秒 } catch (InterruptedException ee){ } } } } } for (int i = 0。 return false。 } } serverSocket = new ServerSocket(4000)。 (系統(tǒng)提示: (系統(tǒng)提示: 啟動(dòng)時(shí)發(fā)生錯(cuò)誤\n可能另一個(gè)服務(wù)器已經(jīng)在運(yùn)行)。 } (true)。 (true)。 (false)。 } sendClients(new StringBuffer(QUIT:+SERVER))。 closeAll()。 (0)。 } Client c = (Client)()。 try { (c)。 } = adaptee。 } = adaptee。 } = adaptee。 }import 。 ClientFrame frame = new ClientFrame()。 // Validate frames that have preset sizes ()。 } if ( ) { (new Runnable() { ()。 } })。 }} package chatclient。import 。import 。import 。import .*。/*** pTitle: /p* pDescription: 網(wǎng)絡(luò)聊天工具客戶(hù)端,由Tommylee開(kāi)發(fā)/p * pCopyright: Copyright (c) 2007/p* pCompany: /p* author Tommylee* version */GridLayout g=new GridLayout(1,3)。 (label1)。 (,jp1)。(jbutton2)。 //// (false)。 (this)。 (this)。 (this)。 (vip++port)。 (*************開(kāi)始連接**********)。if((bye)) +服務(wù)器離開(kāi)說(shuō)+39。 break。\n39。 } }catch(IOException e1){(開(kāi)始連接)。 if(()==jtext3) { \n39。 ()。 } { (true)。})。String saa=()。 int pp=1。 DataOutputStream out1=new DataOutputStream(())。 (