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启动时
  • 队列用途:用于消息处理失败时(包含全部重试失败),通知外部程序