Java 多線程Socket編程通訊--實現聊天室代碼

1、創建服務器類

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

/**
 * 服務器
 * @author Administrator
 *
 */
public class Server {

    private int duankou = 9000;//端口號
    private ServerSocket server;//聲明服務器
    private static Socket socket;//聲明客戶端
    private String serName;
    public Server(){
        try {
            init();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    
    /*
     * 創建服務器，開始監聽
     */
    private void init() throws IOException{
        server = new ServerSocket(duankou);
        System.out.println("------服務器已開啟--------");
        System.out.println("請輸入服務器名字：");
        Scanner sc = new Scanner(System.in);
        serName = sc.next();
        while(true){
            socket = server.accept();
            hands(socket);
        }
    }


    private void hands(Socket socket) {
        String key = socket.getInetAddress().getHostAddress()+":"+socket.getPort();
        System.out.println("監聽到的客戶端："+key);
        Thread thread = new Thread(new ThreadSocket(socket));
        thread.setName(serName);
        thread.start();
    }
    
    public static void main(String[] args) {
        Server server = new Server();
    }
    
}

2、創建客戶端類

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

/**
 * 客戶端
 * @author Administrator
 *
 */
public class Client {
    
    private int port = 9000;
    private String ip="127.0.0.1";
    private static Socket socket;
    private String cliName;
    public Client(){
        try {
            init();
        } catch (Exception e) {
            e.printStackTrace();
        } 
    }

    private void init() throws Exception {

        System.out.println("-----客戶端已開啟-----");
        System.out.println("請輸入客戶端名字：");
        Scanner sc = new Scanner(System.in);
        cliName = sc.next();
        socket = new Socket(ip,port);
    }
    
    public void hands() throws Exception{
        Thread threadReader = new Thread(new ThreadReader(socket.getInputStream()),Thread.currentThread().getName());
        Thread threadWriter = new Thread(new ThreadWriter(socket.getOutputStream()));
        threadWriter.setName(cliName);
        threadReader.start();
        threadWriter.start();
        
    }
    
    public static void main(String[] args) throws Exception  {
        Client client = new Client();
        client.hands();
    }

}

 

 3、服務器處理socket多線程

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

/**
 * 服務器處理Socket線程
 * @author Administrator
 *
 */
public class ThreadSocket implements Runnable{

    private Socket socket;
    
    public ThreadSocket(Socket socket){
        this.socket = socket;
    }
    
    @Override
    public void run() {

        try {
            Thread threadReader = new Thread(new ThreadReader(socket.getInputStream()));
            Thread threadWriter = new Thread(new ThreadWriter(socket.getOutputStream()));
            threadReader.start();
            threadWriter.start();
        
        } catch (IOException e) {
            e.printStackTrace();
        }
        
    }

}

 

4、讀取輸入流多線程

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;

/**
 * 讀取輸入流線程
 * @author Administrator
 *
 */
public class ThreadReader implements Runnable{

    //private static int HEAD_SIZE=5;//傳輸最大字節長度
    //private static int BUFFER_SIZE=10;//每次讀取10個字節
    private InputStream is;
    public ThreadReader(InputStream is) {
        this.is = is;
    }

    @Override
    public void run() {

        try {
            while(true){
                byte[] b = new byte[1024];
                int length = is.read(b);
                String message = new String(b,0,length);
                System.out.println(Thread.currentThread().getName()+":"+message);
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
        
    }

}

 

5、發送數據多線程

import java.io.IOException;
import java.io.OutputStream;
import java.util.Scanner;

/**
 * 發送數據線程
 * @author Administrator
 *
 */
public class ThreadWriter implements Runnable{

    
    private OutputStream os;
    public ThreadWriter(OutputStream os) {
        this.os = os;
    }

    @Override
    public void run() {

        try {
            Scanner sc = new Scanner(System.in);
            while(true){
            System.out.println(Thread.currentThread().getName()+"說：");
            String message = sc.next();
            os.write(message.getBytes());
            os.flush();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
        
    }

}