优化代码

src/Components/amqp/src/Pool/AMQPResource.php

@@ -79,12 +79,12 @@ class AMQPResource extends BasePoolResource
             try
             {
                 $channel->close();
-                unset($this->connection->channels[$key]);
             }
-            catch (\Exception $e)
+            catch (\Throwable $e)
             {
                 /* Ignore closing errors */
             }
+            unset($this->connection->channels[$key]);
         }
     }
 

src/Components/amqp/src/Queue/QueueConsumer.php

@@ -79,7 +79,10 @@ class QueueConsumer extends BaseConsumer
             $this->stop();
         }
         $this->connection = $this->getConnection();
-        $this->channel = $this->connection->channel();
+        if($this->connection->isConnected())
+        {
+            $this->channel = $this->connection->channel();
+        }
     }
 
     /**

src/Components/amqp/src/Swoole/SwooleIO.php

@@ -183,7 +183,7 @@ class SwooleIO extends AbstractIO
 
         if (false === $buffer)
         {
-            throw new AMQPRuntimeException('Error sending data');
+            throw new AMQPRuntimeException('Error sending data, errno=' . $this->sock->errCode);
         }
 
         if (0 === $buffer && !$this->sock->connected)