企业官网建设流程全解析

MySQL MGR 集群 vs 主备集群对比分析报告

MySQL 版本: 8.0.26

一、集群基本信息对比

二、event_scheduler 使用对比

1. 配置值

MGR 集群: event_scheduler = OFF 主备集群: event_scheduler = OFF

2. 配置文件位置

# /etc/mysql/my.cnf [mysqld] event_scheduler=0

3. 使用说明

event_scheduler 默认关闭原因:

• 避免自动化任务在多个节点重复执行
• 主备/MGR 集群中，事件调度器仅需在主节点/PRIMARY节点运行

启用方式:

-- 方式1: 动态开启 (仅主节点)SETGLOBALevent_scheduler=ON;-- 方式2: 在配置文件中开启 (需重启)-- 修改 /etc/mysql/my.cnfevent_scheduler=1

最佳实践:

• MGR 集群: 仅在 PRIMARY 节点开启，SECONDARY 节点保持关闭
• 主备集群: 仅在 Master 节点开启，Slave 节点保持关闭
• 通过应用程序检测节点角色后再开启，或由运维手动管理

三、同步机制异同点

3.1 相同点

3.2 差异点

3.3 MGR 专用配置文件

文件:/etc/mysql.cnf.d/mgr_group.cnf

[mysqld] report_host='245.0.4.201' loose-group_replication_local_address='245.0.4.201:33061' loose-group_replication_group_seeds='mysql-65cbddad00-headless:33061,...' loose-group_replication_gtid_assignment_block_size=1

3.4 主备集群半同步配置

文件:/etc/mysql/ext.semi.cnf

# 半同步复制插件 loose-rpl_semi_sync_master_enabled=1 loose-rpl_semi_sync_master_timeout=1000 loose-rpl_semi_sync_master_wait_no_slave=OFF loose-rpl_semi_sync_master_wait_for_slave_count=1 loose-rpl_semi_sync_master_wait_point=AFTER_SYNC loose-rpl_semi_sync_slave_enabled=1

四、存储过程、触发器、定时器同步机制

4.1 同步原理

4.2 关键配置参数

log_bin_trust_function_creators

MGR 集群: log_bin_trust_function_creators = OFF 主备集群: log_bin_trust_function_creators = OFF 配置文件中: log_bin_trust_function_creators=1 (实际已启用)

此参数控制是否信任存储函数创建者：

• OFF: 创建存储函数/触发器需要 SUPER 权限或 DETERMINISTIC/NO SQL 声明
• ON: 允许创建任意存储函数

4.3 对象同步验证

-- 1. 查看存储过程SELECTROUTINE_NAME,ROUTINE_TYPEFROMinformation_schema.ROUTINESWHEREROUTINE_SCHEMA='your_db';-- 2. 查看触发器SELECTTRIGGER_NAME,EVENT_MANIPULATIONFROMinformation_schema.TRIGGERSWHERETRIGGER_SCHEMA='your_db';-- 3. 查看事件/定时器SELECTEVENT_NAME,STATUS,EXECUTE_ATFROMinformation_schema.EVENTSWHEREEVENT_SCHEMA='your_db';

4.4 存储过程创建与验证

4.4.1 创建存储过程示例

-- 在主节点 (PRIMARY/Master) 执行USEtest_db;-- 删除已存在的存储过程（幂等性设计）DROPPROCEDUREIFEXISTSsp_sample_process;-- 创建存储过程DELIMITER//CREATEPROCEDUREsp_sample_process()DETERMINISTICREADSSQLDATABEGINSELECTCOUNT(*)AStable_countFROMinformation_schema.TABLESWHERETABLE_SCHEMA='test_db';END//DELIMITER;-- 验证创建成功SHOWPROCEDURESTATUSWHEREDb='test_db'ANDName='sp_sample_process';

4.4.2 验证同步到从节点

# 1. 获取 GTID 位置（主节点）kubectlexec-it -n qfusion-admin<primary-pod>-c mysql -- mysql -u root -p -e" SELECT @@GLOBAL.GTID_EXECUTED; "# 2. 检查从节点 GTID 是否一致kubectlexec-it -n qfusion-admin<secondary-pod>-c mysql -- mysql -u root -p -e" SELECT @@GLOBAL.GTID_EXECUTED; SHOW SLAVE STATUS\G "# 3. 在从节点验证存储过程已同步kubectlexec-it -n qfusion-admin<secondary-pod>-c mysql -- mysql -u root -p -e" SELECT ROUTINE_NAME, ROUTINE_TYPE, CREATED FROM information_schema.ROUTINES WHERE ROUTINE_SCHEMA = 'test_db' AND ROUTINE_NAME = 'sp_sample_process'; "# 4. 查看存储过程定义（确认代码一致）kubectlexec-it -n qfusion-admin<secondary-pod>-c mysql -- mysql -u root -p -e" SHOW CREATE PROCEDURE test_db.sp_sample_process\G "

