Java Socket实现多人聊天系统-APISpace

Java Socket实现多人聊天系统

本文实例为大家分享了java Socket实现多人聊天系统的具体代码，供大家参考，具体内容如下

前言

github地址

开发环境：Eclipse Java 2019-06

注意：本项目只在单主机运行调试过，没试过在局域网和不同主机之间接发消息和文件（估计不行），有需要的自行查阅资料。

一、多人聊天系统

1.1 客户端

// Login.java

package exp5;

import java.awt.*;

import javax.swing.*;

public class Login {

JTextField textField = null;

JPasswordField pwdField = null;

ClientReadAndPrint.LoginListen listener=null;

// 构造函数

public Login() {

init();

}

void init() {

JFrame jf = new JFrame("登录");

jf.setBounds(500, 250, 310, 210);

jf.setResizable(false); // 设置是否缩放

JPanel jp1 = new JPanel();

JLabel headJLabel = new JLabel("登录界面");

headJLabel.setFont(new Font(null, 0, 35)); // 设置文本的字体类型、样式和大小

jp1.add(headJLabel);

JPanel jp2 = new JPanel();

JLabel nameJLabel = new JLabel("用户名：");

textField = new JTextField(20);

JLabel pwdJLabel = new JLabel("密码： ");

pwdField = new JPasswordField(20);

JButton loginButton = new JButton("登录");

JButton registerButton = new JButton("注册"); // 没设置功能

jp2.add(nameJLabel);

jp2.add(textField);

jp2.add(pwdJLabel);

jp2.add(pwdField);

jp2.add(loginButton);

jp2.add(registerButton);

JPanel jp = new JPanel(new BorderLayout()); // BorderLayout布局

jp.add(jp1, BorderLayout.NORTH);

jp.add(jp2, BorderLayout.CENTER);

// 设置监控

listener = new ClientReadAndPrint().new LoginListen(); // 新建监听类

listener.setJTextField(textField); // 调用PoliceListen类的方法

listener.setJPasswordField(pwdField);

listener.setJFrame(jf);

pwdField.addActionListener(listener); // 密码框添加监听

loginButton.addActionListener(listener); // 按钮添加监听

jf.add(jp);

jf.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE); // 设置关闭图标作用

jf.setVisible(true); // 设置可见

}

ChatView.java：登录成功后的个人聊天界面

// ChatView.java

package exp5;

import java.awt.event.ActionEvent;

import java.awt.event.ActionListener;

import java.io.File;

import javax.swing.*;

import javax.swing.filechooser.FileNameExtensionFilter;

public class ChatView {

String userName; //由客户端登录时设置

JTextField text;

JTextArea textArea;

ClientReadAndPrint.ChatViewListen listener;

// 构造函数

public ChatView(String userName) {

this.userName = userName ;

init();

}

// 初始化函数

void init() {

JFrame jf = new JFrame("客户端");

jf.setBounds(500,200,400,330); //设置坐标和大小

jf.setResizable(false); // 缩放为不能缩放

JPanel jp = new JPanel();

JLabel lable = new JLabel("用户：" + userName);

textArea = new JTextArea("***************登录成功，欢迎来到多人聊天室！****************\n",12, 35);

textArea.setEditable(false); // 设置为不可修改

jscrollPane scroll = new JScrollPane(textArea); // 设置滚动面板（装入textArea）

scroll.setVerticalScrollBarPolicy(JScrollPane.VERTICAL_SCROLLBAR_ALWAYS); // 显示垂直条

jp.add(lable);

jp.add(scroll);

text = new JTextField(20);

JButton button = new JButton("发送");

JButton openFileBtn = new JButton("发送文件");

jp.add(text);

jp.add(button);

jp.add(openFileBtn);

// 设置“打开文件”监听

openFileBtn.addActionListener(new ActionListener() {

public void actionPerformed(ActionEvent e) {

showFileOpenDialog(jf);

}

});

// 设置“发送”监听

listener = new ClientReadAndPrint().new ChatViewListen();

listener.setJTextField(text); // 调用PoliceListen类的方法

listener.setJTextArea(textArea);

listener.setChatViewJf(jf);

text.addActionListener(listener); // 文本框添加监听

button.addActionListener(listener); // 按钮添加监听

jf.add(jp);

jf.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE); // 设置右上角关闭图标的作用

jf.setVisible(true); // 设置可见

}

