MySQL中server_id一致带来的问题

Posted woqutechteam

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了MySQL中server_id一致带来的问题相关的知识,希望对你有一定的参考价值。



简  介

我们都知道在mysql搭建复制环境的时候,需要设置每个server的server_id不一致,如果主库与从库的server_id一致,那么复制会失败。但是最近在解决一个客户的问题的时候,遇到一个有意思的现象,客户环境有三台数据库服务器,一主两从,客户的两台从库设置了相同server_id,在排查问题的过程中,查看MySQL错误日志,发现有很多奇怪的信息。 
我们模拟了客户的环境,并进行测试、分析,最终在代码中找到了我们想要的答案。下面就是我们测试、分析、总结的步骤以及内容。

测试步骤


环境介绍

  • 主库 
    IP:192.168.1.130 
    server_id:3656

  • 从库A 
    IP:192.168.1.36 
    server_id:56

  • 从库B 
    IP:192.168.1.57 
    server_id:56


三台主机除server_id之外,其余配置如下:

server_id = 123

[client]

socket = /home/mysql/data/mysqldata5.5/sock/mysql.sock

[mysqld]

#server_id = 365

server_id = 123

port = 3306

skip_name_resolve = 1

binlog_format = ROW

#binlog_format = STATEMENT

basedir = /home/mysql/program/mysql5.5.36

datadir = /home/mysql/data/mysqldata5.5/mydata

socket = /home/mysql/data/mysqldata5.5/sock/mysql.sock

pid-file = /home/mysql/data/mysqldata5.5/sock/mysql.pid

tmpdir = /home/mysql/data/mysqldata5.5/tmpdir

log-error = /home/mysql/data/mysqldata5.5/log/error.log

slow_query_log

slow_query_log_file = /home/mysql/data/mysqldata5.5/slowlog/slow-query.log

log-bin = /home/mysql/data/mysqldata5.5/binlog/mysql-bin

relay-log = /home/mysql/data/mysqldata5.5/relaylog/mysql-relay-bin

innodb_data_home_dir = /home/mysql/data/mysqldata5.5/innodb_ts

innodb_log_group_home_dir = /home/mysql/data/mysqldata5.5/innodb_log

#innodb_undo_directory = /home/mysql/data/mysqldata5.5/undo/

sync_binlog=1

innodb_file_per_table=1

#skip_grant_tables

expire_logs_days = 1

log_slave_updates = ON

#replicate-same-server-id=1

skip_slave_start

#innodb_undo_tablespaces=1


5.5.36版本现象

初始搭建环境之后,查看各主机状态。搭建环境的步骤就省略。


主库(192.168.1.130)

主库通过show processlist语句查看,只有一个dump线程,但是通过多次刷新,可以看到连接的是不同的服务器。可以看到每次通过show processlist语句显示的dump线程的Host字段中,IP:PORT的值是不断在更新的,说明dump线程在不断的重连,才会出现占用不同的端口的现象。 


从库A(192.168.1.36)

通过show slave status\\G命令查看复制状态,多次执行可以看到Slave_IO_Running字段显示的内容,出现YES或者Connnecting两种状态。可以看到I/O线程在不断的进行重连。 

并且通过tail -f命令查看error log,可以看到I/O线程一直在尝试重新连接。 

可以看到在错误日志中打印的信息是,I/O线程连接 。


从库B(192.168.1.57)

从库B现象与从库A一致。 


5.6.36版本现象

搭建环境步骤不在赘述。


主库(192.168.1.130)

show processlist查看有两个dump线程,并且多次刷新,发现Host字段中的IP:PORT并没有修改,说明dump线程一直保持连接。 


从库A(192.168.1.36)

tail -f /home/mysql/data/mysqldata5.6/log/error.log查看错误日志,没有不断断开连接 。


从库B(192.168.1.57)

tail -f /home/mysql/data/mysqldata5.6/log/error.log查看错误日志,没有不断断开连接 。


原因分析

