0

我正在使用py4j进行python和java之间的通信。我可以从java端调用python方法。但是从 python 我无法发送任何对象或调用 java 方法。这是我尝试过的代码。

我的java代码:

public interface IHello {
    public String sayHello();

    public String sayHello(int i, String s);

//    public String frompython();

}

//ExampleClientApplication.java
package py4j.examples;

import py4j.GatewayServer;
import java.io.BufferedReader;
import java.io.InputStreamReader;

public class ExampleClientApplication extends Thread {

public void run(){
    System.out.println("thread is running...");
}

public static void main(String[] args) {
    BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
    GatewayServer.turnLoggingOff();
    GatewayServer server = new GatewayServer();
    server.start();
    IHello hello = (IHello) server.getPythonServerEntryPoint(new Class[] { IHello.class });
    try {
        System.out.println("Please enter a string");
        String str = br.readLine();
        System.out.println(hello.sayHello(1, str));
    } catch (Exception e) {
        e.printStackTrace();
    }
    ExampleClientApplication t1 = new ExampleClientApplication();
    t1.start();
    //server.shutdown();
  }
}

我的python代码:

class SimpleHello(object):
    def sayHello(self, int_value=None, string_value=None):
        print(int_value, string_value)
        return "From python to {0}".format(string_value)

class Java:
    implements = ["py4j.examples.IHello"]

# Make sure that the python code is started first.
# Then execute: java -cp py4j.jar 
py4j.examples.SingleThreadClientApplication

from py4j.java_gateway import JavaGateway, CallbackServerParameters
simple_hello = SimpleHello()

gateway = JavaGateway(
callback_server_parameters=CallbackServerParameters(),
python_server_entry_point=simple_hello)
4

1 回答 1

0

通过在 python 实现的 java 接口中实现 getter/eval 方法可以轻松解决发送对象问题,然后可以从 java 调用该方法以获取请求的变量。例如,请查看此处的 py4j 实现:https ://github.com/subes/invesdwin-context-python

具体看这里的get/eval方法实现:https ://github.com/subes/invesdwin-context-python/blob/master/invesdwin-context-python-parent/invesdwin-context-python-runtime-py4j/src/主/java/de/invesdwin/context/python/runtime/py4j/pool/internal/Py4jInterpreter.py

相反,您必须在 java 网关类上做同样的事情,并提供一个可以从 python 调用的 get/eval 方法。实际的java代码可以在groovy的ScriptEngine中执行,结果可以返回给python。(见http://docs.groovy-lang.org/1.8.9/html/groovy-jdk/javax/script/ScriptEngine.html

虽然决定主/从角色可能是一个更好的主意,并且只输入一次参数,然后在 python 中执行代码并检索一次结果。或者如果python应该领先,则反过来。因此,您将大大减少通信开销。为了更紧密的集成而不会像 py4j 那样造成性能损失,您应该查看https://github.com/mrj0/jep以将 python 库直接加载到 java 进程中。然后每次通话不再那么昂贵。

于 2017-06-09T10:44:17.240 回答