4.4.3 完整验证检查清单

4.5 触发器创建与验证

4.5.1 创建触发器示例

-- 在主节点 (PRIMARY/Master) 执行USEtest_db;-- 创建测试表DROPTABLEIFEXISTSt_audit_log;CREATETABLEt_audit_log(idBIGINTAUTO_INCREMENTPRIMARYKEY,table_nameVARCHAR(64),actionVARCHAR(16),old_value JSON,new_value JSON,created_atTIMESTAMPDEFAULTCURRENT_TIMESTAMP);DROPTABLEIFEXISTSt_users;CREATETABLEt_users(idINTAUTO_INCREMENTPRIMARYKEY,usernameVARCHAR(50),emailVARCHAR(100),updated_atTIMESTAMPDEFAULTCURRENT_TIMESTAMPONUPDATECURRENT_TIMESTAMP);-- 删除已存在的触发器DROPTRIGGERIFEXISTStr_users_after_update;-- 创建触发器（记录更新操作）DELIMITER//CREATETRIGGERtr_users_after_updateAFTERUPDATEONt_usersFOR EACH ROWBEGININSERTINTOt_audit_log(table_name,action,old_value,new_value)VALUES('t_users','UPDATE',JSON_OBJECT('id',OLD.id,'username',OLD.username,'email',OLD.email),JSON_OBJECT('id',NEW.id,'username',NEW.username,'email',NEW.email));END//DELIMITER;-- 验证创建成功SHOWTRIGGERSLIKE't_users';

4.5.2 验证同步到从节点

# 1. 在主节点测试触发器kubectlexec-it -n qfusion-admin<primary-pod>-c mysql -- mysql -u root -p test_db -e" INSERT INTO t_users (username, email) VALUES ('user1', 'user1@test.com'); UPDATE t_users SET email = 'newemail@test.com' WHERE username = 'user1'; SELECT * FROM t_audit_log ORDER BY id DESC LIMIT 1; "# 2. 检查从节点同步状态kubectlexec-it -n qfusion-admin<secondary-pod>-c mysql -- mysql -u root -p -e" SHOW SLAVE STATUS\G "|grep-E"Slave_IO_Running|Slave_SQL_Running|Seconds_Behind_Master"# 3. 在从节点验证触发器定义已同步kubectlexec-it -n qfusion-admin<secondary-pod>-c mysql -- mysql -u root -p -e" SELECT TRIGGER_NAME, EVENT_MANIPULATION, EVENT_OBJECT_TABLE, ACTION_TIMING FROM information_schema.TRIGGERS WHERE TRIGGER_SCHEMA = 'test_db' AND TRIGGER_NAME = 'tr_users_after_update'; "# 4. 查看触发器详细定义kubectlexec-it -n qfusion-admin<secondary-pod>-c mysql -- mysql -u root -p -e" SHOW CREATE TRIGGER test_db.tr_users_after_update\G "# 5. 验证数据已同步（注意：从节点不会再次执行触发器）kubectlexec-it -n qfusion-admin<secondary-pod>-c mysql -- mysql -u root -p test_db -e" SELECT * FROM t_users; SELECT * FROM t_audit_log; "

4.5.3 触发器验证检查清单

4.6 定时器 (EVENT) 创建与验证

4.6.1 创建定时器示例

