mongodb 中 objectid 说明

Machine       》3字节：表示运行MongoDB 的机器唯一标识（一般是机器名的hash值，确保分布式环境中不同机器生成值不冲突）

pid                 》2字节：表示生成ObjectId的进程号（pid）

increment    》3字节：由随机数开始的计数器，用来确保同一秒内生成的 objectid 不进行冲突， 允许 256的3次方====16777216 条记录的唯一性

1. protected WriteResult insert(List<DBObject> list, boolean shouldApply , com.mongodb.WriteConcern concern, DBEncoder encoder ){  
2.   
3.             if (encoder == null)  
4.                 encoder = DefaultDBEncoder.FACTORY.create();  
5.   
6.             if ( willTrace() ) {  
7.                 for (DBObject o : list) {  
8.                     trace( "save:  " + _fullNameSpace + " " + JSON.serialize( o ) );  
9.                 }  
10.             }  
11.   
12.             if ( shouldApply ){  
13.                 for (DBObject o : list) {  
14.                     apply(o);  
15.                     _checkObject(o, false, false);  
16.                     Object id = o.get("_id");  
17.                     if (id instanceof ObjectId) {  
18.                         ((ObjectId) id).notNew();  
19.                     }  
20.                 }  
21.             }  
22.   
23.             WriteResult last = null;  
24.   
25.             int cur = 0;  
26.             int maxsize = _mongo.getMaxBsonObjectSize();  
27.             while ( cur < list.size() ) {  
28.   
29.                OutMessage om = OutMessage.insert( this , encoder, concern );  
30.   
31.                for ( ; cur < list.size(); cur++ ){  
32.                     DBObject o = list.get(cur);  
33.                     om.putObject( o );  
34.   
35.                     // limit for batch insert is 4 x maxbson on server, use 2 x to be safe  
36.                     if ( om.size() > 2 * maxsize ){  
37.                         cur++;  
38.                         break;  
39.                     }  
40.                 }  
41.   
42.                 last = _connector.say( _db , om , concern );  
43.             }  
44.   
45.             return last;  
46.         }  

1. /** 
2.    * calls {@link DBCollection#apply(com.mongodb.DBObject, boolean)} with ensureID=true 
3.    * @param o <code>DBObject</code> to which to add fields 
4.    * @return the modified parameter object 
5.    */  
6.   public Object apply( DBObject o ){  
7.       return apply( o , true );  
8.   }  
9.   
10.   /** 
11.    * calls {@link DBCollection#doapply(com.mongodb.DBObject)}, optionally adding an automatic _id field 
12.    * @param jo object to add fields to 
13.    * @param ensureID whether to add an <code>_id</code> field 
14.    * @return the modified object <code>o</code> 
15.    */  
16.   public Object apply( DBObject jo , boolean ensureID ){  
17.   
18.       Object id = jo.get( "_id" );  
19.       if ( ensureID && id == null ){  
20.           id = ObjectId.get();  
21.           jo.put( "_id" , id );  
22.       }  
23.   
24.       doapply( jo );  
25.   
26.       return id;  
27.   }  

1. public WriteResult save( DBObject jo, WriteConcern concern ){  
2.         if ( checkReadOnly( true ) )  
3.             return null;  
4.   
5.         _checkObject( jo , false , false );  
6.   
7.         Object id = jo.get( "_id" );  
8.   
9.         if ( id == null || ( id instanceof ObjectId && ((ObjectId)id).isNew() ) ){  
10.             if ( id != null && id instanceof ObjectId )  
11.                 ((ObjectId)id).notNew();  
12.             if ( concern == null )  
13.                 return insert( jo );  
14.             else  
15.                 return insert( jo, concern );  
16.         }  
17.   
18.         DBObject q = new BasicDBObject();  
19.         q.put( "_id" , id );  
20.         if ( concern == null )  
21.             return update( q , jo , true , false );  
22.         else  
23.             return update( q , jo , true , false , concern );  
24.   
25.     }