🍭Socket API

Socket方法：

TCP是有连接的，连接就意味着通信双方会记录保存对端的信息，UDP来说，每次发送数据都得手动send方法中指定目标地址（UDP自身没有存储这个消息）TCP来说，则不需要，前提是需要先把连接给建立上。那么，如果建立连接呢？不需要代码干预，是系统内核自动负责完成的，对应app来说，客户端这边，主要是要发起”建立连接"动作，服务器这边，主要要把建立好的连接从内核中拿到app里。

我们看到大型商场里，都有很有海底捞，每天海底捞的人是非常多的，你要想去吃海底捞，就要排号。我们给海底捞店当作应用程序。而内核就是一个队列等待着去吃海底捞，每当有客人吃完，走了，空出了一桌，服务员就会叫号。

如果有客户端和服务器建立连接，这个时候服务器的应用程序是不需要任何操作（也没有任何感知的），内核直接完成了连接建立的流程（三次握手），完成流程之后，就会在内核的队列中（这个队列是每个serverSocket都有一个这样的队列）排队。

应用程序要想和客户端进行通信，就需要通过一个accept方法把内核队列里已经建立好的连接对象，拿到app中。

TCP中用ServerSocket (给服务器使用的类，使用这个类来绑定端口号），服务器启动之后用到accept方法，把内核中建立好的连接到应用程序中去（建立连接的过程是内核自动完成的，应用程序是捡漏的），如果没有与客户端连接，那么就阻塞等待。

  private ServerSocket serverSocket=null;public TCPEchoServer(int port) throws IOException {serverSocket =new ServerSocket(port);}public void start() throws IOException {System.out.println("服务器正式启动");while (true){//通过accpet方法，把内核中已经建立好的连接拿到app中//建立连接的细节流程都是内核自动完成的，app只需要“捡现成”的Socket clientSocket=serverSocket.accept();}}

在销售A卖楼盘的时候，销售在路上看到一个人想找一个人问问需不需要买房，然后那个男生就带去楼盘区，然后销售找了一个专业的置业顾问B，来介绍楼盘。而这个销售就去路上继续找人。

A：在外面招揽客人

B：给客人提供详细的服务

然后我们调用方法来处理当前的连接。首先我们先打印一个日志，表示已经与客户端建立连接了。

• getPort() 和 getInetAddress() 得到对端的IP和端口 （客户端）
• getLocalAddress() 和getLocalPort() 得到本地的IP和端口（服务器）

 //打印这个日志，来表示客户端连上了System.out.printf("[%s:%d] 客户端上线!\n",clientSocket.getInetAddress(),clientSocket.getPort());

• 首先我们接收请求，用Scanner包装输入流，并读取请求。
• 然后我们根据请求，计算响应
• 最后把响应写回客户端 ，用PrintWriter类进行包装输出流，并flush().

 Scanner scanner=new Scanner(inputStream);//1.读取请求并解析，此处就以next来作为读取请求的方式，.next的规则是，读到“空白符”就返回String request=scanner.next();//2.根据请求，计算响应String response=process(request);
//3.把响应写回客户端//可以把String转成字节数组，写入到OutputStream，
//也可以使用PrintWriter把OutputStream包裹一下，来写入字符串PrintWriter printWriter=new PrintWriter(outputStream);
//此处的println不是打印到控制台了，而是写入到outputStream对应的流对象，也就是写入到clientSocket
//自然这个数据也就通过网络发送出去了，//此处使用println带有\n 也是为了后续 客户端这边 可以使用 scanner.next来读取数据printWriter.write(response);

空白符 是一类特殊的字符，换行，回车符，空格，制表符，翻页符，垂直制表符

后续客户端发起的请求，会以空白符作为结束标记（此处就约定使用\n)

🍭TCP服务器

package TCP;import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;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("服务器正式启动");while (true){//通过accpet方法，把内核中已经建立好的连接拿到app中//建立连接的细节流程都是内核自动完成的，app只需要“捡现成”的Socket clientSocket=serverSocket.accept();Thread t=new Thread(()->{processConnection(clientSocket);});t.start();}}//通过这个方法，来处理当前的连接public void processConnection(Socket clientSocket) {//打印这个日志，来表示客户端连上了System.out.printf("[%s:%d] 客户端上线!\n",clientSocket.getInetAddress(),clientSocket.getPort());try(InputStream inputStream=clientSocket.getInputStream();OutputStream outputStream=clientSocket.getOutputStream()) {//使用try()方式，避免后续用完了流对象，忘记关闭//由于客户端发来的数据，可能是"多条数据“，针对多条数据，就循环处理while (true){Scanner scanner=new Scanner(inputStream);if(!scanner.hasNext()){//连接断开了，此时循环就应该结束System.out.printf("[%s:%d] 客户端下线！\n",clientSocket.getInetAddress(),clientSocket.getPort());break;}//1.读取请求并解析，此处就以next来作为读取请求的方式，.next的规则是，读到“空白符”就返回String request=scanner.next();//2.根据请求，计算响应String response=process(request);//3.把响应写回客户端//可以把String转成字节数组，写入到OutputStream，//也可以使用PrintWriter把OutputStream包裹一下，来写入字符串PrintWriter printWriter=new PrintWriter(outputStream);//此处的println不是打印到控制台了，而是写入到outputStream对应的流对象，也就是写入到clientSocket//自然这个数据也就通过网络发送出去了，//此处使用println带有\n 也是为了后续 客户端这边 可以使用 scanner.next来读取数据printWriter.println(response);//此处还要记得有个操作，刷新缓冲区，如果没有刷新操作，可能数据仍然是在内存中，没有被写入网卡printWriter.flush();//打印了这次请求交互过程的内容System.out.printf("[%s:%d] req=%s resp=%s\n",clientSocket.getInetAddress(),clientSocket.getPort(),request,response);}} catch (IOException e) {throw new RuntimeException(e);}finally {//进行clientSocket的关闭try {clientSocket.close();} catch (IOException e) {throw new RuntimeException(e);}}}public String process(String request){return request;}public static void main(String[] args) throws IOException {TCPEchoServer tcpEchoServer=new TCPEchoServer(9090);tcpEchoServer.start();}
}

如果我们出现了多个客户端连接同一个服务器该怎么办呢？这就考虑到多线程的知识了，如果有客户端就开启线程。

🍭TCP客户端