edit

src/dai/seller/app/Lib/Get.php

@@ -33,6 +33,7 @@ class Get
                     $this->consumeNewMessages($workerId);
                 } catch (\Throwable $e) {
                     echo "Worker#$workerId 拉取订单失败：" . $e->getMessage() . "\n";
+                    Redis::reconnect();
                     Timer::sleep(0.5);
                 }
             }