http://www.penglixun.com/tech/database/mysql_multi_slave_same_serverid.html这是彭立勋写的关于多个slave使用相同server_id时冲突的原因的一篇文章。按照彭大大的分析,我理解的是,slave的I/O线程连接上主库的时候,主库上会调用register_slave()这个函数,在这个函数中又调用了unregister_slave()函数,会将之前使用相同server_id的线程给注销掉。从而导致从库的I/O线程不断断开重连。 
但是仔细看了一下unregister_slave()函数的代码,并没有发现MySQL是根据server_id来注销dump线程的。并且进一步比较了一下5.5.36和5.6.36版本的代码,并没有发现不同。而从库设置server_id一致导致I/O线程不断重连的现象只在5.5版本中看到,在5.6版本中并没有这个现象,所以导致5.5现象的原因不是在unregister_slave()函数中。 
进一步看了一下彭大大的文章,发现有人在下面评论,说主要是kill_zombie_slave_threads()函数导致的。于是看了一下kill_zombie_slave_threads()函数的逻辑,发现MySQL应该就是在这一步根据server_id将线程kill了。

  • 5.5.36版本 
    首先来看下5.5.36版本的kill_zombie_dump_threads()函数的代码。看到这个函数传入的参数是一个uint32类型的slave_server_id,在函数中做的事情是,遍历MySQL中的所有线程,如果遍历到一个线程是dump线程并且线程的server_id是等于传入的参数值话,则跳出遍历循环,并对kill掉这个线程。

void kill_zombie_dump_threads(uint32 slave_server_id)                          

                                                                             

 mysql_mutex_lock(&LOCK_thread_count);                                        

 I_List_iterator<THD> it(threads);                                            

 THD *tmp;                                                                    

 while ((tmp=it++))                                                            

                                                                             

   if (tmp->command == COM_BINLOG_DUMP &&                                      

     tmp->server_id == slave_server_id)                                      

                                                                             

    mysql_mutex_lock(&tmp->LOCK_thd_data);    // Lock from delete            

    break;                                                                    

                                                                             

                                                                             

 mysql_mutex_unlock(&LOCK_thread_count);                                      

 if (tmp)                                                                      

                                                                             

   /*                                                                          

    Here we do not call kill_one_thread() as                                  

    it will be slow because it will iterate through the list                  

    again. We just to do kill the thread ourselves.                          

   */                                                                          

   tmp->awake(THD::KILL_QUERY);                                                

   mysql_mutex_unlock(&tmp->LOCK_thd_data);                                    

                                                                             


  • 5.6.35版本 
    再来看一下5.6.36版本的kill_zombie_dump_threads()函数的代码实现,与5.5.36大不相同。首先传入的参数是一THD类型的指针,在函数中实现的逻辑同样是遍历MySQL中的所有线程,如果找到dump线程,首先看一下这个线程有没有uuid字段(因为uuid是在5.6之后的版本才有的,这边是为了兼容5.5),如果有uuid则用uuid进行比较,如果没有uuid,则用server_id进行比较。

void kill_zombie_dump_threads(THD *thd)                                                                                                  

                                                                             

 String slave_uuid;                                                            

 get_slave_uuid(thd, &slave_uuid);                                            

 if (slave_uuid.length() == 0 && thd->server_id == 0)                          

   return;                                                                    


 mysql_mutex_lock(&LOCK_thread_count);                                        

 THD *tmp= NULL;                                                              

 Thread_iterator it= global_thread_list_begin();                              

 Thread_iterator end= global_thread_list_end();                                

 bool is_zombie_thread= false;                                                

 for (; it != end; ++it)                                                      

                                                                             

   if ((*it) != thd && ((*it)->get_command() == COM_BINLOG_DUMP || (*it)->get_command() == COM_BINLOG_DUMP_GTID))        

                                                                             

    String tmp_uuid;                                                          

    get_slave_uuid((*it), &tmp_uuid);                                        

    if (slave_uuid.length())                                                  

                                                                           

      is_zombie_thread= (tmp_uuid.length() && !strncmp(slave_uuid.c_ptr(),                        

                                        tmp_uuid.c_ptr(), UUID_LENGTH));


    else                                                                      

                                                                           

      /*                                                                      

      ¦ Check if it is a 5.5 slave's dump thread i.e., server_id should be    

      ¦ same && dump thread should not contain 'UUID'.                        

      */                                                                      

      is_zombie_thread= (((*it)->server_id == thd->server_id) && !tmp_uuid.length());                                

<

以上是关于MySQL中server_id一致带来的问题的主要内容,如果未能解决你的问题,请参考以下文章

mysql2

mysql设置主从复制

认识 MySQL 和 Redis 的数据一致性问题

MySQL:主从复制结构双主复制结构利用SSL实现安全的MySQL主从复制

Mysql主从同步

在Linux中的MySQL数据库内,/etc/my.cnf配置文件中写为server-id还是server_id呢?