如何反序列化Symfony Messenger的messenger_messages表消息？

尝试反序列化messenger_messages表中的Symfony消息时，调用unserialize()函数出现错误：

unserialize(): Error at offset 0 of 1380 bytes in ...

提示消息被截断，无法完成反序列化。示例序列化字符串（已修改隐私数据）：

O:36:"Symfony\Component\Messenger\Envelope":2:{s:44:"\0Symfony\Component\Messenger\Envelope\0stamps";a:1:{s:46:"Symfony\Component\Messenger\Stamp\BusNameStamp";a:1:{i:0;O:46:"Symfony\Component\Messenger\Stamp\BusNameStamp":1:{s:55:"\0Symfony\Component\Messenger\Stamp\BusNameStamp\0busName";s:26:"messenger.bus.pimcore-core";}}}s:45:"\0Symfony\Component\Messenger\Envelope\0message";O:36:"App\Hubspot\TransactionalMailMessage":1:{s:45:"\0App\Hubspot\TransactionalMailMessage\0payload";a:4:{s:7:"emailId";i:53540933612;s:9:"recipient";a:7:{s:5:"email";s:23:"lolozzo.prova@gmail.com";s:5:"phone";s:10:"3989346664";s:9:"firstName";s:5:"Seeki";s:8:"lastName";s:7:"Lolozzo";s:12:"customerType";s:7:"privato";s:17:"newsletterConsent";b:1;s:5:"admin";b:0;}s:4:"data";a:13:{s:11:"ID_ANNUNCIO";i:2220;s:14:"TOKEN_ANNUNCIO";s:15:"PR65E095202E52F";s:15:"TITOLO_ANNUNCIO";s:41:"Agazzini ENDURO CARBON CANE CREEK EDITION";s:12:"EMAIL_AUTORE";s:23:"lolozzo.prova@gmail.com";s:15:"TELEFONO_AUTORE";s:10:"3771234567";s:12:"URL_ANNUNCIO";s:39:"http://localhost/announcement/2220/view";s:17:"URL_ANNUNCIO_EDIT";s:39:"http://localhost/announcement/2220/edit";s:18:"URL_ANNUNCIO_ADMIN";s:65:"https://www.ebikemood.com/admin/login/deeplink?object_5920_object";s:6:"STATUS";s:6:"review";s:15:"NOTE_UNAPPROVED";s:0:"";s:13:"NOTE_REJECTED";s:0:"";s:11:"OFFER_PRICE";s:0:"";s:17:"OFFER_DESCRIPTION";s:0:"";}s:6:"sendId";N;}}}

解决步骤 #

• 修复字符串转义问题：从数据库取出的序列化字符串可能经过HTML转义（如"被转义），需先还原原始格式：

$serializedMessage = htmlspecialchars_decode($dbSerializedString);
$envelope = unserialize($serializedMessage);

• 确保类可自动加载：反序列化依赖的类（如Symfony\Component\Messenger\Envelope、App\Hubspot\TransactionalMailMessage）必须存在于当前环境，且能通过Composer自动加载。若在项目外执行，需引入项目的vendor/autoload.php文件。

• 验证消息完整性：检查数据库中messenger_messages表的body字段，确保复制的字符串完整无截断。

• 使用Symfony官方序列化器：优先使用Messenger自带的序列化器，避免手动unserialize()的兼容性问题：

use Symfony\Component\Messenger\Serializer\SerializerInterface;

// 通过依赖注入获取SerializerInterface实例
$envelope = $serializer->decode([
    'body' => $serializedMessage,
    'headers' => [],
]);

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