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)

暂无评论

暂无资讯

暂无问答

zmq setsockopt()

zmq.RCVTIMEO:在一个recv操作返回EAGAIN错误前的最大时间 设置socket的接收操作超时时间。如果属性值是0,zmq_recv(3)函数将会立刻返回,如果没有接收到任何消息,将会返回EAGAIN错误。如果...

2019/02/18 13:11
15
0
clr_zmq Vs2010版本

.net的消息队列很方便的一个库。 在github上的主版本虽然也支持fw4.0,但是必须使用vs2012以上进行编译。 这样就依赖vcredist运行时。 因为win7 sp1以下版本,无法安装vc2015的运行时,所以z...

2018/04/24 13:23
15
0
zmq导致master收不到minion的key

问题: 官网方式yum安装完saltstack之后,master与minion都成功启动后,但是却发现怎么都收不到minion的key。(zmq版本不一致所致,困扰了我好几天,希望能帮到大家。) 分析: master上的状...

2019/01/08 11:50
9
0
Python zmq的三种简单模式

  ZMQ (以下 ZeroMQ 简称 ZMQ)是一个简单好用的传输层,像框架一样的一个 socket library,他使得 Socket 编程更加简单、简洁和性能更高。 是一个消息处理队列库,可在多个线程、内核和主机...

2019/04/27 00:39
25
0
mysql错误:this authentication plugin is not supported

this authentication plugin is not supported 应用程序连接mysql docker一直报错:this authentication plugin is not supported。 google发现,原来是mysql新版本(8.0以上)将root用户使用...

2018/12/15 09:57
20
0
使用tornado同时提供tcp和http服务 | tornado和zmq结合使用

http + tcp,能更好的提供接口来, 更好的交互

2014/03/19 17:10
546
1
mysql user password plugin

caching_sha2_password caching_sha2_password caching_sha2_password caching_sha2_password caching_sha2_password mysql_native_password D:/webCodeOnline/src/vendor/github.com/go-sql...

2018/08/05 16:46
35
0
zmq利用protobuf通信

protobuf序列化之后为二进制数据,数据中可能包含 ‘\0’,直接转换为char *类型会导致发送数据不完整。 解决方法: void buildProtobufMsg(const string& test,zmq::message_t *msg) { if (...

2019/08/14 10:25
18
0
ZMQ源代码分析(一)-- 基础数据结构的实现

yqueue 和 ypipe zmq号称是”史上最快的消息队列”,由此可见zmq中最重要的数据结构就是队列。 zmq的队列主要由yqueue和ypipe实现。yqueue是队列的基本操作,以下首先分析yqueue的实现。 /...

2018/03/04 15:16
27
0

没有更多内容

加载失败,请刷新页面

返回顶部
顶部