golang 的 rabbitmq 消费项目
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
 
 
 

67 lines
2.2 KiB

  1. package consume
  2. import (
  3. "applet/app/utils/logx"
  4. consumeMd "applet/consume/md"
  5. "time"
  6. )
  7. var (
  8. jobs = map[string]func(consumeMd.MqQueue){}
  9. )
  10. func Init() {
  11. // 初始化任务列表
  12. initConsumes()
  13. }
  14. // 增加消费任务队列
  15. func initConsumes() {
  16. jobs[consumeMd.CanalOrderConsumeFunName] = CanalOrderConsume
  17. jobs[consumeMd.CanalGuideOrderConsumeFunName] = CanalGuideOrderConsume
  18. jobs[consumeMd.ZhiOsUserVisitIpAddressConsumeFunName] = ZhiOsUserVisitIpAddressConsume
  19. jobs[consumeMd.DouShenUserRegisterConsumeForOfficialFunName] = DouShenUserRegisterConsumeForOfficial
  20. jobs[consumeMd.DouShenUserRegisterConsumeForOperationCenterFunName] = DouShenUserRegisterConsumeForOperationCenter
  21. jobs[consumeMd.DouShenUserRegisterConsumeForMyRecommenderFunName] = DouShenUserRegisterConsumeForMyRecommender
  22. jobs[consumeMd.DouShenUserRegisterConsumeForMyFansFunName] = DouShenUserRegisterConsumeForMyFans
  23. jobs[consumeMd.DouShenUserRegisterConsumeForUserRegisterUpLvFunName] = DouShenUserRegisterConsumeForUserRegisterUpLv
  24. jobs[consumeMd.ZhiosFastReturnOrderPayFunName] = ZhiosFastReturnOrderPay
  25. jobs[consumeMd.ZhiosFastReturnOrderSuccessFunName] = ZhiosFastReturnOrderSuccess
  26. jobs[consumeMd.ZhiosFastReturnOrderRefundFunName] = ZhiosFastReturnOrderRefund
  27. jobs[consumeMd.CanalMallOrdForYouMiShangFunName] = CanalMallOrdForYouMiShang
  28. jobs[consumeMd.YoumishangExchangeStoreFunName] = YoumishangExchangeStore
  29. jobs[consumeMd.ZhiosRechargeOrderFailFunName] = ZhiosRechargeOrderFail
  30. jobs[consumeMd.CloudIssuanceAsyncMLoginFunName] = CloudIssuanceAsyncMLoginConsume
  31. jobs[consumeMd.ZhiosTikTokUpdateFunName] = ZhiosTikTokUpdate
  32. jobs[consumeMd.ZhiosTikTokAllUpdateFunName] = ZhiosTikTokAllUpdate
  33. }
  34. func Run() {
  35. for _, v := range consumeMd.RabbitMqQueueKeyList {
  36. if _, ok := jobs[v.ConsumeFunName]; ok {
  37. go doConsume(v.ConsumeFunName, *v)()
  38. }
  39. }
  40. }
  41. func doConsume(fnName string, queue consumeMd.MqQueue) func() {
  42. return func() {
  43. begin := time.Now().Local()
  44. jobs[fnName](queue)
  45. end := time.Now().Local()
  46. logx.Infof(
  47. "[%s] AutoConsume started at <%s>, ended at <%s> duration <%s>",
  48. fnName,
  49. begin.Format("2006-01-02 15:04:05.000"),
  50. end.Format("2006-01-02 15:04:05.000"),
  51. time.Duration(end.UnixNano()-begin.UnixNano()).String(),
  52. )
  53. }
  54. }