快捷導(dǎo)航

Java socket通信模擬QQ實(shí)現(xiàn)多人聊天室

更新時(shí)間：2022年07月16日 15:31:12 作者：陳橘又青

Socket在Java實(shí)戰(zhàn)網(wǎng)絡(luò)通信編程應(yīng)用中有非常重要的作用，你想要跟別人聯(lián)系都得通過(guò)socket占據(jù)端口來(lái)實(shí)現(xiàn)，掌握Socket技術(shù)不僅在聊天應(yīng)用程序中需要用到（比如QQ什么的都都是用socket來(lái)寫(xiě)的），而且對(duì)于學(xué)習(xí) Asp.net 也非常有幫助

一、socket通信基本原理

socket 通信是基于TCP/IP ?絡(luò)層上的?種傳送?式，我們通常把TCP和UDP稱(chēng)為傳輸層。

?

如上圖，在七個(gè)層級(jí)關(guān)系中，我們講的socket屬于傳輸層，其中UDP是?種?向?連接的傳輸層協(xié)議。UDP不關(guān)?對(duì)端是否真正收到了傳送過(guò)去的數(shù)據(jù)。如果需要檢查對(duì)端是否收到分組數(shù)據(jù)包，或者對(duì)端是否連接到?絡(luò)，則需要在應(yīng)?程序中實(shí)現(xiàn)。UDP常?在分組數(shù)據(jù)較少或多播、?播通信以及視頻通信等多媒體領(lǐng)域。在這?我們不進(jìn)?詳細(xì)討論，這?主要講解的是基于TCP/IP協(xié)議下的socket通信。

socket是基于應(yīng)?服務(wù)與TCP/IP通信之間的?個(gè)抽象，他將TCP/IP協(xié)議??復(fù)雜的通信邏輯進(jìn)?分裝，對(duì)?戶來(lái)說(shuō)，只要通過(guò)?組簡(jiǎn)單的API就可以實(shí)現(xiàn)?絡(luò)的連接。

二、用socket制作一個(gè)多人聊天室

對(duì)socket通信基本原理明?后，那我們就寫(xiě)?個(gè)最簡(jiǎn)單的?例，制作聊天室。

服務(wù)器端Server：

import java.io.*;
import java.net.*;
import java.util.ArrayList;
public class Server{
    public static ServerSocket server_socket;
    public static ArrayList<Socket> socketList=new ArrayList<Socket>();  
    public static void main(String []args){
        try{
            server_socket = new ServerSocket(5000);
            while(true){
                Socket socket = server_socket.accept();
                socketList.add(socket); //把sock對(duì)象加入sock集合
                ServerBO_Thread st=new ServerBO_Thread(socket,socketList); //初始化多線程
                st.start();//啟動(dòng)多線程
            }
        }catch(Exception ex){
            ex.printStackTrace();
        }finally{
            try{
                if(server_socket!=null){
                    server_socket.close();
                }
            }catch(Exception ex){
                ex.printStackTrace();
            }
        }
    }
    public void encryptWrite(String src,DataOutputStream output)throws IOException{
        //將一個(gè)字符串轉(zhuǎn)化為字符數(shù)組
        //System.out.println(src);
        char[] char_arr = src.toCharArray();
        //加密操作
        for(int i = 0;i<char_arr.length;i++){
            output.writeChar(char_arr[i]+13);
        }
        //用作結(jié)束標(biāo)志符
        output.writeChar(2333);
        output.flush();
    }
    //讀取并解密
    public String readDecrypt(DataInputStream input)throws IOException{
        String rtn="";
        while(true){
            int char_src =input.readChar();
            if(char_src!=2333){
                rtn=rtn+(char)(char_src-13);
            }else{
                break;
            }
        }
        return rtn;
    }
}
class ServerBO_Thread extends Thread{
    Socket client = null;
    ArrayList<Socket> clients;
    ServerBO_Thread(Socket s,ArrayList<Socket> ss){//初始化
        client=s;
        clients=ss; 
    }
    public void run(){
        DataInputStream input = null;
        DataOutputStream output =null;
        try{
            input = new DataInputStream(client.getInputStream());
            Server bo = new Server();
            String receive=null;
            String send=null;
            while(true){//監(jiān)視當(dāng)前客戶端有沒(méi)有發(fā)來(lái)消息
                if(!client.isClosed()){
                    receive=bo.readDecrypt(input);
                    clients.trimToSize();
                    String[] param = receive.split("&");
                    if(")start".equals(param[1])){    //分析客戶端發(fā)來(lái)的內(nèi)容
                        send = param[0]+"進(jìn)入聊天室";
                    }else{
                        send = param[0]+"說(shuō):    "+param[1];
                    }
                    if(!("3333".equals(param[1]))){//3333為退出聊天室信號(hào)
                        for(Socket socket:clients){ //遍歷socke集合 
                            //把讀取到的消息發(fā)送給各個(gè)客戶端  
                            if(!socket.isClosed()){
                                output = new DataOutputStream(socket.getOutputStream());
                                bo.encryptWrite(send,output);
                            }
                        }  
                    }else{//如果有客戶端退出
                        for(Socket socket:clients){ //遍歷socke集合 
                                if(socket!=client){//告訴其他人此人退出聊天室
                                    if(!(socket.isClosed())){
                                        output = new DataOutputStream(socket.getOutputStream());
                                        bo.encryptWrite(param[0]+"已退出聊天室",output);
                                    }
                                }
                            }
                        output = new DataOutputStream(client.getOutputStream());
                        bo.encryptWrite("3333",output);//返回信號(hào)給要退出的客戶端，然后關(guān)閉線程
                        client.close();
                        input.close();
                        output.close();
                    }
                }else{
                    break;
                }
            }
        }catch(Exception ex){
            ex.printStackTrace();
        }
    }
}

