用mongdb也大半年了，一直是業(yè)務(wù)上的邏輯實(shí)現(xiàn)了就ok。然而這樣并不能進(jìn)步……因此今天查了查java連接mongodb驅(qū)動(dòng)的源碼，搜到的各種信息整合一下，方便以后深入的使用。

成都創(chuàng)新互聯(lián)是一家專注于網(wǎng)站建設(shè)、做網(wǎng)站與策劃設(shè)計(jì),益陽(yáng)網(wǎng)站建設(shè)哪家好?成都創(chuàng)新互聯(lián)做網(wǎng)站,專注于網(wǎng)站建設(shè)10余年,網(wǎng)設(shè)計(jì)領(lǐng)域的專業(yè)建站公司;建站業(yè)務(wù)涵蓋:益陽(yáng)等地區(qū)。益陽(yáng)做網(wǎng)站價(jià)格咨詢:18982081108

    先貼連接數(shù)據(jù)庫(kù)代碼

 List<ServerAddress> replicaSet = new          ArrayList<ServerAddress>();          replicaSet.add(new ServerAddress("127.0.0.1", 27017));          MongoClientOptions option =          MongoClientOptions.builder().autoConnectRetry(true).connectionsPerHost(300).maxWaitTime(30000).build();          MongoConnection.init(replicaSet, option, "test");  public static synchronized void init(List<ServerAddress> replicaSet,                         MongoClientOptions option, String defaultDb){                 mongo = new MongoClient(replicaSet, option);                 mongo.setReadPreference(ReadPreference.nearest());                 setDb(mongo.getDB(defaultDb));         }

    當(dāng)初一眼看過(guò)去也是頭大無(wú)比，就跟大學(xué)背下來(lái)的連接mysql數(shù)據(jù)庫(kù)驅(qū)動(dòng)一樣，只求考試默寫(xiě)下來(lái)不掛科。雖然也能用，但是不求甚解的態(tài)度明顯是錯(cuò)誤的！接下來(lái)分解下來(lái)一步一步看吧：

    public ServerAddress( String host , int port )         throws UnknownHostException {         if ( host == null )             host = defaultHost();         host = host.trim();         if ( host.length() == 0 )             host = defaultHost();                  int idx = host.indexOf( ":" );         if ( idx > 0 ){             if ( port != defaultPort() )                 throw new IllegalArgumentException( "can't specify port in construct and via host" );             port = Integer.parseInt( host.substring( idx + 1 ) );             host = host.substring( 0 , idx ).trim();         }         _host = host;         _port = port;         updateInetAddress();     }

    replicaSet顯然是一個(gè)服務(wù)器地址數(shù)組，點(diǎn)進(jìn)去后是對(duì)IP地址以及端口的解析。如果填寫(xiě)的地址是127.0.0.1:27017樣式的話，冒號(hào)之后的端口必須是27017，否則就拋出異常告訴你不能自己構(gòu)建主機(jī)及端口。不過(guò)既然使用了帶host以及port的構(gòu)造方法，地址和端口分開(kāi)寫(xiě)就好了，何必放在一塊……

boolean updateInetAddress() throws UnknownHostException {         InetSocketAddress oldAddress = _address;         _address = new InetSocketAddress( InetAddress.getByName(_host) , _port );         return !_address.equals(oldAddress);     }      volatile InetSocketAddress _address;

    至于updateInetAddress(),InetAddress是java對(duì)ip地址的封裝，方便其他網(wǎng)絡(luò)類調(diào)用，方法內(nèi)部對(duì)ipv4和ipv6有各種詳細(xì)的判定，不多贅述，畢竟是基礎(chǔ)類，有時(shí)間認(rèn)真學(xué)習(xí)一下提升會(huì)非常大。詳細(xì)內(nèi)容在這個(gè)博客里面http://my.oschina.net/fhd/blog/371997有提及。volatile是一個(gè)類型修飾符（type specifier）。它是被設(shè)計(jì)用來(lái)修飾被不同線程訪問(wèn)和修改的變量。如果不加入volatile，要么無(wú)法編寫(xiě)多線程程序，要么編譯器失去大量?jī)?yōu)化的機(jī)會(huì)?；氐降谝粔K，MongoClientOptions是對(duì)數(shù)據(jù)庫(kù)的一些設(shè)置，用到了人民喜聞樂(lè)見(jiàn)的構(gòu)建者模式builder:

        private String description;         private int connectionsPerHost = 100;         private int threadsAllowedToBlockForConnectionMultiplier = 5;         private int maxWaitTime = 1000 * 60 * 2;         private int connectTimeout = 1000 * 10;         private int socketTimeout = 0;         private boolean socketKeepAlive = false;         private boolean autoConnectRetry = false;         private long maxAutoConnectRetryTime = 0;         private ReadPreference readPreference = ReadPreference.primary();         private DBDecoderFactory dbDecoderFactory = DefaultDBDecoder.FACTORY;         private DBEncoderFactory dbEncoderFactory = DefaultDBEncoder.FACTORY;         private WriteConcern writeConcern = WriteConcern.ACKNOWLEDGED;         private SocketFactory socketFactory = SocketFactory.getDefault();         private boolean cursorFinalizerEnabled = true;         private boolean alwaysUseMBeans = false;

    builder給需要初始化的成員變量賦值。一個(gè)一個(gè)看吧~

