Java实现curl Unix Socket HTTP请求：简化方案及连接方法问询

好问题！确实直接用AFUNIXSocket手动处理HTTP请求会有点繁琐——毕竟你得自己拼HTTP报文、处理响应解析这些细节。不过有几个更简便的方案，也可以给你讲讲手动实现的思路，让你根据项目情况选择。

第三方HTTP客户端库（比如OkHttp、Apache HttpClient）已经内置了对Unix域套接字的支持，不用你手动管理底层套接字和HTTP协议细节，代码更简洁可靠。

方案1：OkHttp（推荐） #

OkHttp是目前Java生态里非常流行的HTTP客户端，配置Unix域套接字的方式很简单：

首先确保项目引入了OkHttp依赖（比如Maven）：

<dependency>
    <groupId>com.squareup.okhttp3</groupId>
    <artifactId>okhttp</artifactId>
    <version>4.11.0</version> <!-- 使用最新稳定版 -->
</dependency>

然后编写代码：

import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.Response;
import okhttp3.internal.platform.Platform;
import java.io.IOException;

public class UnixSocketHttpExample {
    public static void main(String[] args) throws IOException {
        // 配置OkHttpClient使用Unix域套接字
        OkHttpClient client = new OkHttpClient.Builder()
                .socketFactory(Platform.get().newSocketFactory())
                .dns(hostname -> java.util.Collections.singletonList(java.net.InetAddress.getByName("localhost")))
                .build();

        // 构造请求：URL的主机部分可以随便填（因为不走DNS解析），路径要和curl里的一致
        Request request = new Request.Builder()
                .url("http://dummy-host/path/to/rest/request")
                .addHeader("Host", "dummy-host") // 部分服务会校验Host头，按需调整
                .build();

        // 执行请求并打印响应
        try (Response response = client.newCall(request).execute()) {
            System.out.println(response.body().string());
        }
    }
}

这里的dummy-host只是占位符，因为请求是通过Unix套接字直接发送的，不会进行DNS解析。如果你的服务要求特定的Host头，替换成对应的值即可。

方案2：Apache HttpClient #

如果你的项目已经在使用Apache HttpClient，也可以通过自定义连接工厂来支持Unix域套接字（以HttpClient 5.x为例）：

先引入依赖：

<dependency>
    <groupId>org.apache.httpcomponents.client5</groupId>
    <artifactId>httpclient5</artifactId>
    <version>5.2.1</version> <!-- 使用最新稳定版 -->
</dependency>

然后编写代码：

import org.apache.hc.client5.http.classic.methods.HttpGet;
import org.apache.hc.client5.http.impl.classic.CloseableHttpClient;
import org.apache.hc.client5.http.impl.classic.CloseableHttpResponse;
import org.apache.hc.client5.http.impl.classic.HttpClients;
import org.apache.hc.client5.http.impl.io.PoolingHttpClientConnectionManager;
import org.apache.hc.client5.http.socket.ConnectionSocketFactory;
import org.apache.hc.client5.http.socket.PlainConnectionSocketFactory;
import org.apache.hc.core5.http.HttpHost;
import org.apache.hc.core5.http.io.entity.EntityUtils;
import org.apache.hc.core5.http.protocol.HttpContext;

import java.io.IOException;
import java.net.InetSocketAddress;
import java.net.Socket;
import java.net.StandardProtocolFamily;
import java.net.UnixDomainSocketAddress;

public class ApacheHttpClientUnixSocket {
    public static void main(String[] args) throws IOException {
        // 自定义Unix域套接字连接工厂
        ConnectionSocketFactory unixSocketFactory = new ConnectionSocketFactory() {
            @Override
            public Socket createSocket(HttpContext context) throws IOException {
                return Socket.open(StandardProtocolFamily.UNIX);
            }

            @Override
            public Socket connectSocket(int connectTimeout, Socket socket, HttpHost host, InetSocketAddress remoteAddress, InetSocketAddress localAddress, HttpContext context) throws IOException {
                // 指定Unix套接字文件路径
                UnixDomainSocketAddress unixAddress = UnixDomainSocketAddress.of("file.sock");
                socket.connect(unixAddress, connectTimeout);
                return socket;
            }
        };

        // 注册工厂并创建客户端
        PoolingHttpClientConnectionManager connManager = new PoolingHttpClientConnectionManager(
                new ConnectionSocketFactory[]{unixSocketFactory, PlainConnectionSocketFactory.getSocketFactory()}
        );

        try (CloseableHttpClient client = HttpClients.custom().setConnectionManager(connManager).build()) {
            HttpGet request = new HttpGet("/path/to/rest/request");
            // 主机名随便填，实际走Unix套接字连接
            try (CloseableHttpResponse response = client.execute(new HttpHost("dummy-host"), request)) {
                System.out.println(EntityUtils.toString(response.getEntity()));
            }
        }
    }
}

如果不想引入任何第三方库，也可以直接用AFUNIXSocket手动构造HTTP请求——但要注意HTTP报文格式必须严格遵循规范：

import org.newsclub.net.unix.AFUNIXSocket;
import org.newsclub.net.unix.AFUNIXSocketAddress;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.nio.charset.StandardCharsets;

public class ManualUnixSocketHttp {
    public static void main(String[] args) throws IOException {
        // 连接到Unix套接字文件
        try (AFUNIXSocket socket = AFUNIXSocket.newInstance()) {
            socket.connect(AFUNIXSocketAddress.of("file.sock"));

            // 构造HTTP GET请求：请求行 + 请求头 + 空行（分隔头和体）
            String request = "GET /path/to/rest/request HTTP/1.1\r\n"
                    + "Host: localhost\r\n" // 按需调整Host头
                    + "Connection: close\r\n" // 告诉服务端请求完成后关闭连接
                    + "\r\n"; // 必须有这个空行

            // 发送请求
            try (OutputStreamWriter writer = new OutputStreamWriter(socket.getOutputStream(), StandardCharsets.UTF_8)) {
                writer.write(request);
                writer.flush();
            }

            // 读取并打印响应
            try (BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream(), StandardCharsets.UTF_8))) {
                String line;
                while ((line = reader.readLine()) != null) {
                    System.out.println(line);
                }
            }
        }
    }
}

如果是POST请求，你还需要添加Content-Length头和请求体，比如：

String requestBody = "key=value&another=param";
String request = "POST /path/to/rest/request HTTP/1.1\r\n"
        + "Host: localhost\r\n"
        + "Content-Type: application/x-www-form-urlencoded\r\n"
        + "Content-Length: " + requestBody.length() + "\r\n"
        + "Connection: close\r\n"
        + "\r\n"
        + requestBody;

• 优先推荐用OkHttp或Apache HttpClient，它们封装了所有HTTP细节，代码更简洁、容错性更高；
• 手动实现适合不想引入依赖的场景，但需要严格遵守HTTP协议格式，否则服务端可能无法正确解析请求。

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