我想实现一个无服务器函数,它轮询HTTP端点并将响应发布到消息队列。我最初的想法是使用spring集成网关和适配器构建一个spring引导应用程序,用于HTTP轮询和发布到队列(并作为lambda部署)。弹簧堆栈中有更好的选择吗?我看了春云功能,春云流,春云任务。有什么建议吗?
发布于 2020-07-27 13:45:13
在Spring中,这种类型的微服务称为source。因此,您需要一个基于的Supplier bean来构建一个简单的流,让Spring定期轮询它,并将结果生成到绑定目标中。
就像这样:
@Bean
public IntegrationFlow pollingHttpFlow() {
return IntegrationFlows
.from(Supplier.class, gateway -> gateway.beanName("httpSupplier"))
.handle(Http.outboundGateway("http://somehost"))
.get();
}请看一篇关于这种互操作性的博客文章:https://spring.io/blog/2019/10/25/spring-cloud-stream-and-spring-integration
https://stackoverflow.com/questions/63098572
复制相似问题