README

Laravel RabbitMQ

基于发布-订阅模式（其中订阅者是消费者）的简单RabbitMQ库，用于Laravel。

1. 安装

运行

composer require kevin-kibet/laravel-rabbitmq

对于Laravel版本5.5或更高版本，库应该通过包发现自动加载。

对于低于5.5版本的Laravel，您需要将服务提供者添加到app.php

<?php

return [
    // ...
    'providers' => [
        // ...
        NeedleProject\LaravelRabbitMq\Providers\ServiceProvider::class,
    ],
    // ...
];

2. 配置

在您的Laravel配置目录内创建一个名为laravel_rabbitmq.php的新文件。（或者使用artisan vendor:publish - 更多信息这里）
根据需要填写配置。

配置文件有5个主要节点：连接、交换器、队列、发布者、消费者。

它们在以下模式下使用：[配置流程图](https://rawcdn.githack.com/kevin-kibet/laravel-rabbitmq/HEAD/docs/configuration_diagram.png)

示例配置

return [
    'connections' => [
        'connectionA' => [/** Connection A attributes */],
        'connectionB' => [/** Connection B attributes */],
    ],
    'exchanges' => [
        'exchangeA' => [
            // Tells that the exchange will use the connection A
            'connection' => 'connectionA',
            /** Exchange A Attributes */
        ],
        'exchangeB' => [
            // Tells that the exchange will use the connection B
            'connection' => 'connectionB',
            /** Exchange B Attributes */
        ]
    ],
    'queues' => [
        'queueA' => [
            // Tells that the queue will use the connection alias A
            'connection' => 'connectionA',
            /** Queue A Attributes */
        ]
    ],
    'publishers' => [
        'aPublisherName' => /** will publish to exchange defined by alias */ 'exchangeA'
    ],
    'consumers' => [
        'aConsumerName' => [
            // will read messages from
            'queue' => 'queueA',
            // and will send the for processing to an "NeedleProject\LaravelRabbitMq\Processor\MessageProcessorInterface"
            'message_processor' => \NeedleProject\LaravelRabbitMq\Processor\CliOutputProcessor::class
        ]
    ]
]

2.1. 连接

连接属性

所有属性都是可选的，如果没有定义，将使用默认值。

2.2. 队列

队列主要节点

队列属性

示例 1

[
	['exchange' => 'first.exchange', 'routing_key' => '*'],
	['exchange' => 'second.exchange', 'routing_key' => 'foo_bar'],
]

2.3. 交换器

交换器主要节点

交换器属性

示例 2

[
	['queue' => 'first.exchange', 'routing_key' => '*'],
	['queue' => 'second.exchange', 'routing_key' => 'foo_bar'],
]

2.4. 发布者

发布者将消息推送到一个交换器（但也可以将其推送到一个队列）。定义发布者

'publishers' => [
	'myFirstPublisher' => 'echangeAliasName',
	'mySecondPublisher' => 'queueAliasName'
	// and many as you need
]

2.5. 消费者

消费者将从队列中获取消息。定义消费者

'consumers' => [
    'myConsumerName' => [
        'queue' => 'queueAliasName',
        'prefetch_count' => 1,
        'message_processor' => \NeedleProject\LaravelRabbitMq\Processor\CliOutputProcessor::class
    ]
]

3. 用法

配置完成后，您应该得到一个类似于以下内容的配置文件laravel_rabbitmq.php

return [
    'connections' => [
        'connectionA' => [],
    ],
    'exchanges' => [
        'exchangeA' => [
            'connection' => 'connectionA',
			'name' => 'foo_bar',
			'attributes' => [
				'exchange_type' => 'topic'
			]
        ]
	],
    'queues' => [
        'queueB' => [
            'connection' => 'connectionA',
            'name' => 'foo_bar_listener',
			'attributes' => [
				'bind' => [
                    ['exchange' => 'foo_bar', 'routing_key' => '*']
                ]
			]
        ]
    ],
    'publishers' => [
        'aPublisherName' => 'exchangeA'
    ],
    'consumers' => [
        'aConsumerName' => [
            'queue' => 'queueB',
            'message_processor' => \NeedleProject\LaravelRabbitMq\Processor\CliOutputProcessor::class
        ]
    ]
]

3.1. 发布消息

代码示例中的使用方法

<?php
/**
 * @var $app \Illuminate\Contracts\Container\Container
 * @var $publisher \NeedleProject\LaravelRabbitMq\PublisherInterface 
 */
$publisher = $app->makeWith(PublisherInterface::class, ['aPublisherName']);
$message = [
    'title' => 'Hello world',
    'body' => 'Lorem ipsum dolor sit amet, consectetur adipiscing elit, sed do eiusmod tempor incididunt ut labore et dolore magna aliqua.',
];
$routingKey = '*';
$publisher->publish(json_encode($message), /* optional */$routingKey);

可选，有一个命令可以用来发布消息。

php artisan rabbitmq:publish aPublisherName MyMessage

注意：目前，CLI中的路由键不受支持。

3.2. 消费消息

消费消息应通过在守护进程模式下运行命令来完成。虽然PHP并不打算这样做，但您可以使用supervisor来做到这一点。

消费者的流程相当简单：CLI消费者 -> 获取消息 -> 将其传递给配置中的message_processor键。

消息处理器是一个实现NeedleProject\LaravelRabbitMq\Processor接口的类。如果您不想处理确认，可以扩展\NeedleProject\LaravelRabbitMq\Processor\AbstractMessageProcessor，它需要实现processMessage(AMQPMessage $message): bool方法。

您的message_processor键通过Laravel的app命令来构建类。

启动消息消费者/监听器

php artisan rabbitmq:consume aConsumerName

运行有限制的消费者（当达到任一限制时将停止）

php artisan rabbitmq:consume aConsumerName --time=60 --messages=100 --memory=64

这告诉消费者，如果运行1分钟、消费100条消息或内存使用量达到64MB，则停止。

3.3. 可用命令

当运行php artisan时，将出现一个新的命名空间。

3.4. 自定义消息处理器

目前，您可以选择实现MessageProcessorInterface类或扩展AbstractMessageProcessor。

当使用AbstractMessageProcessor时，您将能够访问比在processMessage()中使用的额外API。

protected function ack(AMQPMessage $message);
protected function nack(AMQPMessage $message, bool $redeliver = true);

4. 贡献

您可以通过提交pull request或在GitHub上报告任何问题来贡献。在项目的当前阶段，尚未定义贡献流程。

kevin-kibet / laravel-rabbitmq

维护者

详细信息