laborer-by/laravel-rabbitmq

Laravel的RabbitMQ驱动程序。

v1.1.1 2021-03-10 04:04 UTC

This package is auto-updated.

Last update: 2024-09-10 13:45:21 UTC


README

Latest Stable Version Total Downloads Latest Unstable Version License

Laravel的RabbitMQ驱动程序。

安装

(1) 使用composer安装此包:

composer require laborer-by/laravel-rabbitmq

(2) 在.env文件中添加以下属性并设置正确的值

;RABBITMQ dev
RABBITMQ_HOST=127.0.0.1
RABBITMQ_PORT=5672
RABBITMQ_USER=guest
RABBITMQ_PASSWORD=guest
RABBITMQ_VHOST=oc

(3) 创建一个表

CREATE TABLE `tmp_rabbitmq_msg` (
  `msg_id` char(20) COLLATE utf8_unicode_ci NOT NULL DEFAULT '' COMMENT '消息的唯一id',
  `routing_key` varchar(50) COLLATE utf8_unicode_ci NOT NULL DEFAULT '' COMMENT 'routing_key 消息的路由键',
  `source` varchar(50) COLLATE utf8_unicode_ci NOT NULL DEFAULT '' COMMENT '消息的来源',
  `msg_data` mediumtext COLLATE utf8_unicode_ci NOT NULL COMMENT '消息的主体数据',
  `extra_data` varchar(50) COLLATE utf8_unicode_ci NOT NULL DEFAULT '' COMMENT '额外的数据',
  `created_at` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
  UNIQUE KEY `index_msg_id` (`msg_id`) USING BTREE,
  KEY `index_routing_key` (`routing_key`) USING BTREE,
  KEY `index_created_at` (`created_at`) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci COMMENT='rabbitmq消息表';

配置

通过config/app.php注册LaravelRabbitMQServiceProvider

'providers' => [
    // others ...

    Laborer\LaravelRabbitMQ\LaravelRabbitMQServiceProvider::class,
],

要发布配置文件,请运行以下命令

php artisan vendor:publish --provider="Laborer\LaravelRabbitMQ\LaravelRabbitMQServiceProvider"

变更日志

您可以在CHANGELOG文件中找到完整的变更日志历史。

测试

使用PHPUnit运行测试

vendor/bin/phpunit

composer test