java - 使用打包的.jar作为插件时Py4J回调接口(interface)抛出 "Invalid interface name"

标签 java interface callback py4j fatjar

我的代码与 py4j 网站上显示的示例完全相同:

Implementing Java Interfaces from Python

除了我的类都在同一个 src.main.java 包中

(代码见下文)

问题: 如果我使用 ListenerApplication 作为 main 进行 gradle fatjar 构建,然后执行 jar,一切正常。如果我执行 gradle fatjar 构建并通过插件接口(interface)访问代码,则会收到以下错误:

Py4JError: An error occurred while calling o0.registerListener. Trace:
py4j.Py4JException: Invalid interface name: ExampleListener
    at py4j.Protocol.getPythonProxy(Protocol.java:429)
    at py4j.Protocol.getObject(Protocol.java:311)
    at py4j.commands.AbstractCommand.getArguments(AbstractCommand.java:82)
    at py4j.commands.CallCommand.execute(CallCommand.java:77)
    at py4j.GatewayConnection.run(GatewayConnection.java:238)
    at java.lang.Thread.run(Thread.java:748)

问题:当 .jar 作为插件而不是作为应用程序运行时,为什么 Py4J 在查找“ExampleListener”时出现问题?我什至可以添加:

public String classtest() throws Exception {
    System.out.println("classtest called");
    Class<?> py = Class.forName("ExampleListener");
    return py.toString();
}

到 ListenerApplication,当作为插件和应用程序运行时,它将返回正确的界面!有趣的是,如果我从 netbeans IDE 运行程序和插件,一切都会正常! Netbeans 是否会以某种方式公开接口(interface),而应用程序直接运行却不会?

插件界面

import org.micromanager.MenuPlugin;
import org.micromanager.Studio;
import org.scijava.plugin.Plugin;
import org.scijava.plugin.SciJavaPlugin;
import py4j.GatewayServer;

@Plugin(type = MenuPlugin.class)
public class Py4JPluginInterface implements MenuPlugin, SciJavaPlugin{
    private static final String menuName = "Simpletest_gradle";
    private static final String tooltipDescription = "py4j gateway";
    private static final String version =  "0.1";
    private static final String copyright = "copyright";

    @Override
    public String getSubMenu() {
        return "Simpletest_gradle";
    }

    @Override
    public void onPluginSelected() {
        GatewayServer gatewayServer = new GatewayServer(new ListenerApplication());
        gatewayServer.start();
        System.out.println("Gateway Started at IP:port = "+gatewayServer.getAddress()+":"+gatewayServer.getPort());
    }

    @Override
    public void setContext(Studio app) {
    }

    @Override
    public String getName() {
        return menuName;
    }

    @Override
    public String getHelpText() {
        return tooltipDescription;
    }

    @Override
    public String getVersion() {
        return version;
    }

    @Override
    public String getCopyright() {
        return copyright;
    }

}

界面:

//py4j/examples/ExampleListener.java
package py4j.examples;

public interface ExampleListener {

    Object notify(Object source);

}

应用程序:

package py4j.examples;

import py4j.GatewayServer;

import java.util.ArrayList;
import java.util.List;

public class ListenerApplication {

    List<ExampleListener> listeners = new ArrayList<ExampleListener>();

    public void registerListener(ExampleListener listener) {
        listeners.add(listener);
    }

    public void notifyAllListeners() {
        for (ExampleListener listener: listeners) {
            Object returnValue = listener.notify(this);
            System.out.println(returnValue);
        }
    }

    @Override
    public String toString() {
        return "<ListenerApplication> instance";
    }

    public static void main(String[] args) {
        ListenerApplication application = new ListenerApplication();
        GatewayServer server = new GatewayServer(application);
        server.start(true);
    }
}

Python 监听器

from py4j.java_gateway import JavaGateway, CallbackServerParameters


class PythonListener(object):

    def __init__(self, gateway):
        self.gateway = gateway

    def notify(self, obj):
        print("Notified by Java")
        print(obj)
        gateway.jvm.System.out.println("Hello from python!")

        return "A Return Value"

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

if __name__ == "__main__":
    gateway = JavaGateway(
        callback_server_parameters=CallbackServerParameters())
    listener = PythonListener(gateway)
    gateway.entry_point.registerListener(listener)
    gateway.entry_point.notifyAllListeners()
    gateway.shutdown()

最佳答案

对于那些感兴趣的人来说,这是一个类加载器问题,这对于插件/OSGI 应用程序来说显然很常见。

查看维护者的回复: https://github.com/bartdag/py4j/issues/339#issuecomment-473655738

我只是将以下内容添加到 Java 端 ListenerApplication 构造函数中:

    RootClassLoadingStrategy rmmClassLoader = new RootClassLoadingStrategy();
    ReflectionUtil.setClassLoadingStrategy(rmmClassLoader);

关于java - 使用打包的.jar作为插件时Py4J回调接口(interface)抛出 "Invalid interface name",我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/53288375/

相关文章:

java - 如何在hibernate连接映射上指定固定参数?

c# - 逆变接口(interface)实现顺序

java - 接口(interface)只是为了抽象吗?

reflection - MEF:加载具有不同属性的部件(插件)

javascript - Node.JS - 如何转义多个嵌套回调?

java - 如何在注释的数组值中保留换行符

java - Toplink 对象未显示在 JDeveloper 中的 Toplink Map 节点下

java - 如何在android中解析这种XML

JavaScript 回调范围

c++ - 带/不带类的回调函数指针 C++