javaGUI實現(xiàn)多人聊天功能

第javaGUI實現(xiàn)多人聊天功能本文實例為大家分享了javaGUI實現(xiàn)多人聊天的具體代碼，供大家參考，具體內(nèi)容如下

packagecom.ff.chat.chatserver.frame;

importjavax.swing.*;

importjava.awt.*;

importjava.awt.event.WindowAdapter;

importjava.awt.event.WindowEvent;

importjava.io.DataInputStream;

importjava.io.DataOutputStream;

importjava.io.EOFException;

importjava.io.IOException;

import.BindException;

import.ServerSocket;

import.Socket;

importjava.util.ArrayList;

importjava.util.Iterator;

publicclassServerFrameextendsJFrame{

JTextAreamsgArea;

ArrayListSocketsocketArrayList=newArrayList();

booleanserverFlag=true;//服務器啟動標志

StringBuffersb=newStringBuffer();

ServerSocketserverSocket;

//創(chuàng)建服務器端的顯示窗口

publicvoidcreatFrame(){

this.setTitle("聊天室-服務器端");

this.setSize(500,500);

this.setLocationRelativeTo(null);

this.setResizable(false);

this.setDefaultCloseOperation(JFrame.DO_NOTHING_ON_CLOSE);

//創(chuàng)建一個面板

JPaneljp=newJPanel(newBorderLayout());

//中間面板

JPanelcenterPanel=newJPanel();

msgArea=newJTextArea(30,40);

msgArea.setEditable(false);

JScrollPanejsp=newJScrollPane(msgArea);

centerPanel.add(jsp);

jp.add(centerPanel);

this.add(jp);

this.setVisible(true);

this.addWindowListener(newWindowAdapter(){

@Override

publicvoidwindowClosing(WindowEvente){

intres=JOptionPane.showConfirmDialog(null,"確定要關閉服務器嗎？",

"操作提示",JOptionPane.OK_CANCEL_OPTION);

if(res==0){

try{

dispose();

serverSocket.close();

}catch(IOExceptionioException){

ioException.printStackTrace();

}

}

}

});

}

//啟動服務器，創(chuàng)建ServerSocket

publicvoidstartServer(){

try{

//創(chuàng)建ServerSocket

serverSocket=newServerSocket(9998);

System.out.println("等待客戶端連接");

//循環(huán)監(jiān)聽客戶端連接

while(serverFlag){

if(serverSocket.isClosed()){

serverFlag=false;

break;

}

Socketsocket=serverSocket.accept();

System.out.println("客戶端連接成功");

socketArrayList.add(socket);

//為每一個客戶端開啟一個線程，監(jiān)聽客戶端發(fā)來的消息

newServerThread(socket).start();

}

}catch(BindExceptionb){

b.printStackTrace();

System.out.println("服務器端口被占用");

System.exit(0);

}catch(IOExceptione){

e.printStackTrace();

System.out.println("服務器啟動失敗");

serverFlag=false;

}

}

//創(chuàng)建一個內(nèi)部類，開啟一個線程，接收消息

classServerThreadextendsThread{

Socketsocket;

DataInputStreamin;

DataOutputStreamout;

booleanclientFlag=true;

publicServerThread(Socketsocket){

this.socket=socket;

try{

this.in=newDataInputStream(socket.getInputStream());

}catch(IOExceptione){

e.printStackTrace();

}

}

@Override

publicvoidrun(){

//監(jiān)聽接收客戶端發(fā)送的消息

while(clientFlag){

if(socket.isClosed()){

break;

}

try{

Stringmsg=in.readUTF();//讀到客戶端發(fā)送的消息

sb.append(msg+"\n");

System.out.println(sb);

msgArea.setText(sb.toString());

//從服務器端向客戶端發(fā)送消息

if(socketArrayList.size()0){

IteratorSocketit=socketArrayList.iterator();

while(it.hasNext()){

Socketsoc=it.next();

if(soc.isClosed()){//當客戶端某個socket已經(jīng)為關閉狀態(tài)，移除此socket

it.remove();

continue;

}

//客戶端socket如果沒有關閉，向客戶端發(fā)送消息

out=newDataOutputStream(soc.getOutputStream());

out.writeUTF(sb.toString());

out.flush();

}

}

}catch(EOFExceptionef){

System.out.println("ip為："+socket.getInetAddress()+"的客戶端下線了");

clientFlag=false;

}catch(IOExceptione){

e.printStackTrace();

}

}

}

}

}

packagecom.ff.chat.chatserver.frame;

publicclassServerRun{

publicstaticvoidmain(String[]args){

ServerFrameserverFrame=newServerFrame();

serverFrame.creatFrame();

serverFrame.startServer();

}

}

注意：要在自己的電腦上運行多次客戶端需要勾選如下選項

1.登錄界面

packagecom.ff.chat.chatclient.frame;

importjavax.swing.*;

importjava.awt.*;

importjava.awt.event.ActionEvent;

importjava.awt.event.ActionListener;

importjava.io.IOException;

import.Socket;

publicclassLoginFrameextendsJFrame{

JTextFieldaccountField=null;

//創(chuàng)建窗口

publicvoidcreatFrame(){

this.setTitle("聊天窗口");

this.setSize(400,400);

this.setResizable(false);

this.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);

this.setLocationRelativeTo(null);

/*

*創(chuàng)建一個4行1列的面板

**/

JPaneljp=newJPanel(newGridLayout(4,1));

//歡迎登陸面板

JPanelwelcomePanel=newJPanel();

JLabelwelcomLabel=newJLabel("歡迎登陸");

welcomePanel.add(welcomLabel);

//賬號面板

JPanelaccountPanel=newJPanel();

JLabelaccountLabel=newJLabel("賬號");

accountField=newJTextField(15);

accountPanel.add(accountLabel);

accountPanel.add(accountField);

//密碼面板

JPanelpasswordPanel=newJPanel();

JLabelpasswordLabel=newJLabel("密碼");

JPasswordFieldpasswordField=newJPasswordField(15);

passwordPanel.add(passwordLabel);

passwordPanel.add(passwordField);

//登錄按鈕面板

JPanelbtnPanel=newJPanel();

JButtonloginBtn=newJButton("登錄");

JButtonregBtn=newJButton("注冊");

btnPanel.add(loginBtn);

btnPanel.add(regBtn);

jp.add(welcomePanel);

jp.add(accountPanel);

jp.add(passwordPanel);

jp.add(btnPanel);

this.add(jp);

this.setVisible(true);

//組件綁定事件監(jiān)聽

loginBtn.addActionListener(newActionListener(){

@Override

publicvoidactionPerformed(ActionEvente){

//獲得賬號密碼

Stringaccount=accountField.getText();

Stringpassword=newString(passwordField.getPassword());

if(account.length()==0){

JOptionPane.showMessageDialog(null,"賬號不能為空",

"操作提示",JOptionPane.WARNING_MESSAGE);

return;