老狗的博客

尽管每一步都很微小，但我确认我在进步

日志

关于我

sky

认真生活,努力工作热爱技术,关注DB,存储,分布式,中间层,java,c++,php

文章分类

LOFTER精选

八招诀窍，教你实力撩妹 >

网易考拉推荐

mysql server/client communication protocol [command packet分析]

2012-05-10 11:16:52| 分类： mysql | 标签： |举报 |字号大中小订阅

下载LOFTER 我的照片书 |

mysql internals

http://forge.mysql.com/wiki/MySQL_Internals

command packet

mypump(我的开源mysql行复制协议解析程序)，其实已经写完很长时间了，总是在想着总结一下，也想着能不能继续完成其他的几个开源代码，目前想法如下：

1. 封装Lucene提供类似于db的全模糊查询(可以和mypump结合，实现实时全模糊查询功能)

2. 封装redis,实现mysql到redis/memcache的实时复制

3. 实现mysql的并行行复制

不知道能不能继续写下去，看机会吧

Mysql的command packet的种类有很多，下面一一列出，以供参考

Name	解释	参数
Com_quit	关闭当前的连接
Com_init_db	使用某个db，类似于user xxx;
Com_query	用于执行sql语句
Com_field_list	展示某个表的列，类似于show fields from
Com_create_db	创建DB
Com_drop_db	删除DB
Com_refresh	类似于c api 的mysql_refresh()
Com_shutdown	关闭mysql server	0x00...SHUTDOWN_DEFAULT 0x01...SHUTDOWN_WAIT_CONNECTIONS 0x02...SHUTDOWN_WAIT_TRANSACTIONS 0x08...SHUTDOWN_WAIT_UPDATES 0x10...SHUTDOWN_WAIT_ALL_BUFFERS 0x11...SHUTDOWN_WAIT_CRITICAL_BUFFERS 0xFE...KILL_QUERY 0xFF... KILL_CONNECTION
Com_statistics	获取mysql server的一些统计数据
Com_process_info	等价于mysql的show processlist
Com_process_kill	等价于sql statement(kill pid)
Com_debug	让mysql服务器dump出来一些debug信息	没有参数
Com_ping	用于测试mysql connection,重置mysql inactivity counter
Com_change_user	在不关闭连接的情况下改变用户
Com_binlog_dump	当一个复制连接建立的时候，这是最后一个从client发给server的请求
Com_table_dump	等价于从client端发起Load table..from master statement语句
Com_register_slave	如果slave设置了report_host,在建立复制连接的时候，会发这个包
Com_prepare	Prepare一个sql statement
Com_execute
Com_long_data	在使用mysql_stmet_send_log_data()的时候
Com_close_stmt	Destroy a prepared statement.
Com_reset_stmt	Reset (empty) the parameter buffers for a prepared statement
Com_set_option	he parameter is a 16-bit integer. There is an ENUM type enum_mysql_set_option defined in mysql_com.h:
Com_fetch_stmt	Fetch result rows from a prepared statement.

从抽象意义上来看，command packet的格式分为两个方面，一个是command,另外一个是参数

从行复制协议来看，我们要使用com_binlog_dump命令来从从server dump数据

1byte	command	0x12
4byte	binlog position
2byte	binlog flag
4byte	server id
nbyte	binlog filename

If the binlog file name is not given, it defaults to the first binlog available on the master.

评论这张

转发至微博

阅读(374)| 评论(0)

推荐转载

历史上的今天

在LOFTER的更多文章

this.p={  m:2,
              b:2,
              loftPermalink:'',
              id:'fks_087066086082081069082082083065072087080066086084095068084',
              blogTitle:'mysql server/client communication protocol [command packet分析]',
              blogAbstract:'<div\><br\></div\><div\>mysql internals</div\><div\><a rel=\"nofollow\" href=\"http://forge.mysql.com/wiki/MySQL_Internals\"  \>http://forge.mysql.com/wiki/MySQL_Internals</a\></div\><div\>command packet</div\><div\><br\></div\><div\>mypump(我的开源mysql行复制协议解析程序)，其实已经写完很长时间了，总是在想着总结一下，也想着能不能继续完成其他的几个开源代码，目前想法如下：</div\><div\>1. 封装Lucene提供类似于db的全模糊查询(可以和mypump结合，实现实时全模糊查询功能)</div\><div\>2. 封装redis,实现mysql到redis/memcache的实时复制</div\>',
              blogTag:'communication,command,packet',
              blogUrl:'blog/static/11122970201241011165235',
              isPublished:1,
              istop:false,
              type:2,
              modifyTime:1344855550148,
              publishTime:1336619812035,
              permalink:'blog/static/11122970201241011165235',
              commentCount:0,
              mainCommentCount:0,
              recommendCount:0,
              bsrk:-100,
              publisherId:0,
              recomBlogHome:false,
              currentRecomBlog:false,
              attachmentsFileIds:[],
              vote:{},
              groupInfo:{},
              friendstatus:'none',
              followstatus:'unFollow',
              pubSucc:'',
              visitorProvince:'',
              visitorCity:'',
              visitorNewUser:false,
              postAddInfo:{},
              mset:'000',
              mcon:'',
              srk:-100,
              remindgoodnightblog:false,
              isBlackVisitor:false,
              isShowYodaoAd:false,
              hostIntro:'认真生活,努力工作\n热爱技术,关注DB,存储,分布式,中间层,java,c++,php',
              hmcon:'0',
              selfRecomBlogCount:'0',
              lofter_single:'<iframe width="140" height="560" style="overflow:hidden;" src="http://www.lofter.com/mailEntry.do?blogad=1&blog" frameBorder="0"></iframe>'
            }

