82 lines
2.6 KiB
PHP
82 lines
2.6 KiB
PHP
<?php
|
||
/**
|
||
* RabbitMQ 消息队列配置
|
||
*
|
||
* 用于标签系统的异步消息处理
|
||
*/
|
||
|
||
return [
|
||
'default' => 'rabbitmq',
|
||
|
||
'connections' => [
|
||
'rabbitmq' => [
|
||
'driver' => 'rabbitmq',
|
||
'host' => getenv('RABBITMQ_HOST') ?: '127.0.0.1',
|
||
'port' => (int)(getenv('RABBITMQ_PORT') ?: 5672),
|
||
'user' => getenv('RABBITMQ_USER') ?: 'guest',
|
||
'password' => getenv('RABBITMQ_PASSWORD') ?: 'guest',
|
||
'vhost' => getenv('RABBITMQ_VHOST') ?: '/',
|
||
'timeout' => 10, // 连接超时时间（秒）
|
||
|
||
// 队列配置
|
||
'queues' => [
|
||
// 数据同步队列：外部数据源轮询后推送的数据
|
||
'data_sync' => [
|
||
'name' => 'data_sync_queue',
|
||
'durable' => true, // 队列持久化
|
||
'auto_delete' => false,
|
||
'arguments' => [],
|
||
],
|
||
// 标签计算队列：消费记录写入后触发标签计算
|
||
'tag_calculation' => [
|
||
'name' => 'tag_calculation_queue',
|
||
'durable' => true, // 队列持久化
|
||
'auto_delete' => false,
|
||
'arguments' => [],
|
||
],
|
||
],
|
||
|
||
// 交换机配置
|
||
'exchanges' => [
|
||
'data_sync' => [
|
||
'name' => 'data_sync_exchange',
|
||
'type' => 'direct',
|
||
'durable' => true,
|
||
'auto_delete' => false,
|
||
],
|
||
'tag_calculation' => [
|
||
'name' => 'tag_calculation_exchange',
|
||
'type' => 'direct',
|
||
'durable' => true,
|
||
'auto_delete' => false,
|
||
],
|
||
],
|
||
|
||
// 路由键配置
|
||
'routing_keys' => [
|
||
'data_sync' => 'data.sync',
|
||
'tag_calculation' => 'tag.calculation',
|
||
],
|
||
],
|
||
],
|
||
|
||
// 消息配置
|
||
'message' => [
|
||
'delivery_mode' => 2, // 消息持久化（2 = 持久化）
|
||
'content_type' => 'application/json',
|
||
],
|
||
|
||
// 消费者配置
|
||
'consumer' => [
|
||
'data_sync' => [
|
||
'prefetch_count' => 10, // 每次处理10条消息（批量处理）
|
||
'no_ack' => false, // 需要确认消息
|
||
],
|
||
'tag_calculation' => [
|
||
'prefetch_count' => 1, // 每次只处理一条消息
|
||
'no_ack' => false, // 需要确认消息
|
||
],
|
||
],
|
||
];
|
||
|