RabbitMQ-消息队列之work使用
1、安装rabbitmq
怎么安装rabbitmq请查看之前课程，如果已经安装，请略过此步。
2、创建vendor文件夹或是直接采用PHP框架
mkdir vendor3、进入文件
cd vendor4、安装php扩展
composer require php-amqplib/php-amqplib5、进入上级创建worker文件夹
cd ../
mkdir worker6、进入worker文件并创建生产者php
cd worker
touch pro.php7、输入worker生产者内容
<?phprequire_once '../vendor/autoload.php';use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage;$v_host = 'order';$queue_name = 'task_queue';$connection = new AMQPStreamConnection('localhost',5672,'wangyulong','wangyulong',$v_host);$channel = $connection->channel();$channel->queue_declare($queue_name,false,true,false,false);for($i=1;$i<=10;$i++){$data = 'this is '.$i.' message';$msg = new AMQPMessage($data,['delivery_mode'=>AMQPMessage::DELIVERY_MODE_PERSISTENT]);$channel->basic_publish($msg,'',$queue_name);}$channel->close();$connection->close();8、创建消费者php
touch worker.php9、输入worker消费者内容
<?phprequire_once '../vendor/autoload.php';use PhpAmqpLib\Connection\AMQPStreamConnection;$v_host ='order';
$queue_name = 'task_queue';$connection = new AMQPStreamConnection('localhost',5672,'wangyulong','wangyulong',$v_host);$channel = $connection->channel();$channel->queue_declare($queue_name,false,true,false,false);$callback = function($msg){echo 'received ',$msg->body,"\n";$msg->ack();};$channel->basic_qos(null,1,null);$channel->basic_consume($queue_name,'',false,false,false,false,$callback);while($channel->is_open()){$channel->wait();
}$channel->close();$connection->close()10、执行生产者
php pro.php11、执行消费者
php worker.php