Java-网络编程实现简单的群聊功能

package chat3.client;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.Socket;

/**
 * 
* <p>Title: MyClient_receivemess_thread</p>  
* <p>
*   Description: 
*   收信息的线程
* </p> 
* @author xianxian 
* @date 2019年7月19日
 */
public class MyClient_receivemess_thread implements Runnable {

    private Socket client;
    
    public MyClient_receivemess_thread(Socket client) {
        super();
        this.client = client;
    }
    @Override
    public void run() {
        try(
                BufferedReader br = new BufferedReader(new InputStreamReader(client.getInputStream()));
                ){
            while (true) {
                String message = br.readLine();
                System.out.println(message);
            }
        }catch(Exception e) {
            e.printStackTrace();
        }
    }
}

package chat3.client;

import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.Scanner;

public class MyClient {

    public static void main(String[] args) {

        /**
         * 需求：至少两个线程，
         * 一 个发 信息
         * 一个收信息
         */
        Socket client = null;
        
        try {
            //此处的127.0.0.1相当于localhost
            client = new Socket("127.0.0.1",20000);
            
            
            //记得开一个子线程，不停的收取服务端转发过来的信息
            new Thread(new MyClient_receivemess_thread(client)).start();
            
            
            //希望能够群聊，我能发信息出去
            try(
                    PrintWriter pw = new PrintWriter(new OutputStreamWriter(client.getOutputStream()),true);
                    
                    ){
                while(true) {
                    //控制台输入要发送的信息
                    Scanner s = new Scanner(System.in);
                    String message = s.next();
                    pw.println(message);
                }
            }catch(Exception e) {
                e.printStackTrace();
            }
        }catch(Exception e) {
            e.printStackTrace();
        }
    }
}

package chat3.server;

import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;


public class MyServer {
    /**
     * 
     * <p>Title: main</p>  
     * <p>
     *  Description: 
     * 需求分析：1. 服务端能够响应客户端的连接请求，不管多少个都可以响应
     *          2.客户端发送过来的信息，服务端可以转发给其他客户端
     * </p>  
     * @param args
     */
    
    //存放客户端套接字的集合,为什么给集合上锁，支持并发访问，确保数据安全
    public static List<Socket> socketList = Collections.synchronizedList(new ArrayList<>());
    
    public static void main(String[] args) {
        //开一个服务端
        ServerSocket server = null;
        
        try {
            server = new ServerSocket(20000);
            
            while(true) {
                Socket client = server.accept();
                //拿到客户端套接字后需要做两件事：
                //1.把这个套接字放入集合中
                socketList.add(client);
                
                //2.开一个线程跟客户聊天，
                //其实不聊天，只是不停的接收客户端发
                //来的信息然后转发至其他客户端
                new Thread(new MyServer_chat_thread(client)).start();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

package chat3.server;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;

/**
 * 
* <p>Title: MyServer_chat_thread</p>  
* <p>
*   Description: 
*   服务端和客户端聊天的线程类
*   需求：一直不停地接收客户端发来的信息然后转发至其他客户端
* </p> 
* @author xianxian 
* @date 2019年7月19日
 */
public class MyServer_chat_thread implements Runnable {

    private Socket client;//能够接收客端发送的信息，必定持有该客户端套接字
    
    public MyServer_chat_thread(Socket socket) {
        this.client = socket;//利用构造方法构造当前类的实例的同时，给套接字属性赋值
    }
    @Override
    public void run() {
        //一直不停地接收客户端发来的信息然后转发至其他客户端
        try(
                BufferedReader br = new BufferedReader(new InputStreamReader(client.getInputStream()));
                
                ){
            String message = null;
            while(true) {
                message = br.readLine();//接收客户端发送的信息
                //转发
                for(Socket socket:MyServer.socketList) {
                    //如果是自己发的信息，不用转发回自己
                    if(socket == client) {
                    
                        continue;
                    }else {
                        //拿到每个客户端的套接字做什么呢？获取每个客户端的输出流，给各自的客户端发送信息
                        //后面的参数true表明启动自动刷新功能
                        PrintWriter pw = new PrintWriter(new OutputStreamWriter(socket.getOutputStream()),true);
                        
                        pw.println(message);
                    }
                }
            }
        }catch(Exception e) {
            e.printStackTrace();
        }
    }
}

群聊功能测试：先启动MyServer再启动MyClient启动两次表明开咯两客户端，群聊功能如下图所示

以上就是我关于 Java网络编程实现简单的群聊功能 知识点的整理与总结的全部内容,另附源码

分割线

博主为咯学编程：父母不同意学编程，现已断绝关系;恋人不同意学编程，现已分手;亲戚不同意学编程，现已断绝来往;老板不同意学编程,现已失业三十年。。。。。。如果此博文有帮到你欢迎打赏，金额不限。。。