【从零开始学Skynet】实战篇《球球大作战》(十四):agent跨服务器版

news2024/12/24 9:53:15
        至此,我们已完成了《球球大作战》的绝大部分功能,只剩下完 善agent ,让它和 scene 服务联动了。

1、多个模块

        一般而言,代理服务会承载很多系统,比如邮件、成就等,此处涉及的代码较多,容易混
乱,需划分模块。之前实现的service 模块能让服务带有分模块的潜力。
        新建 service/agent/scene.lua 用于处理 agent的战斗逻辑, 只需在 init.lua 中引入( require )新增的文件,即可使用新文件提供的功能, service/agent/init.lua 中新增的内容:
require "scene"
拓展知识: 如果后续开发邮件、成就等系统,同样要新建一个文件,每个文件处理一项功能

 

2、进入战斗

        现在进入比赛的功能。在 scene.lua文件中 编写战斗协议处理方法s.client.enter
s.client.enter = function(msg)
    if s.sname then
        return {"enter",1,"已在场景"}
    end
    local snode, sid = random_scene()
    local sname = "scene"..sid
    local isok = s.call(snode, sname, "enter", s.id, mynode, skynet.self())
    if not isok then
        return {"enter",1,"进入失败"}
    end
    s.snode = snode
    s.sname = sname
    return nil
end
这段代码可实现如下几个功能:
  • 定义 s.snode s.name 这两个变量,如果玩家尚未进入战场,这两个值为空;如果已进入,分别存储对应场景服务的节点和名字
  • 调用 random_scene (稍后实现)随机获取一个场景服务。变量snode代表场景服务所在的节点, sid 代表场景服务的 id
  • 向场景服务发送 enter 消息 ,请求进入场景。如果成功进入场景,会给s.snode s.sname 赋值。

        随机选择场景的random_scene方法,我们之前提到过, agent 应尽可能地进入同节点的scene。如下代码所示。
