msgpack/igbinary 序列化一个 class 对象发布消息时，订阅回调收到的数据只有部分！

[designinlife]

msgpack/igbinary 序列化一个 class 对象发布消息时，订阅回调收到的数据只有一部分！（字节不完整）
必须 base64_encode(msgpack_serialize($this)) 才行。

测试环境：
PHP: 7.2.9
MessagePack: 2.0.2

[yunnian]

php-nsq 是什么版本的，老版本有类似bug 后来已经解决

[designinlife]

@yunnian 版本是 3.2.0 的

[yunnian]

好的，能够提供一些示例吗，我去复现修复下

[designinlife]

<?php
class SampleMessage {
    /**
     * 创建消息的时间。
     *
     * @var int
     */
    protected $created_time = 0;

    /**
     * 消息发布时间。
     *
     * @var int
     */
    protected $triggered_timestamp = 0;

    /**
     * 消息对象。
     *
     * @var string
     */
    protected $message = NULL;

    /**
     * 自定义参数。
     *
     * @var array
     */
    protected $arguments = [];

    /**
     * AbstractNotifyMessage constructor.
     *
     * @param int            $triggered_timestamp 消息发布(触发)时间。
     * @param string         $message             消息对象。
     * @param array          $arguments           自定义参数。
     */
    function __construct(int $triggered_timestamp, string $message, array $arguments = []) {
        $this->triggered_timestamp = $triggered_timestamp;
        $this->message             = $message;
        $this->arguments           = $arguments;
        $this->created_time        = time();
    }

    /**
     * 对象转换为 MessagePack 编码字符串。
     *
     * @return string
     */
    function __toString(): string {
        return \msgpack_serialize($this);
    }
}

$nsq->publish('topic', strval(new SampleMessage(time() + 15, '测试！', [1,2,3])));

试下上面的代码看看

[designinlife]

这样发过去后 $nsq->subscribe() 回调里 $msg->payload 收到的不完整，字节我看了下都少了。
估计是 msgpack 序列化之后部分乱码不能识别，你扩展里直接截断了吧

[lexand]

Salutations
Same problem

Test data

<?php
$arr = [
    'a' => 0,
    'f' => 0,
    'c' => 0,
    'p' => 0,
    'b' => 0,
    'v' => 0,
    'q' => 0,
    'o' => 0,
    'z' => 0,
    'r' => 0,
    'l' => 0,
    'w' => 2,
    'e' => 0,
    't' => 2,
    'y' => 0,
    'u' => 0,
];
$msg = msgpack_pack($arr);
echo \base64_encode($msg), "\n"; // 3gAQoWEAoWYAoWMAoXAAoWIAoXYAoXEAoW8AoXoAoXIAoWwAoXcCoWUAoXQCoXkAoXUA
// strlen($msg)== 51 
// ....
$nsq->publish('test', $msg);

after publishing on the consumer I got array from one byte only [222]