message controller

src/server/game/message_mgr.go

@@ -2,7 +2,9 @@ package game
 
 import (
 	"fmt"
+	mergeCluster "server/cluster"
 	"server/game/mod/msg"
+	GoUtil "server/game_util"
 	"server/pkg/github.com/name5566/leaf/log"
 )
 
@@ -34,3 +36,16 @@ func (m *MessageMgr) Handle(msg *msg.Msg) (interface{}, error) {
 	log.Error("server mod key:%s handle not exist handle type:%d", m.key, msg.Type)
 	return nil, fmt.Errorf("server mod handler err")
 }
+
+func SendMessage(m1 *msg.Msg) error {
+	if m1.SendT == 0 {
+		m1.SendT = GoUtil.Now()
+	}
+	m := m1.Clone()
+	err := mergeCluster.SendServerMsg(m, 1)
+	if err != nil { // 区服不在线
+		G_GameLogicPtr.FriendMgrSend(m)
+		return err
+	}
+	return nil
+}

src/server/game/mod/msg/Msg.go

@@ -3,16 +3,17 @@ package msg
 import "server/game/mod/item"
 
 type Msg struct {
-	Type   int          // 消息类型
-	To     int          // 接收者
-	From   int          // 发送者
-	Item   []*item.Item // 物品
-	SendT  int64        // 发送时间
-	End    int64        // 过期时间
-	Extra  interface{}  //额外信息
-	Id     int64
-	UniKey string // 回调监听唯一键值
-	H      int    //处理类型
+	Type       int          // 消息类型
+	To         int          // 接收者
+	From       int          // 发送者
+	Item       []*item.Item // 物品
+	SendT      int64        // 发送时间
+	End        int64        // 过期时间
+	Extra      interface{}  //额外信息
+	Id         int64
+	UniKey     string // 回调监听唯一键值
+	H          int    //处理类型
+	HandleType int    //处理类型
 }
 
 var MSG_ZERO_UPDATE = &Msg{Type: SERVER_ZERO_UPDATE}