development_mongodb expalin

Author: yangyazhou

README.md

@@ -4,6 +4,7 @@ mongodb-3.6.1源码注释分析，持续更新
 ### .为什么需要对mongodb开源版本做二次开发，需要做哪些必备二次开发:  
 ===================================  
 * [为何需要对开源mongodb社区版本做二次开发，需要做哪些必备二次开发](https://github.com/y123456yz/reading-and-annotate-mongodb-3.6.1/blob/master/development_mongodb.md)  
+* [对开源mongodb社区版本做二次开发收益列表](https://my.oschina.net/u/4087916/blog/3063529)  
 
 ### .mongos架构性能瓶颈:  
 ===================================  

development_mongodb.md

@@ -6,6 +6,7 @@
 4.  危险操作日志审计。
 5.  所有增删改操作sql异步日志记录。
 6.  mongodb增加热备功能。  
+  对应二次开发的收益可以参考:https://my.oschina.net/u/4087916/blog/3063529
 ......
 
    如果对mongodb数据库和wiredtiger存储引擎源码感兴趣，可以参考如下注释:

mongo/mongodb.cnf

@@ -19,7 +19,7 @@ storage:
     indexConfig:
       prefixCompression: true
 net:
-   port: 27117
+   port: 33320
    maxIncomingConnections: 10000
    bindIpAll: true
 operationProfiling:

mongo/mongos.cnf

@@ -0,0 +1,19 @@
+
+security:
+   keyFile: /home/mongodb/taxi_business/mongos/mongos_1/keys/keyfile
+
+systemLog:
+  destination: file
+  logAppend: true
+  path: /home/mongodb/taxi_business/mongos/mongos_1/logs/mongos.log
+
+processManagement:
+  fork: true
+  pidFilePath: /home/mongodb/taxi_business/mongos/mongos_1/mongos.pid
+
+net:
+  port: 33320
+  maxIncomingConnections: 20000
+
+sharding:
+  configDB: featdoc/127.0.0.1:8000,127.0.0.1:8001,127.0.0.1:8002

mongo/src/mongo/db/storage/mmap_v1/logfile.cpp

@@ -129,6 +129,17 @@ void TransportLayerASIO::end(const SessionHandle& session) {
     asioSession->shutdown();
 }
 
+void TransportLayerASIO::anetSetReuseAddr(int fd) {
+    int yes = 1;
+    /* Make sure connection-intensive things like the redis benckmark
+     * will be able to close/open sockets a zillion of times */
+    if (setsockopt(fd, SOL_SOCKET, SO_REUSEADDR, &yes, sizeof(yes)) == -1) {
+        error() << "setsockopt SO_REUSEADDR failed";
+    }
+    return;
+}
+
+
 //TransportLayerASIO::start  accept处理
 //TransportLayerASIO::setup() listen监听
 
@@ -184,6 +195,7 @@ Status TransportLayerASIO::setup() {
 
             GenericAcceptor acceptor(*_acceptorIOContext);
             acceptor.open(endpoint.protocol());
+			//SO_REUSEADDR配置
             acceptor.set_option(GenericAcceptor::reuse_address(true));
 
             acceptor.non_blocking(true, ec);
@@ -205,6 +217,7 @@ Status TransportLayerASIO::setup() {
                 }
             }
 #endif
+	
             _acceptors.emplace_back(std::make_pair(std::move(addr), std::move(acceptor)));
         }
     }