怎么用java控制臺輸出版多人聊天室

本篇內(nèi)容主要講解“怎么用java控制臺輸出版多人聊天室”，感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷，實用性強。下面就讓小編來帶大家學習“怎么用java控制臺輸出版多人聊天室”吧!

多人聊天室就要用到網(wǎng)絡以及多線程以及輸入輸出流的知識

多人聊天室就是多個人同時聊天,一個發(fā)一條信息所有人都是可以接收得到.

接下來我們捋清楚一下思路

在這里面服務器充當了一個轉(zhuǎn)發(fā)的作用,服務器要做的事情是,得到客戶寫進緩沖流里面的信息,再把得到的信息再寫進其他客戶端的緩沖流里面,得到其他用戶的緩沖流我們可以通過集合把用戶的全部Socket對象寫進集合里面,客戶端把客戶想要發(fā)送的信息寫進緩沖流里,等待客戶端發(fā)來的消息,一邊等由一邊發(fā)送消息,這個是屬于并發(fā)的一個操作,所以讀與寫可以單獨開個線程來進行發(fā)送消息.

下面是客戶端的代碼

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;

public class Server {

    public static List<Socket> links = new ArrayList<>();  //用來存儲客戶端的socket對象

    public static void main(String[] args) throws IOException {                                      
        ServerSocket serverSocket = new ServerSocket(6666);
        while(true){
            Socket accept = serverSocket.accept();
            links.add(accept);             //只要有人連接就可以把他添加進socket對象集合里
            ServerThread serverThread = new ServerThread(accept);    //開啟多線程,實現(xiàn)多人聊天的功能
            serverThread.start();
        }
}

//因為頻繁的對輸入輸出流進行資源的關閉,所以寫了個關閉資源的工具類
import java.io.Closeable;
import java.io.IOException;

public class CloseUtil {
    public static void close(Closeable... closeables){
        for (Closeable closeable : closeables) {
            if (closeable!=null) {
                try {
                    closeable.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

//多線程的代碼如下
import java.io.*;
import java.net.Socket;
import java.util.List;

public class ServerThread extends Thread {
    private Socket socket;
    private boolean flag = true;
    public ServerThread(String name, Socket socket) {
        super(name);
        this.socket = socket;
    }

    @Override
    public void run() {
        while(flag){
            sendother(received());     //轉(zhuǎn)發(fā)功能
        }
    }

    private void sendother(String str)  {
        List<Socket> links = Server.links;     //因為在寫客戶端的時候是socket的集合是 靜態(tài)的屬性,所以可以直接通過類型.屬性直接獲得
        for (Socket link : links) {
            if (link!=socket)
                 send(str,link);        //遍歷整個對象轉(zhuǎn)發(fā)給除當前對象的其他socket對象
        }

    }

    private void send(String str,Socket socket) {
        BufferedWriter bw = null;
        try {
            OutputStream outputStream = socket.getOutputStream();
            bw = new BufferedWriter(new OutputStreamWriter(outputStream));
            bw.write(str);
            bw.newLine();
            bw.flush();
        } catch (IOException e) {
            flag = false;
            CloseUtil.close(bw,socket);
        }

    }
    private String received(){
        BufferedReader br = null;
        try {
            InputStream inputStream = socket.getInputStream();
            br = new BufferedReader(new InputStreamReader(inputStream));
            return br.readLine();
        } catch (IOException e) {
            flag = false;
            CloseUtil.close(br,socket);
        }
        return null;
    }
}

下面是客戶端的代碼

import java.io.IOException;
import java.net.Socket;
import java.util.Scanner;

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

        Scanner input  = new Scanner(System.in);
        System.out.print("請輸入您的名字:");
        String name = input.next();
        Socket socket = new Socket("127.0.0.1", 6666);  //127.0.0.1是指的是本機
        Send send = new Send(socket,name);          //收發(fā)分別開兩個線程,可以收發(fā)并發(fā)執(zhí)行
        Receive receive = new Receive("",socket);
        send.start();
        receive.start();
    }

}

//發(fā)線程
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.net.Socket;
import java.util.Scanner;

public class Send extends Thread {
    private Socket socket;
    private  boolean flag = true;
    public Send(Socket socket,String name) {
        super(name);
        this.socket = socket;
    }

    @Override
    public void run() {
        while(flag){
            send();   //一直循環(huán)保證客戶可以一直發(fā)
        }
    }

    private void send() {
        Scanner input = new Scanner(System.in);
        BufferedWriter bw= null;
        try {
            OutputStream outputStream = socket.getOutputStream();
            bw = new BufferedWriter(new OutputStreamWriter(outputStream));
            bw.write(this.getName()+"說:"+input.next());      // 當前線程名+在客戶端在控制臺輸出的一并發(fā)給服務端
            bw.newLine();
            bw.flush();
        } catch (IOException e) {
            flag = false;         //出現(xiàn)異常的時候關閉循環(huán),防止陷入死循環(huán)
            CloseUtil.close(bw,socket);
        }

    }
}


//收線程
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.Socket;


public class Receive extends Thread {
    private Socket socket;
    private  boolean flag = true;
    public Receive(String name, Socket socket) {
        super(name);
        this.socket = socket;
    }

    @Override
    public void run() {
        while (flag){
            System.out.println(received());    //循環(huán)保證能一直接收服務器發(fā)來的消息
        }
    }
    public String received(){
        BufferedReader br =null;
        try {
            InputStream inputStream = socket.getInputStream();
            br = new BufferedReader(new InputStreamReader(inputStream));
            String line = br.readLine();
            return this.getName()+line;
        } catch (IOException e) {
            flag = false;
            CloseUtil.close(br,socket);
        }
        return "";
    }
}

到此，相信大家對“怎么用java控制臺輸出版多人聊天室”有了更深的了解，不妨來實際操作一番吧！這里是億速云網(wǎng)站，更多相關內(nèi)容可以進入相關頻道進行查詢，關注我們，繼續(xù)學習！