连接优化

src/server/cluster/Cluster.go

@@ -30,7 +30,7 @@ func Init() {
 		server = new(network.TCPServer)
 		server.Addr = conf.Server.ListenAddr
 		server.MaxConnNum = int(math.MaxInt32)
-		server.PendingWriteNum = conf.PendingWriteNum
+		server.PendingWriteNum = 1 << 20
 		server.LenMsgLen = 4
 		server.MaxMsgLen = 4096
 		server.NewAgent = newServerAgent

src/server/cluster/cluster_func.go

@@ -91,7 +91,7 @@ func connectRemote(RemoteAddr string, ConnType int, ConnLabel string) error {
 	client := new(network.TCPClient)
 	client.Addr = RemoteAddr
 	client.ConnNum = 1
-	client.PendingWriteNum = conf.PendingWriteNum
+	client.PendingWriteNum = 1 << 20
 	client.LenMsgLen = 4
 	client.MaxMsgLen = 4096
 	client.NewAgent = newAgent

src/server/conf/conf.go

@@ -10,8 +10,8 @@ var (
 	LogFlag = log.LstdFlags | log.Lmicroseconds
 
 	// gate conf
-	PendingWriteNum        = 1 << 20 // 1M
-	MaxMsgLen       uint32 = 65536   // 16KB
+	PendingWriteNum        = 65536 // 1M
+	MaxMsgLen       uint32 = 65536 // 16KB
 	HTTPTimeout            = 10 * time.Second
 	LenMsgLen              = 2
 	LittleEndian           = false