Mysql讀寫分離配置說明

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

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

3、令時，系統(tǒng)會自動報錯，這一點在改應用時要特別注意。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 定義實體Session工廠（從抽象工廠繼承） 2.2.4 定義專用于分派數(shù)據(jù)庫讀訪問操作的實例 !-其中和之間內(nèi)容為前面定義的實體工廠，可以定義多個實體工廠（這里注釋中的代碼定義了兩個），它們是參與智能分派讀操作請求所針對的數(shù)據(jù)庫鏈接工廠，注意在bean項目中的Session工廠實例前面必須要加&定數(shù)據(jù)庫服務器失效參數(shù)，單位為毫秒，90000代表90秒也就是1分半鐘，如果超出該參數(shù)設定的時間范圍，讀寫分離服務仍沒有得到某服務器的狀態(tài)信息，該服務器將為不可用狀態(tài)。該值是動態(tài)計算的，如果服務器恢復報告其狀態(tài)信息，也會即刻生效。數(shù)據(jù)讀操作請求也可分派到主服務

5、器上去，如果主服務器更空閑的話，這樣做更加合理。這里sessionFactoryForRead_2就是用主服務器模擬的另外一臺從服務器，這里直接用主服務器的session工廠sessionFactory也還是可以的。2.3 安裝服務器狀態(tài)匯報程序每臺參與數(shù)據(jù)庫讀請求智能分派機制的數(shù)據(jù)庫服務器都要安裝，當前是用Python語言實現(xiàn)的，功能是定時（1分鐘）周期匯報最近5分鐘的服務器平均負載指標給讀寫分離服務器，當前的讀寫分離是做在web應用服務上的（也就是和web應用部署在一起的）。狀態(tài)回報程序需要Python2.6以上（含）版本運行，這里簡要列一下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當前的讀寫回報程序如下：#!/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ù)實際情況加以更改，定義的recipient為一個集合，用于定義多個回

10、報對象定時回報功能采用Linux系統(tǒng)crontab來實現(xiàn)Linux下安裝定時匯報執(zhí)行功能。這里假設上面的腳本存為/root/u.py，這里配置為沒分鐘執(zhí)行，錯誤日志輸出到/var/log/reportload/errorlog文件。* * * * /root/u.py 2/var/log/reportload/errorlog匯報接收程序reportload.jsp部署在web服務器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 在項目中如何使用由于采用在應用上進行讀寫分離的配置方案，所以需要在程序設計時判斷當前正在開發(fā)的功能點是否用涉及到數(shù)據(jù)庫寫操作，如果是寫數(shù)據(jù)庫操作，就沿用以前的方式進行開發(fā)；如果當