MySQL ZeroMQ Plugin [](<a href="https://github.com/netkiller/mysql-zmq-">https://github.com/netkiller/mysql-zmq-</a>[](<a href="https://github.com/netkiller/mysql-zmq-">https://g

程序名称：MySQL ZeroMQ Plugin [](<a href="https://github.com/netkiller/mysql-zmq-">https://github.com/netkiller/mysql-zmq-</a>[](<a href="https://github.com/netkiller/mysql-zmq-">https://g

授权协议: GPL

操作系统: Linux

开发语言: C/C++

MySQL ZeroMQ Plugin [](<a href="https://github.com/netkiller/mysql-zmq-">https://github.com/netkiller/mysql-zmq-</a>[](<a href="https://github.com/netkiller/mysql-zmq-">https://g 介绍

MysqL-zmq-plugin

ZeroMQ / ØMQ for MysqL

[](https://github.com/netkiller/mysql-zmq-

plugin/blob/master/README.md#build)Build

cmake .
make && make install

[](https://github.com/netkiller/mysql-zmq-

plugin/blob/master/README.md#install–uninstall)Install & uninstall

drop function zmq_client;
drop function zmq_publish;

create function zmq_client returns string soname 'libzeromq.so';
create function zmq_publish returns string soname 'libzeromq.so';

MysqL> SELECT * FROM `MysqL`.`func` LIMIT 1000;
+--------------+-----+--------------+----------+
| name         | ret | dl           | type     |
+--------------+-----+--------------+----------+
| image_crc32  |   0 | image.so     | function |
| image_rename |   0 | image.so     | function |
| image_move   |   0 | image.so     | function |
| image_remove |   0 | image.so     | function |
| image_check  |   0 | image.so     | function |
| fifo_write   |   0 | fifo.so      | function |
| fifo_read    |   0 | fifo.so      | function |
| fifo_remove  |   0 | fifo.so      | function |
| fifo_create  |   0 | fifo.so      | function |
| zmq_publish  |   0 | libzeromq.so | function |
| zmq_client   |   0 | libzeromq.so | function |
+--------------+-----+--------------+----------+
11 rows in set (0.00 sec)

[](https://github.com/netkiller/mysql-zmq-

plugin/blob/master/README.md#test)Test

[](https://github.com/netkiller/mysql-zmq-

plugin/blob/master/README.md#%E7%BC%96%E8%AF%91zeromq-
server-%E6%B5%8B%E8%AF%95%E7%A8%8B%E5%BA%8F)编译zeromq server 测试程序

cd test
cmake .
make
./server

[](https://github.com/netkiller/mysql-zmq-

plugin/blob/master/README.md#%E5%9C%A8MysqL%E7%BB%88%E7%AB%AF%E4%B8%AD%E8%BF%90%E8%A1%8C%E6%B5%8B%E8%AF%95sql)在MysqL终端中运行测试sql

MysqL> select zmq_client('tcp://localhost:5555','Hello world!');
+---------------------------------------------------+
| zmq_client('tcp://localhost:5555','Hello world!') |
+---------------------------------------------------+
| Hello world! OK                                   |
+---------------------------------------------------+
1 row in set (0.01 sec)

MysqL> select zmq_client('tcp://localhost:5555',mobile) from demo;
+-------------------------------------------+
| zmq_client('tcp://localhost:5555',mobile) |
+-------------------------------------------+
| 13113668891 OK                            |
| 13113668892 OK                            |
| 13113668893 OK                            |
| 13322993040 OK                            |
| 13588997745 OK                            |
+-------------------------------------------+
5 rows in set (0.03 sec)

MySQL ZeroMQ Plugin [](<a href="https://github.com/netkiller/mysql-zmq-">https://github.com/netkiller/mysql-zmq-</a>[](<a href="https://github.com/netkiller/mysql-zmq-">https://g 官网

http://netkiller.github.io/