unzip mysql-replication-listener-master.zip cd mysql-replication-listener-master cmake . -DCMAKE_INSTALL_PREFIX=/usr/local/mysql-replication make & make install
Install php-binloghttps://github.com/bullsoft/php-binlog/archive/master.zip
<code class="hljs lasso">unzip php-binlog-master.zip cd php-binlog-master/ext /usr/local/php5.5.15/bin/phpize ./configure --with-php-config=/usr/local/php5.5.15/bin/php-config --with-mysql-binlog=/usr/local/mysql-replication</code>
<code class="hljs lasso">Examples<code class="hljs lasso">注:Binlog为行格式
<code class="hljs lasso"><code class="php hljs "><!--?php
$link = binlog_connect("mysql://root:cpyf@127.0.0.1:3306");
//binlog_set_position($link, 4);
//binlog_set_position($link, 4, 'mysql-bin.000006');
while($event=binlog_wait_for_next_event($link)) {
// it will block here
switch($event['type_code']) {
case BINLOG_DELETE_ROWS_EVENT:
var_dump($event);
// do what u want ...
break;
case BINLOG_WRITE_ROWS_EVENT:
var_dump($event);
// do what u want ...
break;
case BINLOG_UPDATE_ROWS_EVENT:
var_dump($event);
// do what u want ...
break;
default:
// var_dump($event);
break;
}
}
</pre-->
</code></code><code class="hljs lasso"><code class="php hljs ">Update_rows<code class="hljs lasso"><code class="php hljs "><code class="sql hljs ">update `type` set type_id = 22 WHERE id in (58, 59);</code></code></code>
<code class="hljs lasso"><code class="php hljs "><code class="sql hljs "><code class="php hljs ">array(5) {
'type_code' =>
int(24)
'type_str' =>
string(11) "Update_rows"
'db_name' =>
string(5) "cloud"
'table_name' =>
string(4) "type"
'rows' =>
array(4) {
[0] =>
array(5) {
[0] =>
string(2) "58"
[1] =>
string(8) "adsfasdf"
[2] =>
string(4) "asdf"
[3] =>
string(2) "22"
[4] =>
string(1) "0"
}
[1] =>
array(5) {
[0] =>
string(2) "58"
[1] =>
string(8) "adsfasdf"
[2] =>
string(4) "asdf"
[3] =>
string(1) "4"
[4] =>
string(1) "0"
}
[2] =>
array(5) {
[0] =>
string(2) "59"
[1] =>
string(8) "adsfasdf"
[2] =>
string(4) "asdf"
[3] =>
string(2) "22"
[4] =>
string(1) "0"
}
[3] =>
array(5) {
[0] =>
string(2) "59"
[1] =>
string(8) "adsfasdf"
[2] =>
string(4) "asdf"
[3] =>
string(1) "4"
[4] =>
string(1) "0"
}
}
}</code></code></code></code><code class="hljs lasso"><code class="php hljs "><code class="sql hljs "><code class="php hljs ">Delete_rows<code class="hljs lasso"><code class="php hljs "><code class="sql hljs "><code class="php hljs "><code class="sql hljs ">delete from `type` WHERE id in (58, 59);</code></code></code></code></code>
<code class="hljs lasso"><code class="php hljs "><code class="sql hljs "><code class="php hljs "><code class="sql hljs "><code class="php hljs ">array(5) {
'type_code' =>
int(25)
'type_str' =>
string(11) "Delete_rows"
'db_name' =>
string(5) "cloud"
'table_name' =>
string(4) "type"
'rows' =>
array(2) {
[0] =>
array(5) {
[0] =>
string(2) "58"
[1] =>
string(8) "adsfasdf"
[2] =>
string(4) "asdf"
[3] =>
string(2) "22"
[4] =>
string(1) "0"
}
[1] =>
array(5) {
[0] =>
string(2) "59"
[1] =>
string(8) "adsfasdf"
[2] =>
string(4) "asdf"
[3] =>
string(2) "22"
[4] =>
string(1) "0"
}
}
}</code></code></code></code></code></code><code class="hljs lasso"><code class="php hljs "><code class="sql hljs "><code class="php hljs "><code class="sql hljs "><code class="php hljs ">Write_rows<code class="hljs lasso"><code class="php hljs "><code class="sql hljs "><code class="php hljs "><code class="sql hljs "><code class="php hljs "><code class="sql hljs ">insert into type values (Null, "Hello, World", "Best world", 4, 0), (NULL, "你好,世界", "世界很美好", 3, 5);</code></code></code></code></code></code></code>
<code class="hljs lasso"><code class="php hljs "><code class="sql hljs "><code class="php hljs "><code class="sql hljs "><code class="php hljs "><code class="sql hljs "><code class="php hljs ">array(5) {
'type_code' =>
int(23)
'type_str' =>
string(10) "Write_rows"
'db_name' =>
string(5) "cloud"
'table_name' =>
string(4) "type"
'rows' =>
array(2) {
[0] =>
array(5) {
[0] =>
string(2) "95"
[1] =>
string(12) "Hello, World"
[2] =>
string(10) "Best world"
[3] =>
string(1) "4"
[4] =>
string(1) "0"
}
[1] =>
array(5) {
[0] =>
string(2) "96"
[1] =>
string(15) "你好,世界"
[2] =>
string(15) "世界很美好"
[3] =>
string(1) "3"
[4] =>
string(1) "5"
}
}
}</code></code></code></code></code></code></code></code>
PHP怎么学习?PHP怎么入门?PHP在哪学?PHP怎么学才快?不用担心,这里为大家提供了PHP速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号