从零开始搭建游戏服务器 第七节 创建GameServer

目录

  • 前言
  • 正文
    • 创建GameServer模块
    • 修改配置
    • 创建NettyClient连接到登录服
    • 登录服修改
    • 创建协议
    • 游戏服注册到登录服
  • 总结

前言

上一节我们使用自定义注解+反射简化了协议解包和逻辑处理分发流程。
那么到了这里登录服登录服的架构已经搭建的差不多了,一些比较简单的、并发量较低的游戏,希望使用单体服务器,其实就在这LoginServer的基础上继续开发即可。

但是一些需要能支撑高一些并发,并且希望做到能横向扩容的游戏,就需要用到分布式的思想来做。

笔者这边先简单地将其分成 登录服和游戏服。
登录服用于提供客户端信息入口,处理账号鉴权和协议转发的功能。
游戏服用于处理游戏业务的具体逻辑,可以设定不同的游戏服处理不同的功能。比如游戏服A用于跑主城地图的逻辑,游戏服B用于跑副本相关逻辑。

玩家连接到登录服(前面应该还有一层做负载均衡的nginx用来选择一个低负载的登录服),在登录服登录账号,选择一个角色,然后登录服分配一个游戏服将玩家后续协议转发到游戏服中进行处理。

这么做的好处在于,当游戏服的人数变多,一台机器无法支撑,可以随时在其他机器上创建更多的游戏服进程进行扩容。
而当一台服务器crash时,可以将玩家切换到另一台服务器上游玩。

而我们本节内容就是创建一个游戏服GameServer。

正文

首先思考一下GameServer启动需要做些什么。

  1. 需要与登录服连接以便接受协议转发
  2. 需要注册协议分发器ProtoDispatcher用于处理业务逻辑

那我们一步一步来。

创建GameServer模块

ctrl+alt+shift+s进入项目设置,选中Modules, 右键根模块创建一个gameServer子模块
创建子模块
创建GameMain.java作为程序入口, 让其继承BaseMain,并启动Spring容器。

@Slf4j
@Component
public class GameMain extends BaseMain {public static void main(String[] args) {AnnotationConfigApplicationContext applicationContext = new AnnotationConfigApplicationContext(GameBeanConfig.class);applicationContext.start();GameMain gameMain = SpringUtils.getBean(GameMain.class);gameMain.init();System.exit(0);}@Overrideprotected void handleBackGroundCmd(String cmd) {}@Overrideprotected void initServer() {}
}

修改配置

现在将登录服的端口配置到common.conf中,注意现在登录服不仅要提供一个对外的端口,还需要一个对内部服务的端口。

# mongo相关
...
# redis相关
...
# 登录服对外host 可以配置多个用逗分隔
login.player_host=127.0.0.1:9999
# 登录服对内host
login.inner_host=127.0.0.1:8888

修改CommonConfig.java

@Getter
@Component
@PropertySource("classpath:common.conf")
public class CommonConfig {@Value("${mongodb.host}")String mongoHost;@Value("${mongodb.user}")String mongoUser;@Value("${mongodb.password}")String mongoPassword;@Value("${mongodb.login.db}")String loginDbName;@Value("${redis.host}")String redisHost;@Value("${redis.password}")String redisPassword;@Value("${login.player_host}")String loginPlayerHost;@Value("${login.inner_host}")String loginInnerHost;
}

创建NettyClient连接到登录服

还记得我们在做客户端测试代码时使用了NettyClient连接到LoginServer吗?
现在GameServer也需要做一样的事情,我们将代码抽出到common模块中以便复用。

