ITPub博客
首页 博客 专栏 学院 社区 IT新媒体评选
发博

首页 > 应用开发 > IT综合 > 像vmstat一样输出show slave status 监控延迟

像vmstat一样输出show slave status 监控延迟

原创 IT综合 作者：gaopengtttt 时间：2016-09-01 17:46:03 0 删除 编辑
有时候我们想能够像vmstat一样监控show slave status，当然方法有很多种，
我这里用一下自己的方法，是用C写的调用MYSQL的连接API取到数据
进行小小的处理，输出到屏幕，但是由于只是测试，没有完善，比如连接方式
应该是是参数的方式给出，我这里写死了，但是是一个方法，运行如下：
最后一个字段是字节数，忘记去掉了。
slavecheck  1 3 代表1秒一次输出3次
[root@testmy testmysqlc]# ./slavecheck  1 3
success
retrieved 1 rows
Fetched data..
                Slave_IO_State**********::Waiting for master to send event::32
                   Master_Host**********::192.168.190.93::14
                   Master_User**********::repl::4
                   Master_Port**********::3306::4
                 Connect_Retry**********::60::2
               Master_Log_File**********::binlog.000020::13
           Read_Master_Log_Pos**********::120::3
                Relay_Log_File**********::testmy-relay-bin.000005::23
                 Relay_Log_Pos**********::314::3
         Relay_Master_Log_File**********::binlog.000020::13
              Slave_IO_Running**********::Yes::3
             Slave_SQL_Running**********::Yes::3
                    Last_Errno**********::0::1
                  Skip_Counter**********::0::1
           Exec_Master_Log_Pos**********::120::3
               Relay_Log_Space**********::682::3
               Until_Condition**********::None::4
                 Until_Log_Pos**********::0::1
            Master_SSL_Allowed**********::No::2
         Seconds_Behind_Master**********::0::1
 Master_SSL_Verify_Server_Cert**********::No::2
                 Last_IO_Errno**********::0::1
                Last_SQL_Errno**********::0::1
              Master_Server_Id**********::9356::4
                   Master_UUID**********::edc7037b-5a49-11e6-9f9d-000c29a879a3::36
              Master_Info_File**********::/mysqldata/mysql5.7/data/master.info::36
                     SQL_Delay**********::0::1
       Slave_SQL_Running_State**********::Slave has read all relay log; waiting for more updates::54
            Master_Retry_Count**********::86400::5
                 Auto_Position**********::0::1
Retrive error:
success
retrieved 1 rows
Fetched data..
                Slave_IO_State**********::Waiting for master to send event::32
                   Master_Host**********::192.168.190.93::14
                   Master_User**********::repl::4
                   Master_Port**********::3306::4
                 Connect_Retry**********::60::2
               Master_Log_File**********::binlog.000020::13
           Read_Master_Log_Pos**********::120::3
                Relay_Log_File**********::testmy-relay-bin.000005::23
                 Relay_Log_Pos**********::314::3
         Relay_Master_Log_File**********::binlog.000020::13
              Slave_IO_Running**********::Yes::3
             Slave_SQL_Running**********::Yes::3
                    Last_Errno**********::0::1
                  Skip_Counter**********::0::1
           Exec_Master_Log_Pos**********::120::3
               Relay_Log_Space**********::682::3
               Until_Condition**********::None::4
                 Until_Log_Pos**********::0::1
            Master_SSL_Allowed**********::No::2
         Seconds_Behind_Master**********::0::1
 Master_SSL_Verify_Server_Cert**********::No::2
                 Last_IO_Errno**********::0::1
                Last_SQL_Errno**********::0::1
              Master_Server_Id**********::9356::4
                   Master_UUID**********::edc7037b-5a49-11e6-9f9d-000c29a879a3::36
              Master_Info_File**********::/mysqldata/mysql5.7/data/master.info::36
                     SQL_Delay**********::0::1
       Slave_SQL_Running_State**********::Slave has read all relay log; waiting for more updates::54
            Master_Retry_Count**********::86400::5
                 Auto_Position**********::0::1
Retrive error:
success
retrieved 1 rows
Fetched data..
                Slave_IO_State**********::Waiting for master to send event::32
                   Master_Host**********::192.168.190.93::14
                   Master_User**********::repl::4
                   Master_Port**********::3306::4
                 Connect_Retry**********::60::2
               Master_Log_File**********::binlog.000020::13
           Read_Master_Log_Pos**********::120::3
                Relay_Log_File**********::testmy-relay-bin.000005::23
                 Relay_Log_Pos**********::314::3
         Relay_Master_Log_File**********::binlog.000020::13
              Slave_IO_Running**********::Yes::3
             Slave_SQL_Running**********::Yes::3
                    Last_Errno**********::0::1
                  Skip_Counter**********::0::1
           Exec_Master_Log_Pos**********::120::3
               Relay_Log_Space**********::682::3
               Until_Condition**********::None::4
                 Until_Log_Pos**********::0::1
            Master_SSL_Allowed**********::No::2
         Seconds_Behind_Master**********::0::1
 Master_SSL_Verify_Server_Cert**********::No::2
                 Last_IO_Errno**********::0::1
                Last_SQL_Errno**********::0::1
              Master_Server_Id**********::9356::4
                   Master_UUID**********::edc7037b-5a49-11e6-9f9d-000c29a879a3::36
              Master_Info_File**********::/mysqldata/mysql5.7/data/master.info::36
                     SQL_Delay**********::0::1
       Slave_SQL_Running_State**********::Slave has read all relay log; waiting for more updates::54
            Master_Retry_Count**********::86400::5
                 Auto_Position**********::0::1
