BuddyBoss/BuddyPress批量发送私信性能问题求助

一、排查冗余钩子的实用方法 #

要找出拖慢发送速度的钩子，可以用以下几种方式：

• 开启调试日志记录钩子：在wp-config.php中添加define('WP_DEBUG_LOG', true);，然后自定义代码在messages_new_message执行前后记录触发的钩子及耗时，比如在函数调用前加do_action('log_before_send', microtime(true));，调用后加do_action('log_after_send', microtime(true));，再在日志里对比时间差。
• 禁用第三方插件测试：先禁用所有非BuddyPress核心的插件，测试发送速度，再逐个开启插件，找到导致延迟的元凶——很多第三方插件会挂载BuddyPress消息相关钩子做同步、统计等操作。
• 用Query Monitor分析：安装Query Monitor插件，查看每次调用messages_new_message时执行的SQL查询、钩子回调列表，直接定位耗时最长的操作。

BuddyPress原生可能的冗余钩子（除邮件通知外）：

• messages_pre_new_message：如果有自定义验证逻辑挂载在这里，可能增加耗时
• bp_messages_after_save：消息保存后的动作，部分插件会用它做数据同步
• bp_messages_record_last_activity：更新用户最后活动时间的钩子，若不需要可临时禁用

二、临时优化：批量禁用无关钩子 #

可以在发送代码块前后临时禁用非必需钩子，发送完成后恢复，避免影响其他场景的功能：

// 保存原钩子配置，用于后续恢复
$original_hooks = [];
$target_hook = 'messages_message_sent';

// 列出需要临时禁用的钩子回调
$hooks_to_disable = [
    'messages_notification_new_message',
    'bp_messages_record_last_activity',
    'bp_messages_add_notification',
];

foreach ($hooks_to_disable as $func) {
    if (has_action($target_hook, $func)) {
        // 移除钩子并记录原优先级
        $priority = remove_action($target_hook, $func);
        $original_hooks[$target_hook][$func] = $priority;
    }
}

// 执行批量发送逻辑
foreach ($users as $user) {
    $msg = [
        'recipients' => [$user->ID], 
        'content' => $content
    ];
    messages_new_message($msg);
}

// 恢复原钩子
foreach ($original_hooks as $hook => $funcs) {
    foreach ($funcs as $func => $priority) {
        add_action($hook, $func, $priority);
    }
}

三、终极优化：直接写入数据库 #

如果钩子优化后速度仍不达标，直接操作数据库是最高效的方式，但要注意BuddyPress的双表结构（主消息表+收件人表）：

global $wpdb;
$bp = buddypress();
$admin_id = get_current_user_id(); // 发送私信的管理员ID

// 插入主消息记录
$message_data = [
    'sender_id' => $admin_id,
    'subject' => '批量私信标题',
    'content' => $content,
    'date_sent' => current_time('mysql'),
    'thread_id' => 0, // 单条消息无需线程，若需线程可生成唯一ID
];

$wpdb->insert(
    $bp->messages->table_name_messages,
    $message_data,
    ['%d', '%s', '%s', '%s', '%d']
);
$message_id = $wpdb->insert_id;

// 批量准备收件人数据
$recipients_batch = [];
foreach ($users as $user) {
    $recipients_batch[] = [
        'user_id' => $user->ID,
        'message_id' => $message_id,
        'thread_id' => 0,
        'unread_count' => 1,
        'date_sent' => current_time('mysql'),
    ];
}

// 批量插入收件人表（比循环插入效率高10倍以上）
if (!empty($recipients_batch)) {
    $columns = implode(', ', array_keys($recipients_batch[0]));
    $values = [];
    foreach ($recipients_batch as $item) {
        $escaped = array_map([$wpdb, '_real_escape'], $item);
        $values[] = '(' . implode(', ', $escaped) . ')';
    }
    $sql = "INSERT INTO {$bp->messages->table_name_recipients} ($columns) VALUES " . implode(', ', $values);
    $wpdb->query($sql);
}

// 若需要更新用户未读消息计数，手动调用核心函数
foreach ($users as $user) {
    bp_messages_update_unread_count($user->ID);
}

注意：直接写数据库不会触发任何钩子，若需要某些核心功能（如未读计数更新、前端通知标记），需手动调用对应函数。

内容的提问来源于stack exchange，提问作者tim