(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运行