Nebula框架的队列使用清单
Nebula日志与监控
Rabbit连接配置名称:ClownFish_Log_Rabbit
ClownFish.Log.Logging.InvokeLog 队列
- 发送方:所有使用Nebula开发的应用程序
- 消费方:Nebula.Mercury
- 消费者数量参数:InvokeLog_RabbitSubscriber_Count,默认值:10
- 创建时机:Mercury启动时
- 队列用途:由日志组件写入,消息数据表示一条调用日志
Nebula.StatisticsInfo
- 发送方:Nebula.Mercury
- 消费方:Nebula.Venus
- 消费者数量参数:StatisticsInfo_RabbitSubscriber_Count,默认值:2
- 创建时机:Mercury启动时
- 队列用途:异步持久化(同步转异步)
Nebula.MonitorData
- 发送方:所有使用Nebula开发的服务
- 消费方:Nebula.Venus
- 消费者数量参数:MonitorData_RabbitSubscriber_Count,默认值:3
- 创建时机:所有服务启动时
- 队列用途:各服务向Venus发送监控统计数据
Nebula.Ceres
Rabbit连接配置名称:Nebula_Ceres_Rabbit
Ceres_WebHook_Events
- 发送方:Nebula.Ceres
- 消费方:Nebula.Ceres
- 消费者数量参数:HookEventHandler_RabbitSubscriber_Count,默认值:1
- 创建时机:Ceres启动时
- 队列用途:接收外部请求,同步转异步;并按订阅者做消息拆分
Ceres_WebHook_WaitRetry
- 发送方:Nebula.Ceres
- 消费方:无消费者
- 消费者数量参数:无
- 创建时机:Ceres启动时
- 队列用途:用于实现重试等待
Ceres_WebHook_Retry
- 发送方:Rabbit内部的死信机制,由Ceres_WebHook_WaitRetry队列转入
- 消费方:Nebula.Ceres
- 消费者数量参数:HookEventHandler_Retry_RabbitSubscriber_Count,默认值:1
- 创建时机:Ceres启动时
- 队列用途:消息重试
Ceres_WebHook_DeadMsg
- 发送方:Nebula.Ceres
- 消费方:无消费者
- 消费者数量参数:无,供外部程序订阅
- 创建时机:Ceres启动时
- 队列用途:用于消息处理失败时(包含全部重试失败),通知外部程序
Nebula.Metis
Rabbit连接配置名称:Nebula_Metis_Rabbit
Metis_MsgData
- 发送方:Nebula.Metis
- 消费方:Nebula.Metis
- 消费者数量参数:NotifyMessageHandler_RabbitSubscriber_Count,默认值:1
- 创建时机:Metis启动时
- 队列用途:接收外部请求,同步转异步;并按通知的推送目标做消息拆分
Metis_MsgData_WaitRetry
- 发送方:Nebula.Metis
- 消费方:无消费者
- 消费者数量参数:无
- 创建时机:Metis启动时
- 队列用途:用于实现重试等待
Metis_MsgData_Retry
- 发送方:Rabbit内部的死信机制,由Metis_MsgData_WaitRetry队列转入
- 消费方:Nebula.Metis
- 消费者数量参数:NotifyMessageHandler_Retry_RabbitSubscriber_Count,默认值:1
- 创建时机:Metis启动时
- 队列用途:消息重试
Metis_MsgData_DeadMsg
- 发送方:Nebula.Metis
- 消费方:无消费者
- 消费者数量参数:无,供外部程序订阅
- 创建时机:Metis启动时
- 队列用途:用于消息处理失败时(包含全部重试失败),通知外部程序