Java swing+socket实现多人聊天程序

雨点打透心脏的1/2处 2022-04-17 06:07 193阅读 0赞

swing+socket实现多人聊天程序

### 1.准备工作 ###

先看效果：

![20181114111950531.gif][]

*  客户端项目结构图：

![20181114112121642.png][]

*  服务端项目结构图：

![20181114112214600.png][]

## ##

### 2.运行原理 ###

*  服务端

先开一个线程serverListerner，线程中开启一个Serversocket  
用Serversocket.accept()监听指定端口  
一旦有socket连接进来，就为该socket开启一个线程，用于读取该socket输入流的信息，一旦有信息，就通知其他客户端  
并将线程保存到Vector<ChartThread> 集合内，交给ChatThreadManager管理，主要是处理分发消息

*  客户端:

点击connect按钮和服务端建立连接，客户端会开启线程随时监听socket的输入流  
服务端accept后就会为该socket建立线程，监控该socket的流信息  
当客户端点击发送按钮时，将文本框内的信息，写进socket中，此时服务端的线程抓到了socket的输入流信息，就让ChatThreadManager管理类，去通知集合内其他socket，为多个socket写入相同的信息，那么其余的客户端就收到消息了，实现了多人聊天的功能

## ##

### 3.核心代码 ###

*  服务端：

StartServer.java

Main函数入口，实例ServerListener类，并开启该线程

package com.chart;
    
    public class StartServer
    {
       public static void main(String[] args)
       {
    	   new ServerListener().start();
       }
    }

ServerListener.java:

用Serversocket.accept()监听指定端口,一旦有socket连接进来，就为该socket开启一个ChatThread线程  
并将ChatThread线程保存到Vector<ChartThread> 集合内，交给ChatThreadManager管理,

package com.chart;
    
    import java.io.IOException;
    import java.net.ServerSocket;
    import java.net.Socket;
    import javax.swing.JOptionPane;
    
    
    public class ServerListener extends Thread{
       
    	public void run()
    	{
    		try {
    			ServerSocket serversocket= new ServerSocket(23456);
    			while(true) {
    			Socket socket=serversocket.accept();  //进程会阻塞在这句，直到有socket连接进来，就往下执行
    	        System.out.println("one client has connected");
    			ChatThread cs=new ChatThread(socket);
    			cs.start();
    			ChatThreadManager.getChartManager().add(cs);
    			}  
    		} catch (IOException e) {
    			e.printStackTrace();
    		}
    	}
    }

ChatThread:

在此线程中监听客户端socket的来信 并调用publish()方法，通知ChatThreadManager类

package com.chart;
    
    import java.io.BufferedReader;
    import java.io.InputStreamReader;
    import java.net.Socket;
    
    public class ChatThread extends Thread {
    	
    	Socket socket;
    
    	public ChatThread(Socket s) {
    		this.socket = s;
    	}
    
    	public void out(String out) {
    		try {
    			socket.getOutputStream().write(out.getBytes("UTF-8"));
    		} catch (Exception e) {
    		}
    	}
    
    	public void run() {
    		try {
    			BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream(), "UTF-8"));
    			String line = "";
    			while ((line = br.readLine()) != null) {
    				System.out.println(line);
    				ChatThreadManager.getChartManager().publish(this, line);
    			}
    			br.close();
    		} catch (Exception e) {
    			// TODO: handle exception
    		}
    	}
    }

ChatThreadManager.java

单例类，构造函数私有，管理多个ChatThread, 用于通知其他客户端

package com.chart;
    
    import java.util.Vector;
    
    public class ChatThreadManager {
    
    	private ChatThreadManager() {
    
    	}
    
    	private static final ChatThreadManager Cm = new ChatThreadManager();
    
    	public static ChatThreadManager getChartManager() {
    		return Cm;
    	}
    
    	Vector<ChatThread> ChatSocket_vector = new Vector<ChatThread>();
    
    	public void add(ChatThread cs) {
    		ChatSocket_vector.add(cs);
    	}
    
    	public void publish(ChatThread cs, String msg) {
    		for (int i = 0; i < ChatSocket_vector.size(); i++) {
    			ChatThread csTemp = ChatSocket_vector.get(i);
    			if (!cs.equals(csTemp)) {
    				csTemp.out(msg + "\n");
    			}
    		}
    	}
    }

*  客户端：

StartClient.java:

main 函数入口，新建主窗体，并显示

package com.client;
    
    import java.awt.EventQueue;
    
    import view.MyClientWindow;
    
    public class StartClient {
    
    	public static void main(String[] args) {
    	  EventQueue.invokeLater(new Runnable() {
    		
    		@Override
    		public void run() {
    			try {
    				MyClientWindow frame=new MyClientWindow();
    				frame.setVisible(true);
    				ConnectionManager.getChatManager().setWindow(frame);
    			}
    			catch (Exception e) {
    			}
    		}
    	});
    	}
    }

