定义

Socket – 本意”插座”，在网络编程中表示用于通信的逻辑载体/端点，俗称“套接字”。
是对TCP/IP协议的抽象，是操作系统对外开放的API。

服务端

创建ServerSocket类型的对象，并绑定参数指定的端口号。
等待客户端的连接请求，调用accept()方法。
得到Socket类型的对象并使用输入输出流进行通信。
关闭Socket并释放有关的资源。

客户端

创建Socket类型的对象，并提供服务器的IP地址和端口号。
使用输入输出流进行通信。
关闭Socket并释放有关的资源。

简介

Socket是对TCP/IP协议的抽象，是操作系统对外开放的接口

Socket通信流程

Socket相关的面试题

编写一个网络应用程序，有客户端与服务器端，客户端向服务器发送一个字符串，服务器收到该字符串后将其打印到命令行上，然后向客户端返回该字符串的长度，最后，客户端输出服务器端返回的该字符串的长度，分别用TCP和UDP两种方式去实现

在IDEA的工程中创建socket的包

TCP通信代码实现

package demo.socket;

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

/**
 * 字符串长度计算类
 *
 * @author jinglv
 * @date 2021/03/13
 */
public class LengthCalculator extends Thread {
    /**
     * socket成员变量
     */
    private final Socket socket;

    public LengthCalculator(Socket socket) {
        this.socket = socket;
    }

    @Override
    public void run() {
        try {
            // 获取socket的输出流
            OutputStream os = socket.getOutputStream();
            // 获取socket的输入流
            InputStream is = socket.getInputStream();
            int ch = 0;
            byte[] buff = new byte[1024];
            // buff主要用来读取输入的内容，存成byte数组，ch主要用来获取读取数组的长度
            ch = is.read(buff);
            // 将接收流的byte数组转换成字符串，这里获取的内容时客户端发送过来的字符串参数
            String content = new String(buff, 0, ch);
            System.out.println(content);
            // 往输出流了写入获得的字符串的长度，回发给客户端
            os.write(String.valueOf(content.length()).getBytes());
            // 关闭输入输出流以及socket
            is.close();
            os.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

服务器端

创建ServerSocket类型的对象，并绑定参数指定的端口号。
等待客户端的连接请求，调用accept()方法。
得到Socket类型的对象并使用输入输出流进行通信。
关闭Socket并释放有关的资源。

package demo.socket;

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

/**
 * TCP服务器端
 *
 * @author jinglv
 * @date 2021/03/13
 */
public class TcpServer {

    public static void main(String[] args) throws IOException {
        // 创建socket，并将socket绑定到65000端口
        ServerSocket serverSocket = new ServerSocket(65000);
        // 死循环，使得socket一直顶戴并处理客户端发送过来的请求
        while (true) {
            // 监听65000端口，直到客户端返回连接信息后才返回
            Socket socket = serverSocket.accept();
            // 获取客户端的请求信息，执行相关业务逻辑
            new LengthCalculator(socket).start();
        }
    }
}

客户端

创建Socket类型的对象并提供接收方的IP地址和端口号
获取发送数据输入输出流。
接受服务端返回的字符串长度输出。
关闭输入输出流及Socket并释放有关的资源。

package demo.socket;

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

/**
 * TCP客户端
 *
 * @author jinglv
 * @date 2021/03/13
 */
public class TcpClient {
    public static void main(String[] args) throws IOException {
        //  创建socket，并指定连接的本机的端口号为65000的服务器socket
        Socket socket = new Socket("127.0.0.1", 65000);
        // 获取输出流
        OutputStream os = socket.getOutputStream();
        // 获取输入流
        InputStream is = socket.getInputStream();
        // 将要传递给server的字符串参数转换成byte数组，并数组写入到输出流中
        os.write(new String("hello world").getBytes());
        int ch = 0;
        byte[] buff = new byte[1024];
        // buff主要用来读取输入的内容，存成byte数组，ch主要用来获取读取数组的长度
        ch = is.read(buff);
        // 将接受流的byte数组转换成字符串，这里是从服务端回发回来的字符串参数的长度参数
        String content = new String(buff, 0, ch);
        System.out.println(content);
        // 关闭输入输出流及socket
        is.close();
        os.close();
        socket.close();
    }
}

执行结果

代码编写完成，首先启动TcpServer，再启动TcpClient，结果如下

UDP通信代码实现

服务器端

package demo.socket;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;

/**
 * UDP服务器端
 *
 * @author jinglv
 * @date 2021/03/13
 */
public class UdpServer {
    public static void main(String[] args) throws IOException {
        // 服务器端接受客户端发送的数据报,监听端口号65001
        DatagramSocket socket = new DatagramSocket(65001);
        // 存储从客户端接受到的内容
        byte[] buff = new byte[100];
        DatagramPacket packet = new DatagramPacket(buff, buff.length);
        // 接受客户端发送过来的内容，并将内容封装近DatagramPacket对象中
        socket.receive(packet);

        // 从DatagramPacket对象中获取到真正存储的数据
        byte[] data = packet.getData();
        // 将数据从二进制转换成字符串形式
        String content = new String(data, 0, packet.getLength());
        System.out.println("客户端发送来的数据：" + content);
        // 将要发送给客户端的数据转换成二进制
        byte[] sendContent = String.valueOf(content.length()).getBytes();
        // 服务端给客户端发送数据报
        // 从DatagramPacket对象中获取到数据的来源地址与端口号
        DatagramPacket packetToClient = new DatagramPacket(sendContent, sendContent.length, packet.getAddress(), packet.getPort());
        // 发送数据给客户端
        socket.send(packetToClient);
    }
}

客户端

package demo.socket;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;

/**
 * UDP客户端
 *
 * @author jinglv
 * @date 2021/03/13
 */
public class UdpClient {
    public static void main(String[] args) throws IOException {
        // 客户端发数据给服务端
        DatagramSocket socket = new DatagramSocket();
        // 发送给服务端的数据
        byte[] buf = "Hello World".getBytes();
        // 将IP地址封装成InetAddress对象
        InetAddress address = InetAddress.getByName("127.0.0.1");
        // 将要发送给服务端的数据封装成DatagramPacket对象，需要填写上ip地址和端口号
        DatagramPacket packet = new DatagramPacket(buf, buf.length, address, 65001);
        // 发送数据给服务端
        socket.send(packet);

        // 客户端接受服务端发送过来的数据报
        byte[] data = new byte[100];
        // 创建DatagramPacket对象来存储服务端发送过来的数据
        DatagramPacket receivedPacket = new DatagramPacket(data, data.length);
        // 将接受到的数据存储到DatagramPacket对象中
        socket.receive(receivedPacket);
        // 将服务器端发送过来的数据取出来并打印到控制台
        String content = new String(receivedPacket.getData(), 0, receivedPacket.getLength());
        System.out.println("服务端发送过来的数据：" + content);
    }
}

执行结果

代码编写完成，首先启动UdpServer，再启动UdpClient，结果如下