如何在Spring集成应用程序中实现SmartLifecycleRoleController

Question

我正在编写基于int-IP：TCPendpoint的客户机-服务器应用程序。用Kotlin写的代码。应用程序包含两个tcp clienst,当它们首先建立了与服务器的连接并进行了一些初始化时，它们应该按照sertain顺序一个接一个地连接到服务器。

作为这种同步的解决方案，我想使用SmartLifecyclerOleController启动依赖tcp客户端的endpoint组。为此，在depended（第二个）客户机中，我将role=“rccluster”和auto-startup=“false”属性添加到tcp-outbound-channel-adapter和tcp-inbound-channel-adapter

<int-ip:tcp-connection-factory id="rcClientConnectionFactory"
                               type="client"
                               host="${tdirelay.host}"
                               port="${tdirelay.rcPort}"
                               single-use="false"
                               so-timeout="10000"
                               so-keep-alive="false"
                               serializer="rawSerializerDeserializer"
                               deserializer="rawSerializerDeserializer"
                               ssl-context-support="sslContext"/>


<int-ip:tcp-outbound-channel-adapter id="rcOutBoundAdapter"
                                     channel="rcPacketQueueChannel"
                                     phase="5000"
                                     connection-factory="rcClientConnectionFactory"
                                     role="rcCluster"
                                     auto-startup="false"
/>


<int-ip:tcp-inbound-channel-adapter id="rcInboundAdapter"
                                    channel="rcFromServer"
                                    client-mode="true"
                                    retry-interval="5000"
                                    connection-factory="rcClientConnectionFactory"
                                    role="rcCluster"
                                    auto-startup="false"


/>  

前导（第一个）tcp客户端使用拦截器endpoint根据以下协议与服务器进行序幕交换：

<bean id="dcInterceptorFactoryChain"
      class="org.springframework.integration.ip.tcp.connection.TcpConnectionInterceptorFactoryChain">
    <property name="interceptors">
        <array>
            <bean class="com.tcpclient.DirectCannel.DCConnectionInterceptorFactory">
            </bean>
        </array>
    </property>
</bean>


<int-ip:tcp-connection-factory id="dcClientConnectionFactory"
                               type="client"
                               host="${tdirelay.host}"
                               port="${tdirelay.dcPort}"
                               single-use="false"
                               so-timeout="10000"
                               so-keep-alive="false"
                               interceptor-factory-chain="dcInterceptorFactoryChain"
                               serializer="rawSerializerDeserializer"
                               deserializer="rawSerializerDeserializer"
                               ssl-context-support="sslContext"
/>

我计划在我的拦截器类中调用SmartLifecyclerOleController的StartLifecyclesInRole（String role)和StoplifecyclesInRole（String role)方法。因此，我将@Autowired private val RoleController：SmartLifecycleRoleController添加到InterceptorFactory中，正如Spring-Integration/docs中所解释的那样

我的拦截工厂是：

class DCConnectionInterceptorFactory() : TcpConnectionInterceptorFactory, ApplicationEventPublisherAware {

    @Autowired
    private val roleController: SmartLifecycleRoleController? = null

    @Volatile
    private var applicationEventPublisher: ApplicationEventPublisher? = null

    override fun setApplicationEventPublisher(applicationEventPublisher: ApplicationEventPublisher) {
        this.applicationEventPublisher = applicationEventPublisher
    }

    override fun getInterceptor(): TcpConnectionInterceptorSupport {
        return DCConnectionInterceptor(this.applicationEventPublisher!!, roleController!!)
    }
}

IntelliJ的想法给出警告：不能自取灭亡。未找到“SmartLifecyclerOleController”类型的bean

如果您知道如何做到这一点，请提供一个在xml配置文件中使用SmartLifecyclerOleController类bean的实例。

Answer 1

首先，最好不要在那里使用@autowired，因为不清楚在应用程序上下文中是否启用了注释配置。仅仅因为您只显示了Spring的XML配置。

因此，您的DCConnectionInterceptorFactory应该为RoleController属性设置一个设置器。或者在Kotlin中声明Java bean属性的正确方法是什么...

然后您需要在XML配置中使用如下内容：

<bean class="com.tcpclient.DirectCannel.DCConnectionInterceptorFactory">
    <property name="roleController" ref="integrationLifecycleRoleController"/>
</bean>