MyClientWindow.java:

继承JFrame,布局窗体，connect按钮执行建立连接事件，send按钮则往socket中写入发送信息

package view;
    
    import java.awt.event.MouseAdapter;
    import java.awt.event.MouseEvent;
    
    import javax.swing.GroupLayout;
    import javax.swing.GroupLayout.Alignment;
    import javax.swing.JButton;
    import javax.swing.JFrame;
    import javax.swing.JPanel;
    import javax.swing.JTextArea;
    import javax.swing.JTextField;
    import javax.swing.LayoutStyle.ComponentPlacement;
    import javax.swing.border.EmptyBorder;
    
    import com.client.ConnectionManager;
    
    public class MyClientWindow extends JFrame {
    
    	private static final long serialVersionUID = 1L;
    	private JPanel contentPane;
    	private JTextArea txt;
    	private JTextField txtip;
    	private JTextField txtSend;
    
    	public MyClientWindow() {
    		setAlwaysOnTop(true);
    		setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
    		setBounds(100, 100, 450, 300);
    		contentPane = new JPanel();
    		contentPane.setBorder(new EmptyBorder(5, 5, 5, 5));
    		setContentPane(contentPane);
    
    		txt = new JTextArea();
    		txt.setText("准备...");
    
    		txtip = new JTextField();
    		txtip.setText("120.254.12.102");
    		txtip.setColumns(10);
    
    		JButton btnConnect = new JButton("connect");
    		btnConnect.addMouseListener(new MouseAdapter() {
    			@Override
    			public void mouseClicked(MouseEvent e) {
    				ConnectionManager.getChatManager().connect(txtip.getText());
    			}
    		});
    
    		txtSend = new JTextField();
    		txtSend.setText("hello");
    		txtSend.setColumns(10);
    
    		JButton btnSend = new JButton("send");
    		btnSend.addMouseListener(new MouseAdapter() {
    			@Override
    			public void mouseClicked(MouseEvent e) {
    				ConnectionManager.getChatManager().send(txtSend.getText());
    				appendText("我说: " + txtSend.getText());
    				txtSend.setText("");
    			}
    		});
    		GroupLayout gl_contentPane = new GroupLayout(contentPane);
    
    		gl_contentPane.setHorizontalGroup(gl_contentPane.createParallelGroup(Alignment.LEADING).addGroup(
    				Alignment.TRAILING,
    				gl_contentPane.createSequentialGroup().addGroup(gl_contentPane.createParallelGroup(Alignment.TRAILING)
    						.addGroup(gl_contentPane.createSequentialGroup()
    								.addComponent(txtSend, GroupLayout.DEFAULT_SIZE, 325, Short.MAX_VALUE)
    								.addPreferredGap(ComponentPlacement.RELATED)
    								.addComponent(btnSend, GroupLayout.PREFERRED_SIZE, 109, GroupLayout.PREFERRED_SIZE))
    						.addGroup(Alignment.LEADING,
    								gl_contentPane.createSequentialGroup()
    										.addComponent(txtip, GroupLayout.PREFERRED_SIZE, 294,
    												GroupLayout.PREFERRED_SIZE)
    										.addPreferredGap(ComponentPlacement.RELATED)
    										.addComponent(btnConnect, GroupLayout.DEFAULT_SIZE, 140, Short.MAX_VALUE))
    						.addComponent(txt, GroupLayout.DEFAULT_SIZE, 434, Short.MAX_VALUE)).addContainerGap()));
    
    		gl_contentPane.setVerticalGroup(gl_contentPane.createParallelGroup(Alignment.LEADING)
    				.addGroup(gl_contentPane.createSequentialGroup()
    						.addGroup(gl_contentPane.createParallelGroup(Alignment.BASELINE)
    								.addComponent(txtip, GroupLayout.PREFERRED_SIZE, GroupLayout.DEFAULT_SIZE,
    										GroupLayout.PREFERRED_SIZE)
    								.addComponent(btnConnect))
    						.addPreferredGap(ComponentPlacement.RELATED)
    						.addComponent(txt, GroupLayout.DEFAULT_SIZE, 198, Short.MAX_VALUE)
    						.addPreferredGap(ComponentPlacement.RELATED)
    						.addGroup(gl_contentPane.createParallelGroup(Alignment.TRAILING).addComponent(btnSend)
    								.addComponent(txtSend, GroupLayout.PREFERRED_SIZE, GroupLayout.DEFAULT_SIZE,
    										GroupLayout.PREFERRED_SIZE))));
    
    		contentPane.setLayout(gl_contentPane);
    	}
    
    	/* 客户端发送的内容添加到中间的txt控件中 */
    	public void appendText(String in) {
    		txt.append("\n" + in);
    	}
    }

