cop主题修修改

communication/rocketmq_link.py

@@ -47,7 +47,7 @@ class RocketClient:
                 cls._instance = super(RocketClient, cls).__new__(cls)
         return cls._instance
 
-    def __init__(self, name_server_address, producer_group='alg_cop_result_producer', access_key='', access_secret=''):
+    def __init__(self, name_server_address, producer_group='alg-cop-result-producer', access_key='', access_secret=''):
         """初始化生产者（仅执行一次）"""
         with self._lock:
             if not self.__class__._producer:
@@ -60,7 +60,7 @@ class RocketClient:
                 logger.critical("========Rocket cop producer created ========")
 
     @classmethod
-    def start_consuming(cls, topic, on_message, consumer_group='alg-req-consumer-group', expression='*'):
+    def start_consuming(cls, topic, on_message, consumer_group='alg-cop-req-consumer-group', expression='*'):
         """
         创建消费端
         :param topic: 监听的消息主题

config/config.py

@@ -23,10 +23,10 @@ configs = {
             #"host": os.getenv("ROCKET_HOST_ADDR","http://192.168.1.70:9876"),
             "host": os.getenv("ROCKET_HOST_ADDR","http://172.17.102.51:9876"),
             # cop 触发主题
-            "topic_cop_in": os.getenv("TOPIC_COP_IN","alg-request"),
+            "topic_cop_in": os.getenv("TOPIC_COP_IN","alg-cop-request"),
             "tag_cop_in": os.getenv("TAG_COP_IN","alg-cop-req"),
             # cop 响应主题
-            "topic_cop_out": os.getenv("TOPIC_COP_OUT","alg-response"),
+            "topic_cop_out": os.getenv("TOPIC_COP_OUT","alg-cop-response"),
             "tag_cop_out": os.getenv("TAG_COP_OUT","alg-cop-resp"),
 
     }