Java实现多人聊天室(含界面)-eolink官网

Java实现多人聊天室(含界面)

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

先说，记录本人的学习过程，当笔记了

多人聊天室分为

1.服务器

①.while循环 (guanbo) 每连接一个用户就记录一个用户的属性。②.定义一个存储用户的类（ MySocket ）③.接收信息（ ServerThread ）并发给每一位用户不需要再次发给自己

2.客户机

①.线程（ Clithr ）接收数据添加到文本框。②.Swing（kefuduang）做界面。

代码如下：

先客户机吧简单点

import javax.swing.*;

import java.awt.*;

import java.awt.event.ActionEvent;

import java.io.*;

import java.net.Socket;

import java.time.DateTimeException;

class CilThr extends Thread{

Socket socket;

JTextArea ta;

public CilThr(Socket socket,JTextArea ta){//获取客户端的socket和文本区域

this.socket=socket;

this.ta=ta;

}

@Override

public void run() {

while (true){//一直在接收中

try {

InputStream inputStream=socket.getInputStream();//字节输入流

DataInputStream din=new DataInputStream(inputStream);//数据输入流

String text=din.readUTF();//获取输入的数据

ta.append(text);//添加到文本区域

} catch (IOException e) {

e.printStackTrace();

}

public class kefuduang {

JFrame jf;

JLabel jLabel;

JTextField tf1,tf2;

JButton start,send;

JTextArea ta;

Socket socket=new Socket("localhost",9000);//连接服务器需要的端口号9000

public kefuduang() throws IOException {

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

jLabel=new JLabel("用户名");

tf1=new JTextField(15);

tf2=new JTextField(35);

start=new JButton("连接");

send=new JButton("发送");

ta=new JTextArea(40,40);

init();//调用方法实现界面

}

public void init(){

JPanel jp1=new JPanel();

JPanel jp2=new JPanel();

JPanel jp3=new JPanel();

ta.setEditable(false);//让文本框不能输入，只是显示出来

send.setEnabled(false);//设置发送按钮，不能按，因为还没有连接上服务器

jp1.add(jLabel);

jp1.add(tf1);

jp1.add(start);

jp2.add(ta);

jp2.add(new jscrollPane(ta,JScrollPane.VERTICAL_SCROLLBAR_ALWAYS,JScrollPane.HORIZONTAL_SCROLLBAR_ALWAYS));//设置文本区域的滚动条

jp3.add(tf2);

jp3.add(send);

jf.add(jp1, BorderLayout.NORTH);//设置布局

jf.add(jp2,BorderLayout.CENTER);

jf.add(jp3,BorderLayout.SOUTH);

jf.setVisible(true);

jf.setLocationRelativeTo(null);

jf.setSize(500,500);

jf.setDefaultCloseOperation(JFrame.DISPOSE_ON_CLOSE);

handler();//添加按钮监听

new CilThr(socket,ta).start();//接收其他客户端发来的信息

}

private void handler() {

start.addActionListenehttp://r(new AbstractAction() {//连接

@Override

public void actionPerformed(ActionEvent e) {

//发起连接

String user= tf1.getText();//获取用户名

System.out.println(user+"发起连接请求");

try {

OutputStream outputStream=socket.getOutputStream();//字节输出流

DataOutputStream dout=new DataOutputStream(outputStream);//数据输出流

dout.writeUTF(user+" 加入聊天");//.writeUTF里的内容输出到文本里

ta.append(user+" 加入聊天"+"\n");//添加到显示的文本区域

send.setEnabled(true);//再设置“发送”按钮可以被点击

} catch (IOException ex) {

ex.printStackTrace();

}

//接收

}

});

send.addActionListener(new AbstractAction() {//“发送”按钮

@Override

public void actionPerformed(ActionEvent e) {

try {

OutputStream outputStream=socket.getOutputStream();//字节输出流

DataOutputStream dout=new DataOutputStream(outputStream);//数据输出流

String text=tf2.getText();//获取待发送文本框的内容

dout.writeUTF(text);//输出到文件

ta.append("我说： "+text+"\n");//添加到显示的文本区域

tf2.setText("");//设置下一次需要输入文本框的内容为空

} catch (IOException ex) {

ex.printStackTrace();

}

});

}

public static void main(String[] args) throws IOException {

new kefuduang(); //调用构造方法出界面

}

下面是服务器：

import java.io.*;

import java.net.ServerSocket;

import java.net.Socket;

import java.util.ArrayList;

import java.util.Date;

class ServerThread extends Thread{

Socket socket;

ArrayList sockets;

public ServerThread(Socket socket, ArrayList sockets) {//获取主函数传过来的值

this.socket=socket;

this.sockets=sockets;

}

@Override

public void run() {

while(true){//接收一个用户的多次发送信息

try {

InputStream inputStream=socket.getInputStream();//字节输入流

DataInputStream din=new DataInputStream(inputStream);//数据输入流

String text=din.readUTF();//获取输入的信息

String user="";//设置当前用户名为空，以防下一次赋值

for(int i=0;i

if(socket==sockets.get(i).getSocket()){//判断当前发放信息的用户

user=sockets.get(i).getUser();//获取当前发放信息的用户名

}

for(int i=0;i

Socket sc=sockets.get(i).getSocket();//获取每个用户的socket

if(sc!=socket){//判断不需要自己发信息给自己

OutputStream outpufoAEMmXJqtStream=sc.getOutputStream();//字节输出流

DataOutputStream dout=new DataOutputStream(outputStream);//数据输出流

dout.writeUTF(user+":"+text+"\n");//把当前客户端的名字和信息发送给除自己以外的其他客户端

}

} catch (IOException e) {

e.printStackTrace();

}

class MySocket{//把每一台客户端的socket 和用户名联系起来

private Socket socket;//客户端的socket

private String user;//客户名

public MySocket(Socket socket, String user) {

this.socket=socket;

this.user=user;

}

public Socket getSocket() {

return socket;

}

public void setSocket(Socket socket) {

this.socket = socket;

}

public String getUser() {

return user;

}

public void setUser(String user) {

this.user = user;

}

public class guanbo {

static ArrayList sockets=new ArrayList();//定义一个静态的集合里面的类型是class类 MySocket

public static void main(String[] args) throws IOException {

ServerSocket ss=new ServerSocket(9000);//服务器的端口号为9000

System.out.println("服务器准备就绪");

while(true){//收集每一次客户端的连接

Socket socket=ss.accept();

System.out.println("响应请求");

//每响应一个客户端就产生一个myscokcet

InputStream inputStream=socket.getInputStream();//字节输入流

DataInputStream din=new DataInputStream(inputStream);//数据输入流

String user=din.readUTF();//获取客户端的名称

user=user.substring(0,user.length()-4);//把客户端的名字获取，删除“加入聊天”

MySocket ms=new MySocket(socket,user);//把用户的名字和socket放到MyScket里

sockets.add(ms);//再添加到集合里，这样就可以保存每一个客户端的名字和socket

new ServerThread(socket,sockets).start();//启动线程把当前客户端的socket和加入到服务器的所有socket传到线程通过构造器，并开启线程run方法

}

运行结果：

先开服务器，再开客户端！

if(socket==sockets.get(i).getSocket()){//判断当前发放信息的用户

user=sockets.get(i).getUser();//获取当前发放信息的用户名

}

for(int i=0;i

Socket sc=sockets.get(i).getSocket();//获取每个用户的socket

if(sc!=socket){//判断不需要自己发信息给自己

OutputStream outpufoAEMmXJqtStream=sc.getOutputStream();//字节输出流

DataOutputStream dout=new DataOutputStream(outputStream);//数据输出流

dout.writeUTF(user+":"+text+"\n");//把当前客户端的名字和信息发送给除自己以外的其他客户端

}

} catch (IOException e) {

e.printStackTrace();

}

class MySocket{//把每一台客户端的socket 和用户名联系起来

private Socket socket;//客户端的socket

private String user;//客户名

public MySocket(Socket socket, String user) {

this.socket=socket;

this.user=user;

}

public Socket getSocket() {

return socket;

}

public void setSocket(Socket socket) {

this.socket = socket;

}

public String getUser() {

return user;

}

public void setUser(String user) {

this.user = user;

}

public class guanbo {

static ArrayList sockets=new ArrayList();//定义一个静态的集合里面的类型是class类 MySocket

public static void main(String[] args) throws IOException {

ServerSocket ss=new ServerSocket(9000);//服务器的端口号为9000

System.out.println("服务器准备就绪");

while(true){//收集每一次客户端的连接

Socket socket=ss.accept();

System.out.println("响应请求");

//每响应一个客户端就产生一个myscokcet

InputStream inputStream=socket.getInputStream();//字节输入流

DataInputStream din=new DataInputStream(inputStream);//数据输入流

String user=din.readUTF();//获取客户端的名称

user=user.substring(0,user.length()-4);//把客户端的名字获取，删除“加入聊天”

MySocket ms=new MySocket(socket,user);//把用户的名字和socket放到MyScket里

sockets.add(ms);//再添加到集合里，这样就可以保存每一个客户端的名字和socket

new ServerThread(socket,sockets).start();//启动线程把当前客户端的socket和加入到服务器的所有socket传到线程通过构造器，并开启线程run方法

}

运行结果：

先开服务器，再开客户端！

Socket sc=sockets.get(i).getSocket();//获取每个用户的socket

if(sc!=socket){//判断不需要自己发信息给自己

OutputStream outpufoAEMmXJqtStream=sc.getOutputStream();//字节输出流

DataOutputStream dout=new DataOutputStream(outputStream);//数据输出流

dout.writeUTF(user+":"+text+"\n");//把当前客户端的名字和信息发送给除自己以外的其他客户端

}

} catch (IOException e) {

e.printStackTrace();

}

class MySocket{//把每一台客户端的socket 和用户名联系起来

private Socket socket;//客户端的socket

private String user;//客户名

public MySocket(Socket socket, String user) {

this.socket=socket;

this.user=user;

}

public Socket getSocket() {

return socket;

}

public void setSocket(Socket socket) {

this.socket = socket;

}

public String getUser() {

return user;

}

public void setUser(String user) {

this.user = user;

}

public class guanbo {

static ArrayList sockets=new ArrayList();//定义一个静态的集合里面的类型是class类 MySocket

public static void main(String[] args) throws IOException {

ServerSocket ss=new ServerSocket(9000);//服务器的端口号为9000

System.out.println("服务器准备就绪");

while(true){//收集每一次客户端的连接

Socket socket=ss.accept();

System.out.println("响应请求");

//每响应一个客户端就产生一个myscokcet

InputStream inputStream=socket.getInputStream();//字节输入流

DataInputStream din=new DataInputStream(inputStream);//数据输入流

String user=din.readUTF();//获取客户端的名称

user=user.substring(0,user.length()-4);//把客户端的名字获取，删除“加入聊天”

MySocket ms=new MySocket(socket,user);//把用户的名字和socket放到MyScket里

sockets.add(ms);//再添加到集合里，这样就可以保存每一个客户端的名字和socket

new ServerThread(socket,sockets).start();//启动线程把当前客户端的socket和加入到服务器的所有socket传到线程通过构造器，并开启线程run方法

}

运行结果：

先开服务器，再开客户端！

SpringBoot实现扫码登录的示例代码

547 2022-07-24

Java实现多人聊天室(含界面)

Python入门之——getpass模块

SpringBoot实现扫码登录的示例代码

Python----抽象类的使用方法和使用场景（python运用场景）

推荐文章

接口调用是什么意思？几种常用接口调用方式

接口设计原则

8款在线 API 接口文档管理工具

api管理系统是什么？

什么是接口调试？接口调试的步骤有哪些？

api 接口管理系统有哪些？

接口测试有几种测试方法

API文档生成工具有哪些？

微服务和api网关区别

交换机配置步骤

最近发表

热评文章

在线接口文档管理工具推荐，支持在线测试，HTTP接口

开源的在线接口文档wiki工具Mindoc的介绍与使

如何优雅的进行接口设计？接口设计的六大原则是什么？

什么是API测试,api检测公司

软件接口设计怎么做？前后端分离软件接口设计思路

接口管理平台推荐，几大接口管理平台总有一款适合你！