• connectionsPerHost：每個(gè)主機(jī)的連接數(shù)

• threadsAllowedToBlockForConnectionMultiplier：線程隊(duì)列數(shù)，它以上面 connectionsPerHost值相乘的結(jié)果就是線程隊(duì)列大值。如果連接線程排滿了隊(duì)列就會(huì)拋出“Out of semaphores to get db”錯(cuò)誤。

• maxWaitTime:大等待連接的線程阻塞時(shí)間

• connectTimeout：連接超時(shí)的毫秒。0是默認(rèn)和無(wú)限

• socketTimeout：socket超時(shí)。0是默認(rèn)和無(wú)限

• autoConnectRetry：這個(gè)控制是否在一個(gè)連接時(shí)，系統(tǒng)會(huì)自動(dòng)重試

    以上解釋似乎在各種需要線程池的數(shù)據(jù)庫(kù)連接驅(qū)動(dòng)都通用……ReadPrefrence是多個(gè)節(jié)點(diǎn)時(shí)讀操作的設(shè)置，默認(rèn)是只從主節(jié)點(diǎn)進(jìn)行讀操作，還有其他屬性如只從第二節(jié)點(diǎn)讀、從主節(jié)點(diǎn)讀，若不可讀取則再去從節(jié)點(diǎn)讀取等等。目前還沒(méi)有用到過(guò)……之前的代碼設(shè)置的是從離最近的節(jié)點(diǎn)讀取mongo.setReadPreference(ReadPreference.nearest())。然而我們的程序只有一個(gè)節(jié)點(diǎn)……并沒(méi)有什么卵用。WriteConcern用來(lái)保障寫(xiě)操作的可靠性，是性能和可靠性之間的一個(gè)平衡，http://kyfxbl.iteye.com/blog/1952941這個(gè)博客中講的比較詳細(xì)。簡(jiǎn)單來(lái)說(shuō)就是保障寫(xiě)操作確實(shí)入庫(kù)了，不會(huì)因?yàn)榫W(wǎng)絡(luò)狀況或者服務(wù)器掛掉導(dǎo)致寫(xiě)入失敗的時(shí)候得不到提醒，如果這個(gè)參數(shù)設(shè)置w:-1則得不到任何異常信息，默認(rèn)w:1，最好也設(shè)置jurnal:true,寫(xiě)操作寫(xiě)入內(nèi)存的同時(shí)也寫(xiě)入journal文件，這樣如果mongod非正常down掉，重啟以后就可以根據(jù)journal文件中的內(nèi)容，來(lái)還原寫(xiě)操作。更高級(jí)別則是對(duì)多個(gè)節(jié)點(diǎn)的集群進(jìn)行設(shè)置了，只有一個(gè)節(jié)點(diǎn)的話w:1&journal:true就夠用了。所以第一塊代碼中的init方法里的synchronized到底需不需要呢……mongo既然本身就是一個(gè)線程安全的實(shí)例，mongoclient繼承了mongo，是不是也意味著不需要在初始化mongoclient時(shí)進(jìn)行同步。

另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)cdcxhl.cn，海內(nèi)外云服務(wù)器15元起步，三天無(wú)理由+7*72小時(shí)售后在線，公司持有idc許可證，提供“云服務(wù)器、裸金屬服務(wù)器、高防服務(wù)器、香港服務(wù)器、美國(guó)服務(wù)器、虛擬主機(jī)、免備案服務(wù)器”等云主機(jī)租用服務(wù)以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡(jiǎn)單易用、服務(wù)可用性高、性價(jià)比高”等特點(diǎn)與優(yōu)勢(shì)，專為企業(yè)上云打造定制，能夠滿足用戶豐富、多元化的應(yīng)用場(chǎng)景需求。

新聞標(biāo)題：java連接mongodb源碼解讀-創(chuàng)新互聯(lián)
鏈接分享：http://www.rwnh.cn/article36/dhpppg.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站制作、軟件開(kāi)發(fā)、虛擬主機(jī)、服務(wù)器托管、網(wǎng)站營(yíng)銷、定制開(kāi)發(fā)

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源： 創(chuàng)新互聯(lián)