标签:project-reactor

  • 带有反压力的反应式SQS轮询器 - java

    时间:2020-7-15

    尝试创建SQS轮询器,它: 进行指数轮询(以减少队列中没有消息的请求数)如果队列中有很多消息,则更频繁地查询SQS如果收到一定数量的消息,将产生反压,它将停止轮询不受AWS API速率限制的限制 作为示例,我使用的是this JavaRx实现,该实现可以轻松转换为Project Reactor并使用反压功能对其进行丰富。 private static fin […]