ydf0509/funboost

mqtt项目实例

LQ645218172 opened this issue · 4 comments

大佬能否出一个mqtt项目实例,文档中没有找到相关使用说明。

你是说任务执行完成后把结果实时推送到前端,不用ajax轮询是吧。
这要安装mqtt中间件的,如果要实时推送结果给前端,前端人员还需要配合。

是的,我在进行一个全栈项目,想通过mqtt中间件向vue推送topic,但是不太清楚本框架是如何与mqtt结合工作的。

框架本身不集成mqtt前端交互,前端可以请求后端接口,后端收到请求后推送任务到消息队列(消息队列可以是redis rabbitmq等),在被boost装饰器装饰的消费函数里面,加个发布到mqtt的代码就行了。具体的可以用 funboost/utils/mqtt_util.py 里面的工具类发布mqtt消息,也可以使用mqtt三方包发布mqtt消息。

这是一个思路流程,mqtt推送给前端是你自己在消费函数的最后一行把结果,调用一个发布mqtt消息的函数就行了,这并不是与框架绑定的,不是框架自动发布mqtt消息,而是用户自己来发布的。

框架没有直接集成结果发送给mqtt,用户自己加一行,懂没

好的,谢谢啦