java實現(xiàn)在線聊天系統(tǒng)

第java實現(xiàn)在線聊天系統(tǒng)dis=newDataInputStream(s.getInputStream());

dos=newDataOutputStream(s.getOutputStream());

bConnected=true;

System.out.println("有一個新的客戶端程序在運行");

}catch(IOExceptione){

e.printStackTrace();

}

//一個客戶端連接成功以后，一直在執(zhí)行該while部分的代碼，其他客戶端無法連接

/**

*解決方法：1.異步解決方法：一直監(jiān)聽接收，其他在另外的地方執(zhí)行2.使用單獨的線程：線程：接受客戶端連接

*另外的單獨的線程：處理通訊

*/

}

publicvoidsendString(Stringstr){

try{

dos.writeUTF(str);

}catch(IOExceptione){

clients.remove(this);

System.out.println("對方退出了?。。∥覐腖ist中去掉了?。?！");

}

}

publicvoidrun(){

Clientclient=null;

//注意這部分的包圍關(guān)系

try{

while(bConnected){

Stringstring=dis.readUTF();

System.out.println(string);

for(inti=0;iclients.size();i++){

client=clients.get(i);

client.sendString(string);

}

}

}catch(EOFExceptione){

System.out.println("Clientclosed!");

}catch(IOExceptione){

e.printStackTrace();

System.exit(0);

}finally{

try{

if(dis!=null){

dis.close();

}

if(s!=null){

s.close();

}

}catch(IOExceptione){

e.printStackTrace();

}

}

}

}

}

客戶端代碼：

importjava.awt.BorderLayout;

importjava.awt.Frame;

importjava.awt.TextArea;

importjava.awt.TextField;

importjava.awt.event.ActionEvent;

importjava.awt.event.ActionListener;

importjava.awt.event.WindowAdapter;

importjava.awt.event.WindowEvent;

importjava.io.DataInputStream;

importjava.io.DataOutputStream;

importjava.io.EOFException;

importjava.io.IOException;

import.BindException;

import.Socket;

import.SocketException;

import.UnknownHostException;

*可以和ChatServer版本三配套使用

*@authorAdministrator

publicclassChatClientEdition3extendsFrame{

TextFieldtfText=newTextField();

TextAreataContent=newTextArea();

Socketsocket=null;

DataOutputStreamdataOutputStream=null;

DataInputStreamdataInputStream=null;

privatebooleanbConnected=false;

publicstaticvoidmain(String[]args){

newChatClientEdition3().launchFrame();

}

//加載窗口

publicvoidlaunchFrame(){

setLocation(400,300);

this.setSize(300,300);

this.setTitle("在線聊天時--Quiana");

add(tfText,BorderLayout.SOUTH);

add(taContent,BorderLayout.NORTH);

pack();

//窗口關(guān)閉的時間監(jiān)聽

this.addWindowListener(newWindowAdapter(){

@Override

publicvoidwindowClosing(WindowEvente){

disconnect();

System.exit(0);

}

});

tfText.addActionListener(newTFListener());

this.setVisible(true);

connect();

newThread(newRecvThread()).start();

}

//文字處理的時間監(jiān)聽

privateclassTFListenerimplementsActionListener{

//敲擊回車時，文字的變化事件

@Override

publicvoidactionPerformed(ActionEventarg0){

Strings=tfText.getText().trim();//去掉兩端的空格

tfText.setText("");

try{

dataOutputStream.writeUTF(s);

dataOutputStream.flush();

}catch(IOExceptione){

e.printStackTrace();

}

}

}

//連接到服務器

publicvoidconnect(){

try{

//連接到服務器

socket=newSocket("",8888);

bConnected=true;

dataOutputStream=newDataOutputStream(socket.getOutputStream());

dataInputStream=newDataInputStream(socket.getInputStream());

System.out.println("連接到服務器！??！");

}catch(BindExceptione){

e.printStackTrace();

}catch(UnknownHostExceptione){

e.printStackTrace();

}catch(IOExceptione){

e.printStackTrace();

}

}

//斷開連接

publicvoiddisconnect(){

try{

dataOutputStream.close();

System.out.println("dataOutputStream成功關(guān)閉");

socket.close();

System.out.println("客戶端socket成功關(guān)閉");

}catch(IOExceptione){

e.printStackTrace();

}

}

privateclassRecvThreadimplementsRunnable{

publicvoidrun(){

try{

while(bConnected){

Stringstring=dataInputStream.readUTF();

if(taContent.getText().length()==0){

taContent.setText(string);

}else{

taContent.setText(taContent.getText()+"\n"+string);

}

}

}catch(SocketExceptione){