the new v2.0 can not use in product env

[w3yyb]

In the high load env, the v2.0 often report the following error:
fwrite(): send of 2 bytes failed with errno=32 Broken pipe file:

but the old v1.0 can work well Basically.

[sskaje]

How to reproduce and where this fwrite error occurs ?

[w3yyb]

PHP Notice: fwrite(): send of 2 bytes failed with errno=32 Broken pipe in /var/www/html/phalconapi/app/library/mqtt/SocketClient.php on line 166

[w3yyb]

code:
$cpush = new MQTT('tcp://'.$config->host.':'.$config->port.'/', $pclientid);
$context = stream_context_create();
$cpush->setSocketContext($context);
$cpush->setVersion(MQTT::VERSION_3_1_1);
$cpush->setKeepalive(60);
$cpush->setConnectClean(true);
$connected = $cpush->connect();
$cpush->setRetryTimeout(5);
$myhandler = new \MyPublishHandler();
$pushed = $cpush->publish_async($json->Subject, $content, $config->qos, $config->retain,$msgid);
$myhandler->waitQueue[$pushed['msgid']] = $pushed;
$cpush->setHandler($myhandler);
$cpush->loop();

[w3yyb]

and often throw new Exception('WTFFFFFF!!!! '); too. in MQTT.php 1285行.

[nielsenaa]

Hi guys,

i also get thrown at the wtf exception in MQTT.php;
i seems it depends on message specific content char combination being sent on publish (i am using qos2 async)
i pass alot of ESC chars in there and on specific conditions, exception fires up.. i doesnt seem to be affected by overall payload length / "size".. can reproduce but cannot debug for sure !

[sskaje]

@nielsenaa please give me a copy of your message

[nielsenaa]

Hello Sskaje! want some other kind of message that doesn’t fire exception ? Thank you !

[nielsenaa]

care to chat ? @nielsenaa on skype