MongoClient自定义MongoClientOptions

 @Bean(name = "mongoClient")
    public MongoClient mongoClient() throws Exception {
        List<ServerAddress> addresses = new ArrayList<>();
        String[] addrs = serverAddr.split(",");
        for (String addr : addrs) {
            String[] ipports = addr.split(":");
            if (ipports.length != 2) {
                throw new Exception("Mongo配置不合法: " + addr);
            }
            ServerAddress address = new ServerAddress(ipports[0], Integer.parseInt(ipports[1]));
            addresses.add(address);
        }
        MongoClientOptions clientOptions = new MongoClientOptions.Builder().readPreference(ReadPreference.secondaryPreferred()).build();
        MongoClient mongoClient = new MongoClient(addresses,clientOptions);
        return mongoClient;
    }

 

参考文章：

http://blog.csdn.net/u013753516/article/details/44747615