软件简介

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)