搜尋
首頁php框架ThinkPHPthinkPHP5如何使用rabbitmq

thinkPHP5如何使用rabbitmq

Aug 23, 2019 am 10:42 AM
rabbitmqthinkphp5

thinkPHP5如何使用rabbitmq

thinkPHP5如何使用rabbitmq?

安裝好 tp5 的 rabbitmq 擴充功能後,在專案根目錄檔案中新增檔案 rabbitmq.php 引導啟動 rabbitmq。

<?php
define(&#39;APP_PATH&#39;, __DIR__ . &#39;/application/&#39;);
define(&#39;BIND_MODULE&#39;,&#39;rabbitmq/Client&#39;);
// 加载框架引导文件
require __DIR__ . &#39;/thinkphp/start.php&#39;;

生成者

  private function queueEvent($message)
    {
//        error_log("\n******" . date("His") . "********\n" . print_r($message, 1) . "\n*************\n", 3, 
&#39;messag_event.log&#39;);
        dump($message);
        //设置你的连接
        $conn_args = array(&#39;host&#39; => &#39;ip&#39;, &#39;port&#39; => &#39;5672&#39;, &#39;login&#39; => &#39;ymq&#39;, &#39;password&#39; => &#39;123456&#39;,
        &#39;vhost&#39;=>&#39;/&#39;);
 
 
        $content = $message;
//创建连接和channel
        $conn = new \AMQPConnection($conn_args);
        if (!$conn->connect()) {
            die("Cannot connect to the broker!\n");
        }
        $channel = new \AMQPChannel($conn);
 
//创建交换机
        $e_name = &#39;MQTT_device_event&#39;; //交换机名
        $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(&#39;host&#39; => &#39;ip&#39;, &#39;port&#39; => &#39;5672&#39;, &#39;login&#39; => &#39;ymq&#39;, &#39;password&#39; => &#39;123456&#39;, &#39;vhost&#39; 
        => &#39;/&#39;);
 
        $e_name = &#39;MQTT_device_event&#39;; //交换机名
        $q_name = &#39;q_event&#39;; //队列名
        $k_route = &#39;key_event&#39;; //路由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, &#39;key_33&#39;);  
//阻塞模式接收消息
        echo "Message:\n";
        while(True){
            $q->consume(function($envelope, $queue) {
                $msg = $envelope->getBody();
                //处理数据
                echo $msg . PHP_EOL; //处理消息
                $queue->ack($envelope->getDeliveryTag()); //手动发送ACK应答
            });
            //$q->consume(&#39;processMessage&#39;, AMQP_AUTOACK); //自动ACK应答
        }
 
        $conn->disconnect(); 
    }

執行下指令php rabbitmq

啟動即可

檢視佇列是否被消耗

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

thinkPHP5如何使用rabbitmqthinkPHP5如何使用rabbitmq#

以上是thinkPHP5如何使用rabbitmq的詳細內容。更多資訊請關注PHP中文網其他相關文章!

陳述
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn

熱AI工具

Undresser.AI Undress

Undresser.AI Undress

人工智慧驅動的應用程序,用於創建逼真的裸體照片

AI Clothes Remover

AI Clothes Remover

用於從照片中去除衣服的線上人工智慧工具。

Undress AI Tool

Undress AI Tool

免費脫衣圖片

Clothoff.io

Clothoff.io

AI脫衣器

Video Face Swap

Video Face Swap

使用我們完全免費的人工智慧換臉工具,輕鬆在任何影片中換臉!

熱工具

Safe Exam Browser

Safe Exam Browser

Safe Exam Browser是一個安全的瀏覽器環境,安全地進行線上考試。該軟體將任何電腦變成一個安全的工作站。它控制對任何實用工具的訪問,並防止學生使用未經授權的資源。

Atom編輯器mac版下載

Atom編輯器mac版下載

最受歡迎的的開源編輯器

SAP NetWeaver Server Adapter for Eclipse

SAP NetWeaver Server Adapter for Eclipse

將Eclipse與SAP NetWeaver應用伺服器整合。

SublimeText3漢化版

SublimeText3漢化版

中文版,非常好用

SecLists

SecLists

SecLists是最終安全測試人員的伙伴。它是一個包含各種類型清單的集合,這些清單在安全評估過程中經常使用,而且都在一個地方。 SecLists透過方便地提供安全測試人員可能需要的所有列表,幫助提高安全測試的效率和生產力。清單類型包括使用者名稱、密碼、URL、模糊測試有效載荷、敏感資料模式、Web shell等等。測試人員只需將此儲存庫拉到新的測試機上,他就可以存取所需的每種類型的清單。