消息服务优化

src/server/conf/conf.go

@@ -10,7 +10,7 @@ var (
 	LogFlag = log.LstdFlags | log.Lmicroseconds
 
 	// gate conf
-	PendingWriteNum        = 2000
+	PendingWriteNum        = 65536
 	MaxMsgLen       uint32 = 65536 // 16KB
 	HTTPTimeout            = 10 * time.Second
 	LenMsgLen              = 2

src/server/game/message_mgr.go

@@ -59,7 +59,7 @@ type TaskResult struct {
 }
 
 func (m *MessageMgr) MessageMgrInit() {
-	m.key = MESSAGE_MGR_KEY
+	m.key = MESSAGE_MGR_KEY + fmt.Sprintf("_%d", conf.Server.ServerID)
 	m.data = &MessageData{
 		MessageList: make(map[int64]*MessageList),
 		PlayerList:  make(map[int64]int),