Symfony集成php-enqueue操作SQL Server时出现无效PHP类型错误

问题背景 #

在Symfony 6.4项目中使用php-enqueue实现命令异步执行，项目基于SQL Server数据库，已通过Composer完成enqueue模块安装，且成功创建enqueue相关数据表。

错误场景 #

执行以下异步命令推送代码时触发数据库写入错误：

$cmd = new RunCommand('debug:container', ['--tag=form.type']);
$producer->sendCommand(Commands::RUN_COMMAND, $cmd);

错误信息：

[Doctrine\DBAL\Exception\DriverException (-16)]
执行查询时发生异常：SQLSTATE [IMSSP, -16]: 指定的参数1为无效PHP类型

调试分析 #

经排查，错误对应数据库表的id字段。该字段由php-enqueue的DbalProducer类通过Uuid::uuid4()生成，返回的是Ramsey\Uuid\Lazy\LazyUuidFromString对象（而非字符串）：

Array
(
    [id] => Ramsey\Uuid\Lazy\LazyUuidFromString Object
        (
            [unwrapped:Ramsey\Uuid\Lazy\LazyUuidFromString:private] => 
            [uuid:Ramsey\Uuid\Lazy\LazyUuidFromString:private] => 5909c9e3-1690-4cd0-b0f0-0151e6f7996a
        )

    [published_at] => 17252753310188
    // 其他enqueue表字段
)

SQL Server的DBAL驱动无法自动将该UUID对象转换为字符串类型，导致参数类型错误。

临时修改测试：将生成id的代码改为\Enqueue\Util\UUID::generate()后，id以字符串格式写入，数据库操作恢复正常：

Array
(
    [id] => 6f9cfd8d-4f3a-4675-9f95-a2099de60457
    [published_at] => 17252757497569
    // 其他enqueue表字段
)

可行解决方案 #

1. 自定义DbalProducer替换默认实现 #

不修改源码，通过Symfony的服务替换机制自定义Producer：

• 创建自定义类继承Enqueue\Dbal\DbalProducer，重写send方法中生成id的逻辑：

namespace App\Queue;

use Enqueue\Dbal\DbalProducer;
use Enqueue\Util\UUID;

class CustomDbalProducer extends DbalProducer
{
    public function send(string $topic, $message): void
    {
        $message = $this->messageSerializer->toString($message);

        $this->connection->executeStatement(
            $this->createSendQuery($topic),
            [
                'id' => UUID::generate(), // 替换为字符串UUID生成逻辑
                'topic' => $topic,
                'message' => $message,
                'published_at' => (string) microtime(true) * 10000,
            ]
        );
    }
}

• 在services.yaml中替换默认服务：

services:
    Enqueue\Dbal\DbalProducer:
        class: App\Queue\CustomDbalProducer
        arguments:
            - '@Enqueue\Dbal\DbalConnection'
            - '@Enqueue\Dbal\MessageSerializer'

2. 配置Doctrine DBAL自动处理UUID对象 #

利用ramsey/uuid-doctrine扩展让Doctrine自动转换UUID对象为字符串：

• 安装扩展：

composer require ramsey/uuid-doctrine

• 在config/packages/doctrine.yaml中配置类型映射：

doctrine:
    dbal:
        types:
            uuid: Ramsey\Uuid\Doctrine\UuidType
        connections:
            default:
                # 原有SQL Server连接配置
                mapping_types:
                    uniqueidentifier: uuid # 将SQL Server的uniqueidentifier类型映射为UUID类型

此方案无需修改enqueue源码，由Doctrine层处理类型转换，兼容性更好。

3. 手动转换UUID对象为字符串（临时应急） #

在调用sendCommand前，手动修改生成id的逻辑（若无法修改服务或配置），但此方式需侵入业务代码，不推荐长期使用：

// 在生成消息时确保id为字符串
$message = ...; // 你的消息对象
$message->setId((string) \Ramsey\Uuid\Uuid::uuid4());
$producer->sendCommand(Commands::RUN_COMMAND, $message);

内容的提问来源于stack exchange，提问作者SvenW