(6）優化TCP編寫 服務器端同時支持多個客戶端同時訪問

使用線程池實現服務器端，可以支持同一時間多個客戶端發起的請求

一.編寫TCP協議服務端

package demo.soket.tcp;

import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class TcpService1 {

    public static void main(String args[]) {
        System.out.println("tcp服務器啟動......");
        //創建可緩存的線程池
        ExecutorService executor=Executors.newCachedThreadPool();
        ServerSocket service=null;
        try {
            //創建服務器連接
            service=new ServerSocket(8080);
            while(true) {
                final Socket accept=service.accept();//阻塞
                executor.execute(new Runnable() {
                    public void run() {
                        try {
                            InputStream in = accept.getInputStream();
                            //將字節流轉換為字符串
                            byte[] b=new byte[1024];
                            int len=in.read(b);
                            String str=new String(b,0,len);
                            System.out.println("服務器接收客戶端內容:"+str);
                        } catch (IOException e) {
                            e.printStackTrace();
                        }
                    
                    }
                });
            
            }
        } catch (IOException e) {
            e.printStackTrace();
        }finally {
            if(service!=null) {
                try {
                    service.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }

}

 

二.編寫TCP協議客服端

客服端一：

package demo.soket.tcp;

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

public class TcpClient1 {
    public static void main(String[] args) {
        try {
            Socket client=new Socket("127.0.0.1", 8080);
            OutputStream os=client.getOutputStream();
            os.write("我是客戶端一".getBytes());
        } catch (UnknownHostException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

}

客服端二：

package demo.soket.tcp;

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

public class TcpClient2 {
    public static void main(String[] args) {
        try {
            Socket client=new Socket("127.0.0.1", 8080);
            OutputStream os=client.getOutputStream();
            os.write("我是客戶端二".getBytes());
        } catch (UnknownHostException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

 

瀏覽器模擬客戶端三：

http://127.0.0.1:8080/

三 .demo運行