資源配套軟件開發(fā)指南mycat develope guide

Mycat新一代Mysql分布式集群，大數(shù)據(jù)處理中間件，中國(guó)第一開源軟件，歡迎參與 本文檔由Mycat團(tuán)隊(duì)提供，請(qǐng)注明，謝謝Checkout項(xiàng)可以用eclipsesvn插件來進(jìn)行項(xiàng)目檢出，也可以用TortoiseSVN等工具檢出，由于maven(M2)buildnumber-maven-pluginSVNkit1.7SVN倉(cāng)庫(kù)，因此當(dāng)你用TortoiseSVN1.8的工具或版本高于1.7的SVNKIT時(shí)，此插件無法獲取本地倉(cāng)庫(kù)的SVNreversion，導(dǎo)致編譯失敗，此時(shí)你可以并安裝svn命令行工具（安裝完成后，svnPATHSVN令所在路徑）并重啟Eclipse，SVN命令行工具地址： /pub，然后修改POM.XMLSVNSVNKIT來2處svn命令。Eclispe中啟程序是org.opencloudb.MycatStartup，右鍵runas，出現(xiàn)下面的界面，需要設(shè) ，為你當(dāng)前的工程所在 若啟動(dòng)報(bào)錯(cuò)，DirectBuffer內(nèi)存不夠，則可以再加JVM一：Mycat分片函數(shù)下面說明分片函數(shù)的定義和配置，以Mycatauto-sharding-long<functionname="rang-long"上述表明：用字段idrang-long的分片函數(shù)：org.opencloudb.route.function.AutoPartitionByLong來完成分片映射，此分片函數(shù)有一個(gè)屬mapFileautopartition-long.txt，意思是從這個(gè)文件中加載分片定義：#rangestart-end,datanodeindex 0 Mycat的分片函數(shù)的的目標(biāo)只有一個(gè)：根據(jù)某個(gè)字段的值，返回其所對(duì)應(yīng)的分片節(jié)點(diǎn)DataNode的index，index從零開始；若字段的值為，則返回NULL。

用戶自定義擴(kuò)展的分片函數(shù)要實(shí)現(xiàn)publicinterfaceRuleAlgorithm{voidinit();Integercalculate(String}rule.xml文件中找相關(guān)的屬性，并注入（set方法），最后調(diào)用init()接口，完成初Calculate方法接受字段的值，并計(jì)算返回一個(gè)分片節(jié)點(diǎn)的index附：AutoPartitionByLongpublicclassAutoPartitionByLongimplementsRuleAlgorithmprivateStringprivateLongRange[]publicvoidinit(){}publicvoidsetMapFile(StringmapFile){this.mapFile=mapFile;}publicIntegercalculate(StringcolumnValue){longvalue=Long.valueOf(columnValue);Integerrst=null;for(LongRangelongRang:this.longRongs)if(value<=longRang.valueEnd&&value>=longRang.valueStart){returnlongRang.nodeIndx;}}return}privatevoidinitialize()BufferedReaderin=null;try{//FileInputStreamfin=newFileInputStream(newFile(fileMapPath));InputStreamfin=this.getClass().getClassLoader()if(fin==null)thrownewRuntimeException("can'tfindclassresourcefile+}in=newBufferedReader(newInputStreamReader(fin));LinkedList<LongRange>longRangeList=newLinkedList<LongRange>();for(Stringline=null;(line=in.readLine())!=null;){line=line.trim();if(line.startsWith("#")||line.startsWith("http://"))intind=line.indexOf('=');if(ind<0){System.out.println("warn:badlineint"}tryStringpairs[]=line.substring(0,ind).trim().split("-");longlongStart=Long.parseLong(pairs[0].trim());longlongEnd=Long.parseLong(pairs[1].trim());intnodeId=Integer.parseInt(line.substring(ind+.add(newLongRange(nodeId,}catch(Exceptione)}}longRongs=longRangeList.toArray(new}catch(Exceptione)if(einstanceofRuntimeException){throw(RuntimeException)e;}elsethrownew}}finallytry}catch(Exceptione2)}}}staticclassLongRangepublicfinalintnodeIndx;publicfinallongvalueStart;publicfinallongvalueEnd;publicLongRange(intnodeIndx,longvalueStart,longvalueEnd){this.nodeIndx=nodeIndx;this.valueStart=valueStart;this.valueEnd=