七叶笔记 » golang编程 » redis+mysql数据同步(协同)C/C++实现

redis+mysql数据同步(协同)C/C++实现

关于 Redis + MySQL 协同:

数据量巨大的情况下,频繁的操作数据库(这里值mysql),可能会造成击穿。而分布式缓存技术已经很成熟。

使用 Nosql 缓存 ,然后异步的写入数据库,从而减小mysql甚至服务器的压力。

关于redis+mysql应用:

微博当然是最大的redis集群了:

总结了基本流程:

1. 发微博– > 进入消息队列– > 存入MySQL– > 复制到Redis

2. 查询 – > 查询缓存– > 查询Redis – > 查询MySQL

正文:

既然是两者之间交互,就分为两部分:

先看mysql to redis:

mysql to redis 采用的批量插入的方法。

通过对redis 以及 mysql具体数据库,数据表格式的分析,

利用 *.sql的脚本对数据进行选取,再重定向 到 redis中即可。

(使用到了 redis-cli –pipe的选项)

先看数据表:

对于每行数据中执行的 Redis命令如下:
HSET events_all_time [action] [count]

利用.sql脚本 执行

关于 里面的 * $之类的,是redis数据备份的指定格式

举个例子:

格式说明如下:

*4 #表示有4个参数

$4 #表示“参数”有三个字节(“HSET”字符串为4个字节)

hset #执行的命令

$8 # key有 8个字节

wolys101 #key对应的值

$6 #field对应的长度

passwd #field对应的值

$12 # value的长度

wolysopen111 #value的值

# 一条语句结束

每行默认以 \r\n 结尾

同时在执行玩一行后,以 \r\n 代码一条语句结束

执行如下指令:

mysql -uroot -p redis –skip-column-names –raw < events_to_redis.sql | redis-cli –pipe -a ireanlau

-N, –skip-column-names //不显示列信息

-r, –raw //写列的值而不转义转换。

-a 是redis指定登陆密码的选项

操作成功;查看redis

操作成功。

再谈redis to mysql
这里采用C/C++ api

先查看mysql对应数据表中的数据:

redis当前没有键值对

hash 插入 3 个键值对

执行启动脚本:

产看mysql:

操作成功!

自动化功能的实现,计划采用 crontab 定时功能,定时对两个数据流进行刷入。

至此,所有功能阐述完毕。

注:需要C/C++ Linux 服务器开发学习资料私信“资料”(资料包括C/C++,Linux,golang技术, Nginx ,ZeroMQ,MySQL,Redis,fastdfs, MongoDB ,ZK,流媒体,CDN,P2P,K8S,Docker,TCP/IP,协程,DPDK, ffmpeg 等),免费分享

相关文章