Java实现多人聊天室(含界面)
作者：Li~蒙奇 发布时间：2021-07-15 23:18:36
标签：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.addActionListener(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<MySocket> sockets;
public ServerThread(Socket socket, ArrayList<MySocket> 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<sockets.size();i++){//遍历sockets集合
if(socket==sockets.get(i).getSocket()){//判断当前发放信息的用户
user=sockets.get(i).getUser();//获取当前发放信息的用户名
}
}
for(int i=0;i<sockets.size();i++){
Socket sc=sockets.get(i).getSocket();//获取每个用户的socket
if(sc!=socket){//判断 不需要自己发信息给自己
OutputStream outputStream=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<MySocket> sockets=new ArrayList<MySocket>();//定义一个静态的集合里面的类型是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方法
}
}
}
运行结果：
先开服务器，再开客户端！
来源：https://blog.csdn.net/qq_51654332/article/details/121524290
0
投稿猜你喜欢
- Java * 。具体有如下四步骤：通过实现 InvocationHandler 接口创建自己的调用处理器；通过为 Proxy 类指定 C
Springmvc+hibernate成为现在很多人用的框架整合，最近自己也在学习摸索，由于我们在开发项目中很多项目都用到列表分页功能，在此- 本文所述为基于C#实现的端口扫描器代码，代码内包括了窗体和逻辑处理两部分代码。在代码中，创建TcpClient对象，把TcpClient用于
- 项目中用到用户定义运算公式进行就算的需求，这样需要进行字符串四则运算解析，下面提供字符串公式四则运算解析与计算工具类，需要的同学可参考。工具
- 注解注解为我们在代码中添加信息提供一种形式化的方法，使我们可以在源码、编译时、运行时非常方便的使用这些数据。注解是在JAVA SE5中引入的
- 比较适合新手。逻辑上仍然有点问题。可以用于学习java文件操作下载地址：http://yun.baidu.com/share/link?sh
- 该篇文章是说明在Android手机或平板电脑中如何实现截取当前屏幕的功能，并把截取的屏幕保存到SDCard中的某个目录文件夹下面。实现的代码
- 本文实例讲述了Android编程实现简单文件浏览器功能。分享给大家供大家参考，具体如下：运行效果：布局：<LinearLayout x
- struts2可以非常简单地使用FreeMarker模板作为视图技术，对于传统的jsp页面而言，FreeMarker是一个绝佳的替代方案。除
- 上篇给大家介绍了Spring Boot启动过程完全解析(一)，大家可以点击参考下该说refreshContext(context)了，首先是
- 导入后gradle building 一直到跑，卡住了，一般是gradle没有下载，又下不下来的原因。去 http://serv
- 托管资源指的是.NET可以自动进行回收的资源，主要是指托管堆上分配的内存资源。托管资源的回收工作是不需要人工干预的，有.NET运行库在合适调
- springboot加载yml文件获不到值今天使用spring boot读取yml文件，这种多层嵌套的竟然无法读取到(value注解spri
- 当我们在spring容器中添加一个bean时，如果没有指明它的scope属性，则默认是singleton，也就是单例的。例如先声明一个bea
- 本文实例讲述了Java二维数组。分享给大家供大家参考，具体如下：一 点睛1 每行的元素个数不同的二维数组Java定义二维数组更加灵活，允许二
- 本文实例讲述了C#操作注册表的方法。分享给大家供大家参考，具体如下：下面我们就来用.NET下托管语言C#注册表操作，主要内容包括：注册表项的
- 前几篇主要集中在注册中心eureka的使用上，接下来可以创建服务提供者provider来注册到eureka。demo源码见： https:/
- 本文实例总结了C#子线程更新UI控件的方法，对于桌面应用程序设计的UI界面控制来说非常有实用价值。分享给大家供大家参考之用。具体分析如下：一
- 1.登录腾讯云点击登录选择浏览器登录。输入用户名 按回车键 然后输入 密码。2.安装java环境直接命令：yum -y install ja
- 网上找了一些获取客户端IP的方法，但本地测试时，返回的是IPv6的表示方法"::1":Host文件里面：# &
