thinkphp如何使用rabbitmq消息队列

composer require php-amqplib/php-amqplib

use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage;

<?php
namespace app\index\controller;
use think\Db;

use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage;

class Register
{
    public function reg()
    {
        $data = input('post.');
        $username = trim(input('post.username'));
        $password = trim(input('post.password'));
        $tel = trim(input('post.tel'));
        //判断用户名是否存在
        $user = Db::table('user')->where('username',$username)->find();
        if($user){
            return ['status'=>0,'msg'=>'用户名已存在'];
        }
        //判断手机号是否存在
        $usertel = Db::table('user')->where('tel',$tel)->find();
        if($usertel){
            return ['status'=>0,'msg'=>'手机号已存在'];
        }

        $res = Db::table('user')->insert($data);
        if($res){
            //用户注册成功，将用户的用户名和手机号发给消息队列
            $this->sendmsg(json_encode(['username'=>$username,'tel'=>$tel]));
            return ['status'=>1,'msg'=>'注册成功'];
        }else{
            return ['status'=>0,'msg'=>'注册失败'];
        }
    }
   
    //发送消息给消息队列
    public function sendmsg($data)
    {
        $vhost = 'zhiboblog';//虚拟主机名，要先创建
        $queue_name = 'mailer';//队列名称,可以自定义
       
        $connection = new AMQPStreamConnection('localhost',5672,'guest','guest',$vhost);
        $channel = $connection->channel();
       
        $channel->queue_declare($queue_name,false,true,false,false);
       
        $msg = new AMQPMessage($data,['delivery_mode'=>AMQPMessage::DELIVERY_MODE_PERSISTENT]);
        $channel->basic_publish($msg,'',$queue_name);
       
        $channel->close();
        $connection->close();
    }
}

php think make:command Mailer mailer

<?php

namespace app\command;

use think\console\Command;
use think\console\Input;
use think\console\Output;
use PhpAmqpLib\Connection\AMQPStreamConnection;

class Mailer extends Command
{
    protected function configure()
    {
        // 指令配置
        $this->setName('mailer');
        // 设置参数
       
    }

    protected function execute(Input $input, Output $output)
    {
        // 指令输出
        //$output->writeln('mailer');
        $vhost = 'zhiboblog';
        $queue_name = 'mailer';
        $connection = new AMQPStreamConnection('localhost',5672,'guest','guest',$vhost);
        $channel = $connection->channel();
        $channel->queue_declare($queue_name,false,true,false,false);
        $callback = function($msg){
        //  echo $msg->body."\n";
            $arr = json_decode($msg->body,true);
            $username = $arr['username'];
            $tel = $arr['tel'];
            $title = '有新的注册用户';//邮件标题
            $content = '用户名：'.$username.'，手机号：'.$tel;//邮件内容
            $this->sendmail($title,$content);
            $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();
    }
   
    protected function sendmail($title,$content)
    {
        //发送邮件的方法，我这里就不写了，可以自己发挥
    }
}

php think mailer

//nohup表示不挂断地运行命令，&表示在后台运行，两个结合起来使用就可以守护进程运行
nohup php think mailer &

//先找到进程id
ps -ef |grep mailer
//然后杀掉进程
kill -9 进程id