rabbitmq queue 消息队列 ¶

项目地址：https://github.com/2723659854/rabbitmq ¶

项目介绍 ¶

消息队列主要用于业务解耦，本项目采用rabbitmq，支持thinkPHP，laravel，webman，yii等常用框架，也可以单独使用。

安装方法 install ¶

composer require xiaosongshu/rabbitmq

示例 demo ¶

定义一个队列 queue ¶

<?php
namespace app\commands;

require_once __DIR__.'/vendor/autoload.php';

class Demo extends \Xiaosongshu\Rabbitmq\Client
{

    /** 以下是rabbitmq配置 ，请填写您自己的配置 */
    /** @var string $host 服务器地址 */
    public static $host = "127.0.0.1";

    /** @var int $port 服务器端口 */
    public static $port = 5672;

    /** @var string $user 服务器登陆用户 */
    public static $user = "guest";

    /** @var string $pass 服务器登陆密码 */
    public static $pass = "guest";

    /**
     * 业务处理
     * @param array $params
     * @return int
     */
    public static function handle(array $params): int
    {
        //TODO 这里写你的业务逻辑
        // ...
        var_dump($params);
        return self::ACK;
        //return self::NACK;
    }
}

投递消息 publish ¶

\app\commands\Demo::publish(['name'=>'tome','age'=>15]);

你可以在任何地方投递消息。

开启消费 ¶

\app\commands\Demo::consume();

你可以把消费者放到command命令行里面，使用命令行执行队列消费。举个例子(这里以yii为例子，你也可以换成laravel，webman,thinkPHP等其他框架)： `php <?php

namespace app\commands;

use yii\console\Controller;

/**

• @purpose 开启队列消费

• @note 我只是一个例子 */ class QueueController extends Controller {

  /**

  • @api php yii queue/index
  • @return void
  • @throws \Exception
  • @comment 开启消费者 */ public function actionIndex() { Demo::consume(); } }

    开启消费者命令 consume
    ```bash
    php yii queue/index
    

    注：如果你需要开启多个消费者，那么可以在多个窗口执行开启消费者命令即可。当然你也可以使用多进程来处理。

    关闭消费者 ¶

\app\commands\Demo::close();

异常 Exception ¶

队列使用过程中请使用 \RuntimeException和\Exception捕获异常

若需要使用延迟队列，那么rabbitmq服务需要安装延迟插件，否则会报错 ¶

测试 ¶

本项目根目录有一个demo.php的测试文件，可以复制到你的项目根目录，在命令行窗口直接在命令行执行以下命令即可。 `php php demo.php 测试文件代码如下：php <?php

namespace xiaosongshu\test; require_once DIR . '/vendor/autoload.php';

/**

• demo

• @purpose 定义一个队列演示 */ class Demo extends \Xiaosongshu\Rabbitmq\Client {

  /* 以下是rabbitmq配置 ，请填写您自己的配置 / /* @var string $host 服务器地址 / public static $host = "127.0.0.1";

  /* @var int $port 服务器端口 / public static $port = 5672;

  /* @var string $user 服务器登陆用户 / public static $user = "guest";

  /* @var string $pass 服务器登陆密码 / public static $pass = "guest";

  /**

  • 业务处理
  • @param array $params
  • @return int */ public static function handle(array $params): int { //TODO 这里写你的业务逻辑 // ... var_dump($params); /* 成功，返回ack / return self::ACK; /* 失败，返回NACK/ //return self::NACK; } }

/ 投递普通消息 */ \xiaosongshu\test\Demo::publish(['name' => 'tom']); \xiaosongshu\test\Demo::publish(['name' => 'jim']); \xiaosongshu\test\Demo::publish(['name' => 'jack']); /* 开启消费，本函数为阻塞，后面的代码不会执行 / \xiaosongshu\test\Demo::consume(); / 关闭消费者 */ \xiaosongshu\test\Demo::close(); `

联系作者：2723659854@qq.com ，你也可以直接提issues ¶