Java编写实现多人聊天室

更新时间：2022年09月15日 16:46:59 作者：java_zhangwei

这篇文章主要为大家详细介绍了Java编写实现多人聊天室，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下

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

1.客户端

package tk.javazhangwei.net.tcp.chat.Demo03;
 
import java.io.BufferedReader;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.Socket;
 
/***
 * 创建客户端  发送数据+接收数据
 * 
 * @author zw
 *
 */
public class Client {
    public static void main(String[] args) throws IOException {
        BufferedReader bf = new BufferedReader(new InputStreamReader(System.in));
        System.out.println("请输入一个喜欢的名称：");
        String name = bf.readLine();
        if(name.equals("")) {
            return;
        }
        
        Socket client = new Socket("localhost",1025);
        //控制台输入信息
        //控制台输入信息
        new Thread(new Send(client,name)).start();//一条路径
        new Thread(new Receive(client)).start();//一条路径
}
}

2.服务端（写了个内部类：负责接收与发送多进程）

package tk.javazhangwei.net.tcp.chat.Demo03;
 
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;
 
public class Server {
    List<myChannel> all = new ArrayList<myChannel>();
    
    
    
    public static void main(String[] args) throws IOException {
        new Server().start();
        
 
    }
    
    
    public void start() throws IOException {
        ServerSocket server = new ServerSocket(1025);
        while (true) {
            Socket socket = server.accept();
            myChannel mc = new myChannel(socket);
            Thread t = new Thread(mc);
            all.add(mc);
            t.start();
    }
}
 
 
/***
 * 一个客户端 一个通路
 * @author zw
 *
 */
class myChannel implements Runnable{
    private DataInputStream dis;
    private DataOutputStream dos;
    private boolean isRuning=true;
    private String name;
    
    public myChannel(Socket socket) throws IOException{
        try {
            dis = new DataInputStream(socket.getInputStream());
            dos = new DataOutputStream(socket.getOutputStream());
            this.name = dis.readUTF();
            send("欢迎进入聊天室");
            senOthers(this.name + "进入了聊天室");
        } catch (IOException e) {
            // TODO Auto-generated catch block
            //e.printStackTrace();
                isRuning=false;
                dos.close();
                dis.close();
                
        }
        
    }
    /***
     * 读取数据
     * 
     * @return
     * @throws IOException
     */
    private String receive() throws IOException {
        String msg ="";
        try {
            msg =dis.readUTF();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            //e.printStackTrace();
            isRuning=false;
            dis.close();
        
        }
        
        
        return msg;    
    }
    /***
     * 发送数据
     * @throws IOException 
     */
    private void send(String msg) throws IOException {
        if(msg==null&& msg.equals("")) {
            return;
        }
        try {
            dos.writeUTF(msg);
            dos.flush();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            //e.printStackTrace();
            isRuning=false;
            dos.close();
            all.remove(this);
        }
        
    }
    /***
     * 发送给其他客户端
     * @throws IOException 
     */
    private void senOthers(String msg) throws IOException {
        if (msg.startsWith("@")&&msg.indexOf(":")>-1) {// 表示为私聊
            //获取name
            String name = msg.substring(1, msg.indexOf(":"));
            String content = msg.substring(msg.indexOf(":")+1);//获取冒号后的正文
            for (myChannel others : all) {
                if(others.name.equals(name)) {
                    others.send(this.name+"对您瞧瞧的说："+content);
                }
                
            }
            
            
        } else {
        //遍历容器
        for(myChannel others:all) {
            if(others == this) {//如果是本身，就跳过
                continue;
            }
            others.send(this.name+"对所有人说："+msg);
        }
        }
    }
    
    @Override
    public void run() {
        while(isRuning) {
            try {
                senOthers(receive()) ;
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            
        }
        }
}
}

3.客户端的发送与接收多进程

package tk.javazhangwei.net.tcp.chat.Demo03;
 
import java.io.BufferedReader;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.Socket;
 
/***
 * 发送数据
 * 
 * @author zw
 *
 */
public class Send implements Runnable{
    //控制台输入流
    private BufferedReader console;
    //管道输出流
    private DataOutputStream dos;
    private String name;
    
    private boolean isRuning =true;//线程是否运行
    
    public Send() {
        console =new BufferedReader(new InputStreamReader(System.in));
    }
    
