server/game/game_cluster/internal/rpc/game/game.go

package rpcGame

import (
	"fmt"
	cfacade "github.com/mhaya/facade"
	"github.com/mhaya/game/game_cluster/internal/pb"
	sessionKey "github.com/mhaya/game/game_cluster/internal/session_key"
	clog "github.com/mhaya/logger"
	cproto "github.com/mhaya/net/proto"
)

const (
	playerActor = "player"
)

const (
	sessionClose = "sessionClose"
)
const (
	sourcePath = ".system"
)

// SessionClose 如果session已登录，则调用rpcGame.SessionClose() 告知游戏服
func SessionClose(app cfacade.IApplication, session *cproto.Session) {
	nodeId := session.GetString(sessionKey.TargetPath)
	if nodeId == "" {
		clog.Warnf("Get server id fail. session = %s", session.Sid)
		return
	}

	targetPath := fmt.Sprintf("%s.%s.%s", nodeId, playerActor, session.Sid)
	app.ActorSystem().Call("", targetPath, sessionClose, &pb.Int64{
		Value: session.Uid,
	})
	//clog.Infof("send close session to game node. [node = %s, uid = %d]", nodeId, session.Uid)
}