MySQL ZeroMQ Plugin

GPL
C/C++
Linux
2014-01-01
netkiller-

mysql-zmq-plugin

ZeroMQ / ØMQ for MySQL

Build

cmake .
make && make install

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)

Test

编译zeromq server 测试程序

cd test
cmake .
make
./server

在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)
加载中

评论(0)

暂无评论

暂无资讯

暂无问答

数据库进程间通信解决方案之MQ

你是否想过当数据库中的数据发生变化的时候出发某种操作?但因数据无法与其他进程通信(传递信号)让你放弃,而改用每隔一段时间查询一次数据变化的方法?下面的插件可以解决你的问题。

2013/12/31 17:19
190
0
Python(x,y) News: Python(x, y) 2.7.5.2 Released!

Hi All, I'm happy to announce that Python(x, y) 2.7.5.2 is available for immediate download. The last two releases focused on: Getting out of DLL hell. Eliminate all duplicate v...

2013/12/22 09:29
89
0
storm之一 简介

1、Storm简介 storm是一个分布式、容错的实时计算系统,起先被托管在GitHub上,遵循Eclipse Public License 1.0 。Storm是由BackType开发的实时处理系统,由Twitter开源 2013年,Storm进入A...

2016/06/28 03:41
17
0
twisted的异步库汇总-- mysql,redis,mongo,zmq,sockjs等

sockjs客户端是websocket javascript库(https://github.com/sockjs/sockjs-client), 可能会替代socket.io

2014/02/26 16:56
1K
1
Window c++ ZeroMQ模式初体现

Window c++ ZeroMQ

2016/10/09 17:04
101
0
(转)ZeroMQ的模式-Requset-Reply

我们先来看看第一种模式:Request-Reply Pattern。 请求应答模式。 Request-Reply这个名字很直白,口语点说就是一问一答。可以使同步的遵循请求序的一问一答,也可以 是异步的不按请求序的一问...

2013/09/06 14:45
1K
1
ZeroMQ

zmq 三种模式 第一种: Request-Reply(半双工)模式: #半双工,多客户端多客户端,一问一答模式,多客户端可以通过中间设置代理 # #server端 import zmq content = zmq.Context() sock = co...

02/28 18:06
8
0
zeromq -- 第三篇

本文翻译自http://zguide.zeromq.org/page:all,先将指导手册翻译,然后再进行源码分析 感谢zeromq的工程师将其开源,感谢互联网分享精神, 翻译中文,以便中国程序员方便使用;...

2015/12/17 10:01
13
0

没有更多内容

加载失败,请刷新页面

返回顶部
顶部