From 73c4e730f684254f7862ffd4b8c3c23755fce145 Mon Sep 17 00:00:00 2001 From: shenjiachi Date: Mon, 30 Dec 2024 20:33:29 +0800 Subject: [PATCH] =?UTF-8?q?update:=20=E6=B6=88=E8=B4=B9=E4=B8=B4=E6=97=B6?= =?UTF-8?q?=E9=98=9F=E5=88=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- consume/md/consume_key.go | 184 ++------------------------------------ etc/cfg.yml | 30 +++---- 2 files changed, 23 insertions(+), 191 deletions(-) diff --git a/consume/md/consume_key.go b/consume/md/consume_key.go index ce97056..a502122 100644 --- a/consume/md/consume_key.go +++ b/consume/md/consume_key.go @@ -66,182 +66,14 @@ var RabbitMqQueueKeyList = []*MqQueue{ ConsumeFunName: "IMEggEnergyDelFriendCircleDataConsume", }, { - ExchangeName: "egg.app", - Name: "egg_fin_withdraw_apply", - Type: DirectQueueType, - IsPersistent: false, - RoutKey: "egg_fin_withdraw_apply", - BindKey: "", - ConsumeFunName: "EggFinWithdrawApplyDataConsume", - }, - { - ExchangeName: "egg.energy", - Name: "egg_energy_settlement_public_give_activity_coin", - Type: DirectQueueType, - IsPersistent: false, - RoutKey: "settlement_public_give_activity_coin", - BindKey: "", - ConsumeFunName: "EggEnergySettlementPublicGiveActivityCoinConsume", - }, - { - ExchangeName: "egg.energy", - Name: "egg_energy_start_exchange_egg_energy", - Type: DirectQueueType, - IsPersistent: false, - RoutKey: "start_exchange_egg_energy", - BindKey: "", - ConsumeFunName: "EggEnergyStartExchangeGreenEnergyConsume", - }, - { - ExchangeName: "egg.energy", - Name: "egg_energy_auto_exchange_egg_energy", - Type: DirectQueueType, - IsPersistent: false, - RoutKey: "auto_exchange_egg_energy", - BindKey: "", - ConsumeFunName: "EggEnergyAutoExchangeGreenEnergyConsume", - }, - { - ExchangeName: "egg.app", - Name: "add_public_platoon_user_relation_commission", - Type: DirectQueueType, - IsPersistent: false, - RoutKey: "add_public_platoon_user_relation_commission", - BindKey: "", - ConsumeFunName: "AddPublicPlatoonUserRelationCommissionConsume", - }, - { - ExchangeName: "egg.jpush", - Name: "egg_jpush_record_queue", - Type: DirectQueueType, - IsPersistent: false, - RoutKey: "jpush_record", - BindKey: "", - ConsumeFunName: "JpushRecordConsume", - }, - { - ExchangeName: "egg.aliyun_sms", - Name: "egg_aliyun_sms_record_queue_new", - Type: DirectQueueType, - IsPersistent: false, - RoutKey: "aliyun_sms_record", - BindKey: "", - ConsumeFunName: "AliyunSmsRecordConsume", - }, - { - ExchangeName: "egg.advertising", - Name: "egg_advertising_smash", - Type: DirectQueueType, - IsPersistent: false, - RoutKey: "advertising_smash", - BindKey: "", - ConsumeFunName: "AdvertisingSmashConsume", - }, - { - ExchangeName: "egg.advertising", - Name: "egg_advertising_sign", - Type: DirectQueueType, - IsPersistent: false, - RoutKey: "advertising_sign", - BindKey: "", - ConsumeFunName: "AdvertisingSignConsume", - }, - { - ExchangeName: "egg.app", - Name: "egg_new_user_register_queue", - Type: DirectQueueType, - IsPersistent: false, - RoutKey: "egg_new_user_register", - BindKey: "", - ConsumeFunName: "EggEnergyNewUserRegisterDataConsume", - }, - { - ExchangeName: "egg.energy", - Name: "egg_energy_user_ecpm", - Type: DirectQueueType, - IsPersistent: false, - RoutKey: "user_ecpm", - BindKey: "", - ConsumeFunName: "EggEnergyDealUserECPMConsume", - }, - { - ExchangeName: "egg.canal.topic", - Name: "egg_canal_invite_user_nums_queue", - Type: DirectQueueType, - IsPersistent: false, - RoutKey: "user_relate", - BindKey: "", - ConsumeFunName: "EggCanalInviteUserNumsConsume", - }, - { - ExchangeName: "egg.canal.topic", - Name: "egg_canal_violate_nums_queue", - Type: DirectQueueType, - IsPersistent: false, - RoutKey: "user_tag_records", - BindKey: "", - ConsumeFunName: "EggCanalViolateNumsConsume", - }, - { - ExchangeName: "im.egg.energy", - Name: "im_egg_energy_send_red_package_queue", - Type: DirectQueueType, - IsPersistent: false, - RoutKey: "send_red_package", - BindKey: "", - ConsumeFunName: "IMEggEnergySendRedPackageConsume", - }, - { - ExchangeName: "egg.app", - Name: "egg_record_active_queue", - Type: DirectQueueType, - IsPersistent: false, - RoutKey: "egg_record_active", - BindKey: "", - ConsumeFunName: "EggRecordActiveDataConsume", - }, - { - ExchangeName: "egg.canal.topic", - Name: "egg_canal_person_add_activity_value_queue", - Type: DirectQueueType, - IsPersistent: false, - RoutKey: "egg_canal_user_virtual_coin_flow", - BindKey: "", - ConsumeFunName: "EggCanalPersonAddActivityValueConsume", - }, - { - ExchangeName: "egg.video_playlet", - Name: "egg_video_reward", - Type: DirectQueueType, - IsPersistent: false, - RoutKey: "video", - BindKey: "", - ConsumeFunName: "VideoRewardFunName", - }, - { - ExchangeName: "egg.video_playlet", - Name: "egg_playlet_reward", - Type: DirectQueueType, - IsPersistent: false, - RoutKey: "playlet", - BindKey: "", - ConsumeFunName: "PlayletRewardFunName", - }, - { - ExchangeName: "egg.user", - Name: "egg_user_delete", - Type: DirectQueueType, - IsPersistent: false, - RoutKey: "user_delete", - BindKey: "", - ConsumeFunName: "UserDeleteConsume", - }, - { - ExchangeName: "egg.app", - Name: "egg_auto_score_queue", - Type: DirectQueueType, - IsPersistent: false, - RoutKey: "egg_auto_score", + // 消费临时队列 + ExchangeName: "egg.app", + Name: "egg_auto_score_test_queue", + //Name: "egg_auto_score_queue", + Type: DirectQueueType, + IsPersistent: false, + //RoutKey: "egg_auto_score", + RoutKey: "egg_auto_score_test", BindKey: "", ConsumeFunName: "EggEnergyAutoScoreConsume", }, diff --git a/etc/cfg.yml b/etc/cfg.yml index cae636e..e08bbf2 100644 --- a/etc/cfg.yml +++ b/etc/cfg.yml @@ -81,26 +81,26 @@ log: file_name: 'debug.log' # 连接RabbitMq -mq: - host: '120.77.153.180' - port: '5672' - user: 'guest' - pwd: 'guest' #mq: -# host: '116.62.62.35' +# host: '120.77.153.180' # port: '5672' -# user: 'zhios' -# pwd: 'ZHIoscnfnuo123' - -#es: -# url: 'http://120.55.48.175:9200' -# user: 'elastic' -# pwd: 'fnuo123' +# user: 'guest' +# pwd: 'guest' +mq: + host: '116.62.62.35' + port: '5672' + user: 'zhios' + pwd: 'ZHIoscnfnuo123' es: - url: 'http://123.57.140.192:9200' + url: 'http://120.55.48.175:9200' user: 'elastic' - pwd: 'se4BxqYyGhHyPWPA3w8Q' + pwd: 'fnuo123' + +#es: +# url: 'http://123.57.140.192:9200' +# user: 'elastic' +# pwd: 'se4BxqYyGhHyPWPA3w8Q' im_business_rpc: url: im-rpc-business.izhim.com