游戏跨服开发笔记
服务器管理入口
@Component
@SocketClass
public class ServerFacade {
// 所有游戏服连接时，合服事件
@ReceiverAnno
public void onAllGameServerConnected(EventMergeServer eventMergeServer) {
serverGroupManager.mergeServerExitGroup(eventMergeServer.getGameServer(), eventMergeServer.getChildServerIds());
}
// 所有游戏服连接时，所有游戏服连接事件
@ReceiverAnno
public void onAllGameServerConnected() {
serverGroupManager.forceRefresh();
}
// 注册
@SocketMethod
public void register(Wsession wsessoin, G2cGameServerRegister g2cGameServerRegister) {
gameServerManager.register(wsession, g2cGameServerRegister);
}
// 游戏服心跳事件
@SocketMethod
public void register(GameSerever gameServer, G2cGameServerRegist g2cGameServerHeartbeat) {
gameServerManager.register(wsession, g2cGameServerHeartbeat);
}
// 战斗服心跳事件
@SocketMethod
public void transferHeartbeat(Wsession wsession, T2cTeansferHeartbeat) {
transferServerManger.heartbeat(wsession, heartbeat);
}
// 接受分组参数
@SocketMethod
public void receiveGroupParam(GameServer gameServer, G2cGroupParamUpload paramUpload) {
serverGroupManager.uploadGroupParam(gameServer, paramUpload);
}
// 重新分组
@SocketMethod
public void reServerGroup(GameServer gameServer, G2cCommandReServerGroup commandReServerGroup) {
serverGroupManager.commandReGroup();
}
// 接受分组
@SocketMethod
public void assignServerGroup(GameServer gameServer, G2cCommandAssignServerGroupResp cCommandAssignServerGroupResp) {
serverGroupManager.commandAssignGroup(gameServer.getEntity(), cCommandAssignServerGroupResp.getGroupType());
}
}
// 游戏服 - 跨服处理相关入口
// 注意：Wsession不是玩家会话，是游戏服与中心服的会话
```java
@Componet
@SocketClass
public class GameServerFacade {
// 开服连接
@ReceiverAnno
public void onGameServerOpen(ServerOpenEvent event) {
if(serverManager.getOpenDay().isOpen()) {
centerManager.connect();
}
}
// 开服了，注册到中心服
@ReceiverAnno
public void onServerDayBegin(ServerDayBeginEvent event) {
centerManager.connect();
}
// 连接成功了，尝试注册，如果这时候服务器未达成开服条件，不注册
@ReceiverAnno
public void onConnerctCenter(EventCenterC) {
if(ServerType.isGameServer()) {
gameServerService.tryRegisterGameServer2Center();
}
}
// 玩家断开连接，检测是否需要退出跨服
@ReceiverAnno
public void onPlayerLogout(LogoutEvent event) {
Player player = event.getPlayer();
gameServerService.onPlayerOffine(player);
}
// 收到门票，开始前往跨服
@SocketMethod
public void receiverTicketFormCenter() {
gamServerService.beginEnter(ticketResp.getPlayerId(), ticketResp.getTransferIp(),
ticketResp.getTransferPort(), ticketResp.getTicket());
}
// 确认退出跨服
@SocketMethod
public void confirmExitTransfer(Player player, T2gTransferExitConfirmResp resp) {
gameServerService.exitTransferConfirm(player, resp);
}
// 中心服发送给玩家的通知信息
@SocketMethod
public void sendMessage(Wsession wsession, C2GMessagePacket, c2GMessagePacket) {
gameServerService.sendMessagePacket(c2GMessagePacket);
}
// 确认进入跨服
@SocketMethod
public void enterTransfer(Player player, T2gTransferEnteredResp resp) {
player.submitEvent(TeansgerEnteredEvent.valueOf(resp.getTransferType()));
}
// 收到中心返回的所有跨服地图门票信息
// 中心服会在启动完成初始化之后，主动推送到游戏服
@SocketMethod
public void receiveTransportTicketFromCenter(Wsesion wsession, C2gTransportTicketsResp c2TransportTicketsResp) {
}
// 收到中心服返回的分组信息
@SocketMethod
public void receiveServerGroupInfoFromCneter(Wsession wsession, C2gServerGroupType2ServerIds c2gServerGroupType2ServerIds) {
}
// 收到战斗服回传的玩家事件
@SocketMethod(coustomPacketId = CrossPacketId.GLOBAL_EVENT_RESP)
@IRunInNioThread
public void transferPlayerEvent(Wsession wsession, IEvent eventPacket) {
// 异步提交事件
String simpleName = eventPacket.getClass().getSimpleName();
EventBusManager.getInstance().sumbmit(eventPacket, "globalEvent_"+SimpleName, simpleName.hashCode());
}
// 跨服发奖
@SocketMethod
public void gainReward(Player player, T2gGainRewardResp t2gGainRewardResp) {
palyer.gainReward(t2gGainRewardResp.getReward(), t2gGainRewardResp.getModuleInfo());
}
// 战斗服 -> 游戏服 跨服事务
@SocketMethod
public T2gTransactionResp transaction(Player player, T2gTransactioReq) {
}
// 分组销毁
@SocketMethod
public void receiveServerGroupDestroy(Wsession wsession, C2gTicketsDetroyPacket c2gTicketsDestroyPacket) {
centerManger.onServerGroupDestroy(c2gTicketDestroyPacket.getServerGroupType());
}
}
服务器管理逻辑处理
跨服类型
@Desc("跨服3V3")
transfer_t3v3,
@Desc("跨服地图")
transfer_land,
@Desc("跨服灭神塔")
transfer_godKillTower,
@Desc("跨服灭神塔全服")
transfer_godKillTowerServer,
@Desc("跨服沙巴克")
shabake,
// ...
服务器分组类型
@Desc("服务器哦分组类型")
public enum ServerGroupType {
@Desc("3v3")
t3v3(false, false),
@Desc("第四大陆")
land4(true, true),
@Desc("第五大陆")
land5(true, true),
@Desc("公会秘境争霸")
secretArea(false,false)
// 该战区是否预分配战斗服
private boolean groupOnServerOpen;
// 预分配战斗服之后，是否通知战斗服，检测该战区下面的地图是否需要预创建地图， ps:只判断是否发送检测通知
// 具体某一张地图是否预创建，是检测地图配置MapType枚举里面的initTrandferMap字段
private boolean initMapAfterGroupTransfer;
}
跨服门票
@ProtobufClass
public class Ticket {
@Protobuf(description = "跨服类型")
private TransferType type;
@Protobuf(description = "门票id,同一")
private long ticketId;
@Protobuf(description = "分组类型（战区）")
private ServerGroupType groupType;
@Protobuf(description = "组号")
private int groupIndex;
// 其他额外信息
@Protobuf(description = "阵营类型")
private CampType campType;
@Protobuf(description = "前往的跨服地图ID")
private int mapId;
@Protobuf(description = "x")
private int x;
@Protobuf(description = "y")
private int y;
// 创建一张门票 ...
}
中心服通用业务处理
@Component
public class CenterManager {
// ...
// 创建一个唯一的门票id
public long createTicketId() {
return idGen.getAndIncrement();
}
1
// 发送门票到游戏服
public void sendTicket(TransferType transferType, long playerId, int gameServerId, TransferServer transferServer, Ticket ticket) {
GameServer gameServer = gameServerManager.getSreverIfRegister(gameServerId);
if(gameServer == null) {
return;
}
C2gTransferTicketResp resp = C2gTransferTicketResp.valueOf(
transferServer.getIp(),
transferServer.getPort(),
playerId,
ticket
);
// 通知游戏服
gameServer.send(resp);
}
}