这里涉及到两个核心的知识点ServerSocket和Socket
ServerSocket是创建TCP做事器的API，其布局方法是用来创建一个做事端流套接字并且与指定的端口进行绑定；其自带的方法（accept)与客户端建立连接，accept没有参数，其返回值是一个socket工具，通过这个socket工具来与客户端进行交互；当没有建立连接时就会壅塞；（close）关闭套接字。
Socket是做事端与客户端都会用到，Socket的布局方法用来创建一个客户端流套接字并与对应的IP主机、端口号建立连接；其自带的方法有三个
InetAddress getInetAddress()
返回套接字所在的地址
InputStream getInputStream()
返回此套接字的输入流
OutputStream getOutputStream()
返回此套接字的输出流
TCP中的是非连接：
在TCP发送数据时，须要先建立连接，而什么时候关闭连接就取决于是“长连接”还是“短连接”！
！
！
长连接：不关闭连接，一贯处于保持连接的状态，双方会一直地进行数据的发送，因此长连接就可以多次收发数据；
短连接：每次吸收数据并将相应返回后就会关闭连接，因此短连接只能发生一次收发数据；
两者的差异就在于：
短连接每次建立、关闭连接都须要耗时，而长连接只须要建立一次；
短连接一样平常是客户端向做事端发送要求，长连接可以是相互发送要求；
利用场景不同，短连接适于浏览网页，而长连接适于实时游戏；
二、代码演示
做事端：
public class TcpEchoServer {
private ServerSocket serverSocket = null;
public TcpEchoServer(int port) throws IOException {
serverSocket = new ServerSocket(port);
}
public void start() throws IOException {
System.out.println("做事器已启动");
//创建线程池
ExecutorService service = Executors.newCachedThreadPool();
while(true){
//如果客户端没有建立连接就会壅塞等待；
Socket clientSocket = serverSocket.accept();
//这里对获取到的连接进行处理
//【版本一】：单线程版本，存在bug，无法处理多个客户真个问题
//processConnect(clientSocket);
// //【版本二】：利用多线程：主线程卖力获取客户端，新创建的线程卖力通信----【频繁的创建与销毁线程！
！
！
】
// Thread thread = new Thread(()->{
// try {
// processConnect(clientSocket);
// } catch (IOException e) {
// e.printStackTrace();
// }
// });
//【版本三】：利用线程池来办理“频繁的线程创建与销毁问题”
service.submit(new Runnable() {
@Override
public void run() {
try {
processConnect(clientSocket);
} catch (IOException e) {
e.printStackTrace();
}
}
});
}
}
public void processConnect(Socket clientSocket) throws IOException {
System.out.printf("[%s:%d] 建立连接!\n", clientSocket.getInetAddress().toString(), clientSocket.getPort());
try (InputStream inputStream = clientSocket.getInputStream();
OutputStream outputStream = clientSocket.getOutputStream()){
Scanner scanner = new Scanner(inputStream);
PrintWriter printWriter = new PrintWriter(outputStream);
while (true){
if(!scanner.hasNext()){
System.out.printf("[%s:%d] 断开连接!\n", clientSocket.getInetAddress().toString(), clientSocket.getPort());
break;
}
// 1、读取数据并解析
String request = scanner.next();
// 2、根据要求打算相应
String response = process(request);
// 3、把相应写回给客户端
printWriter.println(response);
// 刷新缓冲区，避免数据没有发送出去：
printWriter.flush();
System.out.printf("[%s:%d] req: %s; resp: %s\n", clientSocket.getInetAddress().toString(),clientSocket.getPort(),request,response);
}
}finally {
clientSocket.close();
}
}
public String process(String req){
return req;
}
public static void main(String[] args) throws IOException {
TcpEchoServer server = new TcpEchoServer(5000);
server.start();
}
}
在做事端代码中，Socket clientSocket = serverSocket.accept();使得做事端与客户端建立连接，当没有完成建立时就会壅塞等待；而在processConnect方法里面的String request = scanner.next();则是在建立连接后读取客户真个数据，对读取到的数据进行打算，打算的结果放在rosponse中，末了通过.println方法返回到客户端。
利用多线程Thread thread = new Thread(()->{});是为了使做事端可以对应多个客户端，但是多线程也会涉及到线程频繁的创建与销毁问题，因此利用线程池 ExecutorService service = Executors.newCachedThreadPool();的办法；
客户端：
public class TcpEchoClient {
private Socket socket= null;
public TcpEchoClient() throws IOException {
socket = new Socket("127.0.0.1",5000);
}
public void start() throws IOException {
Scanner scanner = new Scanner(System.in);
try (InputStream inputStream = socket.getInputStream();
OutputStream outputStream = socket.getOutputStream()){
Scanner scannerNet = new Scanner(inputStream);
PrintWriter printWriter = new PrintWriter(outputStream);
while (true){
// 1、从掌握台读取用户的输入
System.out.println(">");
String request = scanner.next();
// 2、把要求发送给做事器
printWriter.println(request);
printWriter.flush();
// 3、从做事器读取相应
String response = scannerNet.next();
// 4、把结果显示在界面上
System.out.printf("req: %s ; resp: %s\n",request,response);
}
}
}
public static void main(String[] args) throws IOException {
TcpEchoClient client = new TcpEchoClient();
client.start();
}
}
在客户真个代码中，socket = new Socket("127.0.0.1",5000);这里分别对应IP地址和端口号。
把稳：
在上述代码里面，serverSocket和clientSocket的关闭问题？？？
为何无法处理多个客户端？？？如何处理多个客户真个问题？？？
1、serverSocket和clientSocket的生命周期有着实质的差异，serverSocket的生命周期要伴随着程序全体运行期间，而clientSocket则是只存在于建立连接的时候，而且serverSocket只存在一个，而clientSocket则有多个；如果用完不将其关闭就会存在资源透露的问题；
2、在版本一代码里面，一个做事端只能处理一个客户端，那是由于在客户真个代码里，当serverSocket建立连接之后就会进入到processConnnect方法里面，而processConnect里面的方法无法实行完造诣不会跳出循环，因此就不会与第二个客户端建立连接，此时也就无法处理第二个客户真个需求了。而当我们利用多线程的方法时，创建一个新的线程来调用processConnnect方法，此时原来的主线程就可以不受影响的其他的客户端建立连接；但是此时就会涉及到线程频繁的创建与销毁，因此就顺理成章的想到“线程池”的方法来办理这个问题！
！
！
