thinkPHP5如何使用rabbitmq

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了thinkPHP5如何使用rabbitmq，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含2298字，纯文字阅读大概需要4分钟。

内容图文

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();

    }

 

相关推荐：《ThinkPHP教程》

运行 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

启动即可

查看队列是否被消费

登录 http://127.0.0.115672/#/queues 地址

内容总结

以上是互联网集市为您收集整理的thinkPHP5如何使用rabbitmq全部内容，希望文章能够帮你解决thinkPHP5如何使用rabbitmq所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

---