三亚凤凰镇网站建设兼职招聘网,洛阳兼职网站,学网页设计软件开发,网站上传视频教程usb端点轮询如果您想用Spring Integration编写一个流程来轮询HTTP端点并从http端点收集一些内容以进行进一步处理#xff0c;那有点不直观。 Spring Integration提供了几种与HTTP端点集成的方式- Http出站适配器–将消息发送到http端点 Http出站网关–将消息发送到http端点… usb端点轮询 如果您想用Spring Integration编写一个流程来轮询HTTP端点并从http端点收集一些内容以进行进一步处理那有点不直观。 Spring Integration提供了几种与HTTP端点集成的方式- Http出站适配器–将消息发送到http端点 Http出站网关–将消息发送到http端点并收集响应作为消息 我对HTTP端点进行轮询的第一个本能是使用Http Inbound通道适配器我做出的错误假设是适配器将负责从端点获取信息-Http Inbound Gateway实际所做的是公开Http端点。等待请求到来 这就是为什么我首先要说轮询URL并从中收集内容对我来说有点不直观我实际上必须使用Http Outbound网关 在澄清了这一点之后请考虑一个示例在该示例中我要轮询此URL上可用的USGS地震信息提要-http://earthquake.usgs.gov/earthquakes/feed/geojson/all/hour 这是我的示例http Outbound组件的样子 int:channel idquakeinfo.channelint:queue capacity10//int:channelint:channel idquakeinfotrigger.channel/int:channel int-http:outbound-gateway idquakerHttpGatewayrequest-channelquakeinfotrigger.channelurlhttp://earthquake.usgs.gov/earthquakes/feed/geojson/all/hourhttp-methodGETexpected-response-typejava.lang.StringcharsetUTF-8reply-timeout5000reply-channelquakeinfo.channel /int-http:outbound-gateway 在这里http出站网关等待消息进入quakeinfotrigger通道将GET请求发送到“ http://earthquake.usgs.gov/earthquakes/feed/geojson/all/hour”URL并将响应json放入字符串进入“ quakeinfo.channel”通道 测试这很容易 RunWith(SpringJUnit4ClassRunner.class) ContextConfiguration(httpgateway.xml) public class TestHttpOutboundGateway {Autowired Qualifier(quakeinfo.channel) PollableChannel quakeinfoChannel;Autowired Qualifier(quakeinfotrigger.channel) MessageChannel quakeinfoTriggerChannel;Testpublic void testHttpOutbound() {quakeinfoTriggerChannel.send(MessageBuilder.withPayload().build());Message? message quakeinfoChannel.receive();assertThat(message.getPayload(), is(notNullValue()));}} 我在这里所做的是获取对触发出站网关将消息发送到http端点的通道的引用以及对放置来自http端点的响应的另一个通道的引用。 我通过在触发通道中放置一个空虚消息来触发测试流程然后等待消息在响应通道中可用并在内容中声明。 这样做很干净但是我的初衷是编写一个轮询器该轮询器每分钟左右触发一次此端点的轮询为此我要做的实际上是每分钟将一个伪消息放入“ quakeinfotrigger.channel”通道中使用Spring Integration的“ poller”和一些Spring Expression语言可以轻松实现 int:inbound-channel-adapter channelquakeinfotrigger.channel expressionint:poller fixed-delay60000/int:poller /int:inbound-channel-adapter 在这里我有一个与轮询器相连的Spring inbound-channel-adapter触发器该轮询器每分钟都会触发一条空消息。 所有这些看起来有些令人费解但效果很好–这是一个具有有效代码的要点 相关链接 基于我在Spring论坛上提出的问题http://forum.springsource.org/showthread.php?130711-Need-help-with-polling-to-a-json-based-HTTP-service 参考 all和其他博客中使用 JCG合作伙伴 Biju Kunjummen的Spring Integration轮询http端点 。 翻译自: https://www.javacodegeeks.com/2012/11/polling-an-http-end-point-using-spring-integration.htmlusb端点轮询