-- 在主节点 (PRIMARY/Master) 执行USEtest_db;-- 先启用事件调度器（仅主节点）SETGLOBALevent_scheduler=ON;-- 验证调度器已启动SHOWVARIABLESLIKE'event_scheduler';-- 删除已存在的事件DROPEVENTIFEXISTSev_cleanup_old_logs;-- 创建定时清理任务（每分钟执行一次）DELIMITER//CREATEEVENT ev_cleanup_old_logsONSCHEDULE EVERY1MINUTESTARTSCURRENT_TIMESTAMPDOBEGINDECLARErows_deletedINTDEFAULT0;-- 清理30天前的审计日志DELETEFROMt_audit_logWHEREcreated_at<DATE_SUB(NOW(),INTERVAL30DAY)LIMIT1000;SETrows_deleted=ROW_COUNT();-- 记录执行日志（可选）INSERTINTOt_audit_log(table_name,action,new_value)VALUES('event_scheduler','cleanup',JSON_OBJECT('deleted_rows',rows_deleted));END//DELIMITER;-- 验证事件创建并查看状态SELECTEVENT_NAME,STATUS,EXECUTE_AT,INTERVAL_VALUE,INTERVAL_FIELDFROMinformation_schema.EVENTSWHEREEVENT_SCHEMA='test_db'ANDEVENT_NAME='ev_cleanup_old_logs';-- 启用事件（默认创建后即启用）ALTEREVENT ev_cleanup_old_logsENABLE;

4.6.2 验证同步到从节点

# 1. 检查从节点事件定义是否同步kubectlexec-it -n qfusion-admin<secondary-pod>-c mysql -- mysql -u root -p -e" SELECT EVENT_NAME, STATUS, EXECUTE_AT, INTERVAL_VALUE, INTERVAL_FIELD FROM information_schema.EVENTS WHERE EVENT_SCHEMA = 'test_db' AND EVENT_NAME = 'ev_cleanup_old_logs'; "# 2. 验证从节点 event_scheduler 状态（应为 OFF）kubectlexec-it -n qfusion-admin<secondary-pod>-c mysql -- mysql -u root -p -e" SELECT @@event_scheduler; "# 3. 查看从节点事件详情kubectlexec-it -n qfusion-admin<secondary-pod>-c mysql -- mysql -u root -p -e" SHOW CREATE EVENT test_db.ev_cleanup_old_logs\G "# 4. 等待1分钟后检查主节点执行结果kubectlexec-it -n qfusion-admin<primary-pod>-c mysql -- mysql -u root -p test_db -e" SELECT * FROM t_audit_log WHERE table_name = 'event_scheduler' ORDER BY created_at DESC LIMIT 5; "# 5. 验证从节点数据已同步（但事件未在从节点执行）kubectlexec-it -n qfusion-admin<secondary-pod>-c mysql -- mysql -u root -p test_db -e" SELECT * FROM t_audit_log WHERE table_name = 'event_scheduler' ORDER BY created_at DESC LIMIT 5; "

4.6.3 定时器验证检查清单

4.6.4 定时器生产环境配置建议

-- 生产环境建���：每天凌晨2点执行DROPEVENTIFEXISTSev_cleanup_old_logs;DELIMITER//CREATEEVENT ev_cleanup_old_logsONSCHEDULE EVERY1DAYSTARTS CONCAT(CURDATE()+INTERVAL1DAY,' 02:00:00')ONCOMPLETION PRESERVEDOBEGINDELETEFROMt_audit_logWHEREcreated_at<DATE_SUB(NOW(),INTERVAL90DAY)LIMIT10000;END//DELIMITER;-- 查看所有事件状态SELECTEVENT_NAME,STATUS,LAST_EXECUTED,ON_COMPLETION,INTERVAL_VALUE,INTERVAL_FIELDFROMinformation_schema.EVENTSWHEREEVENT_SCHEMA='test_db';

4.7 完整同步验证流程总结

