0

我正在实现一个缓冲区，以执行各种工作。我正在开发一个基于 Spring 的项目。我决定使用 Spring Integration 来实现我的目标。我通过一个 Cafè 示例项目来了解 SI 的工作原理。

为了演示 Spring 集成，我实现了一个表，我在其中动态插入要执行的作业。该表是“网关”。然后我配置了一个路由器和各种通道。

我不完全理解的是必须检查“网关”中是否存在新作业的轮询元素。这个对吗？

如果是这样，我该如何配置轮询器？提前致谢！这里的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:context="http://www.springframework.org/schema/context"
xmlns:int="http://www.springframework.org/schema/integration"
xmlns:int-feed="http://www.springframework.org/schema/integration/feed"
xmlns:int-stream="http://www.springframework.org/schema/integration/stream"
xsi:schemaLocation="http://www.springframework.org/schema/beans
    http://www.springframework.org/schema/beans/spring-beans.xsd
    http://www.springframework.org/schema/integration
    http://www.springframework.org/schema/integration/spring-integration.xsd
    http://www.springframework.org/schema/integration/stream
    http://www.springframework.org/schema/integration/stream/spring-integration-stream.xsd">


<int:gateway id="usersToSend" service-interface="it.stasbranger.spidly.rss.UsersToSend" />


<int:channel id="channel" />

<int:channel id="providers"/>
<int:router input-channel="providers" ref="providerRouter" method="resolveProviderChannel"/>

<int:channel id="twitterChannel">
      <int:queue capacity="10"/>
</int:channel>
<int:service-activator input-channel="twitterChannel" ref="twitterService" method="updateStatusByProfile"/>

<int:channel id="facebookChannel">
      <int:queue capacity="10"/>
</int:channel>
<int:service-activator input-channel="facebookChannel" ref="facebookService" method="updateStatusByProfile"/>

<int:channel id="linkedinChannel">
      <int:queue capacity="10"/>
</int:channel>
<int:service-activator input-channel="linkedinChannel" ref="linkedinService" method="writeSlogan2Linkedin"/>

<bean id="twitterService" class="it.social.TwitterService"/>
<bean id="facebookService" class="it.social.FacebookService"/>
<bean id="linkedinService" class="it.social.LinkedinService"/>

<int:poller id="poller" default="true">

</int:poller>

脸书

4

1 回答 1

2

<gateway/>s 不被轮询，它们是“消息驱动的”，因为调用者使用网关将消息“发送”到流中。

对于轮询方案，使用<int:inbound-channel-adapter/>轮询方法（根据轮询程序的时间表）寻找工作。

如果该方法返回 null，则轮询器将返回睡眠状态（直到下一次触发）。如果该方法返回一个值，则将消息发送到通道。

于 2013-05-16T15:18:29.447 回答