音信队列

日期:2019-09-25编辑作者:编程应用

本文链接:

文书档案提纲:

图片 1

扫描关怀微信徒人号

1.

  1)gitHub下载地址:

  2):

安装php的RabbitMQ PHP扩充安装,正视的Erlang境况

   参谋文书档案: 

  3):提议利用 composer完结,

composer入门 4):    官方教程链接地址:

  5)测验脚本:

--使用官方的demo:

开一个订阅者窗口$ cd php-amqplib/demo$ php amqp_consumer.php开一个发布者窗口$ cd php-amqplib/demo$ php amqp_publisher.php some text to publish

    --使用第三方脚本

图片 2图片 3

 1 //引用所需文件   2 require_once __DIR__ . '/vendor/autoload.php';   3 use PhpAmqpLibConnectionAMQPStreamConnection;   4 use PhpAmqpLibMessageAMQPMessage;   5 //建立一个连接通道,声明一个可以发送消息的队列hello   6 $connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');   7 $channel = $connection->channel();   8 $channel->queue_declare('hello', false, false, false, false);   9   10 //定义一个消息,消息内容为Hello World!  11 $msg = new AMQPMessage('Hello World!');  12 $channel->basic_publish($msg, '', 'hello');  13   14 //发送完成后打印消息告诉发布消息的人:发送成功  15 echo " [x] Sent 'Hello World!'n";  16 //关闭连接  17 $channel->close();  18 $connection->close();

View Code

 1     require_once __DIR__ . '/vendor/autoload.php';   2     use PhpAmqpLibConnectionAMQPStreamConnection;   3     $connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');   4     $channel = $connection->channel();   5        6     $channel->queue_declare('hello', false, false, false, false);   7        8     echo ' [*] Waiting for messages. To exit press CTRL+C', "n";   9     $callback = function($msg) {  10       echo " [x] Received ", $msg->body, "n";  11     };  12       13     //在接收消息的时候调用$callback函数  14     $channel->basic_consume('hello', '', false, true, false, false, $callback);  15       16     while(count($channel->callbacks)) {  17         $channel->wait();  18     }  

本文由今晚最快开奖现场直播发布于编程应用,转载请注明出处:音信队列

关键词:

iOS多线程之GCD深入理解

在 GCD中,参与了五个特别重要的概念:义务和队列一个线程是能够享有多少个试行队列的,全部职务是增多到行列中...

详细>>

GitHub Android Libraries Top 100 简单介绍

继上一篇 Android 学习资料搜聚获得大多响应,因而作者主宰再来一发,希望对您们全体帮忙 本项目根本对日前 GitHu...

详细>>

支付最好实施,Android最棒实践指南

Updated on 2016/2/14 更新Stetho 相关,简书markdown不支持锚-_-||||||||||||Updated on 2016/1/15表明谷歌对ADT的废弃态度,新增段落:...

详细>>

swift中自定义Log,iOS开发之自定义log

在我们日常开发中,打印输出作为调试手段还是占据相当大的一个比重的.但是打印又非常消耗性能,我们仅仅希望在调...

详细>>