客戶端：

import java.io.IOException;
import java.util.Scanner;
import java.net.*;
import java.io.*;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.BufferedWriter;
import java.io.BufferedReader;
import java.io.DataOutputStream;
public class People{
//服務(wù)端ip
    public  String ip = "127.0.0.1";
    //服務(wù)端端口
    public  int port = 5000;
    public  DataOutputStream output = null;
    public  Socket socket = null;
    public  DataInputStream input = null;
    public  Scanner sc =new Scanner (System.in);
    public  String send ;
    public  String receive;
    public  String name;
    public String sd = null;
    public static void main(String[]aa){
        People po = new People();
        po.start();
    }
    public void start(){
        try{
            System.out.println("*******歡迎使用匿名聊天室！**********");
            System.out.println("請(qǐng)輸入你將要使用的昵稱(chēng)：");
            name=sc.nextLine();//獲取昵稱(chēng)
            socket = new Socket(ip,port);
            output=new DataOutputStream(socket.getOutputStream());
            input = new DataInputStream(socket.getInputStream());
            send = name+"&)start";//把昵稱(chēng)發(fā)送到server 告訴所有人有新成員加入聊天室
            System.out.println("(如果要退出聊天室請(qǐng)輸入“3333”！)");
            System.out.println("*******成功進(jìn)入匿名聊天室！**********");
            System.out.println("");
            encryptWrite(send,output);
            Out out=new Out(output,name,input,socket);
            out.start();//啟動(dòng)發(fā)送聊天內(nèi)容的多線程
            while(true){    
                String receive = readDecrypt(input);
                if("3333".equals(receive)){//如果收到“3333”則退出聊天室
                    System.out.println("*******成功退出匿名聊天室！**********");
                    input.close();
                    output.close();
                    socket.close();
                    System.exit(0);
                }
                System.out.println(receive);
            }
        }catch(Exception ex){
                ex.printStackTrace();
        }finally{
            try{
                if(socket!=null) socket.close();
                input.close();
                output.close();
            }catch(Exception ex){
                ex.printStackTrace();
            }
        }    
    }
    public void encryptWrite(String src,DataOutputStream output)throws IOException{
        //將一個(gè)字符串轉(zhuǎn)化為字符數(shù)組
        char[] char_arr = src.toCharArray();
        //加密操作
        for(int i = 0;i<char_arr.length;i++){
            output.writeChar(char_arr[i]+13);
        }
        //用作結(jié)束標(biāo)志符
        output.writeChar(2333);
        output.flush();
    }
    //讀取并解密
    public String readDecrypt(DataInputStream input)throws IOException{
        String rtn="";
        while(true){
            int char_src =input.readChar();
            if(char_src!=2333){
                rtn=rtn+(char)(char_src-13);
            }else{
                break;
            }
        }
        return rtn;
    }
}
class Out extends Thread {
    public DataOutputStream output;
    public DataInputStream input;
    public static String name;
    public Socket socket;
    public  Scanner sc =new Scanner (System.in);
    Out(DataOutputStream ot,String n,DataInputStream it,Socket socket){
        output=ot;
        input=it;
        name=n;
    }
    public void run(){
        People po = new People();
        try{
            while(true){
                String send=sc.nextLine();//獲取用戶輸入
                String send2=name+"&"+send;//把聊天內(nèi)容打包成約定形式
                po.encryptWrite(send2,output);
            }
        }catch(Exception ex){
            ex.printStackTrace();
        }finally{
            System.out.println("sfef");
        }
    }
}

三、實(shí)現(xiàn)效果

?

四、總結(jié)

1、用于接收信息的字符串每次都要重新定義一個(gè)，不能在開(kāi)頭只定義一次，這樣會(huì)導(dǎo)致數(shù)組角標(biāo)異常的錯(cuò)誤，因?yàn)槊看谓邮盏降男畔⒌拈L(zhǎng)度都不一樣的，所以每次用都要重新new一個(gè)字符串。

2、調(diào)用多線程的時(shí)候一定要把socket或者inputoutput參數(shù)傳遞給構(gòu)造函數(shù)初始化，不能用類(lèi).output的形式調(diào)用，不然會(huì)有空指針的錯(cuò)誤（原因大概是直接調(diào)用的可能是還沒(méi)初始化的）。

3、為了程序的健壯性，我們需要對(duì)當(dāng)有客戶端退出聊天室的情況進(jìn)行處理，如果不處理，當(dāng)有人強(qiáng)制退出聊天室時(shí)會(huì)導(dǎo)致服務(wù)端崩潰發(fā)生空指針異常。在這個(gè)程序主中我約定用“3333”為退出信息，當(dāng)客戶端發(fā)出3333時(shí)即退出聊天室，關(guān)閉對(duì)應(yīng)socket，此處關(guān)鍵點(diǎn)是要理清誰(shuí)先關(guān)閉誰(shuí)后關(guān)閉，不然也會(huì)導(dǎo)致socket崩潰，流程應(yīng)該是發(fā)送3333告知服務(wù)器端我要退出了，然后服務(wù)器返回信號(hào)給客戶端我已知曉，你可以退出了，然后客戶端服務(wù)器端才可以關(guān)閉socket。?

到此這篇關(guān)于Java socket通信模擬QQ實(shí)現(xiàn)多人聊天室的文章就介紹到這了,更多相關(guān)Java聊天室內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: