广告

扫码关注官方微信

扫码下载APP
返回顶部
首页 > 资讯 > 后端开发 > Python >Java基于Socket实现多人聊天室
  • 853

0
分享到

Java基于Socket实现多人聊天室

2024-04-02 19:04:59 853人浏览 安东尼

Python 官方文档：入门教程 => 点击学习

摘要

本文实例为大家分享了Java基于Socket实现简易版多人聊天室的具体代码，供大家参考，具体内容如下 一、 聊天室需求 1、一个服务端，多个客户端；2、实现客户端和服务端的交互；3、

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

一、 聊天室需求

1、一个服务端，多个客户端；
2、实现客户端和服务端的交互；
3、客户端发送信息，服务端收到信息，再转发给其他客户端；
4、上下线时显示哪个客户端上下线并且显示在线客户端数量；

二、代码分析

1. 建立连接

客户端类，创建发送端Socket对象，用自己的IP地址和端口号，与服务端建立连接。

class Client:

//用于与服务端通信的Socket
private Socket socket;

public Client() throws Exception {
    
    try {
        System.out.println("正在连接服务器......");
        //localhost 127.0.0.1
        socket = new Socket("LAPTOP-TCK59O6Q",8888);
        System.out.println("与服务端连接完毕");
    } catch (Exception e) {
        System.out.println("初始化失败");
        throw e;
    }
} 

服务端类，使用构造方法初始化服务端，创建接收端的Socket对象

class Server:

private ServerSocket server;

//构造方法初始化服务端
public Server() throws IOException {
    //实例化serverSocket的同时，指定服务端的端口号；
    try {
        server = new ServerSocket(8888);
        allOut = new ArrayList<PrintWriter>();
    } catch (Exception e) {
        System.out.println("服务端初始化失败");
        throw e;
    }
}

2. 客户端发送信息

在客户端的类中写一个start()方法，start()是客户端发送信息给服务端的方法
获取输出流对象，把键盘录入的信息发送到服务端。

class Client:

public void start() throws Exception {
    
    try {
        //启动用于读取服务端发送消息的线程
        ServerHandler handler = new ServerHandler();
        //ServerHandler是自己写的类，实现Runnable接口,有多线程功能
        Thread t = new Thread(handler);
        t.start();
        
        //将数据发送到服务端
        OutputStream out = socket.getOutputStream();//获取输出流对象
        OutputStreamWriter osw = new OutputStreamWriter(out,"utf-8");//转化成utf-8格式
        PrintWriter pw = new PrintWriter(osw,true);
        Scanner scan = new Scanner(System.in);
        while(true) {
            String message = scan.nextLine();//得到键盘录入的信息
            pw.println(message);//把信息输出到服务端
        }
        
    } catch (Exception e) {
        System.out.println("客户端运行失败");
        throw e;
    } 
    
}

服务端工作的start()方法，accept()方法与客户端连接上

class Server:

//服务端工作的方法
public void start() throws IOException {
    
    while(true) {
        System.out.println("等待客户端连接...");
        Socket socket = server.accept();
        System.out.println("一个客户端连接了！");
        //启动一个线程来处理客户端的交互工作
        ClientHandler hander = new ClientHandler(socket);
        Thread t = new Thread(hander);
        t.start();
    }
}

3. 开启多线程、服务端接收读取信息并广播

因为服务端与多个客户端相连，所以要用多线程，即一个客户端用一条线程。

在服务端类中创建一个内部类ClientHandler实现Runnable接口并重写run()方法创建线程
属性有客户端的Socket对象
有参构造方法中通过客户端的Socket获取到其地址host，并且把地址打印出来
这样在main()方法中，实例化服务端类的对象之后，start方法开启服务端，当有客户端连接上时，就能输出这个客户端的ip地址。

ClientHandler类要重写run()方法，使用输入流InputStream读取客户端发来的信息，再使用输出流OutputStream给所有客户端广播收到的信息、用户上下线和在线人数

class Server:


class ClientHandler implements Runnable{
    //当前线程客户端的Socket
    private Socket socket;
    
    //该客户端的地址
    private String host;
    
    public ClientHandler(Socket socket) {
        this.socket=socket;
        
        InetAddress address = socket.getInetAddress();
        
        //获取ip地址
        host = address.getHostAddress();
        System.out.println("host"+host);
    }

    @Override
    public void run() {
        PrintWriter pw = null;
        try {
            //广播给所有客户端，当前用户上线了
            sendMessage("["+host+"]上线了");
            OutputStream out = socket.getOutputStream();
            OutputStreamWriter osw = new OutputStreamWriter(out,"UTF-8");
            pw = new PrintWriter(osw,true);

            //将该客户的输出流存入共享集合，以便消息可以广播给该客户端
            addOut(pw);
            
            //广播当前在线人数
            sendMessage("当前在线人数["+allOut.size()+"]");
            
            //处理来自客户端的数据
            InputStream in = socket.getInputStream();
            InputStreamReader isr = new InputStreamReader(in,"utf-8");
            BufferedReader br = new BufferedReader(isr);
            
            String message = null;
            while((message = br.readLine())!=null) {
                sendMessage(host+"说："+message);
            }
            
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }finally {
            //将该客户端的输出流从共享集合中删除
            removeOut(pw);
            
            //广播给所有客户端，当前用户下线
            sendMessage("["+host+"]下线了");
            
            //广播当前在线人数
            sendMessage("当前在线人数["+allOut.size()+"]");
            
            try {
                socket.close();
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
    }
}

因此服务端类中要写一个sendMessage()方法，为了在接收到一个客户端的信息后，把这个信息转发给所有客户端，这就是广播的效果。
写一个集合allOut，用来存放所有客户端的输出流，客户端的数量就是集合里元素的个数
再写两个方法，一个是addOut()方法把上线客户端的输出流放进集合（在run方法中使用addOut()，获取到启用新线程的客户端的输出流，把输出流加到集合中），
另一个是removeOut()方法拿出集合（同理run()方法中使用，把socket关闭的客户端的输出流移除集合）。

所以sendMessage()方法的参数就是某个客户端发的字符串信息message，遍历allOut集合，把message在每个输出流中打印，用PrintWrite类中的print方法。
当客户端连接服务端时，sendMessage()方法打印这个服务端的地址加上上线了，同理客户端关闭socket的时候打印下线了，
同时上下线后再打印allOut集合的大小，也就是当前连接服务端的客户端数量，就是在线人数。

class Server:

//存放所有客户端的输出流的集合，用于广播
private List<PrintWriter> allOut;

//将给定的输出流放入共享集合
private synchronized void addOut(PrintWriter out){
    allOut.add(out);
}

//将给定的输出流移除共享集合
private synchronized void removeOut(PrintWriter out){
    allOut.remove(out);
}

//将给定的消息发给多个客户端
private synchronized void sendMessage(String message) {
    
    for(PrintWriter out:allOut) {
        out.println(message);
    }
}

4. 客户端读取信息

这个时候所有的客户端都收到了某个客户发的消息，但是还没读，所以客户端类中要加输入流才能读取，
创建ServerHandler类实现Runnable接口，输入流读取并输出。

class Client:

class ServerHandler implements Runnable{
    
    @Override
    public void run() {
        try {
            InputStream in = socket.getInputStream();//输入流
            InputStreamReader isr = new InputStreamReader(in,"UTF-8");//以utf-8读
            BufferedReader br = new BufferedReader(isr);
            String message = null;
            while((message=br.readLine())!=null) {
                System.out.println(message);
            }
        } catch (Exception e) {
            e.printStackTrace();
        } 
    }
}

三、完整代码

1. 客户端

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.io.UnsupportedEncodingException;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.Scanner;


public class Client {
    
    //用于与服务端通信的Socket
    private Socket socket;
    
    public Client() throws Exception {
        
        try {
            System.out.println("正在连接服务器......");
            //localhost 127.0.0.1
            socket = new Socket("LAPTOP-TCK59O6Q",8888);
            System.out.println("与服务端连接完毕");
        } catch (Exception e) {
            System.out.println("初始化失败");
            throw e;
        }
    }
    
    public void start() throws Exception {
        
        try {
            //启动用于读取服务端发送消息的线程
            ServerHandler handler = new ServerHandler();
            //ServerHandler是自己写的类，实现Runnable接口,有多线程功能
            Thread t = new Thread(handler);
            t.start();
            
            //将数据发送到服务端
            OutputStream out = socket.getOutputStream();//获取输出流对象
            OutputStreamWriter osw = new OutputStreamWriter(out,"utf-8");//转化成utf-8格式
            PrintWriter pw = new PrintWriter(osw,true);
            Scanner scan = new Scanner(System.in);
            while(true) {
                String message = scan.nextLine();//得到键盘录入的信息
                pw.println(message);//把信息输出到服务端
            }
            
        } catch (Exception e) {
            System.out.println("客户端运行失败");
            throw e;
        } 
        
    }

    public static void main(String[] args) throws Exception {
        
        try {
            Client client = new Client();
            client.start();
        } catch (Exception e) {
            System.out.println("客户端运行失败");
            e.printStackTrace();
        }
        

    }
    
    class ServerHandler implements Runnable{
        
        @Override
        public void run() {
            try {
                InputStream in = socket.getInputStream();//输入流
                InputStreamReader isr = new InputStreamReader(in,"UTF-8");//以utf-8读
                BufferedReader br = new BufferedReader(isr);
                String message = null;
                while((message=br.readLine())!=null) {
                    System.out.println(message);
                }
            } catch (Exception e) {
                e.printStackTrace();
            } 
        }
    }
    

}

2. 服务端

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.io.UnsupportedEncodingException;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;


public class Server {
    
    private ServerSocket server;
    
    //存放所有客户端的输出流的集合，用于广播
    private List<PrintWriter> allOut;
    
    //将给定的输出流放入共享集合
    private synchronized void addOut(PrintWriter out){
        allOut.add(out);
    }
    
    //将给定的输出流移除共享集合
    private synchronized void removeOut(PrintWriter out){
        allOut.remove(out);
    }
    
    //将给定的消息发给多个客户端
    private synchronized void sendMessage(String message) {
        
        for(PrintWriter out:allOut) {
            out.println(message);
        }
    }
    
    //构造方法初始化服务端
    public Server() throws IOException {
        //实例化serverSocket的同时，指定服务端的端口号；
        try {
            server = new ServerSocket(8888);
            allOut = new ArrayList<PrintWriter>();
        } catch (Exception e) {
            System.out.println("服务端初始化失败");
            throw e;
        }
    }
    
    //服务端工作的方法
    public void start() throws IOException {
        
        while(true) {
            System.out.println("等待客户端连接...");
            Socket socket = server.accept();
            System.out.println("一个客户端连接了！");
            //启动一个线程来处理客户端的交互工作
            ClientHandler hander = new ClientHandler(socket);
            Thread t = new Thread(hander);
            t.start();
        }
    }
    
    
    public static void main(String[] args) throws Exception {
        Server server = new Server();
        server.start();
    }
    
    
    class ClientHandler implements Runnable{
        //当前线程客户端的Socket
        private Socket socket;
        
        //该客户端的地址
        private String host;
        
        public ClientHandler(Socket socket) {
            this.socket=socket;
            
            InetAddress address = socket.getInetAddress();
            
            //获取ip地址
            host = address.getHostAddress();
            System.out.println("host"+host);
        }

        @Override
        public void run() {
            PrintWriter pw = null;
            try {
                //广播给所有客户端，当前用户上线了
                sendMessage("["+host+"]上线了");
                OutputStream out = socket.getOutputStream();
                OutputStreamWriter osw = new OutputStreamWriter(out,"UTF-8");
                pw = new PrintWriter(osw,true);

                //将该客户的输出流存入共享集合，以便消息可以广播给该客户端
                addOut(pw);
                
                //广播当前在线人数
                sendMessage("当前在线人数["+allOut.size()+"]");
                
                //处理来自客户端的数据
                InputStream in = socket.getInputStream();
                InputStreamReader isr = new InputStreamReader(in,"utf-8");
                BufferedReader br = new BufferedReader(isr);
                
                String message = null;
                while((message = br.readLine())!=null) {
                    sendMessage(host+"说："+message);
                }
                
            } catch (Exception e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }finally {
                //将该客户端的输出流从共享集合中删除
                removeOut(pw);
                
                //广播给所有客户端，当前用户下线
                sendMessage("["+host+"]下线了");
                
                //广播当前在线人数
                sendMessage("当前在线人数["+allOut.size()+"]");
                
                try {
                    socket.close();
                } catch (IOException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }
        }
    }
    
}

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

您可能感兴趣的文档:
点击免费下载>>软考高级考试备考技巧/历年真题/备考精华资料

--结束END--

本文标题: Java基于Socket实现多人聊天室

本文链接: https://www.lsjlt.com/news/166680.html(转载时请注明来源链接)

有问题或投稿请发送至: 邮箱/279061341@qq.com    QQ/279061341

本篇文章演示代码以及资料文档资料下载

下载Word文档到电脑，方便收藏和打印～

下载Word文档
去做题
猜你喜欢
  • Java基于Socket实现多人聊天室
    本文实例为大家分享了Java基于Socket实现简易版多人聊天室的具体代码，供大家参考，具体内容如下 一、 聊天室需求 1、一个服务端，多个客户端；2、实现客户端和服务端的交互；3、...
    99+
    2022-11-13
  • Java Socket+多线程实现多人聊天室功能
    本文实例为大家分享了Java Socket+多线程实现多人聊天室的具体代码，供大家参考，具体内容如下 思路简介 分为客户端和服务器两个类，所有的客户端将聊的内容发送给服务器，服务器接...
    99+
    2022-11-12
  • Java通过Socket实现简单多人聊天室
    本文实例为大家分享了Java通过Socket实现多人聊天室的具体代码，供大家参考，具体内容如下 Socket可以实现网络上两个程序通过双向通道进行数据的交换，此外它是Java中网络T...
    99+
    2022-11-12
  • C++基于socket多线程实现网络聊天室
    本文实例为大家分享了C++基于socket多线程实现网络聊天室的具体代码，供大家参考，具体内容如下 1. 实现图解 2. 聊天室服务端：TCP_Server_Chat.cpp ...
    99+
    2022-11-12
  • C#基于Socket实现多人聊天功能
    本文实例为大家分享了C#基于Socket实现多人聊天功能的具体代码，供大家参考，具体内容如下 服务器 服务器负责接受所有客户端发来的消息，和将接受到的问题群发到其他用户。 代码： u...
    99+
    2022-11-13
  • 基于Nodejs利用socket.io实现多人聊天室
    socket.io简介 在Html5中存在着这样的一个新特性，引入了websocket，关于websocket的内部实现原理可以看这篇文章，这篇文章讲述了websocket无到有，根据协议，分析数据帧的头，...
    99+
    2022-06-04
    聊天室 Nodejs socket
  • Android 基于Socket的聊天室实例
    Socket是TCP/IP协议上的一种通信，在通信的两端各建立一个Socket，从而在通信的两端之间形成网络虚拟链路。一旦建立了虚拟的网络链路，两端的程序就可以通过虚拟链路进行...
    99+
    2022-06-06
    聊天室 socket Android
  • Java NIO实现多人聊天室
    本文实例为大家分享了Java NIO实现多人聊天室的具体代码，供大家参考，具体内容如下 1. 服务器端代码 ChatServer类： package nio.test.serve...
    99+
    2022-11-12
  • C#使用Socket实现本地多人聊天室
    本文实例为大家分享了C#使用Socket实现本地多人聊天室的具体代码，供大家参考，具体内容如下 【脚本一：Server端】 使用本机地址：127.0.0.1 完整代码 using S...
    99+
    2022-11-13
  • C#基于Socket实现简单聊天室功能
    因为这段时间在学习Socket，所以就试着写了一个简单的聊天室。主要分为服务器端和多个客户端。利用服务器端作数据中转站，实现消息群发。 1、服务器端有两个类: using Syste...
    99+
    2022-11-13
  • C++基于socket编程实现聊天室功能
    本文实例为大家分享了C++基于socket编程实现聊天室的具体代码，供大家参考，具体内容如下 服务端 // server.cpp : 此文件包含 "main" 函数。程序执行将在...
    99+
    2022-11-12
  • 怎么用Java Socket+多线程实现多人聊天室功能
    这篇文章主要讲解了“怎么用Java Socket+多线程实现多人聊天室功能”，文中的讲解内容简单清晰，易于学习与理解，下面请大家跟着小编的思路慢慢深入，一起来研究和学习“怎么用Java Socket+多线程实现多人聊天室功能”吧！思路简介分...
    99+
    2023-06-20
  • C#如何基于Socket实现多人聊天功能
    这篇文章主要介绍C#如何基于Socket实现多人聊天功能，文中介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们一定要看完！具体内容如下服务器服务器负责接受所有客户端发来的消息，和将接受到的问题群发到其他用户。代码：using ...
    99+
    2023-06-29
  • Java编写实现多人聊天室
    本文实例为大家分享了Java实现多人聊天室的具体代码，供大家参考，具体内容如下 1.客户端 package tk.javazhangwei.net.tcp.chat.Demo03; ...
    99+
    2022-11-13
  • java实现多人聊天对话室
    使用ServerSocket和Socket实现服务器端和客户端的Socket通信。 了解完socket通信步骤后可以发现本实验需要写两个类：Server和Client，并且要先运行...
    99+
    2022-11-12
  • Node.js+express+socket实现在线实时多人聊天室
    本文实例为大家分享了Node.js+express+socket实现在线实时多人聊天室的具体代码，供大家参考，具体内容如下 文件结构如下： 前端部分： 登录页面Login部分： l...
    99+
    2022-11-12
  • Android中基于XMPP协议实现IM聊天程序与多人聊天室
    简单的IM聊天程序 由于项目需要做一个基于XMPP协议的Android通讯软件。故开始研究XMPP。 XMPP协议采用的是客户端-服务器架构，所有从一个客户端发到另一个客户端的...
    99+
    2022-06-06
    xmpp 程序 聊天室 Android
  • C++实现多人聊天室
    本文实例为大家分享了C++实现多人聊天室的具体代码，供大家参考，具体内容如下 UDP 服务端代码： // Test_Console.cpp : 定义控制台应用程序的入口点。 //...
    99+
    2022-11-12
  • Java Socket实现简易聊天室
    Java-Socket编程实现简易聊天室（TCP），供大家参考，具体内容如下 实现一个服务器接收多个客户端 测试： 首先启动服务器，然后启动三个客户端，输入三个不同的用户名，分别在聊...
    99+
    2022-11-11
  • Java Socket模拟实现聊天室
    使用Java Socket模拟实现了一个聊天室，实现了基本的私聊以及群聊。分为服务器端和客户端，下面我来介绍一下实现的步骤。 服务器端 服务器端是聊天室的核心所在，主要用来处理客户端...
    99+
    2022-11-12
软考高级职称资格查询
软考职称历年真题下载
软考职称资料下载
热门wiki
近期文章
推荐阅读
热门问答
热门标签
编程网，编程工程师的家园，是目前国内优秀的开源技术社区之一，形成了由开源软件库、代码分享、资讯、协作翻译、讨论区和博客等几大频道内容，为IT开发者提供了一个发现、使用、并交流开源技术的平台。

  • 官方手机版

  • 微信公众号

  • 商务合作