以对象模型作为参数启动 java 程序答案

【问题标题】：Start a java program with an object model as parameter以对象模型作为参数启动 java 程序
【发布时间】：2009-07-19 18:44:11
【问题描述】：

服务器侦听端口，等待来自客户端的传入请求（客户端实际上是一个 ejb）。这些请求将完整的对象模型作为参数传递（例如，员工列表、每个员工的任务列表等）。

现在服务器必须在同一台机器上在新的 JVM 实例中启动另一个 java 程序，并使用这个对象模型作为参数。

这个其他 java 程序应该是一个独立的 java 程序，但我不能将对象模型作为参数传递给 main 方法 (void main(String[] args))。

那该怎么办？我正在寻找一个“简单”的解决方案，例如最好没有用于持久性的数据库或文件。独立程序确实是 cpu 密集型的，不能由应用服务器托管。

谢谢。

【问题讨论】：

标签： java remoting

【解决方案1】：

运行应用程序并捕获其输入/输出流，然后通过它流式传输序列化的对象模型。新应用程序应该反序列化来自 System.in 的输入。

概念示例（我只是想确保我的示例有效，抱歉耽搁了）：

package tests;

import java.io.File;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;

public class AppFirst {
    public static void main(String[] args) throws Exception {
        ProcessBuilder pb = new ProcessBuilder("java", "-cp", 
            "./bin", "tests.AppSecond");
        pb.directory(new File("."));
        pb.redirectErrorStream(true);
        Process proc = pb.start();

        ObjectOutputStream out = new ObjectOutputStream(
            proc.getOutputStream());
        ObjectInputStream oin = null;

        for (int i = 0; i < 1000; i++) {
            out.writeObject("Hello world " + i);
            out.flush();
            if (oin == null) {
                oin = new ObjectInputStream(proc.getInputStream());
            }
            String s = (String)oin.readObject();
            System.out.println(s);
        }
        out.writeObject("Stop");
        out.flush();

        proc.waitFor();
    }
}

package tests;

import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;

public class AppSecond {
    public static void main(String[] args) throws Exception {
        ObjectInputStream oin = null;
        ObjectOutputStream out = new ObjectOutputStream(System.out);
        while (true) {
            if (oin == null) {
                oin = new ObjectInputStream(System.in);
            }
            String s = (String)oin.readObject();
            if ("Stop".equals(s)) {
                break;
            }
            out.writeObject("Received: " + s);
            out.flush();
        }
    }
}

编辑：添加了循环版本。请注意，OOS 需要一个技巧，因为它会立即开始读取传入的流（并阻止您的应用程序如果您在错误的步骤中执行此操作 - 它应该在第一个 AFTER 之后包装对象被发送到子进程）。

【讨论】：

您的解决方案与“乔治四世”建议的解决方案相比如何？如果请求很多，这个解决方案也能执行吗？
坦率地说，我从未尝试将多个对象写入 OOS。您可以将两个示例应用程序中的请求和响应对包装到一个 for 循环中并执行 1000 次。我现在会检查并返回。
@akarnokdthis 对我不起作用。你能帮我解决这个问题吗？我正在从大量数据中生成碧玉报告。但它永远在等待。最后，应用程序挂起，最后不得不终止进程。

【解决方案2】：

看看RMI。您的服务器可以启动新服务，该服务又将自身发布并导出到本地注册表。然后，您的新服务可以接收对象模型作为远程扩展方法的参数。应该非常简单，不需要文件访问或附加服务，并且不比任何其他答案更重要。

【讨论】：

【解决方案3】：

您可以序列化对象并将其写入文件系统。然后，您可以在运行时读入该序列化对象。或者，您可以使用 JMS 将该对象作为字节流传输。