Mysql讀寫分離配置說明

1、武漢眾采在線科技有限公司Mysql讀寫分類配置說明1 方案本文檔是針對(duì)基于Mysql數(shù)據(jù)庫復(fù)制技術(shù)且從應(yīng)用上進(jìn)行讀寫分離的配置方案，遵循的原則為：a) 所用數(shù)據(jù)庫寫操作都在主數(shù)據(jù)庫上完成b) 所有涉及事務(wù)處理的數(shù)據(jù)庫操作在主數(shù)據(jù)庫上完成c) 讀操作可以根據(jù)從數(shù)據(jù)庫服務(wù)器的負(fù)載狀態(tài)進(jìn)行智能選擇d) 每臺(tái)數(shù)據(jù)庫服務(wù)器安裝服務(wù)器狀態(tài)匯報(bào)程序及時(shí)向讀寫分離服務(wù)器回報(bào)自己的忙閑狀態(tài)指標(biāo)本文檔中的配置說明是遵循以上原則的一種實(shí)現(xiàn)，并非是固定的模式。2 配置說明2.1 數(shù)據(jù)服務(wù)器配備由于測(cè)試環(huán)境只裝了主、從服務(wù)器各一臺(tái)，這里用主服務(wù)器再邏輯模擬一臺(tái)從服務(wù)器IP地址：端口服務(wù)器類型applicationCon

2、text.xml中的配置:3306主sessionFactory:3306從sessionFactoryForRead1:3306從（模擬）sessionFactoryForRead22.2 在Spring配置文件中進(jìn)行配置2.2.1 定義數(shù)據(jù)源以上定了了3個(gè)數(shù)據(jù)源，分別是dataSource、dataSourceForRead_1、 dataSourceForRead_2。注意上面dataSourceForRead_1和dataSourceForRead_2定義中增加了的配置，配置這兩個(gè)數(shù)據(jù)源為只讀數(shù)據(jù)源，當(dāng)通過他們發(fā)出修改命

3、令時(shí)，系統(tǒng)會(huì)自動(dòng)報(bào)錯(cuò)，這一點(diǎn)在改應(yīng)用時(shí)要特別注意。2.2.2 定義抽象的Spring Session工廠com.shf.utils.web.DialectForInkfishbeeeye2trueupdate!- true -truecom.googlecode.hibernate.memcached.MemcachedCacheProvidertruenet.rubyeye.xmemcached.utils.hibernate.XmemcachedClientFactory:11211300 classpath:/com/shf/pojo/WEB-INF/lib/suc

4、ai-pojo.jar2.2.3 定義實(shí)體Session工廠（從抽象工廠繼承） 2.2.4 定義專用于分派數(shù)據(jù)庫讀訪問操作的實(shí)例 !-其中和之間內(nèi)容為前面定義的實(shí)體工廠，可以定義多個(gè)實(shí)體工廠（這里注釋中的代碼定義了兩個(gè)），它們是參與智能分派讀操作請(qǐng)求所針對(duì)的數(shù)據(jù)庫鏈接工廠，注意在bean項(xiàng)目中的Session工廠實(shí)例前面必須要加&定數(shù)據(jù)庫服務(wù)器失效參數(shù)，單位為毫秒，90000代表90秒也就是1分半鐘，如果超出該參數(shù)設(shè)定的時(shí)間范圍，讀寫分離服務(wù)仍沒有得到某服務(wù)器的狀態(tài)信息，該服務(wù)器將為不可用狀態(tài)。該值是動(dòng)態(tài)計(jì)算的，如果服務(wù)器恢復(fù)報(bào)告其狀態(tài)信息，也會(huì)即刻生效。數(shù)據(jù)讀操作請(qǐng)求也可分派到主服務(wù)