local function random_scene()
    --选择node
    local nodes = {}
    for i, v in pairs(runconfig.scene) do
        table.insert(nodes, i)
        if runconfig.scene[mynode] then
            table.insert(nodes, mynode)
        end
    end
    local idx = math.random( 1, #nodes)
    local scenenode = nodes[idx]
    --具体场景
    local scenelist = runconfig.scene[scenenode]
    local idx = math.random( 1, #scenelist)
    local sceneid = scenelist[idx]
    return scenenode, sceneid
end
为了模拟合适的匹配机制,random_scene 返回同节点场景服务的概率是其他节点的数倍。
具体做法: 先把所有配置了场景服务的节点都放在表 nodes 中, 同一节点(mynode )会插入多次,使它能有更高被选中的概率。插入 完成后在nodes 表随机选择一个节点( scenenode )。再在选出的节点中 随机选出一个场景(sceneid

3、退出战斗

        当客户端掉线时,agent 需要向场景服务请求退出。要实现该功能,首先得修改resp.kick ,使 agent 在退出前调用s.leave_scene方法。 service/agent/init.lua 中修改的内容:
s.resp.kick = function(source)
	s.leave_scene()
	--在此处保存角色数据
	skynet.sleep(200)
end
       然后编写 s.leave_scene 方法,它会给场景服务发 送leave消息。 service/agent/scene.lua 中新增的内容:
s.leave_scene = function()
    --不在场景
    if not s.sname then
        return
    end
    s.call(s.snode, s.sname, "leave", s.id)
    s.snode = nil
    s.sname = nil
end

4、最后的辅助方法

        最后完成几个简单方法。 scene 调用了agent的远程调用方法 send 给客户端发送消息,它的实现如下 所示,这里仅仅是将消息转发到gateway上。 service/agent/init.lua 中新增的内容:
s.resp.send = function(source, msg)
	skynet.send(s.gate, "lua", "send", s.id, msg)
end
        当玩家要改变移动方向时,客户端会发送 shift协议,经由agent转发,实现如下代码。 service/agent/scene.lua 中新增的内容:
--改变方向
s.client.shift  = function(msg)
    if not s.sname then
        return
    end
    local x = msg[2] or 0
    local y = msg[3] or 0
    s.call(s.snode, s.sname, "shift", s.id, x, y)
end

5、运行结果

        我们成功编写完所有代码,可以测试了。运行客户端,然后登录、进入场景。可以看到服务端回应的 进入成功 等消息,如下图所示:

        客户端A( 101 )先登录游戏,然后进入场景,进入时服务端会回应enter 协议并发送 balllist foodlist 协议告诉客户端A 当前的战场信息。服务端会随机添加食物,发送 addfood 协 议。当客户端A 改变移动方向( shift )时,服务端会一直广播 move 协 议。稍后客户端B 102 )登录,如果进入同一场景,客户端 A 会收 到“enter,102...” 的信息。客户端 B 获得的战场信息 balllist 也会包含玩家101(客户端 A )的信息,且收到客户端 A 的移动协议。
完整项目地址: https://gitee.com/frank-yangyu/ball-server​​​​​​​

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

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

相关文章

<Windows> 《VMware各类问题及解决方法》(持续更新...)

《VMware各类问题》 1 虚拟机无法获取权限2 虚拟机开机无法启动原因2.1 可能原因12.2 可能原因2 1 虚拟机无法获取权限 出现原因: 在虚拟机运行时,一次非正常关机。导致虚拟机出现此错误。此虚拟机似乎正在使用中。 解决方法: 方法一&#xf…

华为电脑如何录屏?2个方法教您快速录制!

案例:如何在华为电脑上进行电脑屏幕录制? 【我是一名老师,我想在电脑上录制一段教学视频,但是我不知道如何录制我的电脑屏幕。有没有哪位朋友知道华为电脑怎么录屏?可以分享一下方法吗?】 华为电脑是目前…

【Vue】学习笔记-Vue生命周期

引出生命周期 生命周期 a.又名生命周期回调函数、生命周期函数、生命周期钩子 b.是什么:vue 在关键时刻帮助我们调用一些特殊名称的函数 c.生命周期函数的名字不可更改,但函数的具体内容是程序员根据需求编写的 d.生命周期函数中的this指向是vm或组件实…

Win10 开机输入密码后登入桌面就黑屏,只有鼠标可以移动, 打不开任务管理器,不用重装系统怎么修复?(已解决)十四个解决参考方案

环境: Win10 专业版21H2 戴尔5590笔记本 Win11PE 系统安装U盘 USB固态硬盘盒 闪迪16G U盘 DiskGenius_Pro_v5.4.3 问题描述: Win10开机输入密码登入桌面后突然黑屏,只有鼠标可以移动, 打不开任务管理器,按住ctrl shift esc鼠标会有蓝色圈转动,但是不会弹出任务管理…

Elasticsearch——文档操作

新增文档 POST /索引库名/_doc/文档id { "字段1": "值1", "字段2": "值2", "字段3": { "子属性1": "值3", "子属性2": "值4" }, // ... } 查询文档 GET /索引库名/_doc/文档id 删除…

Transactional事务失效场景汇总

文章目录 1、前言2、失效场景2.1、Service没有被Spring管理2.2、事务方法被final、static关键字修饰2.3、同一个类中,方法内部调用2.4、方法的访问权限不是public2.5、数据库的存储引擎不支持事务2.6、Transactional 注解配置错误2.7、使用了错误的事务传播机制2.8、…

elasticsearch与mysql数据同步

目录 数据同步一.思路分析1.同步调用2.异步通知3.监听binlog4.选择 二.实现数据同步1.思路2.导入demo3.声明交换机、队列3.1引入依赖3.2 配置文件3.3 声明队列交换机名称3.4 声明队列交换机 4.发送MQ消息4.1 事务配置类4.2 service 代码 5.接收MQ消息 数据同步 elasticsearch中…

数据分析----IQR(Interquartile Range)四分位距的理解与应用及Python实现

【原文链接】数据分析----IQR(Interquartile Range)四分位距的理解与应用及Python实现 一、IQR(Interquartile Range)四分位距的含义 1.1 IQR的官方定义 IQR 是用于标记离群值的另一种稳健方法。用于检测离群值的 IQR&#xff…

解放你的双手:自动化文档整理

目录 引子: 应用场景: 源代码: 源代码说明: 效果如下所示: movefiletofolderbytype.py 引子: 例如,一个人可能会在计算机上存储大量的照片、视频和文档文件,这些文件可能散落在不同的文件夹中&#xf…

1678_计算机架构黄金时代_文章阅读

全部学习汇总: GreyZhang/g_risc_v: Learning notes about RISC V. (github.com) 看了一份几年前的文章,觉得还是挺有收获的,因此做一个简单的整理。 对于架构有很大影响的主要考虑四点:专用硬件的实现、高安全性的要求、开放指令…

原来这些功能才是blender大受欢迎的原因

作为全球最热门的免费开源3D创作套件,好用、易上手是Blender的公认优点。相比许多付费的三维软件来说,Blender在功能上是有过之无不及。除了在建模方面表现出色外,还提供了从模型雕刻、动画、材质、渲染、到音频处理、视频剪辑等一系列制作解…

Nature子刊:HPV改变阴道菌群的机制

​ 研究背景 人类乳头瘤病毒(HPV)是最常见的性传播感染,影响全球3亿人以上。 虽然大多数感染像得了场“感冒”一样被免疫系统清除,或保持在无症状或潜伏状态,但致癌(高危)HPV株(如最明显的HPV16和18型)会导致宫颈鳞状上皮内病变[低级别(LSIL…

MATLAB在逐渐被Python淘汰吗?

Python和MATLAB都是常用的科学计算工具,但是它们有很多不同之处。 Python是一种通用编程语言,而MATLAB主要是用来做数值计算的。Python的基本数据类型和一般的编程语言一样普遍,但是离开了Numpy这个包,就不再有数组或者矩阵的数据…

网络安全为什么缺人? 缺什么样的人

1.网络安全为什么缺人? 缺人的原因是有了新的需求。 以前的时候,所有企业是以产品为核心的,管你有啥漏洞,管你用户信息泄露不泄露,我只要做出来的产品火爆就行。 这一切随着《网络安全法》、《数据安全法》、《网络安全审查办法…

Blender插件Lazy Viewport

目录 1.Lazy Viewport插件1.1 解压Lazy Viewport插件1.2 blender偏好设置1.3 打开插件1.4 安装插件1.5 勾选插件Lazy Viewport1.6 安装插件前1.7 安装插件后 1.Lazy Viewport插件 Blender 的一个简单插件,用于将标准 G、R、S 热键映射到视图工具,因此您…

哪款无线洗地机最好用?好用的无线洗地机分享

洗地机是近几年来比较火的家庭清洁工具,我从推出以来就一直在使用,这些年下来也使用过不少品牌的洗地机,其中有好用的,也有体验一般的。今天为大家分享几款个人使用下来感觉还不错的洗地机。希望对于同样在选购洗地机的你有所帮助…

线程七大状态

线程生命周期(七大状态) 新建状态(New):当Java线程被创建时,它处于新建状态。此时,线程对象已被创建,但尚未启动。在这个状态下,线程并没有开始执行任何代码,…

[Java]监听器(Listener)

过滤器(Filter)https://blog.csdn.net/m0_71229255/article/details/130246404?spm1001.2014.3001.5501 一 : Listener监听器简述 监听器就是监听某个对象的的状态变化的组件 监听器的相关概念: 事件源: 被监听的对象 ----- 三…

Jenkins安装maven integration plugin以及jenkins安装allure插件失败的解决方法

这里写目录标题 一、Jenkins安装maven integration plugin失败解决方法(1)修改系统时间(2)查看当前操作系统时间(3)防止出错先执行命令(4)修改系统时间(5)写入…

Cocos Creator 源码解读:引擎启动与主循环

前言 本文基于 Cocos Creator 2.4.3 撰写。 Ready? 不知道你有没有想过,假如把游戏世界比作一辆汽车,那么这辆“汽车”是如何启动,又是如何持续运转的呢? 如题,本文的内容主要为 Cocos Creator 引擎的启动流程和主…