我目前正在尝试设置我自己的ManagedServiceFactory
. 这是我正在尝试做的事情:我需要基于每个配置的某些服务的多个实例。使用 DS,组件可以完美运行,但现在我发现这些服务应该根据某些外部资源的可用性来处理自己的生命周期(即在服务注册表中(取消)注册),而这在 DS 中是不可能的。
因此,我的想法是创建一个ManagedServiceFactory
,然后它将接收来自ConfigurationAdmin
我的类的配置并创建实例。这些将再次尝试在单独的线程中连接到资源,并在准备好操作时将自己注册为服务。
由于我还没有实现这一点,我试图将所有内容分解为最基本的部分,甚至不处理动态(取消)注册,只是试图让其ManagedServiceFacotry
工作:
package my.project.factory;
import java.util.Dictionary;
import java.util.HashMap;
import java.util.Hashtable;
import java.util.Map;
import org.osgi.framework.BundleActivator;
import org.osgi.framework.BundleContext;
import org.osgi.framework.Constants;
import org.osgi.framework.ServiceRegistration;
import org.osgi.service.cm.ConfigurationException;
import org.osgi.service.cm.ManagedServiceFactory;
public class Factory implements BundleActivator, ManagedServiceFactory {
private ServiceRegistration myReg;
private BundleContext ctx;
private Map<String, ServiceRegistration> services;
@Override
public void start(BundleContext context) throws Exception {
System.out.println("starting factory...");
this.ctx = context;
java.util.Dictionary properties = new Hashtable<String, Object>();
properties.put(Constants.SERVICE_PID, "my.project.servicefactory");
myReg = context.registerService(ManagedServiceFactory.class, this,
properties);
System.out.println("registered as ManagedServiceFactory");
services = new HashMap<String, ServiceRegistration>();
}
@Override
public void stop(BundleContext context) throws Exception {
for(ServiceRegistration reg : services.values()) {
System.out.println("deregister " + reg);
reg.unregister();
}
if(myReg != null) {
myReg.unregister();
} else {
System.out.println("my service registration as already null " +
"(although it shouldn't)!");
}
}
@Override
public String getName() {
System.out.println("returning facotry name");
return "ServiceFactory";
}
@Override
public void updated(String pid, Dictionary properties)
throws ConfigurationException {
System.out.println("retrieved update for pid " + pid);
ServiceRegistration reg = services.get(pid);
if (reg == null) {
services.put(pid, ctx.registerService(ServiceInterface.class,
new Service(), properties));
} else {
// i should do some update here
}
}
@Override
public void deleted(String pid) {
ServiceRegistration reg = services.get(pid);
if (reg != null) {
reg.unregister();
}
}
}
现在,它应该从ConfigurationAdmin
for PID接收配置my.project.servicefactory
,不是吗?但它没有从ConfigurationAdmin
. 捆绑包已启动,服务已注册,在 Web 控制台中,我可以看到配置管理员持有对我的 ManagedServiceFactory 的引用。是否应该设置某个属性?接口规范不建议这样做。实际上我的实现与那里的示例或多或少相同。我不知道我在这里做错了什么,非常欢迎任何指向解决方案的指针。
另外,我最初考虑将ManagedServiceFactory
自身实现为 DS,这也应该是可能的,但我在同一点上失败了:没有配置由ConfigAdmin
.
更新
澄清问题:我认为这主要是一个配置问题。正如我所看到的,我应该能够为工厂指定两个 PID,一个标识工厂本身的配置(如果有的话),另一个通过这个工厂生产服务,我认为应该是factory.pid
. 但是框架常量不包含这样的东西。
更新2
在搜索了一下Felix Fileinstall源代码后,我发现当文件名中是否有a时,它对配置文件的处理方式不同-
。将配置文件命名为my.project.servicefactory.cfg
它不起作用,但命名的配置my.project.servicefactory-foo.cfg
并按my.project.servicefactory-bar.cfg
预期正确移交给了我的 ManagedServiceFactory,并且ServiceInterface
注册了多个服务。欢呼!
更新 3 根据 Neil 的建议,我将声明性服务部分放在一个新问题中,以限制该问题的范围。