作者:似懂非懂2502904027 | 来源:互联网 | 2022-07-18 16:14
thinkPHP5如何使用rabbitmq?
安装好 tp5 的 rabbitmq 扩展后,在项目根目录文件添加文件 rabbitmq.php 引导启动 rabbitmq。
生成者
private function queueEvent($message)
{
// error_log("\n******" . date("His") . "********\n" . print_r($message, 1) . "\n*************\n", 3,
'messag_event.log');
dump($message);
//设置你的连接
$conn_args = array('host' => 'ip', 'port' => '5672', 'login' => 'ymq', 'password' => '123456',
'vhost'=>'/');
$cOntent= $message;
//创建连接和channel
$cOnn= new \AMQPConnection($conn_args);
if (!$conn->connect()) {
die("Cannot connect to the broker!\n");
}
$channel = new \AMQPChannel($conn);
//创建交换机
$e_name = 'MQTT_device_event'; //交换机名
$ex = new \AMQPExchange($channel);
$ex->setName($e_name);
// $ex->setType(AMQP_EX_TYPE_TOPIC); //direct类型
$ex->setType(AMQP_EX_TYPE_DIRECT); //direct类型
$ex->setFlags(AMQP_DURABLE); //持久化
$ex->declareExchange();
}