MySQL ZeroMQ Plugin 正在参加 2021 年度 OSC 中国开源项目评选,请投票支持!
MySQL ZeroMQ Plugin 在 2021 年度 OSC 中国开源项目评选 中已获得 {{ projectVoteCount }} 票,请投票支持!
2021 年度 OSC 中国开源项目评选 正在火热进行中,快来投票支持你喜欢的开源项目!
2021 年度 OSC 中国开源项目评选 >>> 中场回顾
MySQL ZeroMQ Plugin 获得 2021 年度 OSC 中国开源项目评选「最佳人气项目」 !
授权协议 BSD
开发语言 C/C++ 查看源码 »
操作系统 Linux
软件类型 开源软件
开源组织
地区 国产
投 递 者 netkiller-
适用人群 未知
收录时间 2014-01-01

软件简介

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)
展开阅读全文

代码

的 Gitee 指数为
超过 的项目

评论 (0)

加载中
更多评论
暂无内容
发表了博客
2019/02/18 13:11

zmq setsockopt()

zmq.RCVTIMEO:在一个recv操作返回EAGAIN错误前的最大时间 设置socket的接收操作超时时间。如果属性值是0,zmq_recv(3)函数将会立刻返回,如果没有接收到任何消息,将会返回EAGAIN错误。如果属性值是 -1,将会阻塞,直到接收到消息为止。对于任何其它值,都会进行等待这么多时间,直到返回EAGAIN错误。 zmq.SNDHWM:对向外发送的消息设置高水位(最大缓存量) ZMQ_SNDHWM属性将会设置socket参数指定的socket对外发送的消息的高水...

0
0
发表了博客
2020/12/29 10:46

MySQL Clone Plugin

文章目录 一、clone插件介绍 二、安装克隆插件 三、克隆数据 3.1 克隆本地数据 3.2 克隆远程数据 3.3 基于clone建立复制 四、clone运维相关 4.1 相关文件 4.2 故障处理 4.3 clone监控 4.4 clone插件限制 一、clone插件介绍   MySQL 从8.0.17开始支持克隆插件,允许在本地或远程 MySQL 实例在线克隆数据。克隆数据是存储在 InnoDB 其中的数据的物理快照,其中包括库、表、表空间和数据字典元数据。克隆的数据包含一个功能齐全的...

0
0
发表于服务端专区
2020/03/15 10:10

聊聊skywalking的mysql-plugin

## 序 本文主要研究一下skywalking的mysql-plugin ## skywalking-plugin.def skywalking-6.6.0/apm-sniffer/apm-sdk-plugin/mysql-8.x-plugin/src/main/resources/skywalking-plugin.def ``` mysql-8.x=org.apache.skywalking.apm.plugin.jdbc.mysql.v8.define.ConnectionImplCreateInstrumentation mysql-8.x=org.apache.skywalking.apm.plugin.jdbc.mysql.v8.define.ConnectionInstrumentation mysql-8.x=org.apache.skywalki...

0
0
发表了博客
2018/06/22 17:05

nodejs安装zmq出错

想用zmq来做进程间通信,在Windows下、Centos下安装成功。记录如下: 一、Windows安装zmq   直接 npm install zmq 成功就成功。   不成功的话估计是报"未能加载Visual C++ 组件 “VCBuild.exe"这类的错误,可以这样试试:   1、npm cache clean   2、npm install --global --production windows-build-tools   3、安装成功后,安装安装.net framework4.7 之后重启(百度一下就有了)  最后npm install zmq,成功 二、C...

0
0
发表了博客
2019/02/18 10:55

zmq 自动绑定socket

def auto_bind(socket): """ auto bind zmq socket :param socket: socket instance :return: zmq socket address """ if os.name == 'nt': # for Windows socket.bind_to_random_port('tcp://127.0.0.1') else: # Get the location for tmp file for sockets try: tmp_dir = os.environ['ZEROMQ_SOCK_TMP_DIR'] if not os.path.exi...

0
0
没有更多内容
加载失败,请刷新页面
点击加载更多
加载中
下一页
暂无内容
0 评论
20 收藏
分享
OSCHINA
登录后可查看更多优质内容
返回顶部
顶部