优雅实现异步转同步
在异步场景中,如何优雅地实现异步转同步操作?例如,当控制器方法调用后发送消息至队列,队列消费者写入结果到 redis,如何让控制器方法在调用后直接返回处理结果,避免死循环轮询?
这个问题可以采用以下方式解决:
首先,轮询的方式并非不可接受,当外部程序无法回调时,轮询是一个有效的方案。然而,在特殊场景下,我们需要实现更优雅的异步回调。
对于上述场景,控制器方法在发送消息后,可以使当前线程阻塞,并通过消费者的行为通知本地,例如:
- 使用 Redis 的订阅/发布功能。
- 消费者将处理完成的消息写入队列。
- 使用另一个线程消费该消息,并唤醒阻塞线程。
另一种方法是在本地程序中启动一个额外的 http 接口接收完成消息。控制器启动异步过程后,让线程阻塞在一个对象上。异步过程结束后,通过该接口接收成功消息,找到阻塞的对象,唤醒阻塞线程即可。