OSGi/蓝图中的服务引用无法正常工作

Question

我目前有两个 OSGi 捆绑包（bundle1 和 bundle2），两者都通过 EBA 中的蓝图公开服务。在 bundle2 的 blueprint.xml 中，我想引用 bundle1 中的服务并将其注入到 BuildService 中（代码如下），因为 BuildService 将用于调用 TicketService。然而，这会导致超时异常（也在下文中）。似乎 BuildService 从未在 OSGi 中注册。我该如何做这样的事情？

bundle1 的 blueprint.xml：

<?xml version="1.0" encoding="UTF-8"?>
<blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0" xmlns:bptx="http://aries.apache.org/xmlns/transactions/v1.0.0">

    <bean id="TicketServiceBean" class="com.example.b2.impl.TicketServiceImpl">
        <bptx:transaction value="Required" method="*" />
    </bean>

        <service ranking="0" id="TicketService" interface="com.example.b2.service.TicketService" ref="TicketServiceBean">
        <service-properties>
            <entry key="service.exported.interfaces" value="*" />
        </service-properties>
    </service>  

</blueprint>

bundle2 的 blueprint.xml

<?xml version="1.0" encoding="UTF-8"?>
<blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0">

    <bean 
        id="BuildServiceImplBean"
        class="com.example.b1.impl.BuildServiceImpl" 
        activation="eager" >
        <property name="ticketService" ref="TicketServiceRef" />
    </bean>  


    <service    
        id="BuildService" 
        ref="BuildServiceImplBean"
        interface="com.example.b1.service.BuildService"
        activation="eager"> 

        <service-properties>
            <entry key="service.exported.interfaces" value="*" />
        </service-properties>

    </service>



    <reference 
        id="TicketServiceRef" 
        interface="com.example.b2.service.TicketService" 
        availability="mandatory"
        activation="eager" />


</blueprint>

BuildService 的实现：

public class BuildServiceImpl implements BuildService {

    private TicketService ticketService;

    @Override
    public TicketBuildResponse ticketBuild(TicketBuildRequest ticketBuildRequest) throws BuildServiceException {

        //do stuff here
    }



    public TicketService getTicketService() {
        return ticketService;
    }

    public void setTicketService(TicketService ticketService) {
        this.ticketService = ticketService;
    }


}

启动应用程序服务器时（Websphere）我得到以下异常：

  BlueprintCont E org.apache.aries.blueprint.container.BlueprintContainerImpl$1 run Unable to start blueprint container for bundle com.example.b1.module due to unresolved dependencies [(objectClass=com.example.b2.service.TicketService)]
                                     java.util.concurrent.TimeoutException
        at org.apache.aries.blueprint.container.BlueprintContainerImpl$1.run(BlueprintContainerImpl.java:273)
        at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:453)
        at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:315)
        at java.util.concurrent.FutureTask.run(FutureTask.java:150)
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:98)
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:207)
        at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
        at java.lang.Thread.run(Thread.java:736)

Answer 1

解决方案如下：由于默认调用语义不同（本地按引用传递与远程按值传递），OSGi 应用程序运行时以不同方式对待远程服务和本地服务。为了防止应用程序意外调用仅为传递值调用而设计的导出服务，它在本地查找中被隐藏。

解决方案是导出同一个 bean 两次，一次用于远程调用，第二次用于本地。换句话说，您将添加另一个具有相同配置的 元素，但没有 service.exported.interfaces 属性。

<service ranking="0" id="TicketServiceExport" interface="com.example.b2.service.TicketService" ref="TicketServiceBean">
    <service-properties>
        <entry key="service.exported.interfaces" value="*" />
    </service-properties>
</service>  

<service ranking="0" id="TicketService" interface="com.example.b2.service.TicketService" ref="TicketServiceBean"/>

实际上，websphere 中还有一个 osgi 控制台，可以在 [本地 websphere 安装]/profiles/[profileName]/bin/osgiApplicationConsole.bat 下找到。启动后，help() 会为您提供命令列表。要查看从 SCA 导入的服务，您首先连接到您的应用程序（例如 connect(2)），其中应用程序的编号在 list() 的结果中给出> 命令）。然后，您可以执行 services("(service.imported=true)") 来查看 SCA 添加的服务代理。命令 services() 将列出应用程序中的所有服务。