新手求教：如何在OSGi Apache Felix应用中调用Bundle服务

嘿，作为OSGi新手能把两个依赖不同库的Bundle成功加载运行，已经迈出超关键的一步啦！针对你问的如何用BundleContext、ServiceReference这套方式调用服务，我给你拆解成具体步骤和实用场景，帮你快速上手～

这是教程里最常见的写法，适合你已经确认服务存在的场景：

1. 获取BundleContext #

你有两种常见方式拿到它：

• 如果你的Project C本身也是一个Bundle，那可以在BundleActivator的start方法里直接拿到参数里的BundleContext：

  public class CActivator implements BundleActivator {
      @Override
      public void start(BundleContext context) throws Exception {
          // 这里就可以直接用context来操作服务
          callMyService(context);
      }
  }
  

• 如果是直接操控Felix框架实例，也可以从框架获取：

  Framework framework = new Felix(config);
  framework.start();
  BundleContext context = framework.getBundleContext();
  

2. 获取ServiceReference #

因为你有两个Bundle都注册了MyService，这里分两种情况：

情况1：随便获取一个可用的服务 #

直接根据接口类获取即可，OSGi会返回排序后的第一个可用服务：

ServiceReference<MyService> serviceRef = context.getServiceReference(MyService.class);

情况2：指定获取某个Bundle提供的服务 #

如果需要精准调用Bundle A或Bundle B的服务，你可以给服务注册时添加自定义属性，然后用过滤条件筛选：

• 先看Bundle A注册服务时的代码（Bundle B同理）：

  // 注册服务时添加自定义属性，比如标记来源Bundle
  Hashtable<String, Object> serviceProps = new Hashtable<>();
  serviceProps.put("bundle.symbolicName", "com.example.bundleA");
  serviceProps.put("service.version", "1.0");
  context.registerService(MyService.class, new MyServiceImplA(), serviceProps);
  

• 然后在Project C里用过滤条件获取指定服务：

  // 过滤出Bundle A提供的服务
  String filter = "(bundle.symbolicName=com.example.bundleA)";
  Collection<ServiceReference<MyService>> refs = context.getServiceReferences(MyService.class, filter);
  if (!refs.isEmpty()) {
      ServiceReference<MyService> targetRef = refs.iterator().next();
      // 后续获取服务实例
  }
  

3. 获取服务实例并调用 #

拿到ServiceReference后，就可以获取实际的服务对象并调用方法了：

if (serviceRef != null) {
    MyService myService = context.getService(serviceRef);
    if (myService != null) {
        // 调用服务方法
        myService.yourServiceMethod();
        // 用完记得释放服务，避免内存泄漏
        context.ungetService(serviceRef);
    }
}

因为OSGi是动态模块化框架，服务可能随时上线或下线，用ServiceTracker可以自动监听服务的生命周期，比手动获取更稳妥：

public class MyServiceTracker extends ServiceTracker<MyService, MyService> {
    public MyServiceTracker(BundleContext context) {
        // 可以传入过滤条件，比如只监听Bundle A的服务
        super(context, "(bundle.symbolicName=com.example.bundleA)", null);
    }

    @Override
    public MyService addingService(ServiceReference<MyService> reference) {
        MyService service = super.addingService(reference);
        // 服务上线时自动触发，在这里调用服务方法
        if (service != null) {
            service.yourServiceMethod();
        }
        return service;
    }

    @Override
    public void removedService(ServiceReference<MyService> reference, MyService service) {
        // 服务下线时触发，可以做清理工作
        super.removedService(reference, service);
    }
}

// 在Project C里启动Tracker
MyServiceTracker tracker = new MyServiceTracker(context);
tracker.open();
// 不需要时关闭Tracker
// tracker.close();

• 一定要记得调用ungetService释放服务，尤其是手动获取的场景，否则会导致服务无法被正确销毁，引发内存泄漏。
• 如果你的MyService接口是单独打包的Jar，要确保Project C也依赖这个接口Jar，并且所有Bundle都能正确访问到这个接口类（OSGi里要注意类加载的可见性，通常接口Jar要做成一个单独的Bundle，或者通过Export-Package/Import-Package配置好）。

内容的提问来源于stack exchange，提问作者Laborious Fox