Java 16+ 无第三方库实现Unix域套接字HTTP POST请求

Java 16 新增了java.net.UnixDomainSocketAddress类，支持直接操作Unix域套接字。由于标准HttpClient并未直接提供Unix域套接字的适配，我们可以通过以下两种方式实现需求：

方法一：手动构造HTTP请求报文（简单直接） #

这种方式无需依赖额外API，直接通过SocketChannel连接Unix域套接字，手动拼接HTTP POST请求并读取响应：

import java.net.UnixDomainSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.SocketChannel;
import java.nio.charset.StandardCharsets;

public class UnixSocketPost {
    public static void main(String[] args) throws Exception {
        // 替换为你的Unix域套接字路径
        String socketPath = "/var/run/your-api-server.sock";
        UnixDomainSocketAddress socketAddr = UnixDomainSocketAddress.of(socketPath);
        
        // 要发送的JSON数据
        String jsonBody = "{\"username\": \"test\", \"password\": \"123456\"}";
        int contentLength = jsonBody.getBytes(StandardCharsets.UTF_8).length;
        
        // 构造完整的HTTP POST请求
        String postRequest = String.format(
            "POST /api/login HTTP/1.1\r\n" +
            "Host: localhost\r\n" +
            "Content-Type: application/json\r\n" +
            "Content-Length: %d\r\n" +
            "\r\n" +
            "%s",
            contentLength, jsonBody
        );

        // 连接套接字并发送请求
        try (SocketChannel channel = SocketChannel.open(socketAddr)) {
            // 写入请求数据
            channel.write(StandardCharsets.UTF_8.encode(postRequest));
            
            // 读取响应
            ByteBuffer buffer = ByteBuffer.allocate(4096);
            StringBuilder response = new StringBuilder();
            while (channel.read(buffer) != -1) {
                buffer.flip();
                response.append(StandardCharsets.UTF_8.decode(buffer));
                buffer.clear();
            }
            
            System.out.println("服务器响应：");
            System.out.println(response);
        }
    }
}

注意事项 #

• 需确保请求报文的格式严格符合HTTP/1.1规范，尤其是换行符必须用\r\n，且请求头与报文体之间要有空行。
• 如果API需要其他请求头（如Authorization），直接添加到请求头部分即可。

方法二：借助HttpClient的底层API（更优雅） #

如果希望复用HttpClient的请求构建、响应解析能力，可以通过自定义SocketChannel结合HttpClient的send方法实现：

import java.net.UnixDomainSocketAddress;
import java.net.http.HttpClient;
import java.net.http.HttpRequest;
import java.net.http.HttpResponse;
import java.nio.channels.SocketChannel;
import java.nio.charset.StandardCharsets;
import java.time.Duration;

public class UnixSocketHttpClient {
    public static void main(String[] args) throws Exception {
        String socketPath = "/var/run/your-api-server.sock";
        UnixDomainSocketAddress socketAddr = UnixDomainSocketAddress.of(socketPath);
        
        // 构建HttpClient
        HttpClient client = HttpClient.newBuilder()
                .connectTimeout(Duration.ofSeconds(5))
                .build();
        
        // 构建POST请求（URI可随意填写，实际连接由自定义套接字处理）
        HttpRequest request = HttpRequest.newBuilder()
                .uri(java.net.URI.create("http://localhost/api/login"))
                .header("Content-Type", "application/json")
                .POST(HttpRequest.BodyPublishers.ofString("{\"username\": \"test\", \"password\": \"123456\"}"))
                .build();
        
        // 自定义套接字连接并发送请求
        try (SocketChannel channel = SocketChannel.open(socketAddr)) {
            // 将请求转换为字节流写入套接字
            HttpResponse<String> response = client.send(request, HttpResponse.BodyHandlers.ofString(), (req, sslContext) -> channel);
            System.out.println("服务器响应状态码：" + response.statusCode());
            System.out.println("服务器响应体：" + response.body());
        }
    }
}

注意事项 #

• 部分环境下，send方法的三参数重载可能受模块访问限制，此时方法一的手动拼接方式更可靠。
• 若使用模块化项目，需在module-info.java中添加requires jdk.net;以访问UnixDomainSocketAddress。

内容的提问来源于stack exchange，提问作者Prashanna Rai