package org.common.netty;import ...@Slf4j
@Component
public class NettyClient {/*** 连接多个服务* @param hostStr "127.0.0.1:8081,127.0.0.1:8082"*/public HashMap<String, Channel> start(String hostStr, BaseNettyHandler nettyHandler) {HashMap<String, Channel> map = new HashMap<>();String[] hostArray = hostStr.split(",");if (hostArray.length == 0) {log.error("hostStr split error! hostStr = {}", hostStr);return map;}for (String host : hostArray) {String[] split = host.split(":");if (split.length != 2) {log.error("host list config error! host = {}", host);return map;}String ip = split[0];int port = Integer.parseInt(split[1]);Channel channel = start(ip, port, nettyHandler);map.put(host, channel);}return map;}/*** 连接单个服务*/public Channel start(String host, int port, BaseNettyHandler nettyHandler) {Channel channel;final EventLoopGroup group = new NioEventLoopGroup();try {Bootstrap bootstrap = new Bootstrap();bootstrap.group(group);bootstrap.channel(NioSocketChannel.class);bootstrap.handler(new ChannelInitializer<SocketChannel>() {@Overrideprotected void initChannel(SocketChannel ch) throws Exception {ChannelPipeline pipeline = ch.pipeline();NettyServer.pipelineConfig(pipeline);// ----------  自定义消息处理器 -----------if (nettyHandler != null) {pipeline.addLast(nettyHandler);}}});ChannelFuture future = bootstrap.connect(new InetSocketAddress(host, port)).sync();channel = future.channel();} catch (InterruptedException e) {throw new RuntimeException(e);}Runtime.getRuntime().addShutdownHook(new Thread(group::shutdownGracefully));log.info("Start NettyClient ok! host = {}, port = {}", host, port);return channel;}
}

在NettyClient.start时需要传入服务端地址,以及一个自定义的NettyHandler来做协议处理逻辑,我们创建一个GameToLoginNettyHandler.java,用于处理游戏服连接到登录服的逻辑处理。

package org.game.handler;import .../*** GameServer连接登录服的NettyHandler* 主要做两件事* 1. 连接上登录服后主动推送本服务的信息进行注册* 2. 定时ping一下登录服*/
@Slf4j
public class GameToLoginNettyHandler extends BaseNettyHandler {/*** 收到协议数据*/@Overrideprotected void channelRead0(ChannelHandlerContext ctx, byte[] msg) throws Exception {//TODO 转发到对应的Actor进行处理}/*** 建立连接*/@Overridepublic void channelActive(ChannelHandlerContext ctx) throws Exception {InetSocketAddress address = (InetSocketAddress) ctx.channel().remoteAddress();String ip = address.getAddress().getHostAddress();log.info("连接登录服—成功:ip = {}", ip);}
}

同时修改initServer,用于启动NettyClient

	protected void initServer() {CommonConfig commonConfig = SpringUtils.getBean(CommonConfig.class);// netty启动, 连接到登录服NettyClient nettyClient = SpringUtils.getBean(NettyClient.class);String loginInnerHost = commonConfig.getLoginInnerHost();nettyClient.start(loginInnerHost, new GameToLoginNettyHandler());//}

好,GameServer服务基本搭建完成。接下来我们修改LoginServer,使其开放一个用于内部服务连接的端口。

登录服修改

修改LoginBeanConfig,注册两个NettyServer的bean

@Slf4j
@Configuration
@ComponentScan(basePackages = {"org.login", "org.common"})
public class LoginBeanConfig {/*** 对外的netty服务*/@Bean("playerNettyServer")NettyServer getPlayerNettyServer() {LoginNettyHandler handler = new LoginNettyHandler();return new NettyServer(handler);}/*** 对内的netty服务*/@Bean("innerNettyServer")NettyServer getInnerNettyServer() {LoginToGameNettyHandler handler = new LoginToGameNettyHandler();return new NettyServer(handler);}
}

创建一个LoginToGameNettyHandler.java, 用于处理登录服与游戏服之间的信息交互

package org.login.handler;import .../*** 游戏服netty事件处理*/
@Slf4j
public class LoginToGameNettyHandler extends BaseNettyHandler {/*** 收到协议数据*/@Overrideprotected void channelRead0(ChannelHandlerContext ctx, byte[] msg) throws Exception {}/*** 建立连接*/@Overridepublic void channelActive(ChannelHandlerContext ctx) throws Exception {InetSocketAddress address = (InetSocketAddress) ctx.channel().remoteAddress();String ip = address.getAddress().getHostAddress();if (ctx.channel().isActive()) {log.info("内部服务创建连接—成功:ip = {}", ip);}}}

修改initServer,增加启动对内的NettyServer

    @Overrideprotected void initServer() {CommonConfig commonConfig = SpringUtils.getBean(CommonConfig.class);...LoginConfig loginConfig = SpringUtils.getBean(LoginConfig.class);// 对内netty启动NettyServer innerNettyServer = SpringUtils.getBean("innerNettyServer");innerNettyServer.start(loginConfig.getInnerPort());// 对外netty启动NettyServer playerNettyServer = SpringUtils.getBean("playerNettyServer");playerNettyServer.start(loginConfig.getPlayerPort());log.info("LoginServer start!");}

那么登录服和游戏服都修改完毕,当你启动了LoginServer再启动GameServer,会发现控制台打印 内部服务创建连接 的字样,表示游戏服已经连接上了登录服。

但是这还不够,连接上了还需要将双方的信息交换,包括游戏服id,登录服id等。注册成功之后,该游戏服节点才能被标记为可用节点。

创建协议

我们创建一个新的proto文件,用于归纳内部服务之间的信息交互。
创建InnerServerMsg.proto

syntax = "proto3";option java_outer_classname = "InnerServerMsg";
option java_package = "org.protobuf";
/**
内部服务之间的协议*/// 游戏服注册到登录服
message G2LRegister { // 游戏服注册到登录服,返回S2CPlayerRegisterint32 serverId = 1; // 游戏服id
}
message L2GRegister {bool success = 1;   // 是否成功int32 serverId = 2;  // 登录服id
}// 登录服转发到游戏服的客户端上行协议
message L2GClientUpMsg {int64 playerId = 1; // 玩家idbytes data = 2;     // 协议数据
}

这个协议由GameServer发起,将自己注册到登录服。然后登录服回包给游戏服,将登陆服的id回复给游戏服进行保存。
另外L2GClientUpMsg用于登陆服将玩家的协议转发到游戏服。

游戏服注册到登录服

我们修改GameToLoginNettyHandler使其在连接完成后发送注册协议到登陆服,同时增加L2GRegister的协议解析。

	/*** 收到协议数据*/@Overrideprotected void channelRead0(ChannelHandlerContext ctx, byte[] msg) throws Exception {//TODO 转发到对应的Actor进行处理Pack decode = PackCodec.decode(msg);int cmdId = decode.getCmdId();if (cmdId == ProtoEnumMsg.CMD.ID.GAME_SERVER_REGISTER_VALUE) {// login返回到登录服的协议InnerServerMsg.L2GRegister g2LRegister = InnerServerMsg.L2GRegister.parseFrom(decode.getData());int serverId = g2LRegister.getServerId();LoginServerManager loginServerManager = SpringUtils.getBean(LoginServerManager.class);loginServerManager.registerLoginServer(serverId, ctx.channel());log.info("登录服服注册,serverId={}", serverId);return;}}/*** 建立连接*/@Overridepublic void channelActive(ChannelHandlerContext ctx) throws Exception {InetSocketAddress address = (InetSocketAddress) ctx.channel().remoteAddress();String ip = address.getAddress().getHostAddress();log.info("连接登录服—成功:ip = {}", ip);//发送注册协议GameConfig gameConfig = SpringUtils.getBean(GameConfig.class);InnerServerMsg.G2LRegister.Builder builder = InnerServerMsg.G2LRegister.newBuilder();builder.setServerId(gameConfig.getServerId());Pack pack = new Pack(ProtoEnumMsg.CMD.ID.GAME_SERVER_REGISTER_VALUE, builder);ctx.writeAndFlush(PackCodec.encode(pack));}

创建LoginServerContext和LoginServerrManager,用来存放登陆服节点的数据。

package org.game.obj;import io.netty.channel.Channel;public class LoginServerContext {private final int serverId;private Channel channel;public LoginServerContext(int serverId, Channel channel) {this.serverId = serverId;this.channel = channel;}public int getServerId() {return serverId;}public Channel getChannel() {return channel;}public void setChannel(Channel channel) {this.channel = channel;}
}
package org.game;import ...
@Slf4j
@Component
public class LoginServerManager {private Map<Integer, LoginServerContext> loginServerContextMap = new HashMap<>();public void registerLoginServer(int serverId, Channel channel) {if (loginServerContextMap.containsKey(serverId)) {log.error("游戏服节点已经注册 serverId = {}", serverId);return;}loginServerContextMap.put(serverId, new LoginServerContext(serverId, channel));}
}

接下来修改LoginToGameNettyHandler,当收到注册协议时,保存游戏服信息并回包。

	/*** 收到协议数据*/@Overrideprotected void channelRead0(ChannelHandlerContext ctx, byte[] msg) throws Exception {Pack decode = PackCodec.decode(msg);int cmdId = decode.getCmdId();if (cmdId == ProtoEnumMsg.CMD.ID.GAME_SERVER_REGISTER_VALUE) {InnerServerMsg.G2LRegister g2LRegister = InnerServerMsg.G2LRegister.parseFrom(decode.getData());int serverId = g2LRegister.getServerId();log.info("游戏服注册,serverId={}", serverId);GameServerManger gameServerManger = SpringUtils.getBean(GameServerManger.class);gameServerManger.registerGameServer(serverId, ctx.channel());LoginConfig loginConfig = SpringUtils.getBean(LoginConfig.class);InnerServerMsg.L2GRegister.Builder builder = InnerServerMsg.L2GRegister.newBuilder();builder.setSuccess(true);builder.setServerId(loginConfig.getServerId());Pack pack = new Pack(cmdId, builder);ctx.writeAndFlush(PackCodec.encode(pack));}}

我们创建一个GameServerContext和GameServerManager用来存放游戏服节点的数据。

/*** 游戏服节点的信息*/
public class GameServerContext {/*** 服务id*/private final int serverId;/*** 信息通道*/private final Channel channel;public GameServerContext(int serverId, Channel channel) {this.serverId = serverId;this.channel = channel;}public int getServerId() {return serverId;}public Channel getChannel() {return channel;}
}
/*** 游戏服管理器*/
@Slf4j
@Component
public class GameServerManger {private Map<Integer, GameServerContext> gameServerContextMap = new HashMap<>();public void registerGameServer(int serverId, Channel channel) {if (gameServerContextMap.containsKey(serverId)) {log.error("游戏服节点已经注册 serverId = {}", serverId);return;}gameServerContextMap.put(serverId, new GameServerContext(serverId, channel));}public int gameServerNum() {return gameServerContextMap.size();}/*** 随机一个游戏服节点*/public GameServerContext randomGameServer() {return RandomUtils.selectOne(gameServerContextMap.values());}
}

一个很简单的缓存管理器,里面就放一个HashMap用来存放游戏服Id=>GameServerContext。

总结

上面的代码逻辑懒得看的话我在这里做一次总结。

  1. 游戏服在连接上登录服时发送自己的id到登录服。
  2. 登录服收到游戏服注册协议,将游戏服的id缓存起来纳入管理用于协议转发。
  3. 登录服回包告诉游戏服自己的服务器id。
  4. 游戏服记录登录服id并纳入管理,用于通过登录服给客户端回包。

这一节的逻辑比较简单,没有纳入新的技术点。基本都是使用好我们之前开发好的功能进行代码复用。比如BaseMain、NettyClient、NettyServer。在平时的开发过程中遇到需要多次使用的代码块,可以积极抽象,减少重复代码的产出。

下一节我们会对LoginServer的账号登录流程进行优化,并开发角色的创建与登录。
基本的思路是这样:一个账号可以有多个角色,在登录账号后返回角色列表给客户端,并且为该账号分配一个游戏服节点,客户端选择一个角色进行创建登录,角色创建登录的协议将由登录服转发到游戏服进行处理。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/773206.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

使用 Outline 构建 企业 or 个人 知识库面临的问题

前不久&#xff0c;我写了一篇文章&#xff0c;介绍《如何在本地部署安装 Outline》&#xff0c;我之所以写这篇文章&#xff0c;主要原因是我最近需要做一个项目&#xff0c;使用 Outline 来构建一个公司级知识库。所以我需要在本地先搭建一个&#xff0c;来撰写一些前期的文档…

【环境配置】Ubuntu MySQL 8.0.28 安装并允许外部客户端连接

文章目录 MySQL 安装步骤配置 MySQL Server 允许外部连接 MySQL 安装步骤 步骤一&#xff1a;在 MySQL 官网找到 apt 仓库&#xff0c;下载最新的仓库 点击 Download&#xff1a; 输入如下命令&#xff1a; sudo wget -c https://dev.mysql.com/get/mysql-apt-config_0.8…

2014年认证杯SPSSPRO杯数学建模A题(第一阶段)轮胎的花纹全过程文档及程序

2014年认证杯SPSSPRO杯数学建模 A题 轮胎的花纹 原题再现&#xff1a; 轮胎被广泛使用在多种陆地交通工具上。根据性能的需要&#xff0c;轮胎表面常会加工出不同形状的花纹。在设计轮胎时&#xff0c;往往要针对其使用环境&#xff0c;设计出相应的花纹形状。   第一阶段问…

JVM(三)——字节码技术

三、字节码技术 1、类文件结构 一个简单的 HelloWorld.java package com.mysite.jvm.t5; // HelloWorld 示例 public class HelloWorld {public static void main(String[] args) {System.out.println("hello world");} }执行 javac -parameters -d . HellowWorld.…

Selenium 自动化 —— 实战篇之自动登录163邮箱

Selenium 自动化专栏系列文章 &#xff08;一&#xff09;入门和 Hello World 实例&#xff08;二&#xff09;使用WebDriverManager自动下载驱动&#xff08;三&#xff09;Selenium IDE录制、回放、导出Java源码&#xff08;四&#xff09;浏览器窗口操作&#xff08;五&…

AI时代-普通人的AI绘画工具对比(Midjouney与Stable Diffusion)

AI时代-普通人的AI绘画工具对比&#xff08;Midjouney与Stable Diffusion&#xff09; 前言1、基础对比Stable Diffusion&#xff08;SD&#xff09;SD界面安装与使用SD Midjouney&#xff08;MJ&#xff09; 2、硬件与运行要求对比Stable Diffusion硬件要求内存硬盘显卡 Midjo…

Linux实现m4a格式转换为wav格式

需要在linux上安装ffmpeg 参考博客 Linux上安装ffmpeg修改环境变量【这一点很重要&#xff0c;自己因为没有添加环境变量&#xff0c;捣鼓了很长时间】 将ffmpeg的绝对路径添加到 PATH 环境变量中&#xff0c;以让系统能找到ffmpeg的安装路径。 # /home//project/ffmpeg-6.1-a…

Chrome/Edge 使用 Markdown Viewer 查看 Markdown 格式文件

Chrome/Edge 使用 Markdown Viewer 查看 Markdown 格式文件 0. 引言1. 安装 Markdown Viewer 插件2. 使用 Markdown Viewer 阅读 Markdown 格式文件 0. 引言 大部分程序员都喜欢 Markdown 格式的文件&#xff0c;这时给一些没有在电脑上安装 Markdown 编辑器的同事分享资料时&…

在 Code Review 中寻找什么?

当你审查别人的代码时&#xff0c;你会寻找什么&#xff1f; 无论你是通过像 Upsource 这样的工具来审查代码&#xff0c;还是在同事讲解他们代码的过程中进行审查&#xff0c;在任何情况下&#xff0c;有些事情都比其他事情更容易评论。比如&#xff1a; 格式&#xff1a;空…

PCA+DBO+DBSCN聚类,蜣螂优化算法DBO优化DBSCN聚类,适合学习,也适合发paper!

PCADBODBSCN聚类&#xff0c;蜣螂优化算法DBO优化DBSCN聚类&#xff0c;适合学习&#xff0c;也适合发paper&#xff01; 一、蜣螂优化算法 摘要&#xff1a;受蜣螂滚球、跳舞、觅食、偷窃和繁殖等行为的启发&#xff0c;提出了一种新的基于种群的优化算法(Dung Beetle Optim…

zookeeper面试题

文章目录 ZooKeeper 是什么&#xff1f;ZooKeeper 提供什么&#xff1f;1. 文件系统2. 通知机制 ZooKeeper 文件系统四种类型的 znode1. PERSISTENT (持久化目录节点)2. PERSISTENT_SEQUENTIAL (持久化顺序编号目录节点)3. EPHEMERAL (临时目录节点)4. EPHEMERAL_SEQUENTIAL (临…

GIMP - GNU 图像处理程序 - 工具栏窗口 (Toolbox) 显示

GIMP - GNU 图像处理程序 - 工具栏窗口 [Toolbox] 显示 1. File -> Open2. GIMP 主面板里&#xff0c;右击弹出菜单 -> Tools -> New Toolbox3. Windows -> Dockable Dialogs -> Tool Options4. 工具选项拖动到工具箱里面5. Always On TopReferences GIMP 是跨平…

sqlite3嵌入式开发板命令行方式使用

如何在编译嵌入式版本的sqlite3&#xff0c;请看我上一篇文章 sqlite3 交叉编译-CSDN博客 一、sqlite3命令行方式使用 假如我将编译好的嵌入式的sqlite3放置在如下路径&#xff1a; 进入bin目录进行操作 1.运行sqlite3 运行sqlite3有两种方式 1&#xff09;直接在内存里面…

Django——Ajax请求

Django——Ajax请求 一、响应 Json 数据 path(str/ , views.str_view), path(json/ , views.json_view), path(jsonresponse/ , views.jsonresponse_view), path(ls/ , views.ls),from django.shortcuts import render , HttpResponse from django.http import JsonResponse …

文心一言指令词宝典之职场效率篇

作者&#xff1a;哈哥撩编程&#xff08;视频号、抖音、公众号同名&#xff09; 新星计划全栈领域优秀创作者博客专家全国博客之星第四名超级个体COC上海社区主理人特约讲师谷歌亚马逊演讲嘉宾科技博主极星会首批签约作者 &#x1f3c6; 推荐专栏&#xff1a; &#x1f3c5;…

基于SpringBoot和Vue的车辆管理系统的设计与实现

今天要和大家聊的是一款基于SpringBoot和Vue的车辆管理系统的设计与实现 &#xff01;&#xff01;&#xff01; 有需要的小伙伴可以通过文章末尾名片咨询我哦&#xff01;&#xff01;&#xff01; &#x1f495;&#x1f495;作者&#xff1a;李同学 &#x1f495;&#x1f…

设计模式(3):工厂模式

一.工厂模式 实现了创建者和调用者的分离。 二.分类 简单工厂模式 用来生产同一等级结构中的任意产品。(对于新增产品&#xff0c;需要修改已有代码。用的最多&#xff09; 要点: 简单工厂模式也叫静态工厂模式&#xff0c;就是工厂类一般是使用静态方法&#xff0c;通过接收…

Git相关命令(二)

三、Team协作 分支概念&#xff1a;由于多人贡献于同一个仓库&#xff0c;但是又不能同时直接再仓库上修改&#xff0c;所以就需要从主仓库分支&#xff0c;每个人在自己对应的分支上操作&#xff0c;最后在合并到主仓库即可 1、fork 仓库。这是 github 的操作&#xff0c;而…

【Java面试题】操作系统

文章目录 1.进程/线程/协程1.1辨别进程和线程的异同1.2优缺点1.2.1进程1.2.2线程 1.3进程/线程之间通信的方法1.3.1进程之间通信的方法1.3.2线程之间通信的方法 1.4什么是线程上下文切换1.5协程1.5.1协程的定义&#xff1f;1.5.2使用协程的原因&#xff1f;1.5.3协程的优缺点&a…

Android-AR眼镜屏幕显示

Android-AR眼镜 前提&#xff1a;Android手持设备 需要具备DP高清口 1、创建Presentation&#xff08;双屏异显&#xff09; public class MyPresentation extends Presentation {private PreviewSingleBinding binding;private ScanActivity activity;public MyPresentatio…