我有一个受此示例启发的 Mojolicious 服务器，以及受此示例启发的 RabbitMQ 消费者。我的计划是将它们结合起来，以便网络客户端可以访问 Mojolicious 服务器并订阅某种更新。mojo 服务器会时不时地检查一个rabbitmq 队列，看是否有一些更新，如果有，它会将数据发送到连接的websocket 客户端。
我正在努力看看如何做到这一点。我是把rabbitmq 的东西放在mojo 服务器的东西里，还是反过来。如何防止rabbitmq消耗阻塞传入的websocket连接。我想我必须在消耗时使用超时，但是我可能不得不在循环中运行它，这可能会阻塞 websocket。还是我误解了什么？也许 Mojolicious 不是使用正确的库？
我在想服务器每 10 秒检查一次 rabbitmq 队列，但同时接受 websocket 连接。
有人对如何解决这个问题有一些想法吗？一些伪代码或任何东西将不胜感激。