|
há 1 ano atrás | |
---|---|---|
.. | ||
internal | há 1 ano atrás | |
README.md | há 1 ano atrás | |
main.go | há 1 ano atrás |
任务类型: 定时类任务,设备上报状态触发类任务,场景联动任务等
使用rabbitmq的exchange的Routing类型,将任务类型作为routing key,将任务内容作为消息体,将消息投递到对应的Queue中
消息类型:删除,更新,停止,启动。
所有任务的生命周期消息都投递到一个交换机上,交换机的类型为fanout,所有任务执行器都可以订阅该交换机。保证每个执行器都可以管理目前正在执行的任务的生命周期