// “打开文件”调用函数

void showFileOpenDialog(JFrame parent) {

// 创建一个默认的文件选择器

JFileChooser fileChooser = new JFileChooser();

// 设置默认显示的文件夹

fileChooser.setCurrentDirectory(new File("C:/Users/Samven/Desktop"));

// 添加可用的文件过滤器（FileNameExtensionFilter 的第一个参数是描述, 后面是需要过滤的文件扩展名）

// fileChooser.addChoosableFileFilter(new FileNameExtensionFilter("(txt)", "txt"));

// 设置默认使用的文件过滤器（FileNameExtensionFilter 的第一个参数是描述, 后面是需要过滤的文件扩展名可变参数）

fileChooser.setFileFilter(new FileNameExtensionFilter("(txt)", "txt"));

// 打开文件选择框（线程将被堵塞，知道选择框被关闭）

int result = fileChooser.showOpenDialog(parent); // 对话框将会尽量显示在靠近 parent 的中心

// 点击确定

if(result == JFileChooser.APPROVE_OPTION) {

// 获取路径

File file = fileChooser.getSelectedFile();

String path = file.getAbsolutePath();

ClientFileThread.outFileToServer(path);

}

Client.java：客户端

// Client.java

package exp5;

import java.net.*;

import javax.swing.*;

import java.awt.event.*;

import java.io.*;

public class Client {

// 主函数，新建登录窗口

public static void main(String[] args) {

new Login();

}

/**

* 负责客户端的读和写，以及登录和发送的监听

* 之所以把登录和发送的监听放在这里，是因为要共享一些数据，比如mySocket,textArea

class ClientReadAndPrint extends Thread{

static Socket mySocket = null; // 一定要加上static，否则新建线程时会清空

static JTextField textInput;

static JTextArea textShow;

static JFrame chatViewJFrame;

static BufferedReader in = null;

static PrintWriter out = null;

static String userName;

// 用于接收从服务端发送来的消息

public void run() {

try {

in = new BufferedReader(new InputStreamReader(mySocket.getInputStream())); // 输入流

while (true) {

String str = in.readLine(); // 获取服务端发送的信息

textShow.append(str + '\n'); // 添加进聊天客户端的文本区域

textShow.setCaretPosition(textShow.getDocument().getLength()); // 设置滚动条在最下面

http://}

} catch (Exception e) {}

}

/**********************登录监听(内部类)**********************/

class LoginListen implements ActionListener{

JTextField textField;

JPasswordField pwdField;

JFrame loginJFrame; // 登录窗口本身

ChatView chatView = null;

public void setJTextField(JTextField textField) {

this.textField = textField;

}

public void setJPasswordField(JPasswordField pwdField) {

this.pwdField = pwdField;

}

public void setJFrame(JFrame jFrame) {

this.loginJFrame = jFrame;

}

public void actionPerformed(ActionEvent event) {

userName = textField.getText();

String userPwd = String.valueOf(pwdField.getPassword()); // getPassword方法获得char数组

if(userName.length() >= 1 && userPwd.equals("123")) { // 密码为123并且用户名长度大于等于1

chatView = new ChatView(userName); // 新建聊天窗口,设置聊天窗口的用户名（静态）

// 建立和服务器的联系

try {

InetAddress addr = InetAddress.getByName(null); // 获取主机地址

mySocket = new Socket(addr,8081); // 客户端套接字

loginJFrame.setVisible(false); // 隐藏登录窗口

out = new PrintWriter(mySocket.getOutputStream()); // 输出流

out.println("用户【" + userName + "】进入聊天室！"); // 发送用户名给服务器

out.flush(); // 清空缓冲区out中的数据

} catch (IOException e) {

e.printStackTrace();

}

// 新建普通读写线程并启动

ClientReadAndPrint readAndPrint = new ClientReadAndPrint();

readAndPrint.start();

// 新建文件读写线程并启动

ClientFileThread fileThread = new ClientFileThread(userName, chatViewJFrame, out);

fileThread.start();

}

else {

JOptionPane.showMessageDialog(loginJFrame, "账号或密码错误，请重新输入！", "提示", JOptionPane.WARNING_MESSAGE);

}

/**********************聊天界面监听(内部类)**********************/

class ChatViewListen implements ActionListener{

public void setJTextField(JTextField text) {

textInput = text; // 放在外部类，因为其它地方也要用到

}

public void setJTextArea(JTextArea textArea) {

textShow = textArea; // 放在外部类，因为其它地方也要用到

}

public void setChatViewJf(JFrame jFrame) {

chatViewJFrame = jFrame; // 放在外部类，因为其它地方也要用到

// 设置关闭聊天界面的监听

chatViewJFrame.addWindowListener(new WindowAdapter() {

public void windowClosing(WindowEvent e) {

out.println("用户【" + userName + "】离开聊天室！");

out.flush();

System.exit(0);

}

});

}

// 监听执行函数

public void actionPerformed(ActionEvent event) {

try {

String str = textInput.getText();

// 文本框内容为空

if("".equals(str)) {

textInput.grabFocus(); // 设置焦点（可行）

// 弹出消息对话框（警告消息）

JOptionPane.showMessageDialog(chatViewJFrame, "输入为空，请重新输入！", "提示", JOptionPane.WARNING_MESSAGE);

return;

}

out.println(userName + "说：" + str); // 输出给服务端

out.flush(); // 清空缓冲区out中的数据

textInput.setText(""); // 清空文本框

textInput.grabFocus(); // 设置焦点（可行）

// textInput.requestFocus(true); // 设置焦点（可行）

} catch (Exception e) {}

}

ClientFileThread.java：文件传输功能（客户端）

// ClientFileThread.java

package exp5;

import java.io.*;

import java.net.*;

import javax.swing.*;

public class ClientFileThread extends Thread{

private Socket socket = null;

private JFrame chatViewJFrame = null;

static String userName = null;

static PrintWriter out = null; // 普通消息的发送（Server.java传来的值）

static DataInputStream fileIn = null;

static DataOutputStream fileOut = null;

static DataInputStream fileReader = null;

static DataOutputStream fileWriter = null;

public ClientFileThread(String userName, JFrame chatViewJFrame, PrintWriter out) {

ClientFileThread.userName = userName;

this.chatViewJFrame = chatViewJFrame;

ClientFileThread.out = out;

}

// 客户端接收文件

public void run() {

try {

InetAddress addr = InetAddress.getByName(null); // 获取主机地址

socket = new Socket(addr, 8090); // 客户端套接字

fileIn = new DataInputStream(socket.getInputStream()); // 输入流

fileOut = new DataOutputStream(socket.getOutputStream()); // 输出流

// 接收文件

while(true) {

String textName = fileIn.readUTF();

long totleLength = fileIn.readLong(http://);

int result = JOptionPane.showConfirmDialog(chatViewJFrame, "是否接受？", "提示",

JOptionPane.YES_NO_OPTION);

int length = -1;

byte[] buff = new byte[1024];

long curLength = 0;

// 提示框选择结果，0为确定，1位取消

if(result == 0){

// out.println("【" + userName + "选择了接收文件！】");

// out.flush();

File userFile = new File("C:\\Users\\Samven\\Desktop\\接受文件\\" + userName);

if(!userFile.exists()) { // 新建当前用户的文件夹

userFile.mkdir();

}

File file = new File("C:\\Users\\Samven\\Desktop\\接受文件\\" + userName + "\\"+ textName);

fileWriter = new DataOutputStream(new FileOutputStream(file));

while((length = fileIn.read(buff)) > 0) { // 把文件写进本地

fileWriter.write(buff, 0, length);

fileWriter.flush();

curLength += length;

// out.println("【接收进度:" + curLength/tonBGpdYChtleLength*100 + "%】");

// out.flush();

if(curLength == totleLength) { // 强制结束

break;

}

out.println("【" + userName + "接收了文件！】");

out.flush();

// 提示文件存放地址

JOptionPane.showMessageDialog(chatViewJFrame, "文件存放地址：\n" +

"C:\\Users\\Samven\\Desktop\\接受文件\\" +

userName + "\\" + textName, "提示", JOptionPane.INFORMATION_MESSAGE);

}

else { // 不接受文件

while((length = fileIn.read(buff)) > 0) {

curLength += length;

if(curLength == totleLength) { // 强制结束

break;

}

fileWriter.close();

}

} catch (Exception e) {}

}

// 客户端发送文件

static void outFileToServer(String path) {

try {

File file = new File(path);

fileReader = new DataInputStream(new FileInputStream(file));

fileOut.writeUTF(file.getName()); // 发送文件名字

fileOut.flush();

fileOut.writeLong(file.length()); // 发送文件长度

fileOut.flush();

int length = -1;

byte[] buff = new byte[1024];

while ((length = fileReader.read(buff)) > 0) { // 发送内容

fileOut.write(buff, 0, length);

fileOut.flush();

}

out.println("【" + userName + "已成功发送文件！】");

out.flush();

} catch (Exception e) {}

}

1.2 服务器端

MultiChat.java：多人聊天系统界面（服务器端）

// MultiChat.java

package exp5;

import java.awt.event.WindowAdapter;

import java.awt.event.WindowEvent;

import javax.swing.*;

public class MultiChat {

JTextArea textArea;

// 用于向文本区域添加信息

void setTextArea(String str) {

textArea.append(str+'\n');

textArea.setCaretPosition(textArea.getDocument().getLength()); // 设置滚动条在最下面

}

// 构造函数

public MultiChat() {

init();

}

void init() {

JFrame jf = new JFrame("服务器端");

jf.setBounds(500,100,450,500); // 设置窗口坐标和大小

jf.setResizable(false); // 设置为不可缩放

JPanel jp = new JPanel(); // 新建容器

JLabel lable = new JLabel("==欢迎来到多人聊天系统（服务器端）==");

textArea = new JTextArea(23, 38); // 新建文本区域并设置长宽

textArea.setEditable(false); // 设置为不可修改

JScrollPane scroll = new JScrollPane(textArea); // 设置滚动面板（装入textArea）

scroll.setVerticalScrollBarPolicy(ScrollPaneConstants.VERTICAL_SCROLLBAR_ALWAYS); // 显示垂直条

jp.add(lable);

jp.add(scroll);

jf.addWindowListener(new WindowAdapter() {

public void windowClosing(WindowEvent e) {

System.exit(0);

}

});

jf.add(jp);

jf.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE); // 设置关闭图标作用

jf.setVisible(true); // 设置可见

}

Server.java：服务器端

// Server.java

package exp5;

import java.io.*;

import java.net.*;

import java.util.*;

public class Server{

static ServerSocket server = null;

static Socket socket = null;

static List list = new ArrayList(); // 存储客户端

public static void main(String[] args) {

MultiChat multiChat = new MultiChat(); // 新建聊天系统界面

try {

// 在服务器端对客户端开启文件传输的线程

ServerFileThread serverFileThread = new ServerFileThread();

serverFileThread.start();

server = new ServerSocket(8081); // 服务器端套接字（只能建立一次）

// 等待连接并开启相应线程

while (true) {

socket = server.accept(); // 等待连接

list.add(socket); // 添加当前客户端到列表

// 在服务器端对客户端开启相应的线程

ServerReadAndPrint readAndPrint = new ServerReadAndPrint(socket, multiChat);

readAndPrint.start();

}

} catch (IOException e1) {

e1.printStackTrace(); // 出现异常则打印出异常的位置

}

/**

* 服务器端读写类线程

* 用于服务器端读取客户端的信息，并把信息发送给所有客户端

class ServerReadAndPrint extends Thread{

Socket nowSocket = null;

MultiChat multiChat = null;

BufferedReader in =null;

PrintWriter out = null;

// 构造函数

public ServerReadAndPrint(Socket s, MultiChat multiChat) {

this.multiChat = multiChat; // 获取多人聊天系统界面

this.nowSocket = s; // 获取当前客户端

}

public void run() {

try {

in = new BufferedReader(new InputStreamReader(nowSocket.getInputStream())); // 输入流

// 获取客户端信息并把信息发送给所有客户端

while (true) {

String str = in.readLine();

// 发送给所有客户端

for(Socket socket: Server.list) {

out = new PrintWriter(socket.getOutputStream()); // 对每个客户端新建相应的socket套接字

if(socket == nowSocket) { // 发送给当前客户端

out.println("(你)" + str);

}

else { // 发送给其它客户端

out.println(str);

}

out.flush(); // 清空out中的缓存

}

// 调用自定义函数输出到图形界面

multiChat.setTextArea(str);

}

} catch (Exception e) {

Server.list.remove(nowSocket); // 线程关闭，移除相应套接字

}

ServerFileThread.java：文件传输功能（服务器端）

// ServerFileThread.java

package exp5;

import java.io.*;

import java.net.*;

import java.util.ArrayList;

import java.util.List;

public class ServerFileThread extends Thread{

ServerSocket server = null;

Socket socket = null;

static List list = new ArrayList(); // 存储客户端

public void run() {

try {

server = new ServerSocket(8090);

while(true) {

socket = server.accept();

list.add(socket);

// 开启文件传输线程

FileReadAndWrite fileReadAndWrite = new FileReadAndWrite(socket);

fileReadAndWrite.start();

}

} catch (IOException e) {

e.printStackTrace();

}

class FileReadAndWrite extends Thread {

private Socket nowSocket = null;

private DataInputStream input = null;

private DataOutputStream output = null;

public FileReadAndWrite(Socket socket) {

this.nowSocket = socket;

}

public void run() {

try {

input = new DataInputStream(nowSocket.getInputStream()); // 输入流

while (true) {

// 获取文件名字和文件长度

String textName = input.readUTF();

long textLength = input.readLong();

// 发送文件名字和文件长度给所有客户端

for(Socket socket: ServerFileThread.list) {

output = new DataOutputStream(socket.getOutputStream()); // 输出流

if(socket != nowSocket) { // 发送给其它客户端

output.writeUTF(textName);

output.flush();

output.writeLong(textLength);

output.flush();

}

// 发送文件内容

int length = -1;

long curLength = 0;

byte[] buff = new byte[1024];

while ((length = input.read(buff)) > 0) {

curLength += length;

for(Socket socket: ServerFileThread.list) {

output = new DataOutputStream(socket.getOutputStream()); // 输出流

if(socket != nowSocket) { // 发送给其它客户端

output.write(buff, 0, length);

output.flush();

}

if(curLength == textLength) { // 强制退出

break;

}

} catch (Exception e) {

ServerFileThread.list.remove(nowSocket); // 线程关闭，移除相应套接字

}

二、运行效果

2.1 初始化

服务器端（先运行Server.java）

登录界面（接着运行Client.java，运行一次生成一个登录界面）

这里我还没有实现注册功能，登录的用户名随意（不为空即可），密码是123。

2.2 登录成功

2.3 发送信息

2.4 发送文件

打开文件我设置了默认路径是在桌面。接受文件需要先在桌面创建一个名为“接受文件”的文件夹，用于存放所有用户接收的文件。

如果出现无法发送文件，应该是ClientFileThread.java那里的路径问题，路径包括了电脑用户的名字，比如我的是“Samven”，可以试试修改为自己的真实路径。

c语言sscanf函数的用法是什么

324 2022-12-27

Java Socket实现多人聊天系统

c语言sscanf函数的用法是什么

r语言清空数组的方法是什么

linux怎么查看本机内存大小

推荐文章

api接口有哪几种分类及功能

什么是API接口?API接口简单介绍

短信API接口概述，短信API接口的优势

7款快递物流的物流查询API工具，物流快递查询API接口怎么对接？

企业四要素: 了解企业经营成功的关键

什么是语音验证码?,语音验证码平台有哪些

全国工商查询系统怎么查企业名录

哪些平台提供实名认证的接口？

PHP如何调用API接口?

如何使用百度天气预报API接口?

最近发表

热评文章

数据接口api（数据接口API开发平台）

数据开放接口api（数据服务api开发）

Python爬虫教程：爬取酷狗音乐（python爬取

hbuilder怎么更改字体大小和颜色

直播平台api接口 - 构建卓越的直播平台

实时股票数据api接口（股票实时行情api接口）