야근은 싫어

 
      /**
         * Applies last reduce and finalize.
         * After calling this method, the temp collection will be completed.
         * If inline, the results will be in the in memory map
         */
        void State::finalReduce( CurOp * op , ProgressMeterHolder& pm ) {


            // 변경전
            if ( ! _onDisk ) {
                // all data has already been reduced, just finalize
                if ( _config.finalizer ) {
                    long size = 0;
                    for ( InMemory::iterator i=_temp->begin(); i!=_temp->end();i++) {
                        BSONObj key = i->first;
                        BSONList& all = i->second;

                        assert( all.size() == 1 );

                        BSONObj res = _config.finalizer->finalize( all[0] );
                       all.clear();
                       all.push_back( res );
                       size += res.objsize();
                    }
                    _size = size;
                }
                return;
            }

           // 변경후
            if ( ! _onDisk ) {
                // all data has already been reduced, just finalize
                if ( _config.finalizer ) {
                    long size = 0;
                    for ( InMemory::iterator i=_temp->begin(); i!=_temp->end();) {
                        BSONObj key = i->first;
                        BSONList& all = i->second;

                        assert( all.size() == 1 );

                        BSONObj res = _config.finalizer->finalize( all[0] );
                        // finalize가 null을 반환하면 해당 key값은 삭제한다
                        if (res["value"].isNull()) {
                            _temp->erase(i++);
                        }
                        else {
                            all.clear();
                            all.push_back( res );
                            size += res.objsize();
                            i++;
                        }
                    }
                    _size = size;
                }
                return;
            }

 
class MapReduceFinishCommand : public Command {

                        while ( cursor.more() || !values.empty() ) {
                            BSONObj t;
                            if (cursor.more()) {
                                t = cursor.next().getOwned();

                                if ( values.size() == 0 ) {
                                    values.push_back( t );
                                    continue;
                                }

                                if ( t.woSortOrder( *(values.begin()) , sortKey ) == 0 ) {
                                    values.push_back( t );
                                    continue;
                                }
                            }

                            BSONObj res = config.reducer->finalReduce( values , config.finalizer.get());
                            // finalize가 null을 반환하면 해당 key값은 삭제한다 (변경후)
                            if (!res["value"].isNull()) {
                                if (state.isOnDisk())
                                    state.insertToInc(res);
                                else
                                    state.emit(res);
                            }
                            values.clear();
                            if (!t.isEmpty())
                                values.push_back( t );

                            /*  변경전
                            if (state.isOnDisk())
                                state.insertToInc(res);
                            else
                                state.emit(res);
                            values.clear();
                            if (!t.isEmpty())
                                values.push_back( t );
                            */
                        }

• 특징
  • 부하와 분산에 따라서 자동의로 균형을 맞춰준다
    
  • 새머신의 추가히기 쉽다
    
  • 자동 복구가 가능하다
    
  • 수천개의 노드도 수평적으로 확장가능
    
  • config server, mongos, mongod 로 구성됨

 
sudo pecl install mongo
vi /etc/php5/apache2/php.ini
//  Dynamic Extensions쪽에 extension=mongo.so 추가후
/etc/init.d/apache2 restart

 
Alias /rock_mongo /var/www/rock_mongo
/etc/init.d/apache2 restart

// config.php파일에서  요걸 수정
$MONGO["servers"][$i]["control_auth"] = false;