【文章內容簡介】 nPerformed(ActionEvent e) { if(()==loadBtn||()==nameText){//創(chuàng)建客戶端主界面 text=()。 new StateFrame(text)。 dispose()。 }else if(()==cancelBtn){//取消登錄，推出程序 dispose()。 (0)。 } } 程序的登錄窗口,從此窗口中，輸入用戶名，點擊“登陸”來初始化一個StateFrame對象，并在顯示器上顯示出客戶端的主界面。在后期的完善中，會完成記住用戶名及自動登錄功能。主要通過將用戶名寫入一個記事本保存起來。2．StateFrame public final static int DEFAULT_PORT=8322。//默認端口 public final static int CATCH_PORT=7322。 public final static int TCP_PORT=6322。//默認TCP連接端口 public void init(){//初始化應用程序窗口…… (new ActionListener(){//用ActionListener接口來對圖形界面中的各個組件進行監(jiān)聽 public void actionPerformed(ActionEvent e) { //雙擊登錄到列表框內容時觸發(fā)的事件為連通列表框中的IP,建立TCP通信 Socket socket。 int s=()。 String address=userinfo[s].getIP()。//獲取對方IP try { socket=new Socket(address,TCP_PORT)。//建立連接 MainChatFrame mf=new MainChatFrame(socket,userinfo[s].getName())。//啟動私聊主界面 } catch (Exception e1) {()。} }})。 ……//初始化UDP協(xié)議端口信息 //首先向已在線的程序發(fā)送本機的IP以及請求響應并對相應的組播端進行監(jiān)聽 public void JoinGroup(){ try { group=()。 //初始化廣播聊天信息組 groupC=()。//初始化登錄信息組 socket=new DatagramSocket()。 byte notify[]=new byte[100]。 byte nametag[]=new byte[20]。 nametag=()。 //發(fā)送一個登錄信息給已登錄的用戶，通知他們本程序上線。 //包的數據結構為：判斷位+用戶名+IP地扯+用戶名長度 notify=new String(C+name +().getHostAddress()+()).getBytes()。 packet=new DatagramPacket(notify,groupC,CATCH_PORT)。 (packet)。 socketC=new MulticastSocket(CATCH_PORT)。 (groupC)。 Catcher catcher=new Catcher(socketC,this,name,userinfo)。 CheckIn login=new CheckIn(this,userinfo)。 } catch (Exception e) { ()。 }} 用來顯示用用戶名及在線人的窗口，并對窗口中各組件實施監(jiān)聽。讓其可順利生成各個聊天主界面。3．Catcher//實現對組播端口的監(jiān)聽，并作出反映 public void run(){ try {socket=new DatagramSocket()。 while(true){ byte[] Rdata=new byte[256]。 packet=new DatagramPacket(Rdata,)。 (packet)。//等待接受數據包 String count=new String(()).substring(()1,())。 int num=(count)。 //count記錄了數據包的最后一位數，也就是記錄了用戶名的長度。 String check=new String(()).substring(1+num,()1)。 //check為數據包的IP地址 String judge=new String(()).substring(0,1)。 String usertag=new String (()).substring(1,num+1)。 if((C)){//judge為“C”時反送一個含有對方用戶名以及本機的IP的數據包到組播組 …… } public void Connect(String check){ //Connect()方法實現了對對方回應本機信息的過程， //其中第一以及最后一個為無用信息，在接受方被吸收掉 …… CheckSocket=new Socket(check,CHECK_PORT)。 in=new BufferedReader(new InputStreamReader(()))。 out=new PrintWriter(())?！脕韺Φ卿浶畔⒌谋O(jiān)聽，并解析傳送過來的數據包。4．Listenerpublic void run(){ try {while(true){ byte[] Rdata=new byte[256]。 packet=new DatagramPacket(Rdata,)。//用Rdata數組來接收數據， (packet)。 //并傳給MulticastSocket對象 (new String(()))。 (true)。ring()。 } } catch (IOException e) { ()。}} 用來對群消息的監(jiān)聽及處理，將接收到的消息打包，傳給MulticastSocket對象，再利用CheckIn和Logon對象進行處理。5．CheckIn//對回應信息的端口的監(jiān)聽，一旦收到回應信息則開啟一個新線程對其進行信息的接收 public void run(){ try { Check=new ServerSocket(CHECK_PORT)。 } catch (IOException e) {()。} try { while(true){ client=()。 Logon ll=new Logon(sf,client,userinfo)。 ()。} } catch (IOException e) {()。 }}6．Logon public void run(){//run()方法實現對回應的TCP連接的信息的接收，并且完成對UserInfo信息的保存 String msg=null。 Try{ msg=receiveMsg()。 name=msg。//獲取對方的名字 msg=receiveMsg()。 ip=msg。//獲取對方的IP { k=()。 userinfo[k]=new UserInfo(name,ip)。 } (userinfo[k].getName())。 msg=receiveMsg()?！? } } public String receiveMsg()throws IOException{//接收數據 String msg=new String()。 try { msg=()。 } catch (IOException e) {……} return msg。 }5和6主要完成對群消息的處理，5主要完成對信息的解包，顯示等等；而6主要是對TCP連接的信息的接收，以及對用戶信息的保存。7．TCPConnectpublic void run(){ try { listen=new ServerSocket(port)。 processMsg(正在監(jiān)聽TCP端口………)。//建立TCP連接 } catch (Exception e) { processMsg(群聊功能仍可使用)。//建立失敗，不過還可以群聊 } …… while(true){ Socket client = ()。 MainChatFrame mf=new MainChatFrame(client,name)。//啟動一個私聊主界面 } …… } 根據所得到對方的IP信息建立一個TCP連接，并啟動一個私聊主界面，進行TCP通信。8．UserInfopublic class UserInfo {//初始化用戶信息，姓名以及IP地址，姓名是通過登錄界面由用戶鍵入的，IP//地址是程序直接由機器獲取的 private String name。 private String IP。 public UserInfo(String name, String ip) { = name。IP = ip。} public String getIP() {return IP。} public void setIP(String ip) {IP = ip。} public String getName() {return name。} public void setName(String name) { = name。}} 記錄IP及用戶名。9．MainChatFramepublic void init(String name){//傳入的參數為自身的用戶名 …… (new ActionListener(){//接收信息的監(jiān)聽器 public void actionPerformed(ActionEvent e) { try { sendMsg(())。 processMsg(I:+())。 ()。 }}})。 …… (new ActionListener(){//發(fā)送信息的監(jiān)聽器 public void actionPerformed(ActionEvent e) { try { sendMsg(())。 processMsg(I:+())。 ()。 }}})。 …… } 顯示點對點聊天窗口，建立接收和發(fā)送數據的監(jiān)聽。10．GroupChatFrame public void eventHandle(){ (new KeyListener(){//接收信息的監(jiān)聽器 public void keyPressed(KeyEvent e) { if(()==39。\n39。) try{ byte[] dataS=(name+:+()).getBytes()。 =new DatagramPacket(dataS,)。 ()。 ()。 }…… }})。 (new ActionListener(){//發(fā)送信息的監(jiān)聽器 public void actionPerformed(ActionEvent e) { try{ byte[] dataS=(name+:+()).getBytes()。 =new DatagramPacket(dataS,)。 ()。 ()。 } …… }})。} 顯示群聊天窗口。11．LoadingFrameDemopublic class LoadingFrameDemo {//主方法程序 public static void main(String[] args) { new LoadingFrame().init()。 }} 程序的入口。4 JAVAqq局域網聊天程序的設計與實現 開發(fā)環(huán)境工具基于JAVA聊天系統(tǒng)的設計主要運用JAVA與語言與Socket類開發(fā)。其開發(fā)的主要環(huán)境包括（Windows平臺）： java環(huán)境jdk,，另外還需配置classpath環(huán)境變量。 硬件環(huán)境 本系統(tǒng)運行環(huán)境所需用到的環(huán)境為:硬件配置 ：中央處理器（CPU） ：Intel Core Duo processor T2250；硬 盤：40GB HDD；內 存：1G 667HZ；顯示器：” WXGA CrystalBrite LCD；顯 卡：Up to 256MB NVIDIA GeForce Go 7300軟件環(huán)境：WINDOWS XP、MyEclipse 、。 聊天系統(tǒng)功能模塊的測試本次課程設計的編譯環(huán)境，及編寫平臺為java。服務器線程在程序運行期間一直有效，接受客戶端請求信息，轉發(fā)客戶端聊天內容，查看用戶信息。 客戶端運行時必須先登陸，登陸界面如圖1，客戶端主界面如圖2，聊天