5、器上去，如果主服務(wù)器更空閑的話，這樣做更加合理。這里sessionFactoryForRead_2就是用主服務(wù)器模擬的另外一臺(tái)從服務(wù)器，這里直接用主服務(wù)器的session工廠sessionFactory也還是可以的。2.3 安裝服務(wù)器狀態(tài)匯報(bào)程序每臺(tái)參與數(shù)據(jù)庫讀請(qǐng)求智能分派機(jī)制的數(shù)據(jù)庫服務(wù)器都要安裝，當(dāng)前是用Python語言實(shí)現(xiàn)的，功能是定時(shí)（1分鐘）周期匯報(bào)最近5分鐘的服務(wù)器平均負(fù)載指標(biāo)給讀寫分離服務(wù)器，當(dāng)前的讀寫分離是做在web應(yīng)用服務(wù)上的（也就是和web應(yīng)用部署在一起的）。狀態(tài)回報(bào)程序需要Python2.6以上（含）版本運(yùn)行，這里簡(jiǎn)要列一下python 2.7在linux上的安裝步驟以及

6、python for mysql客戶端：tar xvzf Python-2.7.2.tgzcd Python-2.7.2./configure -prefix=/usrmakemake install安裝python for mysql客戶端unzip petehunt-PyMySQL-pymysql-0.5-31-g3656421.zipcd petehunt-PyMySQL-3656421python setup.py install當(dāng)前的讀寫回報(bào)程序如下：#!/usr/bin/pythonimport osimport sysimport pymysqlimport urllib, ur

7、llib2from datetime import *database_ip = database_port = 3306database_user = rootdatabase_password = 123456database_db = beeeye2recipient_list = /help/reportload.jsp?load=f = open(/proc/loadavg)cont = f.readline()f.close()loadavg = cont.split( ,2)1conn = pymysql.connect(hos

8、t=database_ip, port=database_port, user=database_user, passwd=database_password, db=database_db)cur = conn.cursor()count = cur.execute(show slave status)if 1 != count:cur.close()conn.close()os._exit(1)r = cur.fetchone()cur.close()conn.close()if r0 != Waiting for master to send event or r10 != Yes or

9、 r11 != Yes or r32 10:os._exit(1)for rec in recipient_list:url = rec + urllib.pathname2url(loadavg)try:urllib2.urlopen(url, None, 3).close()except Exception, err:print sys.stderr, str(datetime.today() + : Error for getting + url + , message: + str(err)上面腳本中的配置參數(shù)需要根據(jù)實(shí)際情況加以更改，定義的recipient為一個(gè)集合，用于定義多個(gè)回

10、報(bào)對(duì)象定時(shí)回報(bào)功能采用Linux系統(tǒng)crontab來實(shí)現(xiàn)Linux下安裝定時(shí)匯報(bào)執(zhí)行功能。這里假設(shè)上面的腳本存為/root/u.py，這里配置為沒分鐘執(zhí)行，錯(cuò)誤日志輸出到/var/log/reportload/errorlog文件。* * * * /root/u.py 2/var/log/reportload/errorlog匯報(bào)接收程序reportload.jsp部署在web服務(wù)器0的/help目錄下，其代碼如下：= dBForReadLoadAVG.serverNumber) return;try loadint = Math.round(Float.parseFlo

11、at(load) * 100);if(0 loadint) return; catch(NumberFormatException ex) return;Integer idxInt = dBForReadLoadAVG.ipToServerIndex.get(remoteAddr);if (null != idxInt)dBForReadLoadAVG.updateServerLoad(idxInt,loadint);%2.4 在項(xiàng)目中如何使用由于采用在應(yīng)用上進(jìn)行讀寫分離的配置方案，所以需要在程序設(shè)計(jì)時(shí)判斷當(dāng)前正在開發(fā)的功能點(diǎn)是否用涉及到數(shù)據(jù)庫寫操作，如果是寫數(shù)據(jù)庫操作，就沿用以前的方式進(jìn)行開發(fā)；如果當(dāng)