Spring-Integration-TCP с использованием шлюзов - PullRequest
0 голосов
/ 05 февраля 2019

Использование Task Executor для многопоточности путем определения размера пула.Это правильный выбор или использование асинхронных шлюзов - это то, на что я должен обратить внимание?Я могу отправлять и получать приличное количество сообщений с помощью TaskExecutor.Ценю вашу помощь !!

<int-ip:tcp-connection-factory id="server" type="server" port="6060" using-nio="true" serializer="balhserializer" deserializer="balhserializer" task-executor="tasks"/>
<int-ip:tcp-connection-factory id="client" type="client" port="6080" host="localhost" serializer="balhserializer" deserializer="balhserializer"  task-executor="tasks"/>

<bean id="balhserializer" class="org.springframework.integration.ip.tcp.serializer.ByteArrayLengthHeaderSerializer">
    <constructor-arg name="headerSize"><value>2</value></constructor-arg>
</bean>

<task:executor id="tasks" keep-alive="5" pool-size="10"/>

<!-- <int-ip:tcp-inbound-channel-adapter connection-factory="server" channel="request"/> -->    
<!-- <int-ip:tcp-outbound-channel-adapter connection-factory="client" channel="request">
    <int:poller fixed-delay="1" time-unit="SECONDS"></int:poller>
</int-ip:tcp-outbound-channel-adapter> -->

<int-ip:tcp-inbound-gateway id="tigw" connection-factory="server"  request-channel="request" reply-channel="reply"/>

<int-ip:tcp-outbound-gateway id="togw" connection-factory="client" request-channel="request" reply-channel="reply">
    <int:poller fixed-delay="1" time-unit="MILLISECONDS"></int:poller>
</int-ip:tcp-outbound-gateway>


<int:channel id="request">
    <int:queue capacity="1000"/>
</int:channel>

<int:channel id="reply">
    <int:queue capacity="1000"/>
</int:channel>

<!-- <bean id="mre" class="com.mastercard.iso.lb.MessageReaderEndPoint"/> -->

<!-- <int:service-activator id="sa" input-channel="reply" ref="mre" method="read">
    <int:poller fixed-delay="2" time-unit="SECONDS"/>
</int:service-activator> -->

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...