README

1 安装与配置

1.1 安装

composer require adt/background-queue-nette

1.2 配置

parameters:
	database:
		serverVersion: '8.0'
		driver: pdo_mysql
		host: %env.DB_HOST%
		port: %env.DB_PORT%
		user: %env.DB_USER%
		password: %env.DB_PASSWORD%
		dbname: %env.DB_DBNAME%

	backgroundQueue:
		queue: %env.PROJECT_NAME%

extensions:
	backgroundQueue: ADT\BackgroundQueueNette\DI\BackgroundQueueExtension

backgroundQueue:
	callbacks:
		sendEmail: [@App\Model\Mailer, sendEmail]
		sendEmail2: # možnost specifikace jiné fronty pro tento callback
			callback: [@App\Model\Mailer, sendEmail]
			queue: some_other_queue
	notifyOnNumberOfAttempts: 5 # počet pokusů o zpracování záznamu před zalogováním
	tempDir: %tempDir% # cesta pro uložení informace, že byla provedena aktualizace databázové struktury
	locksDir: %locksDir% # cesta pro uložení zámku proti vícenásobnému spuštění commandů
	connection: %database% # parametry predavane do Doctrine\Dbal\Connection
	queue: %backgroundQueue.queue% # název fronty, do které se ukládají a ze které se vybírají záznamy
	tableName: background_job # nepovinné, název tabulky, do které se budou ukládat jednotlivé joby
	logger: Tracy\Bridges\Psr\TracyToPsrLoggerAdapter(\Tracy\Debugger::getLogger()) # nepovinné, musí implementovat psr/log LoggerInterface
	onBeforeProcess: null # nepovinné
	onError: [ADT\Utils\Guzzle, handleException]  # nepovinné
	onAfterProcess: null # nepovinné
	onProcessingGetMetadata: null # nepovinné

1.3 代理（可选）

为了获得最佳性能和用户体验，建议使用 AMQP 代理（例如 RabbitMQ）https://github.com/AppsDevTeam/background-queue#131-php-amqplib-installation 并按如下方式配置

parameters:
	backgroundQueue:
		...
		broker:
			connection:
				host: %env.BROKER_HOST%
				port: %env.BROKER_PORT%
				user: %env.BROKER_USER%
				password: %env.BROKER_PASSWORD%
			queue:
				arguments: {'x-queue-type': ['S', 'quorum']} 

services:
	backgroundQueue.broker.manager: ADT\BackgroundQueue\Broker\PhpAmqpLib\Manager(%backgroundQueue.broker.connection%, %backgroundQueue.broker.queue%)
	backgroundQueue.broker.producer: ADT\BackgroundQueue\Broker\PhpAmqpLib\Producer
	backgroundQueue.broker.consumer: ADT\BackgroundQueue\Broker\PhpAmqpLib\Consumer

backgroundQueue:
	...
	producer: @backgroundQueue.broker.producer
	waitingJobExpiration: 1000

1.4 代理（可选）

为了避免服务循环引用，建议使用 https://github.com/AppsDevTeam/nette-proxy 并将 BackgroundQueue 设置为延迟加载

services:
	backgroundQueue.service:
		tags: [lookyman.lazy]

2. 使用方法

https://github.com/AppsDevTeam/background-queue#2-pou%C5%BEit%C3%AD