在本地启了一个docker运行rabbitmq，通过实时跟踪日志查看到，当webman退出时，调用消费队列进程的onWorkerStop方法时，虽然FasterBuilder中针对连接处理$this->_connection->close();，但发现rabbitmq这边有warning日志：

2022-09-04 02:55:53.458 [warning] <0.20366.1> closing AMQP connection <0.20366.1> (172.19.0.1:60280 -> 172.19.0.2:5672, vhost: '/', user: 'rabbitmq'):
client unexpectedly closed TCP connection

同时发现如果在发布消息时，通过调用helpers的async_publish方法，设置close参数为true时，连接是正常关闭的：

2022-09-04 03:02:36.367 [info] <0.20824.1> connection <0.20824.1> (172.19.0.1:60316 -> 172.19.0.2:5672): user 'rabbitmq' authenticated and granted access to vhost '/'
******
2022-09-04 03:02:36.421 [info] <0.20824.1> closing AMQP connection <0.20824.1> (172.19.0.1:60316 -> 172.19.0.2:5672, vhost: '/', user: 'rabbitmq')

推送：sync_publish(Builder::instance(), $params, null, true); 说明文档中，最后的close 参数，最好默认是true。 如果该方法应用在 controller 部分，这个会因为没有固定的 心跳监听而造成大量的发布失败。 虽然每次都会重新创建连接，那也是稳定和高效的。

process 里的消息接收。建议加入重连检查。有时候网络断开造成的消费者丢失没有重连。 或者搞个重连开关。

` public function onWorkerStart(Worker $worker): void { parent::onWorkerStart($worker);

    Timer::add(10, function () {
        $this->checkConnection();
    });

}

private function checkConnection() {
    try {
        if($this->connection()->client()->isConnected() == false) {
            $this->logger->debug('Reconnect');
            $this->connection()->consume($this->getMessage());
        }else {
            $this->logger->debug('Connection is OK');
        }
    } catch (\Exception $e) {
        $this->logger->error($e->getMessage());
    }
}

`

最近在看rabbitmq相关的组件，在尝试使用这个组件时，关于helpers下的两个方法有个疑问，如下

 * 同步生产
 * @param FastBuilder $builder
 * @param string $body
 * @param array|null $headers
 * @param bool $close
 * @return bool
 */
function sync_publish(FastBuilder $builder, string $body, ?array $headers = null, bool $close = false) : bool
{
    $message = $builder->getMessage();
    if(
        ($message->getExchangeType() !== Constants::DELAYED and $headers['x-delay'] ?? 1) or
        ($message->getExchangeType() === Constants::DELAYED and !($headers['x-delay'] ?? 0))
    ){
        throw new WebmanRabbitMQException('Invalid publish. ');
    }
    $message->setBody($body);
    if($headers !== null){
        $message->setHeaders(array_merge($message->getHeaders(), $headers));
    }
    return $builder->syncConnection()->publish($message, $close);
}

若这里$builder是普通队列，则$message的ExchangeType是Constants::DIRECT，当$headers不传递时，默认为null，那这里不是始终抛WebmanRabbitMQException了？