Mysql讀寫分離配置說明

1、武漢眾采在線科技有限公司http:/ 武漢眾采在線科技有限公司http:/ 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ù)器配備由于測試環(huán)境只裝了主、 從服務(wù)器各一臺(tái)， 這里用主服務(wù)器再邏輯模擬一臺(tái)從服

2、務(wù)器ip 地址：端口服務(wù)器類型applicationcontext.xml 中的配置:3306 主sessionfactory :3306 從sessionfactoryforread1 :3306 從（模擬）sessionfactoryforread2 武漢眾采在線科技有限公司http:/ 武漢眾采在線科技有限公司http:/ 2.2 在 spring配置文件中進(jìn)行配置2.2.1 定義數(shù)據(jù)源武漢眾采在線科技有限公司http:/ 武漢眾采在線科技有限公司http:/ 以 上 定 了 了3個(gè) 數(shù) 據(jù) 源 ， 分 別 是dataso

3、urce、datasourceforread_1 、 datasourceforread_2 。注意上面 datasourceforread_1 和 datasourceforread_2 定義中增加了的配置，配置這兩個(gè)數(shù)據(jù)源為只讀數(shù)據(jù)源， 當(dāng)通過他們發(fā)出修改命令時(shí)， 系統(tǒng)會(huì)自動(dòng)報(bào)錯(cuò)，這一點(diǎn)在改應(yīng)用時(shí)要特別注意。2.2.2 定義抽象的spring session工廠com.shf.utils.web.dialectforinkfish beeeye2trueupdate!- true -truecom.googlecode.hibernate.memcached.memcachedcachep

4、rovidertruenet.rubyeye.xmemcached.utils.hibernate.xmemcachedclientfactory:11211300 武漢眾采在線科技有限公司http:/ 武漢眾采在線科技有限公司http:/ classpath:/com/shf/pojo/web-inf/lib/sucai-pojo.jar2.2.3 定義實(shí)體 session工廠（從抽象工廠繼承）2.2.4 定義專用于分派數(shù)據(jù)庫讀訪問操作的實(shí)例 !-武漢眾采在線科技有限公司http:/ 武漢眾采在線科技有限公司http:/ 其中和之間內(nèi)容為前面定義的實(shí)體工廠，可以定義多個(gè)

5、實(shí)體工廠（這里注釋中的代碼定義了兩個(gè)），它們是參與智能分派讀操作請求所針對(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ù)讀操作請求也可分派到主服務(wù)器上去，如果主服務(wù)器更空閑的話，這樣做更加合理。這里sessionfactoryforread_2就是用主服務(wù)器模擬的另外一臺(tái)從服務(wù)器，這里直接用主服務(wù)器的s

6、ession 工廠sessionfactory也還是可以的。2.3 安裝服務(wù)器狀態(tài)匯報(bào)程序每臺(tái)參與數(shù)據(jù)庫讀請求智能分派機(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)行，這里簡要列一下 python 2.7在 linux 上的安裝步驟以及python for mysql 客戶端：tar xvzf python-2.7.2.tgz cd python-2.7.2 武漢眾采

7、在線科技有限公司http:/ 武漢眾采在線科技有限公司http:/ ./configure -prefix=/usr make make install 安裝 python for mysql 客戶端unzip petehunt-pymysql-pymysql-0.5-31-g3656421.zip cd petehunt-pymysql-3656421 python setup.py install 當(dāng)前的讀寫回報(bào)程序如下：#!/usr/bin/python import os import sys import pymysql import urllib, urllib2 from dat

8、etime import * database_ip = database_port = 3306 database_user = root database_password = 123456 database_db = beeeye2 recipient_list = /help/reportload.jsp?load= 武漢眾采在線科技有限公司http:/ 武漢眾采在線科技有限公司http:/ f = open(/proc/loadavg) cont = f.readline() f.close() loadavg = cont.sp

9、lit( ,2)1 conn = pymysql.connect(host=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 != wai

10、ting for master to send event or r10 != yes or r11 != yes or r32 10: os._exit(1) for rec in recipient_list: url = rec + urllib.pathname2url(loadavg) try: 武漢眾采在線科技有限公司http:/ 武漢眾采在線科技有限公司http:/ urllib2.urlopen(url, none, 3).close() except exception, err: print sys.stderr, str(datetime.today() + : erro

11、r for getting + url + , message: + str(err) 上面腳本中的配置參數(shù)需要根據(jù)實(shí)際情況加以更改，定義的recipient 為一個(gè)集合，用于定義多個(gè)回報(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

12、 部署在 web 服務(wù)器 0的/help 目錄下，其代碼如下：= dbforreadloadavg.servernumber) return; try loadint = math.round(float.parsefloat(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ù)庫操作， 就沿