java實現(xiàn)多人聊天系統(tǒng)

更新時間：2022年09月16日 08:37:30 作者：Makish

這篇文章主要為大家詳細(xì)介紹了java實現(xiàn)多人聊天系統(tǒng)，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價值，感興趣的小伙伴們可以參考一下

本文實例為大家分享了java實現(xiàn)多人聊天系統(tǒng)的具體代碼，供大家參考，具體內(nèi)容如下

開發(fā)環(huán)境

Windows 7 操作系統(tǒng)
MyEclipse

聊天室程序結(jié)構(gòu)設(shè)計

1.系統(tǒng)分為客戶端、服務(wù)器端和連接服務(wù)器客戶端三個模塊。
2.客戶端負(fù)責(zé)發(fā)送消息。
3.服務(wù)器端負(fù)責(zé)接收客戶端發(fā)來的信息并執(zhí)行相應(yīng)操作處理，最后通過群發(fā)功能，使客戶端將群聊的消息的顯示出來。
4.連接服務(wù)器端負(fù)責(zé)連接服務(wù)器，從而進(jìn)入客戶端。

總體模塊圖

客戶端代碼

Client.java

package servlet;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.Socket;
import java.net.UnknownHostException;
import java.io.OutputStreamWriter;

public class Client {
? ? ? ? ? ? ? Socket socket;
? ? ? ? ? ? ? BufferedWriter bw;
? ? ? ? ? ? ? BufferedReader br ;
?? ??? ?
public Client(String ip, int port){
? ? ? ? ?try {
? ? ? ? ? ? ? socket =new Socket(ip,port);
? ? ? ? ? ? ? bw=new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
?? ? ? ? ? ? ?br=new BufferedReader(new InputStreamReader(socket.getInputStream()));
? ? ? ? ? ? ? }catch (UnknownHostException e){
? ? ? ? ? ? ? e.printStackTrace();
? ? ? ? ? ? ? }catch(IOException e){
? ? ? ? ? ? ? e.printStackTrace();
? ? ? ? ? ? ? ? }
? ? }
public void sendMessage(String message) {
? ? ? ? ? try{?
? ? ? ? ? ? ? bw.write(message);
? ? ? ? ? ? ? bw.newLine();
? ? ? ? ? ? ? bw.flush();
? ? ? ?}catch(IOException e){
? ? ? ? ? ? ?e.printStackTrace();
?? ?
? ? ?}
? ?}

public String reciveMessage() {
? ? ? ?String message=null;
? ? ? ?try {?
? ? ?? ? ? message = br.readLine();
? ? ? }catch(IOException e) {
? ? ? ? ? e.printStackTrace();
? ? ? }
? ? return message;
}

public void close(){
?? ? try{
?? ? socket.close();
?? ?}catch(IOException e){
?? ?e.printStackTrace();
?? ?}
}}

ClientFrame.java

package servlet;

import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.WindowAdapter;
import java.awt.event.WindowEvent;
import java.text.SimpleDateFormat;
import java.util.Date;


import javax.swing.*;
import javax.swing.border.EmptyBorder;


