天天看點

簡單實作redis資料實時插入MySQL過程

 為什麼要把REDIS已經持久化的資料還要插入MySQL呢,原因就不說了.....相信大神各有見解.....

首先來了解基礎資訊:

一一般來說,消息隊列有兩種場景:一種是釋出者訂閱者模式;一種是生産者消費者模式。利用redis這兩種場景的消息隊列都能夠實作,定義:

生産者消費者模式:生産者生産消息放到隊列裡,多個消費者同時監聽隊列,誰先搶到消息誰就會從隊列中取走消息;即對于每個消息隻能被最多一個消費者擁有。(常用于處理高并發寫操作)

簡單實作redis資料實時插入MySQL過程

###list實作的原則是FIFO

二、實作阻塞隊列的原理

redis中有一個blpop、brpop的指令,阻塞的從清單(list)中取資料,當清單為空,則阻塞知道取到資料或逾時。

blpop指令後面參數中可以跟多個list的key,内部是按照順序進行通路的,基于這個原理可以實作高優先級隊列。

三、簡單實戰過程

簡單實作redis資料實時插入MySQL過程

    實戰要求:一台redis伺服器、一個DB執行個體即可、一個簡單的python腳本、一個簡單驗證

簡單實作redis資料實時插入MySQL過程

1、redis伺服器(精簡操作)

    a、測試環境直接用yum安裝即可使用:yum -y  install redis

    b、登入redis指令為:redis-cli

<a href="http://s3.51cto.com/wyfs02/M00/89/B6/wKiom1gapobg1cQGAAATJ5YQimg357.png-wh_500x0-wm_3-wmp_4-s_2727926703.png" target="_blank"></a>

c、具體更多操作請度娘去

2、MySQL安裝(略),

    a、安裝好後,添加庫和表,後面的腳本會用到。

    b、事例庫表為

<a href="http://s4.51cto.com/wyfs02/M02/89/B7/wKiom1gap77x7Qk5AAB4gJEX-Tw208.png-wh_500x0-wm_3-wmp_4-s_68686327.png" target="_blank"></a>

Create Table: CREATE TABLE `redis_data` (

  `id` int(11) NOT NULL AUTO_INCREMENT,

  `id_type` varchar(20) DEFAULT NULL,

  `name` varchar(20) DEFAULT NULL,

  PRIMARY KEY (`id`)

) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=latin1

3、一個簡單的PYTHON腳本:

<a href="http://down.51cto.com/data/2368339" target="_blank">附件:http://down.51cto.com/data/2368339</a>

本文轉自 DBAspace 51CTO部落格,原文連結:http://blog.51cto.com/dbaspace/1868828