1

我最近开始研究 OSGi 框架。我有一个名为 Bundle-A 的捆绑包。我想从我的主应用程序中调用 Bundle-A jar 中的一种方法。

我已经从我的主应用程序加载并安装了 Bundle-A。下面是我安装 Bundle-A 的主要应用程序的代码。

private void initializeModelFramework() {

    try {

        FileUtils.deleteDirectory(new File("felix-cache"));
        FrameworkFactory frameworkFactory = ServiceLoader.load(FrameworkFactory.class).iterator().next();

        Framework framework = frameworkFactory.newFramework(new HashMap<String, String>());
        framework.start();

        BundleContext bundleContext = framework.getBundleContext();

        modulesNameVersionHolder.put("Bundle-A", "1.0.0");

        List<Bundle> installedBundles = new LinkedList<Bundle>();

        String basePath = "C:\\ClientTool\\LocalStorage";

        for (Map.Entry<String, String> entry : modulesNameVersionHolder.entrySet()) {
            String version = entry.getValue();
            final String filename = name + Constants.DASH + version + Constants.DOTJAR;
            final String localFilename = GoldenModulesConstants.FILE_PROTOCOL + basePath+ File.separatorChar + filename;

            installedBundles.add(bundleContext.installBundle(localFilename));
        }   

        for (Bundle bundle : installedBundles) {
            bundle.start();// this will start bundle A
        }

        // After starting the Bundle-A, now I need to call one of the methods in Bundle-A
        for(int i=0; i<=10; i++) {
            //call processingEvents method of Bundle-A class GoldenModelFramework
        }
    } catch (Exception e) {
        e.printStackTrace();
    }

现在 Bundle-A 已经启动。下面是我的 Bundle-A 激活器类。

public class Activator implements BundleActivator {

    private static final String BUNDLE_VERSION_KEY = "Bundle-Version";
    private static Logger s_logger = Logger.getLogger(Activator.class.getName());

    @Override
    public void start(BundleContext context) throws Exception {

        final Bundle bundle = context.getBundle();
        final String bundleName = bundle.getSymbolicName();
        final String bundleVersion = (String) bundle.getHeaders().get(BUNDLE_VERSION_KEY);

        System.out.println(bundleName+" - "+bundleVersion);
    }

    @Override
    public void stop(BundleContext context) throws Exception {
            System.out.println("Bye.!");
    }
}

下面是我在 Bundle-A jar 中的类。processingEventsBundle-A 启动后,我需要从上面的主应用程序代码中调用方法。

public class GoldenModelFramework {

    private static final Logger LOGGER = Logger.getLogger(GoldenModelFramework.class.getName());
    private static final long checkingAfterEveryXMinutes = 15L;


    public GoldenModelFramework() {
        // following the traditions
    }

    public static void processingEvents(final String item) {

        for (BundleRegistration.HolderEntry entry : BundleRegistration.getInstance()) {
            final String response = entry.getPlugin().process(item);
            System.out.println(response);
        }
    }
}

我不确定正确的方法是什么?我知道一种方法是在我的主应用程序 pom.xml 文件中添加这个 Bundle-A 的依赖项,因为我正在使用基于 maven 的项目。但我不认为这是正确的做法。因为最终,我将有更多的捆绑包,所以应该有一些其他的方法来解决这个问题,我不知道。

我应该在这里使用 ServiceListener 或 ServiceTracker 吗?基于我的代码的任何简单示例都将帮助我更好地理解。谢谢。

我希望这个问题足够清楚。我试图在 Bundle-A 加载和安装后调用其中的一种方法。

4

1 回答 1

3

你有几个选择:

动态导入包

您可以使用 DynamicImport-Package 而不是 Import-Package。在这种情况下,当主包启动时,包 A 不必处于活动状态。虽然这可行,但我不推荐此解决方案,因为我不喜欢 DynamicImport-Package。在这种情况下,当然包 A 必须是主包的依赖项。

使用反射

您可以使用反射调用您想要的方法,如下所示(草稿示例):

Class<GoldenModelFramework> clazz = bundleA.loadClass("GoldenModelFramework");
Method m = clazz.getMethod("processingEvents", String.class);
m.execute(null, myParam);

这有点好,但是这个解决方案仍然有点模糊,我不会说这是一个干净的代码。

使用接口和 OSGi 服务

最干净的方法需要一些重构。在这种情况下,您应该创建一个接口,并在捆绑包 A 的 Activator 中注册一个基于该接口的服务。在主包中,您应该使用服务跟踪器来捕获该服务并调用它的方法。

如果你真的想让你的方法 processEvent 静态,注册的服务对象(基于接口)应该简单地调用里面的静态方法。

不必将包 A 作为依赖项添加到主包中,应将接口放入第三个包中,该包是主包和 A 包的依赖项。

虽然这个解决方案似乎是最复杂的,但我建议这个解决方案。

一个例子:

创建一个接口并将其放入一个新的包中,如 Goldenframework-api。

public interface GoldenModelFrameworkOSGi {
    void processingEvents(final String item);
}

Goldenframework-api 将是主捆绑包和捆绑包-A 的依赖项。主包将使用它,而 bundle-A 将实现它。

下面是 bundle A 的实现方式:

public class GoldenFrameworkOSGiImpl {
    public void processingEvents(final String item) {
        GoldenModelFramework.processEvents(item);
    }
}

在 bundle-A 中创建一个 Activator 类(我将在该激活器中省略您的代码以减少输入):

public class Activator {
  private ServiceRegistration goldenFrameworkSR;

  @Override
  public void start(BundleContext context) {
    goldenFrameworkSR = context.registerService(GoldenFrameworkOSGi.class, new GoldenFrameworkOSGi(), new HashTable());
  }

  @Override
  public void stop(BundleContext context) {
    goldenFrameworkSR.unregister();
  }
}

如您所知 Bundle-A 的代码,您可以作弊。当 bundle-A 处于活动状态时,您可以确定您需要的服务已注册。但是,将来您应该考虑基于事件工作(例如使用 ServiceTracker)。我的意思是这将是一个不好的做法:):

ServiceReference sr = context.getServiceReference(GoldenServiceOSGi.class);
GoldenServiceOSGi gs = context.getService(sr);
gs.processEvents(...);
context.ungetService(sr);

这可能会暂时解决您的问题,您可以继续您的工作。但是,请考虑阅读诸如“OSGi in Action”之类的书,以了解 OSGi 包和服务生命周期,以便您可以重新设计您的框架。

于 2013-08-18T15:27:59.607 回答