Retrive error:


给出源码

点击(此处)折叠或打开

  1. 文件testcon3.c
  2. #include<stdio.h>
  3. #include<stdlib.h>
  4. #include<string.h>
  5. #include"mysql.h"
  6. void display_row(MYSQL* mycon, const MYSQL_ROW* sqlrow,MYSQL_RES* res_ptr)
  7. {
  8.         unsigned int field_count;
  9.         field_count = 0;
  10.         MYSQL_FIELD *field_ptr;
  11.         char* mychar;

  13.         field_ptr=mysql_fetch_field(res_ptr);
  14.         while (field_count<mysql_field_count(mycon))
  15.         {
  16.                 //if(strlen((*sqlrow)[field_count]))
  17.                 //{
  18.                 if((*sqlrow)[field_count]&&strlen((*sqlrow)[field_count]))
  19.                 {
  20.                 printf("%30s**********::%s::%u",field_ptr->name,(*sqlrow)[field_count],strlen((char *)(*sqlrow)[field_count]));
  21.                 printf("\n");
  22.                 }
  23.                 //}
  24.                 field_count++;
  25.                 field_ptr++;
  26.         }
  27. }

  29. int giveslave(void)
  30. {
  31.         MYSQL *conn_ptr;
  32.         conn_ptr = mysql_init(NULL);
  33.         MYSQL_RES *res_ptr;
  34.         MYSQL_ROW sqlrow;
  35.         int res; //
  36.         if(!conn_ptr)
  37.         {
  38.                 printf("%s\n","error");
  39.                 return 1;
  40.         }

  42.         conn_ptr = mysql_real_connect(conn_ptr,"localhost","root","test123","test",3307,"/mysqldata/mysql5.7/mysqld3307.sock",0);
  43.         if(conn_ptr)
  44.         {
  45.                 printf("%s\n","success");
  46.         }
  47.         else
  48.         {
  49.                 printf("%s\n","error");
  50.         }
  51.         
  52.         res = mysql_query(conn_ptr,"show slave status");
  53.         if(res)
  54.         {
  55.                 printf("show error:",mysql_error(conn_ptr));
  56.         }
  57.         else
  58.         {
  59.                 res_ptr = mysql_store_result(conn_ptr);
  60.                  if(res_ptr)
  61.                  {
  62.                                 printf("retrieved %lu rows\n",(unsigned long)mysql_num_rows(res_ptr));
  63.                                 while((sqlrow = mysql_fetch_row(res_ptr)))
  64.                                         {
  65.                                                 printf("Fetched data..\n");
  66.                                                 display_row(conn_ptr,&sqlrow,res_ptr);
  67.                                         }
  68.                                         if(mysql_error(conn_ptr))
  69.                                         {
  70.                                                 printf("Retrive error:%s\n",mysql_error(conn_ptr));
  71.                                         }
  72.                                         mysql_free_result(res_ptr);
  73.                  }
  74.         }
  75.         mysql_close(conn_ptr);
  76.         return 0;
  77. }

点击(此处)折叠或打开

  1. 文件main.c
  2. #include<stdio.h>
  3. #include <unistd.h>


  6. int main(int argc,char *argv[])
  7. {
  8.    unsigned int m;
  9.    unsigned int n;
  10.    unsigned int i;
  11.    if(argc != 3)
  12.         {printf("error:");return 10;}
  13.    sscanf(argv[2],"%u",&m);
  14.    sscanf(argv[1],"%u",&n);
  15.    for(i=0;i<m;i++)
  16.    {
  17.         giveslave();
  18.         sleep(n);
  19.    }
  20.    return 0;
  21. }
编译
gcc testcon3.c main.c -L/mysqldata/mysql5.7/lib -lmysqlclient -I/mysqldata/mysql5.7/include -g -o slavecheck
然后就可以了

如果哪天写一个监控软件可以把这个集成到子功能上去

来自 “ ITPUB博客 ” ，链接：https://blog.itpub.net/7728585/viewspace-2124364/ ，如需转载，请注明出处，否则将追究法律责任。

0
0
上一篇： 类模板继承和部分具体化例子及非类型参数
下一篇： C++ RTTI中dynamic_cast的用法
请登录后发表评论 登录
全部评论
gaopengtttt
专家姓名：高鹏
wxh gp_22389860 公众号 MySQL学习 书籍 深入理解MySQL主从原理

注册时间：2021-06-07

  • 博文量
    868
  • 访问量
    3495546

最新文章

支持我们 作者招募 用户协议 FAQ Contact Us

北京盛拓优讯信息技术有限公司. 版权所有  京ICP备16024965号-8 北京市公安局海淀分局网监中心备案编号：11010802021510 niuxiaotong@pcpop.com 17352615567 未成年人举报专区

广播电视节目制作经营许可证(京) 字第1234号 中国互联网协会会员

违法和不良信息举报电话:18101376593