Интерфейс обратного вызова Py4J выдает «Неверное имя интерфейса», когда упакованный .jar используется в качестве плагина - PullRequest
Новая
       7

Интерфейс обратного вызова Py4J выдает «Неверное имя интерфейса», когда упакованный .jar используется в качестве плагина

0 голосов
/ 13 ноября 2018

Мой код точно такой же, как в примере, показанном на сайте py4j:

Реализация Java-интерфейсов из Python

За исключением того, что все мои классы находятся в одном и том же src.Пакет main.java

(см. код ниже)

Проблема: Если я выполняю сборку grad fatjar с ListenerApplication в качестве основной, затем выполняю jar, все работаетхорошо.Если я выполняю сборку grad fatjar и вместо этого получаю доступ к коду через интерфейс плагина, я получаю следующую ошибку: 

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)

Вопрос: Почему у Py4J возникают проблемы с поиском «ExampleListener», когда.jar запускается как плагин, а не как приложение?Я даже могу добавить: 

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

к приложению Listener, которое вернет правильный интерфейс как при запуске в качестве плагина, так и в качестве приложения!Интересно то, что, если я запускаю программу плюс плагин из IDE NetBeans, все работает отлично!Netbeans каким-то образом предоставляет интерфейс, в то время как приложение запускается напрямую?

Интерфейс плагина 

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);
    }
}

Слушатель питона 

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()

1 Ответ

0 голосов
/ 25 июля 2019

Для тех, кто заинтересован, это была проблема загрузчика классов, которая, по-видимому, распространена для плагинов / приложений OSGI.

См. Ответ сопровождающего: https://github.com/bartdag/py4j/issues/339#issuecomment-473655738

Я просто добавилследующий к конструктору ListenerApplication на стороне Java: 

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