Java的UNIX套接字实现？

Question

我意识到，由于 UNIX 套接字是特定于平台的，因此必须涉及一些非 Java 代码。具体来说，我们有兴趣使用 JDBC 连接到仅启用了 UNIX 域套接字的 MySQL 实例。

看起来不支持这个，但从我读过的内容来看，至少应该可以为基于 UNIX 套接字的 JDBC 编写一个 SocketFactory 如果我们可以找到一个不错的实现用于 Java 的 UNIX 套接字。

有人试过吗？有人知道这样的实现吗？

Answer 1

查看 JUDS 库。它是一个 Java Unix Domain Socket 库...

https://github.com/mcfunley/juds

Answer 2

你可以使用 junixsocket：https://github.com/kohlschutter/junixsocket

它已经提供了通过 Unix 套接字从 Java (Connector/J) 连接到 MySQL 的代码。

与其他实现相比，一个很大的优势是 junixsocket 使用标准的 Java Socket API。

Answer 3

由于另一个答案中提到的原始kohlschutter/junixsocket 似乎已死，您可以查看它的叉子。

尤其是 fiken/junixsocket 看起来很有希望。例如，它的作者添加了对使用 unix socket 通过pgjdbc 连接到 PostgreSQL 的支持。

Answer 4

MariaDB JDBC driver 现在支持此功能并与 MySQL JDBC 驱动程序兼容。

使用 JDBC 网址，例如：

jdbc:mariadb://localhost:3306/revmgt?localSocket=/var/run/mysqld/mysqld.sock

值得注意的是，该库需要包含 JNA 库，因为它使用 JNA 访问本机 unix 域套接字。它在我的测试中运行良好。我看到了从卸载到本机代码的 CPU 绑定 Java 进程的速度改进。

Answer 5

查看 JNA 库。它是纯 Java 和 JNI 原生代码之间的中间地带

https://github.com/twall/jna/

Answer 6

从 Java 16 开始，Unix 域套接字由 Java 通过 SocketChannel 和 ServerSocketChannel API 原生支持。

您可以在JEP380 提案和实施示例here 中找到有关它的更多信息。

Answer 7

JNR project（这是project panama 的松散基础）有一个unix socket 实现。

Answer 8

在互联网上的一些搜索发现了以下看起来很有用的库：

http://www.nfrese.net/software/gnu_net_local/overview.html

Wayback Link

编写套接字工厂应该很容易。完成后，您可以将其传递给您的驱动程序THUSLY.(Wayback Link)。

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;

import com.mysql.management.driverlaunched.ServerLauncherSocketFactory;

public class ConnectorMXJTestExample {
    public static void main(String[] args) throws Exception {
        String hostColonPort = "localhost:3336";

        String driver = com.mysql.jdbc.Driver.class.getName();
        String url = "jdbc:mysql://" + hostColonPort + "/" + "?"
                + "socketFactory="
                + ServerLauncherSocketFactory.class.getName();
        String userName = "root";
        String password = "";

        Class.forName(driver);
        Connection conn = null;
        try {
            conn = DriverManager.getConnection(url, userName, password);
            Statement stmt = conn.createStatement();
            ResultSet rs = stmt.executeQuery("SELECT VERSION()");
            rs.next();
            String version = rs.getString(1);
            rs.close();
            stmt.close();

            System.out.println("------------------------");
            System.out.println(version);
            System.out.println("------------------------");
        } finally {
            try {
                conn.close();
            } catch (Exception e) {
                e.printStackTrace();
            }
            ServerLauncherSocketFactory.shutdown(hostColonPort);
        }
    }
}