    public Send(Socket client,String name) throws IOException {
        this();
        try {
            dos = new DataOutputStream(client.getOutputStream());
            this.name = name;
            send(name);
        } catch (IOException e) {
            // TODO Auto-generated catch block
            //e.printStackTrace();
             isRuning =false;
             dos.close();
             console.close();
        }
    }
    private String getMsgFromConsole() {
        try {
            return console.readLine();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return "";
    }
 
    
@Override
    public void run() {
        
        while(isRuning) {
            try {
                send(getMsgFromConsole());
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
    }

 
    public void send(String msg) throws IOException {
        if (msg!=null && !msg.equals("")) {
            try {
                dos.writeUTF(msg);
                dos.flush();// 强制刷新
            } catch (IOException e) {
                // TODO Auto-generated catch block
                // e.printStackTrace();
                isRuning = false;
                dos.close();
                console.close();
 
            }
        }
    }
 
}

package tk.javazhangwei.net.tcp.chat.Demo03;
 
import java.io.DataInputStream;
import java.io.IOException;
import java.net.Socket;
 
/***
 * 接收数据
 * @author zw
 *
 */
public class Receive implements Runnable{
    //客户端的输入流
    private DataInputStream dis;
    private boolean isRuning = true;
    
    public Receive() {
    
    }
 
    public Receive(Socket client) {
        super();
        try {
            dis = new DataInputStream(client.getInputStream());
        } catch (IOException e) {
            // TODO Auto-generated catch block
            //e.printStackTrace();
            isRuning =false;
            try {
                dis.close();
            } catch (IOException e1) {
                // TODO Auto-generated catch block
                e1.printStackTrace();
            }
        }
    }
    /***
     * 接收数据
     * @return
     * @throws IOException 
     */
    public String receive() throws IOException {
        String msg = "";
        try {
            msg =dis.readUTF();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
            isRuning =false;
            dis.close();
        }
        
        return msg;
    }
    @Override
    public void run() {
        while(isRuning) {
            try {
                System.out.println(receive());
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
        
    }
 
}

4.效果

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。

您可能感兴趣的文章:

在SpringBoot项目中整合拦截器的详细步骤
在系统中经常需要在处理用户请求之前和之后执行一些行为,例如检测用户的权限,或者将请求的信息记录到日志中,即平时所说的"权限检测"及"日志记录",下面这篇文章主要给大家介绍了关于在SpringBoot项目中整合拦截器的相关资料,需要的朋友可以参考下
2022-09-09
Spring中Websocket身份验证和授权的实现
在Web应用开发中,安全一直是非常重要的一个方面,本文主要介绍了Spring中Websocket身份验证和授权的实现,具有一定的参考价值,感兴趣的可以了解一下
2023-08-08
tio-boot框架整合ehcache实现过程示例
这篇文章主要为大家介绍了tio-boot框架整合ehcache实现过程示例，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
2023-12-12
JAVA读取二进制文件以及画图教程
由于项目需要,需要对二进制文件进行读取,所以这篇文章主要给大家介绍了关于JAVA读取二进制文件以及画图的相关资料,文中通过实例代码介绍的非常详细,需要的朋友可以参考下
2023-07-07
Eclipse的Debug调试技巧大全（总结）
这篇文章主要介绍了Eclipse的Debug调试技巧大全（总结）,小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧
2017-12-12
深入浅析Java注解框架
这篇文章主要介绍了深入浅析Java注解框架的相关资料,介绍的非常详细，具有参考价值，需要的朋友参考下吧
2016-05-05
SpringBoot中加密模块的使用
本文主要介绍了SpringBoot中加密模块的使用，包括对称加密、非对称加密和哈希加密等，同时还会提供相应的代码示例，感兴趣的朋友可以参考一下
2023-05-05
关于Springboot+gateway整合依赖并处理依赖冲突问题
这篇文章主要介绍了Springboot+gateway整合依赖并处理依赖冲突问题,给大家提到了spring boot版本和spring cloud版本，本文通过实例代码给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
2022-01-01
Java中StringBuilder类的介绍与常用方法
StringBuilder是一个可变的字符串的操作类,我们可以把它看成是一个对象容器,下面这篇文章主要给大家介绍了关于Java中StringBuilder类的介绍与常用方法,文中通过示例代码介绍的非常详细,需要的朋友可以参考下
2022-12-12
SpringBoot集成Druid配置(yaml版本配置文件)详解
这篇文章主要介绍了SpringBoot集成Druid配置(yaml版本配置文件),本文通过实例代码给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
2020-12-12

Java编写实现多人聊天室

相关文章

最新评论

大家感兴趣的内容

最近更新的内容

常用在线小工具