ConnectionManager.java

package com.client;
    
    import java.io.BufferedReader;
    import java.io.IOException;
    import java.io.InputStreamReader;
    import java.io.OutputStreamWriter;
    import java.io.PrintWriter;
    import java.net.Socket;
    import java.net.UnknownHostException;
    import view.MyClientWindow;
    
    public class ConnectionManager {
    	private ConnectionManager() {
    	}
    
    	private static final ConnectionManager instance = new ConnectionManager();
    
    	public static ConnectionManager getChatManager() {
    		return instance;
    	}
    
    	MyClientWindow window;// 为了能在界面上显示服务器发来的信息，就需要传一个MainWindow的引用进来
    	Socket socket;
    	private String IP;
    	BufferedReader bReader;
    	PrintWriter pWriter;
    
    	public void setWindow(MyClientWindow window) {
    		this.window = window;
    	}
    
    	public void connect(String ip) {
    		this.IP = ip;
    		new Thread() {
    			@Override
    			public void run() {
    				// 实现网络方法
    				try {
    					socket = new Socket(IP, 23456);
                        // 输出流 
    					pWriter = new PrintWriter(new OutputStreamWriter(socket.getOutputStream()));
    					// 输入流
    					bReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
    					String line = null;
    					// 如果读取数据为空
    					while ((line = bReader.readLine()) != null) {
    						window.appendText("收到： " + line);
    					}
    					// 读完数据之后要关闭
    					pWriter.close();
    					bReader.close();
    					pWriter = null;
    					bReader = null;
    				} catch (UnknownHostException e) {
    					e.printStackTrace();
    				} catch (IOException e) {
    					e.printStackTrace();
    				}
    			}
    		}.start();
    	}
    
    	public void send(String sendMsg) {
    		if (pWriter != null) {
    			pWriter.write(sendMsg + "\n");
    			pWriter.flush();
    		} else {
    			window.appendText("当前链接已经中断...");
    		}
    	}
    }

## ##

### 4.运行服务端程序： ###

1.把MainServerPro服务端程序导出成jar包

2.用xshell把jar包上传到linux

3.程序选用了23456端口，因为部署在阿里云的服务器上，所以要打开阿里云的端口限制

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3djYzI3ODU3Mjg1_size_16_color_FFFFFF_t_70][]

4.关闭centos7的防火墙

\# service firewalld status; \#查看防火墙状态

![Center][]

（disabled 表明 已经禁止开启启动 enable 表示开机自启，inactive 表示防火墙关闭状态 activated（running）表示为开启状态）

\# service firewalld start;  \#开启防火墙

\# service firewalld stop;  \#关闭防火墙

5.启动服务，运行MainServerPro.jar

有以下三种方式，选择第二种：java -jar xxxxx.jar &

java -jar xxxxx.jar  // 当前ssh窗口被锁定，可按CTRL + C打断程序运行，或直接关闭窗口，程序退出

java -jar xxxxx.jar &   //当前ssh窗口不被锁定，但是当窗口关闭时，程序中止运行。

nohup Java -jar xxxxxx.jar &  //不挂断运行命令,当账户退出或终端关闭时,程序仍然运行

6.最后启动客户端，进行聊天

在点击connect的时候出现报错：

Exception in thread "Thread-0" java.awt.HeadlessException:  No X11 DISPLAY variable was set, but this program performed an operation which requires it.

原因是因为服务端程序中有一句JOptionPane.showMessageDialog(null, "one client has connect to 12345 port");

在linux这种不支持图形界面的环境中 调用图形界面swing有关的代码时，会抛出异常。。。

解决方法很粗暴，直接把这句代码删掉

### 5.源代码下载 ###

[https://download.csdn.net/download/wcc27857285/10784144][https_download.csdn.net_download_wcc27857285_10784144]

[20181114111950531.gif]: /images/20220417/fdf54cf6f080438689d4e2cd16b77200.png
[20181114112121642.png]: /images/20220417/20bba869a5104f1aa88772da85b8e693.png
[20181114112214600.png]: /images/20220417/3f01ffcfb7664cdca824eaada801b278.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3djYzI3ODU3Mjg1_size_16_color_FFFFFF_t_70]: /images/20220417/740791ea03144c4c991c904fc35a4a44.png
[Center]: /images/20220417/2357059a291b4fae8a30379d5846416e.png
[https_download.csdn.net_download_wcc27857285_10784144]: https://download.csdn.net/download/wcc27857285/10784144