mmorpg游戏服务器模型

前言

mmoprg,即大型多人在线角色扮演游戏,其典型的游戏有:UO :《网络创世纪》、传奇、奇迹MU、WOW、剑侠、天堂2,

这里游戏还是有一定的市场。本文主要是有关MMORPG游戏服务器框架大致结构。

网络通信

客户端和服务端主要建立的是TCP/IP连接,在玩家登陆后,会与服务器创建一个Session回话。

而且现在采用的都是NIO(非阻塞模型),如果是用Java开发,那么netty是一个优秀的NIO模型

框架。消息编码协议,可以采用Protobuf,这个加快数据额传输和转换。

netty中 handler代码块


//服务类

ServerBootstrap b = new ServerBootstrap();

try{

b.group(boss,worker)

.channel(NioServerSocketChannel.class)  //指定所使用的NIO传输Channel

.handler(new LoggingHandler(LogLevel.INFO))

.childHandler(new ChannelInitializer() {

@Override

protected void initChannel(SocketChannel ch) throws Exception {

ChannelPipeline pipeline = ch.pipeline();

pipeline.addLast("IdleStateHandler",new IdleStateHandler(0,0,180));

pipeline.addLast("WriteTimeoutHandler",new WriteTimeoutHandler(60));

pipeline.addLast("reqDecoder",new RequestDecoder());

pipeline.addLast("serverHandler",new GameServerHandler());

pipeline.addLast("respEncoder",new ResponseEncoder());

}

}).option(ChannelOption.SO_BACKLOG,128)

.childOption(ChannelOption.SO_KEEPALIVE,true);

ChannelFuture f = b.bind(port).sync(); //异步的绑定服务器

线程模型

  • 1:所有的Scene都是继承一个抽象类(场景线程基础类),该类是一个继承了Runnable的线程

  • 2:该基础类重写run方法,在run方法中循环的执行其本身的一个excute()抽象方法,其实对于每个线程来说,就是定时的执行其方法,等于该场景的入口。在excuet()方法中,执行一个tick()方法,在这个方法中,传入的是最后执行时间。 也就是每帧会执行一次,33秒为一贞。在tick()方法中,就可以业务处理。处理场景消息,玩家消息,怪物,地图,NPC等。

  • 3:如果要在该场景线程中,加入其他消息处理,如何操作呢,定义一个同步队列,队列中为一个场景方法执行接口,每次put进去就行,然后同样在tick中调用该队列,拿出一个sceneMessage出来执行。

  • 4:玩家消息如何处理呢,在处理玩家消息的时候,其实是调用玩家心跳,玩家心跳中有各种逻辑处理,处理各种请求包和消息包,消息包和场景消息包一样,设置一个同步队列

存储

  • 1:缓存

用的是Google的Cache作为缓存机制,使用泛型Cache cache = CacheBuilder.newBuilder().softValues().build().软引用,在gc的时候会被回收。

其中K为索引,V为继承了基础的DBEntity的实例,现在比较主流的缓存为Caffeine 。

  • 2:DB

当进行DB操作时,进行异步存储,异步执行会调用submit方法,异步执行器中有一个DB实体的阻塞队列和一个线程池。

当submit后,会把entity放入到阻塞队列中。然后用线程去执行run方法,在run方法中,启动线程池,调用execute()方法,把从队列中获得的DBEntity进行db操作。

战斗模块

技能(主动)

在战斗对象中(GObject),设置一个技能收集器,castSkillRequests集合,当客户端请求使用技能或者其他怪物AI(在心跳中),

都会执行reqCastSkill()方法,该方法中,就会把技能转化为SkillCastRequest对象,然后add到castSkillRequests集合中。

然后在GObject的心跳中,会执行procesSkill()方法,在这个方法中,会循环的将集合中收集的技能执行,调用caskSkill()方法释放技能。

然后获取技能模型,并获取技能的处理器,再调用process.execue()方法,做完各种逻辑判断后,

调用真正技能处理器对象的process()方法。可能是添加步buff或者伤害。

伤害的话会调用fight()方法,或者直接根据技能参数计算出hurt值,fight方法中进行各种伤害计算,最终计算一个hurt值。

最后就是扣血操作,并同步到客户端。

AI

AI是要做在GObject心跳中去执行,并设置好AI状态,扫描对象。

具体战斗实现,参考mmorpg战斗

热更

对于热更是必不可少的,线上难免会可能会出现问题,通常要去修复,最好的方式就是修复后再热更上去。若使用C++开发,一般会嵌入脚本(lua)语言,做为支持动态编译热更。如果使用Java开发,

Groovy脚本应该是比较好的选择,Spring对Groovy有着良好的支持,能把Groovy实现累,做为Bean来使用和管理。

参考Spring+Groovy热更

GitHub:代码[图片上传失败...(image-d72df0-1551867714221)]

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • Swift1> Swift和OC的区别1.1> Swift没有地址/指针的概念1.2> 泛型1.3> 类型严谨 对...
    cosWriter阅读 11,174评论 1 32
  • 原文地址:https://blog.csdn.net/erlib/article/details/8936990 ...
    Caiaolun阅读 769评论 0 2
  • iOS多线程编程 基本知识 1. 进程(process) 进程是指在系统中正在运行的一个应用程序,就是一段程序的执...
    陵无山阅读 6,179评论 1 14
  • 进程和线程 进程 所有运行中的任务通常对应一个进程,当一个程序进入内存运行时,即变成一个进程.进程是处于运行过程中...
    胜浩_ae28阅读 5,189评论 0 23
  • 精读 1)从精读中学到的最重要的概念 写作和成为作家是有区别的,就如同很多事一样,所以我们要明确自己究竟要做什么,...
    136段欣荣阅读 227评论 4 0