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

用戶自定義擴展的分片函數(shù)要實現(xiàn)publicinterfaceRuleAlgorithm{voidinit();Integercalculate(String}rule.xml文件中找相關的屬性，并注入（set方法），最后調(diào)用init()接口，完成初Calculate方法接受字段的值，并計算返回一個分片節(jié)點的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=