java連接mongodb源碼解讀

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

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

 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)初一眼看過去也是頭大無比，就跟大學(xué)背下來的連接mysql數(shù)據(jù)庫驅(qū)動一樣，只求考試默寫下來不掛科。雖然也能用，但是不求甚解的態(tà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顯然是一個服務(wù)器地址數(shù)組，點進去后是對IP地址以及端口的解析。如果填寫的地址是127.0.0.1:27017樣式的話，冒號之后的端口必須是27017，否則就拋出異常告訴你不能自己構(gòu)建主機及端口。不過既然使用了帶host以及port的構(gòu)造方法，地址和端口分開寫就好了，何必放在一塊……

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

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

• connectionsPerHost：每個主機的連接數(shù)

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

• maxWaitTime:最大等待連接的線程阻塞時間

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

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

• autoConnectRetry：這個控制是否在一個連接時，系統(tǒng)會自動重試

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