Spring TCP 支持 - 获取异常 "No qualifying bean of type AbstractServerConnectionFactory"

Question

我不熟悉 Spring 集成和 Spring TCP 支持。我正在尝试启动

的 TCP 客户端

连接到 serverSocket。 ServerSocket 位于本地主机的 5678 端口
客户端向服务器发送消息并收到响应。

但是在运行 spring 基本示例时出现以下错误。

我已经对 %spring-samples%/basic/tcp-client-server.xml 代码进行了更改。变化是我在 tcpClientServerDemo-context.xml 中注释掉了服务器端。

变化如下。

    <?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:int="http://www.springframework.org/schema/integration"
    xmlns:int-ip="http://www.springframework.org/schema/integration/ip"
    xmlns:context="http://www.springframework.org/schema/context"
    xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd
        http://www.springframework.org/schema/integration http://www.springframework.org/schema/integration/spring-integration.xsd
        http://www.springframework.org/schema/integration/ip http://www.springframework.org/schema/integration/ip/spring-integration-ip.xsd">

    <context:property-placeholder />

    <!-- Client side -->

    <int:gateway id="gw"
        service-interface="org.springframework.integration.samples.tcpclientserver.SimpleGateway"
        default-request-channel="input" />

    <int-ip:tcp-connection-factory id="client"
        type="client"
        host="localhost"
        port="5678"
        single-use="true"
        so-timeout="10000"/>

    <int:channel id="input" />

    <int-ip:tcp-outbound-gateway id="outGateway"
        request-channel="input"
        reply-channel="clientBytes2StringChannel"
        connection-factory="client"
        request-timeout="10000"
        reply-timeout="10000"/>

    <int:object-to-string-transformer id="clientBytes2String"
        input-channel="clientBytes2StringChannel" />


    <!-- Server side ${availableServerSocket}-->
<!--
    <int-ip:tcp-connection-factory id="crLfServer"
        type="server"
        port="5678"/>

    <int-ip:tcp-inbound-gateway id="gatewayCrLf"
        connection-factory="crLfServer"
        request-channel="serverBytes2StringChannel"
        error-channel="errorChannel"/>

    <int:channel id="toSA" />

    <int:service-activator input-channel="toSA"
        ref="echoService"
        method="test"/>

    <bean id="echoService"
        class="org.springframework.integration.samples.tcpclientserver.EchoService" />

    <int:object-to-string-transformer id="serverBytes2String"
        input-channel="serverBytes2StringChannel"
        output-channel="toSA"/>
-->
    <int:transformer id="errorHandler"
        input-channel="errorChannel"
        expression="payload.failedMessage.payload + ':' + payload.cause.message"/>

</beans>

此更改后出现以下错误。

Exception in thread "main" org.springframework.beans.factory.NoSuchBeanDefinitionException: No qualifying bean of type [org.springframework.integration.ip.tcp.connection.AbstractServerConnectionFactory] is defined
    at org.springframework.beans.factory.support.DefaultListableBeanFactory.getBean(DefaultListableBeanFactory.java:372)
    at org.springframework.beans.factory.support.DefaultListableBeanFactory.getBean(DefaultListableBeanFactory.java:332)
    at org.springframework.context.support.AbstractApplicationContext.getBean(AbstractApplicationContext.java:1063)
    at org.springframework.integration.samples.tcpclientserver.Main.main(Main.java:77)

我能知道我错过了什么以及为什么我不应该错过它吗？

此外，当我运行只有 ServerSocket 时它工作正常。我是运行启用了服务器端的相同 Main 方法，但客户端在 tcpClientSererDemoContext.xml 中进行了评论。以下是监听输入的 serverSocket 的 xml 配置。我已经通过 Telnet 连接并作为服务激活器在 EchoService.java 中获得控制权来对此进行了测试。

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:int="http://www.springframework.org/schema/integration"
    xmlns:int-ip="http://www.springframework.org/schema/integration/ip"
    xmlns:context="http://www.springframework.org/schema/context"
    xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd
        http://www.springframework.org/schema/integration http://www.springframework.org/schema/integration/spring-integration.xsd
        http://www.springframework.org/schema/integration/ip http://www.springframework.org/schema/integration/ip/spring-integration-ip.xsd">

    <context:property-placeholder />

    <!-- Client side -->

<!--    <int:gateway id="gw"
        service-interface="org.springframework.integration.samples.tcpclientserver.SimpleGateway"
        default-request-channel="input" />

    <int-ip:tcp-connection-factory id="client"
        type="client"
        host="localhost"
        port="${availableServerSocket}"
        single-use="true"
        so-timeout="10000"/>

    <int:channel id="input" />

    <int-ip:tcp-outbound-gateway id="outGateway"
        request-channel="input"
        reply-channel="clientBytes2StringChannel"
        connection-factory="client"
        request-timeout="10000"
        reply-timeout="10000"/> -->

    <!-- int:object-to-string-transformer id="clientBytes2String"
        input-channel="clientBytes2StringChannel" 
        output-channel="clientInboundStringChannel"/-->

    <!-- Server side ${availableServerSocket} -->

    <int-ip:tcp-connection-factory id="crLfServer"
        type="server"
        port="5678"/>

    <int-ip:tcp-inbound-gateway id="gatewayCrLf"
        connection-factory="crLfServer"
        request-channel="serverBytes2StringChannel"
        error-channel="errorChannel"/>

    <int:channel id="toSA" />

    <int:service-activator input-channel="toSA"
        ref="echoService"
        method="test"/>

    <bean id="echoService"
        class="org.springframework.integration.samples.tcpclientserver.EchoService" />

    <int:object-to-string-transformer id="serverBytes2String"
        input-channel="serverBytes2StringChannel"
        output-channel="toSA"/>

    <int:transformer id="errorHandler"
        input-channel="errorChannel"
        expression="payload.failedMessage.payload + ':' + payload.cause.message"/>

</beans>

Answer 1

已解决。问题是评论服务器请求，因为服务器套接字在上下文文件中被注释掉了。

Spring TCP 支持 - 获取异常 "No qualifying bean of type AbstractServerConnectionFactory"

Spring TCP Support - Getting Exception "No qualifying bean of type AbstractServerConnectionFactory"

sockets

integration

spring

client

tcp