數據庫異步寫入功能概要設計

在新項目中，我們要求每一個寫入數據庫的操作不允許直接寫入到MYSQL數據庫中，防止在大並發情況下數據庫的瓶頸出現，解決的思路是凡是有需要更新、插入數據庫的需求，必須按規定封裝成JSON數據，然后存放到REDIS的隊列中，由數據庫寫入隊列監控程序進行監視，發現后串行寫入到數據庫中。如果JAVA項目有在寫入數據庫的同時修改緩存的需要，那么自行修改緩存，數據庫寫入程序不負責修改緩存數據。

 

下面以一個有代表性的寫入動作為例，進行說明：

學生表

CREATE TABLE `t_base_student` (
  `ID` int(11) NOT NULL AUTO_INCREMENT COMMENT '學生表主鍵，自增長',
  `STUDENT_GUID` char(36) DEFAULT NULL COMMENT '學生的GUID編號',
  `STUDENT_NAME` varchar(20) DEFAULT NULL COMMENT '學生姓名',
  `XB` char(2) DEFAULT NULL COMMENT '性別',
  `BYXX` varchar(50) DEFAULT NULL COMMENT '畢業學校',
  PRIMARY KEY (`ID`)
) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8;

插入一條測試數據

INSERT INTO `t_base_student` VALUES ('1', 'bd81eb89-b933-11e3-8d96-7427eab28b71', '黃海', '男', '東北師范大學');

 

家長表

CREATE TABLE `t_base_parent` (
  `PARENT_ID` int(11) NOT NULL AUTO_INCREMENT COMMENT '家長的編號',
  `PARENT_GUID` char(36) DEFAULT NULL COMMENT '家長的GUID號',
  `PARENT_NAME` varchar(255) DEFAULT NULL COMMENT '家長的姓名',
  `STUDENT_ID` int(11) DEFAULT NULL COMMENT '學生號',
  `STUDENT_GUID` char(36) DEFAULT NULL COMMENT '學生GUID號',
  `PARENT_TYPE` int(11) DEFAULT NULL COMMENT '家長的類型',
  PRIMARY KEY (`PARENT_ID`)
) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8;

 插入兩條測試數據

INSERT INTO `t_base_parent` VALUES ('1', 'f1af5347-b933-11e3-8d96-7427eab28b71', '黃章', '1', 'bd81eb89-b933-11e3-8d96-7427eab28b71', '1');
INSERT INTO `t_base_parent` VALUES ('2', '0f517382-b934-11e3-8d96-7427eab28b71', '王雲', '1', 'bd81eb89-b933-11e3-8d96-7427eab28b71', '2');

 最終確定使用存儲過程來解決這個問題：

 

-- 刪除存儲過程
drop PROCEDURE sp_addstudent;

-- 清空測試數據表
TRUNCATE TABLE a;
TRUNCATE TABLE t_base_parent;
TRUNCATE TABLE t_base_student;

-- 'bd81eb89-b933-11e3-8d96-7427eab28b71','黃海','男','東北師范大學'

CREATE PROCEDURE sp_addstudent (IN V_STUDENT_GUID CHAR (36),IN V_STUDENT_NAME VARCHAR (20),V_XB CHAR (2),V_BYXX VARCHAR (50))
BEGIN

DECLARE v_student_id INT;

START TRANSACTION;
INSERT INTO t_base_student (STUDENT_GUID,STUDENT_NAME,XB,BYXX)VALUES(V_STUDENT_GUID,V_STUDENT_NAME,V_XB,V_BYXX);
SELECT LAST_INSERT_ID() INTO v_student_id;
INSERT INTO a VALUES(v_student_id);
COMMIT;

END;

 

通過lpush命令寫入到REDIS緩存中，串行寫入數據庫系統通過rrange命令讀取，執行寫入到MYSQL數據庫。並執行rpop彈出這個指令。

后期可以考慮使用更加安全的隊列形態，比如rpoplpush,可以參考：http://www.cnblogs.com/youxin/p/3585867.html