public class ClientFrame extends JFrame {
? ? private JPanel contentPane;
? ? private JLabel lblUserName;
? ? private JTextField tfMessage;
? ? private JButton btnSend;
? ? private JTextArea textArea;
? ? private String userName;
? ? private Client client;

public ClientFrame(String ip,String userName){
? ? this.userName = userName;
? ? init();//添加窗體初始化內(nèi)容
? ? addListener();
? ? client=new Client(ip,8080);
? ? ReadMessageThread t=new ReadMessageThread();
? ? t.start();
}
private class ReadMessageThread extends Thread{
? ? ?public void run() {
?? ? ?while(true) {
?? ??? ? ?String str=client.reciveMessage();
?? ??? ? ?textArea.append(str+"\n");//添加文本內(nèi)容
?? ? ?}
? }
??
}
private void init(){
? ?setTitle("客戶端");
? ?setResizable(false);
? ?setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
? ?setBounds(100,100,450,300);

? ?contentPane = new JPanel();
? ?contentPane.setBorder(new EmptyBorder(5,5,5,5));
? ?contentPane.setLayout(null);
? ?setContentPane(contentPane);

? ?JScrollPane scrollPane = new JScrollPane();
? ?scrollPane.setBounds(5,5,434,229);
? ?contentPane.add(scrollPane);

? textArea =new JTextArea();
? scrollPane.setViewportView(textArea);
? textArea .setEditable(false);

? JPanel panel =new JPanel();
? panel.setBounds(5,235,434,32);
? contentPane.add(panel);
? panel.setLayout(null);

? lblUserName = new JLabel(userName);
? lblUserName.setHorizontalAlignment(SwingConstants.TRAILING);
? lblUserName.setBounds(2,4,55,22);
? panel.add(lblUserName);

? tfMessage =new JTextField();
? tfMessage.setBounds(62,5,274,22);
? tfMessage.setColumns(10);
? panel.add(tfMessage);

? btnSend =new JButton("發(fā)送");
? btnSend.setBounds(336,4,93,23);
? panel.add(btnSend);

? tfMessage.validate();
}
private void addListener(){
?btnSend.addActionListener(new ActionListener(){
? public void actionPerformed(ActionEvent e){
? ? ? ? Date date=new Date();
?? ??? ?SimpleDateFormat sf=new SimpleDateFormat("yyyy年MM月dd日 HH:mm:ss");
? ? ? ? client.sendMessage(userName+""+sf.format(date)+":\n"+tfMessage.getText());
?? ??? ?tfMessage.setText("");//清空

? ? ? ? ? }
? ? ? });
? ?this.addWindowListener(new WindowAdapter(){//開啟窗口監(jiān)聽
?? ?public void windowClosing(WindowEvent atg0) {
?? ??? ?int op = JOptionPane.showConfirmDialog(ClientFrame.this,"確定要退出聊天室嗎？","確定",JOptionPane.YES_NO_OPTION);
?? ??? ?if(op == JOptionPane.YES_OPTION) {
?? ??? ? ? ?client.sendMessage("%EXIT%:" + userName);
?? ??? ??? ?try {
?? ??? ??? ??? ?Thread.sleep(200);
?? ??? ??? ??? ?
?? ??? ??? ?}catch(InterruptedException e) {
?? ??? ??? ??? ?e.printStackTrace();
?? ??? ??? ?}
?? ??? ??? ?client.close();
? ? ? ? ? ? System.exit(0);
?? ??? ?}
? ? ? ? ?}
? ? ? });
? }
}

LinkServerFrame.java

package servlet;
import java.awt.Font;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;

import javax.swing.*;
import javax.swing.border.EmptyBorder;

@SuppressWarnings("serial")
public class LinkServerFrame extends JFrame {

?? ?private JPanel contentPane;//下方面板
? ? private JLabel lblIP;
? ? private JLabel lblUserName;
? ? private JTextField tfIP;
? ? private JTextField tfUserName;
? ? private JButton btnLink;


? ?public LinkServerFrame(){
?? ?setTitle("連接服務(wù)器");
?? ?setResizable(false);
?? ?setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
?? ?setBounds(100, 100, 390, 150);

? ?contentPane = new JPanel();
? ?contentPane.setBorder(new EmptyBorder(5,5,5,5));
? ?contentPane.setLayout(null);
? ?setContentPane(contentPane);

? ?lblIP =new JLabel("服務(wù)器IP地址:");
? ?lblIP.setFont(new Font("微軟雅黑",Font.PLAIN,14));
? ?lblIP.setBounds(20,15,100,15);
? ?contentPane.add(lblIP);

? ?tfIP =new JTextField("127.0.0.1");
? ?tfIP.setBounds(121,13,242,21);
? ?contentPane.add(tfIP);
? ?tfIP.setColumns(10);

? ?lblUserName = new JLabel("用戶名:");
? lblUserName.setFont(new Font("微軟雅黑",Font.PLAIN,14));
? lblUserName.setBounds(60,40,60,15);
? ?contentPane.add(lblUserName);

? ?tfUserName =new JTextField();
? tfUserName.setBounds(121,42,242,21);
? contentPane.add(tfUserName);
? tfUserName.setColumns(10);

? btnLink =new JButton("連接服務(wù)器");
? btnLink.addActionListener(new ActionListener(){
? ? ? ? public void actionPerformed(ActionEvent e){
?? ? ?do_btnlink_actionPerformed(e);
? }
? ?});
? btnLink.setFont(new Font("微軟雅黑",Font.PLAIN,14));
? ?btnLink.setBounds(140,80,120,23);
? ?contentPane.add(btnLink);//顯示連接服務(wù)器窗口
?}
public static void main(String[] args){
? ? ?LinkServerFrame linkServerFrame = new LinkServerFrame();
? ? ?linkServerFrame.setVisible(true);
}
? protected void do_btnlink_actionPerformed(ActionEvent e) {
?? ? ?if(!tfIP.getText().equals("")&&!tfUserName.getText().equals("")) {//文本框的內(nèi)容不能為空
?? ??? ? ?dispose();//銷毀當(dāng)前窗口
?? ??? ? ClientFrame clientFrame=new ClientFrame(tfIP.getText().trim(), tfUserName.getText().trim());
?? ??? ? ?clientFrame.setVisible(true);//顯示客戶窗體
?? ? ?}
?? ? ?else {
?? ??? ? ?JOptionPane.showMessageDialog(null,"文本框里的內(nèi)容不能為空！","警告",JOptionPane.WARNING_MESSAGE);
?? ? ?}
? ? ? ?}
}

