composer安裝php rabbitmq包

新建composer.json文件，composer install 安裝

{"require": {"php-amqplib/php-amqplib": ">=2.6.1"} }

創(chuàng)建config.php文件

<?php return ['vendor' => ['path' => './vendor'],'rabbitmq' => ['host' => '127.0.0.1','port' => '5672','login' => 'guest','password' => 'guest','vhost' => '/'] ]; ?>

?

創(chuàng)建消費(fèi)者 rabbit_consumer.php，注意具體文件引用的路徑

<?phpuse PhpAmqpLib\Connection\AMQPStreamConnection; use PhpAmqpLib\Message\AMQPMessage;$config = require "./config.php"; require_once $config['vendor']['path'] . '/autoload.php';$connection = new AMQPStreamConnection($config['rabbitmq']['host'], $config['rabbitmq']['port'],$config['rabbitmq']['login'], $config['rabbitmq']['password'], $config['rabbitmq']['vhost']); $channel = $connection->channel();$channel->queue_declare('hello', false, false, false, false); $callback = function($msg) {echo $msg->body;file_put_contents('log.txt', $msg->body); };$channel->basic_consume('hello', '', false, true, false, false, $callback);while(true) {$channel->wait(); } $channel->close(); $connection->close();?>

?

創(chuàng)建生產(chǎn)者 rabbit_pulisher.php

<?php$config = require "./config.php";require_once $config['vendor']['path'] . '/autoload.php';use PhpAmqpLib\Connection\AMQPStreamConnection; use PhpAmqpLib\Message\AMQPMessage;$connection = new AMQPStreamConnection($config['rabbitmq']['host'], $config['rabbitmq']['port'],$config['rabbitmq']['login'], $config['rabbitmq']['password'], $config['rabbitmq']['vhost']); $channel = $connection->channel();//發(fā)送方其實(shí)不需要設(shè)置隊(duì)列， 不過(guò)對(duì)于持久化有關(guān)，建議執(zhí)行該行 $channel->queue_declare('hello', false, false, false, false);$msg = new AMQPMessage('Hello World!123'.time()); $channel->basic_publish($msg, '', 'hello');echo " [x] Sent 'Hello World!x'\n";$channel->close(); $connection->close(); ?>

?

首先運(yùn)行消費(fèi)者

php rabbit_consumer.php

另起窗口運(yùn)行生產(chǎn)者?

php rabbit_publisher.php

轉(zhuǎn)載于:https://www.cnblogs.com/mmmzh/p/10100993.html

總結(jié)

以上是生活随笔為你收集整理的php rabbitmq demo的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。