当前位置: 首页 > news >正文

mysql互为主从失效,重新同步

一、分别登录服务器A和服务器B的mysql

mysql -u root -p 123456789

二、分别查看数据库状态信息,下边两项参数有一项为NO就表示同步异常

Slave_IO_Running:从服务器(Slave)中的 I/O 线程的运行状态

Slave_SQL_Running:从服务器上的 SQL 线程是否正在运行

mysql> show slave status\G                                                
Slave_IO_Running: Yes
Slave_SQL_Running: No

三、修复异常,重新同步

数据库A

1、停止同步操作

mysql> stop slave;

2、进行锁表,防止数据写入

mysql> flush tables with read lock;

3、备份数据库数据、同步数据库数据

4、查看log日志的同步点位

mysql> show master status;
+-------------------+----------+--------------+-------------------------------+
| File              | Position | Binlog_Do_DB | Binlog_Ignore_DB              |
+-------------------+----------+--------------+-------------------------------+
| mysqld-bin.000001 |     3260 |              | mysql,test,information_schema |
+-------------------+----------+--------------+-------------------------------+
1 row in set (0.00 sec)

数据库B

5、停止同步操作

mysql> stop slave;

6、备份数据库数据、同步数据库数据

7、设置从库同步,注意该处的同步点,就是数据库Ashow master status信息里的| File| Position两项

mysql> change master to master_host = '192.168.128.100', master_user = 'rsync',  master_port=3306, master_password='', master_log_file =  'mysqld-bin.000001', master_log_pos=3260;

8、打开数据库同步状态

mysql> start slave;

9、参看同步状态信息

Slave_IO_Running、Slave_SQL_Running数据都为yes表示同步成功,为no时可能为7中的File| Position两项配置不正确

mysql> show slave status\G  Slave_IO_Running: Yes
Slave_SQL_Running: Yes

10、查看log日志的同步点位,供数据库A使用

mysql> show master status;
+-------------------+----------+--------------+-------------------------------+
| File              | Position | Binlog_Do_DB | Binlog_Ignore_DB              |
+-------------------+----------+--------------+-------------------------------+
| mysqld-bin.000001 |     3260 |              | mysql,test,information_schema |
+-------------------+----------+--------------+-------------------------------+
1 row in set (0.00 sec)

数据库A

11、数据库A同步B

mysql> change master to master_host = '192.168.128.100', master_user = 'rsync',  master_port=3306, master_password='', master_log_file =  'mysqld-bin.000001', master_log_pos=3260;

12、打开从库同步状态

mysql> start slave;

13、查看同步状态信息

mysql> show slave status\G  Slave_IO_Running: Yes
Slave_SQL_Running: Yes

14、解除表锁定 

UNLOCK TABLES;

四、crontab定时检查数据库同步状态,发现异常时发送消息到钉钉群,脚本如下

<?phpfunction httpsPost($url = '', $data = []){$curl = curl_init();// 设置请求头$headers = array("Content-Type: application/json");curl_setopt($curl, CURLOPT_HTTPHEADER, $headers);curl_setopt($curl, CURLOPT_URL, $url);if (stripos($url, "https://") !== false) {curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false);curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, false);curl_setopt($curl, CURLOPT_SSLVERSION, 1); //CURL_SSLVERSION_TLSv1}if (!empty($data)) {curl_setopt($curl, CURLOPT_POST, 1);curl_setopt($curl, CURLOPT_POSTFIELDS, json_encode($data));}curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);$output = curl_exec($curl);if (curl_error($curl) != 0) {curl_error($curl);curl_close($curl);return false;} else {curl_close($curl);return $output;}
}try {$dsn = 'mysql:host=127.0.0.1;dbname=数据库名';$username = '数据库账号';$password = '数据库密码';$pdo = new PDO($dsn, $username, $password);$pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);$sql = 'show slave status';$stmt = $pdo->prepare($sql);$id = 1; // 示例值$stmt->bindParam(':id', $id); // 绑定参数以防止SQL注入$stmt->execute(); // 执行查询$result = $stmt->fetch(PDO::FETCH_ASSOC); // 获取单行结果if($result["Slave_SQL_Running"] != "Yes"){$data = ['msgtype' => 'text','text'    =>['content' => "@所有人 同学快来:数据库同步异常了"],];//监控群$url="钉钉监控群消息接口地址";//测试环境httpsPost($url,$data);}echo "数据库同步正常";} catch (PDOException $e) {die("Query failed: " . $e->getMessage());
}

http://www.lryc.cn/news/583159.html

相关文章:

  • qml加载html以及交互
  • HarmonyOS中各种动画的使用介绍
  • C语言extern的用法(非常详细,通俗易懂)
  • 〔从零搭建〕数据湖平台部署指南
  • 17.Spring Boot的Bean详解(新手版)
  • OpenCV颜色矩哈希算法------cv::img_hash::ColorMomentHash
  • STM32-待机唤醒实验
  • [Leetcode] 预处理 | 多叉树bfs | 格雷编码 | static_cast | 矩阵对角线
  • User手机上如何抓取界面的布局uiautomatorviewer
  • 【机器人】Aether 多任务世界模型 | 4D动态重建 | 视频预测 | 视觉规划
  • 速卖通跨境运营破局:亚矩阵云手机如何用“本地化黑科技”撬动俄罗斯市场25%客单价增长
  • React 编译器与性能优化:告别手动 Memoization
  • 开始读 PostgreSQL 16 Administration Cookbook
  • 苍穹外卖项目日记(day04)
  • 【Netty+WebSocket详解】WebSocket全双工通信与Netty的高效结合与实战
  • 冷冻电镜重构的GPU加速破局:从Relion到CryoSPARC的并行重构算法
  • 《重构项目》基于Apollo架构设计的项目重构方案(多种地图、多阶段、多任务、状态机管理)
  • 仓颉语言 1.0.0 升级指南:工具链适配、collection 操作重构与 Map 遍历删除避坑
  • IT系统安全刚需:绝缘故障定位系统
  • Tailwind CSS纵向滚动条设置
  • PiscTrace深蹲计数功能实现:基于 YOLO-Pose 和人体关键点分析
  • 基于Java+Maven+Testng+Selenium+Log4j+Allure+Jenkins搭建一个WebUI自动化框架(4)集成Allure报表
  • JavaScript数组方法——梳理和考点
  • SpringBoot实现动态Job实战
  • DRT-Net: Dual-Branch Rectangular Transformer with Contrastive Learning
  • 离线二维码生成器,无需网络快速制作
  • springBoot使用XWPFDocument 和 LoopRowTableRenderPolicy 两种方式填充数据到word模版中
  • Android-重学kotlin(协程源码第一阶段)新学习总结
  • npm init vue@latestnpm error code ETIMEDOUT
  • 网络请求与现实生活:用办理业务类比理解HTTP通信