java - 在java中使用py4j从java调用script.py

Question

我想在java中实时运行脚本python（kafka流）所以我在python中安装py4j：

!pip install py4j 

然后我从 github 下载 py4j 项目，这是我运行的一个 maven 项目

mvn install 

我复制 py4j.jar 并复制到我的 java 项目的外部库中

现在我在java中实现服务器py4j

public class StackEntryPoint {
private Stack stack;

public StackEntryPoint() {
    stack = new Stack();
    stack.push("Initial Item");
}

public Stack getStack() {
    return stack;
}

public static void main(String[] args) throws IOException {
    GatewayServer gatewayServer = new GatewayServer(new StackEntryPoint(),25335);
    gatewayServer.start();
    System.out.println("Gateway Server Started");
    
}

我的问题是如何在 java 项目中调用 myscript.py

标签： javapythonapache-kafka-streamspy4j