lpflpf
时不时会出现段错误这个是怎么回事
时不时会出现段错误这个是怎么回事
代码如下 `namespace RocketMQ;
$instanceName = "mp"; $consumer = new PushConsumer($instanceName); $consumer->setInstanceName($instanceName); $consumer->setNamesrvAddr("192.168.1.64:9876"); //$consumer->setSessionCredentials("accessKey","secretKey","ALIYUN"); //阿里云生产环境接入签权配置 测试环境无需设置 $consumer->setThreadCount(1); $consumer->setListenerType(MessageListenerType::LISTENERCONCURRENTLY); $consumer->setConsumeFromWhere(ConsumeFromWhere::CONSUME_FROM_FIRST_OFFSET); $consumer->setMessageModel(MessageModel::BROADCASTING); $result = array(); $count = 0;
$consumer->setCallback(function ($msg) use (&$count){ if ($msg) { $msgs = $msg->getMessage(); var_dump($msgs->getBody()); } }); $consumer->subscribe("COMPANY_CENTER_EVENT", "ffkfqGi2fh1pIf32"); $consumer->start();`
