Java 进程间通信方法详解

1. 引言

我们之前探讨过进程间通信（IPC）的基本概念，并对比了不同方法的性能差异。本文将聚焦如何在Java应用中实现这些IPC机制，提供可直接落地的实践方案。

2. 什么是进程间通信？

进程间通信（IPC）是不同进程间交换数据的机制。这些进程可能属于同一应用，运行在同一台机器上，或分布在互联网的不同节点。

典型场景：现代浏览器将每个标签页作为独立进程运行。这种隔离设计需要标签页进程与主浏览器进程通过IPC保持协同工作。

本文所有方案都基于消息传递模型。Java原生不支持共享内存机制（虽有第三方库实现），因此我们将聚焦生产者进程向消费者进程发送消息的场景。

3. 基于文件的IPC

标准Java中最简单的IPC方式就是利用本地文件系统。一个进程写入文件，另一个进程读取同一文件。任何进程在文件系统上的操作，对同机其他进程都可见。

3.1 共享文件

最基础的方式是让两个进程读写同一文件。生产者进程写入文件，消费者进程稍后读取。

⚠️ 需特别注意：读写操作不能重叠。多数文件系统操作非原子性，并发读写可能导致消息损坏。若能保证操作顺序（如使用文件锁），共享文件是简单有效的IPC方案。

3.2 共享目录

升级方案是共享整个目录而非单个文件。生产者每次写入新文件，消费者通过监听目录变化响应。

Java NIO2的WatchService API完美适配此场景。消费者进程监听目标目录，检测到新文件创建时触发处理：

WatchService watchService = FileSystems.getDefault().newWatchService();

Path path = Paths.get("pathToDir");
path.register(watchService, StandardWatchEventKinds.ENTRY_CREATE);

WatchKey key;
while ((key = watchService.take()) != null) {
    for (WatchEvent<?> event : key.pollEvents()) {
        // 响应新文件
    }
    key.reset();
}

生产者只需在目录创建文件，消费者会自动检测处理。

⚠️ 关键点：确保文件创建事件在完全写入后才触发。推荐做法：

先写入临时目录
完成后原子移动到目标目录（多数文件系统同分区移动是原子操作）

3.3 命名管道

命名管道（Named Pipes）是特殊的文件系统条目，但不占用存储空间，它本质是读写进程间的数据管道。

消费者进程通过标准文件IO打开命名管道：

BufferedReader reader = new BufferedReader(new FileReader(file));

String line;
while ((line = reader.readLine()) != null) {
    // 处理读取的行
}

写入管道的数据会被消费者立即读取。生产者进程像普通文件一样写入即可。

❌ 缺陷：Java无法直接创建命名管道，需先用OS命令创建。Linux系统使用：

$ mkfifo /tmp/ipc-namedpipe

随后在Java中使用/tmp/ipc-namedpipe路径。

4. 基于网络的IPC

前述方案依赖共享文件系统，要求进程运行在同一台机器。当需要跨主机通信时，需转向网络方案——本质上是一个进程运行网络服务器，另一个运行客户端。

4.1 原生Socket

最直接的网络IPC方案是使用Socket通信。可选用JDK原生Socket支持或Netty等框架。

消费者进程启动服务器监听已知端口，处理连接和消息：

try (ServerSocket serverSocket = new ServerSocket(1234)) {
    Socket clientSocket = serverSocket.accept();

    PrintWriter out = new PrintWriter(clientSocket.getOutputStream(), true);
    BufferedReader in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));

    String line;
    while ((line = in.readLine()) != null) {
        // 处理接收的行
    }
}

生产者进程发送消息实现通信：

try (Socket clientSocket = new Socket(host, port)) {
    PrintWriter out = new PrintWriter(clientSocket.getOutputStream(), true);
    BufferedReader in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));

    out.println(msg);
}

✅ 优势：相比文件方案，天然支持双向通信。

4.2 JMX

原生Socket需要处理大量底层细节，JMX提供了更高级的抽象。虽底层仍使用网络，但开发者只需关注MBean操作。

消费者进程需注册MBean到JVM的MBeanServer：

先定义MBean接口：

public interface IPCTestMBean {
    void sendMessage(String message);
}

class IPCTest implements IPCTestMBean {
    @Override
    public void sendMessage(String message) {
        // 处理消息
    }
}

注册到MBeanServer：

ObjectName objectName = new ObjectName("com.baeldung.ipc:type=basic,name=test");

MBeanServer server = ManagementFactory.getPlatformMBeanServer();
server.registerMBean(new IPCTest(), objectName);

生产者通过JMXConnectorFactory发送消息：

JMXServiceURL url = new JMXServiceURL("service:jmx:rmi:///jndi/rmi://localhost:1234/jmxrmi");
try (JMXConnector jmxc = JMXConnectorFactory.connect(url, null)) {
    ObjectName objectName = new ObjectName("com.baeldung.ipc:type=basic,name=test");

    IPCTestMBean mbeanProxy = JMX.newMBeanProxy(jmxc.getMBeanServerConnection(), objectName, IPCTestMBean.class, true);
    mbeanProxy.sendMessage("Hello");
}

⚠️ 注意：消费者进程需添加JVM参数暴露JMX端口：

-Dcom.sun.management.jmxremote=true
-Dcom.sun.management.jmxremote.port=1234
-Dcom.sun.management.jmxremote.authenticate=false
-Dcom.sun.management.jmxremote.ssl=false

5. 消息中间件

前述方案适用于简单场景。当需要：

多个消费者
动态路由
高可靠性等复杂需求时，需引入专业消息中间件，如：
JMS
AMQP
Kafka

这些方案支持分布式系统中大规模消息传递，但复杂度也相应提升。

6. 总结

我们探讨了多种Java IPC实现方案，覆盖了从共享文件到企业级消息中间件的全场景。主要方案对比：

方案	适用场景	优势	限制
共享文件	同机简单通信	实现简单	需处理并发，低效
命名管道	同机实时流式通信	低延迟	跨平台支持差
Socket	跨机双向通信	灵活通用	需处理协议细节
JMX	Java应用监控管理	与JVM集成	仅限Java生态
消息中间件	分布式大规模系统	高可靠、可扩展	架构复杂，运维成本高

下次设计多进程协作时，根据实际需求选择合适的IPC方案吧！

本文所有代码可在GitHub仓库获取。

Persistence

REST

Security