#!/bin/bash# 完整的对象同步验证脚本NAMESPACE="qfusion-admin"PRIMARY_POD="<primary-pod-name>"SECONDARY_POD="<secondary-pod-name>"DB_USER="root"DB_PASS="<password>"DB_NAME="test_db"echo"=== 1. 检查复制状态 ==="kubectlexec-it -n$NAMESPACE$SECONDARY_POD-c mysql -- mysql -u$DB_USER-p$DB_PASS-e" SHOW SLAVE STATUS\G "|grep-E"Slave_IO_Running|Slave_SQL_Running|Seconds_Behind_Master|Last_Error"echo-e"\n=== 2. 验证存储过程同步 ==="kubectlexec-it -n$NAMESPACE$SECONDARY_POD-c mysql -- mysql -u$DB_USER-p$DB_PASS-e" SELECT ROUTINE_NAME, CREATED FROM information_schema.ROUTINES WHERE ROUTINE_SCHEMA = '$DB_NAME'; "echo-e"\n=== 3. 验证触发器同步 ==="kubectlexec-it -n$NAMESPACE$SECONDARY_POD-c mysql -- mysql -u$DB_USER-p$DB_PASS-e" SELECT TRIGGER_NAME, EVENT_OBJECT_TABLE FROM information_schema.TRIGGERS WHERE TRIGGER_SCHEMA = '$DB_NAME'; "echo-e"\n=== 4. 验证定时器同步 ==="kubectlexec-it -n$NAMESPACE$SECONDARY_POD-c mysql -- mysql -u$DB_USER-p$DB_PASS-e" SELECT EVENT_NAME, STATUS, LAST_EXECUTED FROM information_schema.EVENTS WHERE EVENT_SCHEMA = '$DB_NAME'; "echo-e"\n=== 5. 验证 GTID 一致性 ==="echo"主节点 GTID:"kubectlexec-it -n$NAMESPACE$PRIMARY_POD-c mysql -- mysql -u$DB_USER-p$DB_PASS-e" SELECT @@GLOBAL.GTID_EXECUTED; "echo"从节点 GTID:"kubectlexec-it -n$NAMESPACE$SECONDARY_POD-c mysql -- mysql -u$DB_USER-p$DB_PASS-e" SELECT @@GLOBAL.GTID_EXECUTED; "echo-e"\n=== 6. 检查 event_scheduler 状态 ==="echo"主节点:"kubectlexec-it -n$NAMESPACE$PRIMARY_POD-c mysql -- mysql -u$DB_USER-p$DB_PASS-e" SELECT @@event_scheduler; "echo"从节点:"kubectlexec-it -n$NAMESPACE$SECONDARY_POD-c mysql -- mysql -u$DB_USER-p$DB_PASS-e" SELECT @@event_scheduler; "

五、节点读写状态对比

5.1 MGR 集群

5.2 主备集群

注意:主备集群的 Slave 节点read_only=1由配置文件/etc/mysql/ext.semi.cnf设置。

六、配置、检查方法总结

6.1 检查 event_scheduler 状态

SHOWVARIABLESLIKE'event_scheduler';-- 或SELECT@@event_scheduler;

6.2 检查节点角色

-- MGR 集群SELECTMEMBER_HOST,MEMBER_PORT,MEMBER_STATE,MEMBER_ROLEFROMperformance_schema.replication_group_members;-- 主备集群SHOWSLAVESTATUS\G

6.3 检查复制状态

-- MGR 集群SHOWVARIABLESLIKE'group_replication%';-- 主备集群SHOWSLAVESTATUS\GSHOWMASTERSTATUS;

6.4 检查对象同步

-- 检查 GTID 执行情况SHOWVARIABLESLIKE'gtid%';SELECT@@GLOBAL.GTID_EXECUTED;-- 检查 binlog 位置SHOWMASTERSTATUS;

6.5 启用 event_scheduler (仅主节点)

-- MGR 集群 - 在 PRIMARY 节点执行SETGLOBALevent_scheduler=ON;-- 主备集群 - 在 Master 节点执行SETGLOBALevent_scheduler=ON;

6.6 永久配置修改

# 编辑配置文件kubectlexec-it -n qfusion-admin<pod-name>-c mysql --vi/etc/mysql/my.cnf# 修改 event_scheduler=0 为 event_scheduler=1# 然后重启 Podkubectl delete pod -n qfusion-admin<pod-name>

七、建议与注意事项

7.1 event_scheduler 使用建议

1. 默认保持关闭: 集群默认配置为关闭是合理的
2. 按需启用: 仅在需要执行定时任务的节点上手动启用
3. 单点执行: 避免多节点同时执行相同任务
4. 应用层控制: 建议在应用层检测节点角色后再启用

7.2 存储过程/触发器/定时器开发建议

1. 幂等性设计: 确保对象可以被重复创建而不报错

   DROPPROCEDUREIFEXISTSproc_name;CREATEPROCEDUREproc_name()...

2. 声明确定性: 函数应声明 DETERMINISTIC 或 NO SQL

   CREATEFUNCTIONfunc_name()RETURNSINTDETERMINISTICREADSSQLDATABEGIN...

3. 避免不确定性操作: 不使用 RAND(), UUID(), NOW() 等不确定函数

7.3 监控建议

-- 监控 MGR 状态SELECT*FROMperformance_schema.replication_group_member_stats;-- 监控主备延迟SHOWSLAVESTATUS\G-- 关注: Seconds_Behind_Master-- 监控事件执行SELECT*FROMinformation_schema.EVENTS;

八、配置文件路径汇总