[extension] xiaosongshu/rabbitmq

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 ¶

AddToAny

[extension] xiaosongshu/rabbitmq