thinkPHP5如何使⽤rabbitmq thinkPHP5如何使⽤rabbitmq？
安装好 tp5 的 rabbitmq 扩展后，在项⽬根⽬录⽂件添加⽂件 rabbitmq.php 引导启动 rabbitmq。
<?php
define('APP_PATH', __DIR__ . '/application/');
define('BIND_MODULE','rabbitmq/Client');
// 加载框架引导⽂件
require __DIR__ . '/thinkphp/start.php';
⽣成者
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();
}
相关推荐：《》
运⾏ php ⽬录运⾏⽣产者
消费者
public function index()
{
//连接RabbitMQ
$conn_args = array('host' => 'ip', 'port' => '5672', 'login' => 'ymq', 'password' => '123456', 'vhost'
=> '/');
$e_name = 'MQTT_device_event'; //交换机名
$q_name = 'q_event'; //队列名
$k_route = 'key_event'; //路由key
//创建连接和channel
$conn = new \AMQPConnection($conn_args);
if (!$conn->connect()) {
die("Cannot connect to the broker!\n");
}
$channel = new \AMQPChannel($conn);
//创建交换机
$ex = new \AMQPExchange($channel);
$ex->setName($e_name);
$ex->setType(AMQP_EX_TYPE_DIRECT); //direct类型
$ex->setFlags(AMQP_DURABLE); //持久化
$ex->declareExchange();
/
/创建队列
$q = new \AMQPQueue($channel);
$q->setName($q_name);
$q->setFlags(AMQP_DURABLE); //持久化
$q->declareQueue();    //最好队列object在这⾥declare()下，否则如果是新的queue会报错//绑定交换机与队列，并指定路由键，可以多个路由键
$q->bind($e_name, $k_route);
//$q->bind($e_name, 'key_33');
//阻塞模式接收消息
echo "Message:\n";
while(True){
$q->consume(function($envelope, $queue) {
$msg = $envelope->getBody();
//处理数据
echo $msg . PHP_EOL; //处理消息
$queue->ack($envelope->getDeliveryTag()); //⼿动发送ACK应答
});
//$q->consume('processMessage', AMQP_AUTOACK); //⾃动ACK应答
}
$conn->disconnect();
}
执⾏下命令 php rabbitmq
启动即可
查看队列是否被消费php如何运行代码
登录 127.0.0.115672/#/queues 地址

版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。