add heart beat test

Author: zhao.zhiqiang

Connect.php

@@ -86,8 +86,8 @@ public static function init($gtid = false, $slave_id = '') {
  }
  socket_set_block(self::$_SOCKET);
  socket_set_option(self::$_SOCKET, SOL_SOCKET, SO_KEEPALIVE, 1);
- //socket_set_option(self::$_SOCKET,SOL_SOCKET,SO_SNDTIMEO,['sec' => 2, 'usec' => 5000]);
- //socket_set_option(self::$_SOCKET,SOL_SOCKET,SO_RCVTIMEO,['sec' => 2, 'usec' => 5000]);
+// socket_set_option(self::$_SOCKET,SOL_SOCKET,SO_SNDTIMEO,['sec' => 2, 'usec' => 5000]);
+// socket_set_option(self::$_SOCKET,SOL_SOCKET,SO_RCVTIMEO,['sec' => 2, 'usec' => 5000]);
 
  self::$_FLAG = ConstCapability::$CAPABILITIES ;//| S::$MULTI_STATEMENTS;
  if(self::$_DB) {
@@ -188,6 +188,7 @@ private static function _goneAway($msg) {
 
 
  private static function _readPacket() {
+
  //消息头
  $header = self::_readBytes(4);
 
@@ -237,14 +238,18 @@ public static function excute($sql) {
  self::_write($prelude . $sql);
  }
 
-
  public static function getBinlogStream() {
 
  // checksum
  self::$_CHECKSUM = DBHelper::isCheckSum();
  if(self::$_CHECKSUM){
  self::excute("set @master_binlog_checksum= @@global.binlog_checksum");
  }
+ //heart_period
+ $heart = (int)Config::$DB_CONFIG['heartbeat'];
+ if($heart) {
+ self::excute("set @master_heartbeat_period=".($heart*1000000000));
+ }
 
  self::_writeRegisterSlaveCommand();
 
@@ -316,6 +321,36 @@ private static function _sync($result, $flag) {
  return $result;
  }
 
+ /**
+ * todo
+ * @breif 注册成slave
+ * @return void
+ */
+ private static function _writeRegisterSlaveCommand2() {
+ $len = 22+strlen(Config::$DB_CONFIG['username'])+
+ strlen(Config::$DB_CONFIG['hostname'])+
+ strlen(Config::$DB_CONFIG['password']);
+ $header = pack('l', $len);
+
+ // COM_BINLOG_DUMP
+ $data = $header . chr(ConstCommand::COM_REGISTER_SLAVE);
+
+ $data .= pack('l', self::$_SLAVE_SERVER_ID);
+ $data .= pack('C',strlen(Config::$DB_CONFIG['hostname']));
+ $data .= Config::$DB_CONFIG['hostname'];
+ $data .= pack('C',strlen(Config::$DB_CONFIG['username']));
+ $data .= Config::$DB_CONFIG['username'];
+ $data .= pack('C',strlen(Config::$DB_CONFIG['password']));
+ $data .= Config::$DB_CONFIG['password'];
+
+ $data .= pack('s', Config::$DB_CONFIG['port']);
+ $data .= pack('l', 0);
+ $data .= pack('l', 0);
+ self::_write($data);
+ $result = self::_readPacket();
+ PackAuth::success($result);
+ }
+
  /**
  * @breif 注册成slave
  * @return void

bin/BinLogPack.php

@@ -42,9 +42,7 @@ public function init($pack, $checkSum = true) {
  self::$_PACK = $pack;
  self::$_PACK_KEY = 0;
  self::$EVENT_INFO = [];
-
  $this->advance(1);
-
  self::$EVENT_INFO['time'] = $timestamp = unpack('L', $this->read(4))[1];
  self::$EVENT_INFO['type'] = self::$EVENT_TYPE = unpack('C', $this->read(1))[1];
  self::$EVENT_INFO['id'] = $server_id = unpack('L', $this->read(4))[1];
@@ -53,12 +51,9 @@ public function init($pack, $checkSum = true) {
  //position of the next event
  self::$EVENT_INFO['pos'] = $log_pos = unpack('L', $this->read(4))[1];//
  self::$EVENT_INFO['flag'] = $flags = unpack('S', $this->read(2))[1];
-
  $event_size_without_header = $checkSum === true ? ($event_size -23) : $event_size - 19;
-
  $data = [];
 
-
  // 映射fileds相关信息
  if (self::$EVENT_TYPE == ConstEventType::TABLE_MAP_EVENT) {
  RowEvent::tableMap(self::getInstance(), self::$EVENT_TYPE);
@@ -82,12 +77,13 @@ public function init($pack, $checkSum = true) {
 
  }elseif(self::$EVENT_TYPE == 15) {
  //$pack = self::getInstance();
-
  //$pack->read(4);
-
-
  } elseif(self::$EVENT_TYPE == ConstEventType::QUERY_EVENT) {
 
+ } elseif(self::$EVENT_TYPE == ConstEventType::HEARTBEAT_LOG_EVENT) {
+ //心跳检测机制
+ $binlog_name = $this->read($event_size_without_header);
+ echo 'heart beat '.$binlog_name."\n";
  }
 
  if(DEBUG) {
@@ -96,14 +92,9 @@ public function init($pack, $checkSum = true) {
  $msg .= ' -- typeEvent -> '.self::$EVENT_TYPE;
  Log::out($msg);
  }
-
  return $data;
-
-
  }
 
-// private function
-
  public function read($length) {
  $length = (int)$length;
  $n='';

config/Config.php

@@ -8,30 +8,28 @@
 class Config {
 
  public static $DB_CONFIG = array(
-'username' => 'root',
-'host' => '127.0.0.1',
-'port' => '3307',
-'password' => '123456',
-'db_name' => 'zzq'
-);
+ 'username' => 'root',
+ 'hostname' => 'slave',
+ 'host' => '127.0.0.1',
+ 'port' => 3306,
+ 'password' => '123456',
+ 'db_name' => 'zzq',
+ 'heartbeat' => 5// 心跳检测0不开启，>0 开启，（second）
+ );
 
  // 默认100次mysql dml操作记录一次 pos，filename到文件
  public static $BINLOG_COUNT = 100;
 
  // 记录当前执行到的pos，filename
  public static $BINLOG_NAME_PATH = 'file-pos';
-
- public static $OUT = 'out.log';
-
-
+ //
+ public static $OUT = 'out.log';
 
  // log记录
  public static $LOG_ERROR_PATH = 'log/error.log';
  public static $LOG_WARN_PATH = 'log/warn.log';
  public static $LOG_NOTICE_PATH = 'log/notice.log';
 
-
-
  public static $LOG = [
  'binlog' => [
  'error' => 'log/binlog-error.log'
@@ -47,17 +45,15 @@ class Config {
  ],
  ];
 
-
-public static function init() {
-
+ public static function init() {
  self::$BINLOG_NAME_PATH = ROOT . 'file-pos';
  self::$OUT = ROOT . 'out.log';
-foreach(self::$LOG as $key => $value) {
- foreach($value as $k => $v) {
- self::$LOG[$key][$k] = ROOT . $v;
-}
-}
-}
+ foreach(self::$LOG as $key => $value) {
+  foreach($value as $k => $v) {
+  self::$LOG[$key][$k] = ROOT . $v;
+ }
+ }
+ }
 }
 
 Config::init();