{list a as x}
    {if !!x}
    <div class="iblock nbw-fce nbw-f40">
      <a class="fc03 noul" target="_blank" hidefocus="true" href="http://blog.163.com/${x.visitorName}/">
      {if x.visitorName==visitor.userName}
      <img alt="${x.visitorNickname|escape}" onerror="this.src=location.f40" class="cwd bdwa bdc0" src="${fn1(x.visitorName)}&r=${visitor.imageUpdateTime}"/>
      {else}
      <img alt="${x.visitorNickname|escape}" onerror="this.src=location.f40" class="cwd bdwa bdc0" src="${fn1(x.visitorName)}"/>
      {/if}
      </a>
      <div class="cwd vname thide">
        {if x.moveFrom=='wap'}
          <a class="noul pnt" target="_blank" href="http://blog.163.com/services/wapblog.html?frompersonalbloghome"><span title="来自网易手机博客" class="iblock wapIcon"> </span></a>
        {elseif x.moveFrom=='iphone'}
          <a class="noul pnt" target="_blank"><span title="来自iPhone客户端" class="iblock iphoneIcon"> </span></a>
        {elseif x.moveFrom=='android'}
          <a class="noul pnt" target="_blank"><span title="来自Android客户端" class="iblock androidIcon"> </span></a>
        {elseif x.moveFrom=='mobile'}
          <a class="noul pnt" target="_blank" href="http://blog.163.com/services/emsblog.html?frompersonalbloghome"><span title="来自网易短信写博" class="iblock wapIcon"> </span></a>
        {/if}
        <a class="fc03 m2a"  target="_blank" hidefocus="true" href="http://blog.163.com/${x.visitorName}/">
          ${fn(x.visitorNickname,8)|escape}
        </a>
      </div>
    </div>
    {/if}
    {/list}

<#--最新日志，群博日志--> <#--推荐日志-->

<p class="fc06">推荐过这篇日志的人：</p>
    <div>
      {list a as x}
      {if !!x}
      <div class="iblock nbw-fce nbw-f40">
        <a class="fc03 noul" target="_blank" hidefocus="true" href="http://blog.163.com/${x.recommenderName}/">
        <img alt="${x.recommenderNickname|escape}" onerror="this.src=location.f40" class="cwd bdwa bdc0" src="${fn1(x.recommenderName)}"/>
        </a>
        <div class="cwd thide">
          <a class="fc03 m2a" target="_blank" hidefocus="true" href="http://blog.163.com/${x.recommenderName}/">
            ${fn(x.recommenderNickname,6)|escape}
          </a>
        </div>
      </div>
      {/if}
      {/list}
    </div>
    {if !!b&&b.length>0}
    <p  class="fc06">他们还推荐了：</p>
    <ul>
    {list b as y}
      {if !!y}
        <li class="rrb"><span class="iblock">·</span><a class="fc03 m2a" target="_blank" href="http://blog.163.com/${y.recommendBlogPermalink}/?from=blog/static/11122970201241011165235">${y.recommendBlogTitle|escape}</a></li>
      {/if}
    {/list}
    </ul>
    {/if}

<#--引用记录--> <#--博主推荐--> <#--随机阅读--> <#--首页推荐--> <#--历史上的今天--> <#--被推荐日志--> <#--上一篇，下一篇--> <#-- 热度 -->

{list a as x}
    {if !!x}
    <div class="hotItem iblock nbw-fce nbw-f40">
      <a class="fc03 noul" target="_blank" hidefocus="true" href="http://blog.163.com/${x.publisherUsername}/">
      {if x.publisherUsername==visitor.userName}
      <img alt="${x.publisherNickname|escape}" onerror="this.src=location.f40" class="cwd bdwa bdc0" src="${fn1(x.publisherUsername)}&r=${visitor.imageUpdateTime}"/>
      {else}
      <img alt="${x.publisherNickname|escape}" onerror="this.src=location.f40" class="cwd bdwa bdc0" src="${fn1(x.publisherUsername)}"/>
      {/if}
      </a>
      <div class="cwd vname thide">
        <a class="fc03 m2a"  target="_blank" hidefocus="true" href="http://blog.163.com/${x.publisherUsername}/">
          ${fn(x.publisherNickname,8)|escape}
        </a>
      </div>
      <a class="f-myLikeIcons hottype {if x.type==1} js-liketype{elseif x.type==2} js-reblogtype{elseif x.type==3} js-sharetype{else}{/if}" target="_blank" hidefocus="true" href="http://blog.163.com/${x.publisherUsername}/"> </a>
    </div>
    {/if}
    {/list}

<#-- 网易新闻广告 --> <#--右边模块结构--> <#--评论模块结构--> <#--引用模块结构--> <#--博主发起的投票-->

页脚

我的照片书 - 博客风格 - 手机博客 - 下载LOFTER APP - 订阅此博客

老狗的博客

导航

日志

mysql server/client communication protocol [command packet分析]

历史上的今天

最近读者

热度

在LOFTER的更多文章

评论

页脚