删除rabbitmq关闭方法代码

FworkSpider/feapder/buffer/item_buffer.py

@@ -385,5 +385,3 @@ class ItemBuffer(threading.Thread):
                 pipeline.close()
             except:
                 pass
-        # 关闭rabbitmq
-        self._rabbitmq.close(1)

FworkSpider/feapder/buffer/request_buffer.py

@@ -56,8 +56,6 @@ class RequestBuffer(threading.Thread):
 
             tools.delay_time(1)
 
-        self.close()
-
     def stop(self):
         self._thread_stop = True
         self._started.clear()
@@ -147,7 +145,3 @@ class RequestBuffer(threading.Thread):
                 log.exception(e)
 
         self._is_adding_to_db = False
-
-    def close(self):
-        # 关闭rabbitmq
-        self._rabbitmq.close(2)

FworkSpider/feapder/core/collector.py

@@ -57,8 +57,6 @@ class Collector(threading.Thread):
 
             time.sleep(self._interval)
 
-        self.close()
-
     def stop(self):
         self._thread_stop = True
         self._started.clear()
@@ -123,7 +121,3 @@ class Collector(threading.Thread):
 
     def is_collector_task(self):
         return self._is_collector_task
-
-    def close(self):
-        # 关闭rabbitmq
-        self._rabbitmq.close(3)

FworkSpider/feapder/core/scheduler.py

@@ -440,7 +440,3 @@ class Scheduler(threading.Thread):
             return
 
         super().join()
-
-    def stop(self):
-        # 关闭rabbitmq
-        self._rabbitmq.close(4)

FworkSpider/feapder/core/spiders/spider.py

@@ -94,8 +94,6 @@ class Spider(
 
             tools.delay_time(1)  # 1秒钟检查一次爬虫状态
 
-        self.stop()
-
     @classmethod
     def to_DebugSpider(cls, *args, **kwargs):
         # DebugSpider 继承 cls