rabbitMq 教程一：“ Hello World！”

生产者

/**
 * 生产者
 */
public function actionSend($n=0)
    {
        $queue='hello';

        $connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
        //创建通道
        $channel = $connection->channel();

        //创建队列（无则创建）
        /**
         * 1、对列名
         * 3、是否持久化 true是 false否
         */
        $channel->queue_declare($queue, false, false, false, false);

        //消息内容
        $message='Hello World! '.$n;
        $msg = new AMQPMessage($message);

        /**
         * 1、内容
         * 2、交换机
         * 3、路由 队列
         */
        $channel->basic_publish($msg, '', $queue);

        echo " [x] Sent '.$message.'\n";

        //关闭
        $channel->close();
        $connection->close();
    }

消费者：

/**
 * 消费者
 */
  public function actionReceive()
    {
        $queue='hello';
        $connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
        $channel = $connection->channel();
        $channel->queue_declare($queue, false, false, false, false);

        echo " [*] Waiting for messages. To exit press CTRL+C\n";

        $callback = function ($msg) {
            echo ' [x] Received ', $msg->body, "\n";
        };

        //创建一个消费者 （监听器）
        /**
         * 4、是否自动确认收到消息
         */
        $channel->basic_consume($queue, '', false, true, false, false, $callback);

        while ($channel->is_consuming()) {
            $channel->wait();
        }
    }

使用

使用：命令行执行
先运行消费者 php receive
再执行生产者 php send

官网代码示例：https://github.com/rabbitmq/rabbitmq-tutorials/tree/master/php