服務(wù)器端代碼

Server.java

package servlet;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.HashSet;
import java.io.BufferedWriter;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;

public class Server {
? ?private HashSet<Socket> allSocket;
? ?private ServerSocket server;


?public Server() {
?? ? try {
?? ??? ?server = new ServerSocket(8080);
? }catch(IOException e) {

?? ? ?e.printStackTrace();
? }
?? ? allSocket=new HashSet<Socket>();
?}?
?public void startServer() throws IOException{
?? ? while(true) {
? ? ? ? ?Socket socket =server.accept();
?? ??? ? System.out.println("用戶已經(jīng)進(jìn)入聊天室");
?? ??? ? allSocket.add(socket);
? ? ? ? ?ServerThread t= new ServerThread(socket);
? ? ? ? ?t.start();
?? ??? ?
?? ? }
?}
?private class ServerThread extends Thread{
?? ? ? Socket socket;
?? ? public ServerThread(Socket socket) {
? ? ? ?this.socket=socket;
?? ? }
? ? public void run() {
?? ??? ? BufferedReader br=null;
?? ??? ? try {
?? ??? ??? ?br=new BufferedReader(new InputStreamReader(socket.getInputStream()));
?? ??? ??? ?while(true) {
?? ??? ??? ??? ?String str=br.readLine();
?? ??? ??? ??? ?if(str.contains("%EXIT%")) {
? ? ? ? ? ? ??? ? String tmp=str.split(":")[1]+"用戶退出聊天室";
? ? ? ? ? ? ? ? ?sendMessageToALLClient(tmp);
? ? ? ? ? ? ? ? ?allSocket.remove(socket);
? ? ? ? ? ? ? ? ?socket.close();
? ? ? ? ? ? ? ? ?return;?? ?
?? ??? ??? ??? ?}
?? ??? ??? ??? ?sendMessageToALLClient(str);
?? ??? ??? ?}
?? ??? ? }catch(IOException e) {
?? ??? ??? ??? ?e.printStackTrace();
?? ??? ??? ?
?? ??? ? }
?? ? }}
?? ?private void sendMessageToALLClient(String str) throws IOException {
?? ?for(Socket s: allSocket) {
?? ??? ?try{
?? ? ? ?BufferedWriter bw=new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
?? ??? ?bw.write(str);
?? ??? ?bw.newLine();
? ? ? ? bw.flush();
?? ?}catch(IOException e) {
?? ??? ?e.printStackTrace();
?? ??? ??? ?
?? ??? ? }
?? ?}
?}
?public static void main(String[] args) {
?? ? Server s = new Server();
?? ? try {
?? ??? ? s.startServer();
?? ? }catch(IOException e){
?? ??? ? e.printStackTrace();
?? ? }
?? ? }
?}