YII框架的数据同步是什么？YII框架如何同步多数据库？

insert()

update()

User

db1

db2

User

afterSave()

db2

// 假设在User模型或某个服务中
public function saveUserAndSync($data)
{
    $transaction1 = Yii::$app->db1->beginTransaction();
    $transaction2 = Yii::$app->db2->beginTransaction(); // 假设db2是另一个数据库连接组件

    try {
        // 写入主数据库
        $user = new User();
        $user->attributes = $data;
        if (!$user->save()) {
            throw new \Exception('Save to db1 failed.');
        }

        // 写入第二个数据库（可能只同步部分字段或不同表结构）
        $syncModel = new SyncUser($user->id); // 假设SyncUser是针对db2的模型
        $syncModel->username = $user->username;
        $syncModel->email = $user->email;
        if (!$syncModel->save()) {
            throw new \Exception('Save to db2 failed.');
        }

        $transaction1->commit();
        $transaction2->commit();
        return true;
    } catch (\Exception $e) {
        $transaction1->rollBack();
        $transaction2->rollBack();
        Yii::error("Data sync failed: " . $e->getMessage());
        return false;
    }
}

// 假设在User模型中，使用YII的事件机制
class User extends ActiveRecord
{
    const EVENT_USER_SAVED = 'userSaved';

    public function afterSave($insert, $changedAttributes)
    {
        parent::afterSave($insert, $changedAttributes);
        // 触发事件，将当前用户模型实例作为事件数据
        $this->trigger(self::EVENT_USER_SAVED);
    }
}

// 在某个地方注册事件监听器 (例如在config/web.php 或 components/EventHandlers.php)
// 这只是一个示意，实际中可能更复杂
Yii::$app->on(User::EVENT_USER_SAVED, function ($event) {
    /** @var User $user */
    $user = $event->sender;
    // 这里可以将数据推送到消息队列，或者直接调用同步服务
    // 假设我们有一个SyncService
    Yii::$app->syncService->syncUserToAnalyticsDb($user->attributes);
});

// SyncService.php
class SyncService extends \yii\base\Component
{
    public function syncUserToAnalyticsDb($userData)
    {
        // 假设这里是发送到消息队列的逻辑
        // Yii::$app->queue->push(new SyncUserJob(['userData' => $userData]));
        // 或者直接写入db2 (不推荐，这里只是为了演示)
        $syncModel = new SyncUser(); // db2的模型
        $syncModel->attributes = $userData; // 注意字段映射
        if (!$syncModel->save()) {
            Yii::error("Failed to sync user data to analytics DB: " . json_encode($userData));
        }
    }
}

// config/db.php 或 config/main.php 中配置多个数据库连接
return [
    'components' => [
        'db1' => [
            'class' => 'yii\db\Connection',
            'dsn' => 'mysql:host=localhost;dbname=main_db',
            'username' => 'root',
            'password' => 'password',
            'charset' => 'utf8mb4',
            'enableSchemaCache' => true, // 开启Schema缓存
            'schemaCacheDuration' => 3600, // 缓存时间
            'attributes' => [ // 更多PDO属性
                PDO::ATTR_TIMEOUT => 5, // 连接超时5秒
            ],
        ],
        'db2' => [
            'class' => 'yii\db\Connection',
            'dsn' => 'mysql:host=remote_host;dbname=analytics_db',
            'username' => 'sync_user',
            'password' => 'sync_password',
            'charset' => 'utf8mb4',
            // ... 其他配置
        ],
    ],
];

yii2-queue

composer require --prefer-dist yiisoft/yii2-queue

// config/main.php 或 config/console.php
'components' => [
    'queue' => [
        'class' => \yii\queue\redis\Queue::class,
        'redis' => 'redis', // Redis 连接组件ID
        'channel' => 'data-sync-queue', // 队列通道名称
        // 可选配置：
        // 'asynchronous' => true, // 生产环境通常设为true，异步执行
        // 'ttr' => 300, // Time to run, 任务最长执行时间
        // 'attempts' => 3, // 任务失败后重试次数
    ],
    'redis' => [ // 确保你有一个redis连接组件
        'class' => 'yii\redis\Connection',
        'hostname' => 'localhost',
        'port' => 6379,
        'database' => 0,
    ],
],

namespace app\jobs;

use yii\base\BaseObject;
use yii\queue\JobInterface;

class UserSyncJob extends BaseObject implements JobInterface
{
    public $userId;
    public $action; // 'created', 'updated', 'deleted'
    public $data; // 变更的原始数据或部分关键数据

    public function execute($queue)
    {
        // 这里是消费者实际执行的逻辑
        // 假设我们有一个SyncService来处理同步
        try {
            Yii::$app->syncService->syncUser($this->userId, $this->action, $this->data);
            Yii::info("UserSyncJob for user {$this->userId} completed.");
        } catch (\Exception $e) {
            Yii::error("UserSyncJob for user {$this->userId} failed: " . $e->getMessage());
            // 抛出异常，让队列系统知道任务失败，可能会触发重试
            throw $e;
        }
    }
}

// 在控制器或服务中推送任务
// ...
if ($user->save()) {
    Yii::$app->queue->push(new \app\jobs\UserSyncJob([
        'userId' => $user->id,
        'action' => $isNewRecord ? 'created' : 'updated',
        'data' => $user->attributes, // 传递需要同步的数据
    ]));
}
// ...