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, // 需要确认消息
|
|||
|
|
],
|
|||
|
|
],
|
|||
|
|
];
|
|||
|
|
|