java socket 編程 多線程異步通信

最近在學習分布式，分布式的前提是要知道網絡服務器的通信，自己對這一塊基本不了解，最近學習了一下，整理一個demo，方便以后查閱

這個是關於TCP/BIO，所謂BIO就是阻塞IO，沒收到消息時就處於阻塞狀態，有消息就工作，我用了多線程來處理收消息和發消息，實現了異步發送

 

服務器端代碼：

package internetCommunication;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;

public class Server {

    public static void main(String[] args) {
        try {
            ServerSocket server = new ServerSocket(8888);
            Socket client = server.accept();
            BufferedReader in = new BufferedReader(new InputStreamReader(client.getInputStream()));
            PrintWriter out=new PrintWriter(client.getOutputStream());
            BufferedReader userin = new BufferedReader(new InputStreamReader(System.in));
            
            
            new ReceiveTread(server,in,out,userin,client).start();
            new SendThread(out, userin,true).start();
        } catch (IOException e) {
            e.printStackTrace();
        }
        
        
    }

}

客戶端代碼

package internetCommunication;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.Socket;

public class Client {
    
    
    public static void main(String[] args) {
        try {
            Socket server = new Socket(InetAddress.getLocalHost(), 8888);
            BufferedReader in = new BufferedReader(new InputStreamReader(server.getInputStream()));
            PrintWriter out=new PrintWriter(server.getOutputStream());
            BufferedReader userin = new BufferedReader(new InputStreamReader(System.in));
            
            new SendThread(out,userin,false).start();
            new ReceiveTread(server,in,out,userin).start();
            
            
        } catch (IOException e) {
            e.printStackTrace();
        }
        
        
    }
}

 

發消息多線程類

package internetCommunication;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.PrintWriter;
import java.text.SimpleDateFormat;
import java.util.Date;

public class SendThread extends Thread{

    PrintWriter out;
    BufferedReader userin;
    boolean isServer;
    
    public SendThread(PrintWriter out,BufferedReader userin,boolean isServer) {
        this.out = out;
        this.userin = userin;
        this.isServer = isServer;
    }

    @Override
    public void run() {
        SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        
        try {
            while(true){
                if(isServer){
                    out.println("Server  "+sf.format(new Date())+"\n\t"+ userin.readLine());
                }else{
                    out.println("client  "+sf.format(new Date())+"\n\t"+ userin.readLine());
                }
                out.flush();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
        
    }
    
    
    
    
    
    
}

 

接消息多線程類

package internetCommunication;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;

public class ReceiveTread extends Thread{
    BufferedReader in ;
    ServerSocket server;
    PrintWriter out;
    BufferedReader userin;
    Socket client;
    
    
    public ReceiveTread(ServerSocket server,BufferedReader in,PrintWriter out,BufferedReader userin,Socket client) {
        this.in = in;
        this.server = server;
        this.client = client;
        this.out = out;
        this.userin = userin;
    }
    
    public ReceiveTread(Socket client ,BufferedReader in,PrintWriter out,BufferedReader userin) {
        this.in = in;
        this.client = client;
        this.out = out;
        this.userin = userin;
    }
    
    
    @Override
    public void run() {
        try {
            while(true){
                String info = in.readLine();
                while(info !=null){
                    System.out.println(info);
                    info = in.readLine();
                }
                if(in.readLine().equals("end")){
                    break;
                }
            }
            in.close();
            out.close();
            userin.close();
            if(client != null){
                client.close();
            }
            server.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

 

以下是控制輸出：

這是客戶端的

 

 

這是服務器的：

 

這里要注意的是： 1、啟動時要先啟動服務器，在啟動客戶端，因為只有服務器啟動了，開始監聽某個端口，客戶端才能連上

                       2、因為輸入控制台和輸出控制台都揉在一起顯示，控制台顯示接收消息的時候，光標還是會停留在上一次輸入的地方，如果輸入非漢字類的，光標會自動跳下來

但是輸入漢字，會出現把接收到消息也發送的情況，所以需要輸入的時候將光標自己點下來，如果是GUI編程的話，就沒有這個問題，因為輸入的面板和顯示面板是獨立開來的，呵呵