第七章---Bot代码的执行

2023-12-24 13:36
文章标签 代码 执行 第七章 bot

本文主要是介绍第七章---Bot代码的执行,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

1.流程设计

在这里插入图片描述
接下来要实现的是,Bot代码执行的微服务部分。

在这里插入图片描述

2.初始化

相应的,首先要创建该服务的后端。

在这里插入图片描述
然后将matchingsystem模块的依赖直接复制过来

<dependencies><!--Spring Security--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-security</artifactId><version>2.7.1</version></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!--spring-cloud-dependencies--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-dependencies</artifactId><version>2021.0.3</version><type>pom</type><scope>import</scope></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency><!--Project Lombok--><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><version>1.18.24</version><scope>provided</scope></dependency></dependencies>

同时在BotRunningSystem项目中添加依赖joor-java-8(Maven仓库地址):用于动态的编译和执行代码

在这里插入图片描述
为了如果拓展为实现其他语言,可以在云端自动启动一个docker容器,来执行其他语言。

在这里插入图片描述
重命名:
在这里插入图片描述
在这里插入图片描述
同时添加resources/application.properties文件,写入端口号

server.port=3002

3.后端API

首先要实现一个后端API,接收Bot代码,并将其加入到Bot运行池

实现后端API需要加入对应的controllerserviceservice.impl,以及添加ResTemplateConfig,并且在SecurityConfig中配置网关。

在这里插入图片描述
下面暂时写一些测试性的内容。

BotRunningService.java

在这里插入图片描述
BotRunningServiceImpl.java

在这里插入图片描述
BotRunningController.java

在这里插入图片描述
RestTemplateConfig.java

在这里插入图片描述
SecurityConfig.java,用于配置网关

在这里插入图片描述

4.修改前端

前端需要做一些修改,可以选择人工对战还是Bot参与对战。

并且,在client向server发请求时,如果是Bot参与对战,还需要指名bot_id

需要在匹配页面加入一个复选框

在这里插入图片描述
在BootStrap中找到相应工具

在这里插入图片描述
添加如下:

在这里插入图片描述
效果:

在这里插入图片描述
然后还需要动态的获取Bot列表,

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
同样,需要将用户选择了哪个bot告诉前端,引出需要做一个双向数据绑定。

在这里插入图片描述
在这里插入图片描述
这样将用户的选择与前端的变量就双向绑定了起来。

在这里插入图片描述

5.参数传递

然后需要在通信的时候,将user_id作为参数返回,并且后端也要相应的接收参数。

在这里插入图片描述
BackEnd端接收

在这里插入图片描述
在这里插入图片描述
BackEnd端向MatchingSystem端发送

在这里插入图片描述
在这里插入图片描述
MatchingSystem端接收

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
同样MatchingSystem端再向Backend端返回结果的时候,也需要发送一个botId

在这里插入图片描述
在这里插入图片描述
Backend接收参数

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
这次,整个发送bot_id的流程才算完整。

在这里插入图片描述

6.取到Bot信息

WebSocketServer.java

1)首先将BotMapper注入

private static BotMapper botMapper;
@Autowired
public void setBotMapper(BotMapper botMapper){WebSocketServer.botMapper = botMapper;
}

2)借助BotMapper将两个用户选择的bot取出

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
此时将bot的信息传入了Game中

在这里插入图片描述

7.Bot or not判断

取到了bot信息,创建完地图之后,在执行nextstep之前,判断botid是否等于-1,如果是-1,就要处理的是用户手动键入的指令,那么就等待用户输入;如果不等于-1,说明参与游戏的是Bot代码,则需要向BotRunningSystem发送消息,使其自动计算,并返回结果。

因此,需要在nextStep()中实现上述的判断。
在这里插入图片描述
如果是人工输入,则无需操作;如果是Bot参与,需要将用户id,bot代码,以及当前的局面传到RotRunningSystem系统的BotRunningController

在这里插入图片描述
其中,getInput(Player player)表示获取当前游戏局面的信息

在这里插入图片描述
此外,为了防止人工输入和bot执行混淆,还需要在执行bot的时候,屏蔽掉用户的输入。只有判断用户亲自出马的时候,才接收人的输入。

在这里插入图片描述
测试如下:

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
可以看到,经过了漫长的传递过程,此时bot的信息,终于传到了BotRunningSystem

在这里插入图片描述

8.Bot微服务

接下来就是本节的重点,也就是实现Bot Running System微服务。

8.1生产者—消费者模式

这部分的工作在于,不断的接收用户的输入,将接收到的代码放在一个队列里面,也就是队列中存储当前所有的任务。每接收一个来自生产者的任务过来,就将其放在队列里。BotPool相当于消费者,每完成一个任务,检查一下队列是否为空,如果队列不空,就从队头取出代码执行。执行完之后继续检查。

MatchingPool中的循环,每循环一次,sleep一秒钟,但BotPool中的循环,为了保证用户体验,需要满足一旦有任务,立即执行。执行完之后,如果队列为空,就继续等待。因此两者循环的实现逻辑不一样,后者用到条件变量。

首先实现消费者线程及其流程。

8.2消费者线程

1)如果任务队列为空,就要将其阻塞,当有任务出现时,就要发生信号量,将其唤醒。因此需要用到条件变量。

使用condition.await()将当前线程阻塞
Causes the current thread to wait until it is signalled or interrupted.
(导致当前线程等待,直到发出信号或中断。)

2)此外还需要队列,来存储Bot,定义一个Bot类,

在这里插入图片描述
并定义一个存储Bot对象的队列Queue<Bot>

生产者和消费者都会对Queue<Bot>进行操作,因此处理的时候需要加锁。

3)在消费Bot对象之前,一点要先解锁,否则往队列添加Bot对象的时候就会被阻塞,但完全没有必要,因为没有读写冲突。

代码如下:

在这里插入图片描述
其中,如果队列为空,线程将会被阻塞。当addBot()被调用,队列中添加新的任务时,线程将会被唤醒

在这里插入图片描述
BotPool线程的存储,以及关于添加Bot的调用,均放在BotRunningServiceImpl

在这里插入图片描述
在这里插入图片描述
与匹配系统一样,也是在BootStrap服务启动的时候,启动BotPool线程。
在这里插入图片描述

8.3consum操作

这里只是简单的实现Java代码的编译和执行。后续如果需要添加安全验证或者支持其他语言,只需要修改consum函数即可。对于安全验证,也就是防止程序运行可能产生的危害,可以将其放在沙箱中运行。对于支持其他语言,可以将consum函数改为对docker的执行(Java中执行终端命令,将终端命令的执行放进docker即可)

这里使用Java中的一个工具Joor,可以动态编译和执行Java代码。

为了让整个执行过程时间可控,每执行一段代码,就需要将其放在一个线程中,线程可以支持如果超时就会断掉的操作。新建一个Consumer类用于表示这种线程。

在这里插入图片描述

然后在botpoolconsum函数中,创建一个Consumer对象,并调用对象的startTimeout方法。

在这里插入图片描述
再回到Consumer类的run()中,需要使用到joor.Reflect类来动态编译执行一段代码

在这里插入图片描述
在这里插入图片描述
不过这里有个问题,在动态编译过程中,如果是重名的类,只会编译一次。但是对于每一个任务代码,都应该重新编译一遍,因此,需要在类名之前,添加一个随机字符串,来保证类不一样。

下面这段代码,就可以实现从前端动态接收一段代码,并动态编译一遍。

在这里插入图片描述

8.4测试Bot代码

1)1号玩家的Bot,返回0,表示向上走

在这里插入图片描述
2)6号玩家,返回2,表示向下走

在这里插入图片描述
在这里插入图片描述
解决一个空指针异常

在这里插入图片描述
修改依赖

在这里插入图片描述
这样,在控制台中就能看到输出结果

在这里插入图片描述
表示1号玩家往上移动,6号玩家往下移动。

此时Bot信息就传递到了consumer(Joor)

在这里插入图片描述
接下来一步要考虑的,就是将Bot代码执行的结果,返回给3000断开的主后端服务器,最终传到nextstep中

在这里插入图片描述

9.Bot结果返回

9.1Backend API

为了接收consumer中计算的结果,我们要在主服务器中实现一个新的API。

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
取出bot所对应的玩家userId和操作direction,然后需要玩家的操作传递到setNextStep

参考WebSocketServer中的move(玩家操作传递到setNextStep)

在这里插入图片描述

9.2setNextStep

在这里插入图片描述
这样就能实现,用户Bot生成的操作,通过Server传递给Game

在这里插入图片描述
现在只需要实现consumer动态编译Bot代码的结果返回给主服务器StartGameController

9.3结果返回

RestTemplate注入通过@Component到当前的Consumer

在这里插入图片描述
通过RestTemplate将结果返回到主服务器(主服务器中的StartGameController接收)

在这里插入图片描述
此时,整个流程就已经打通,通信过程完成闭环。

在这里插入图片描述

9.4功能测试

在这里插入图片描述
此时测试,两个Bot均可以实现自动执行。注意,先点击匹配的用户在左下角,后点匹配的在右上角。

可以修改使得左边用户返回1,则会一直往右走。

在这里插入图片描述
当然,可以实现人机对战,即左边蛇一直往右走(Bot运行)右边的蛇用户控制。

在这里插入图片描述

10.Bot编写

10.1设计过程

Bot代码的编写可以直接在IDEA中实现,之后将其复制到浏览器上。

在这里插入图片描述

这里实现一个稍微正常一点的AI,也就是在执行的时候判断上下左右哪一步可以走。

对input进行解码

String[] str = input.split("#");
String map = str[0];// 取出地图
int aSx = Integer.parseInt(str[1]), aSy = Integer.parseInt(str[2]);//取出我方起点坐标
String aSteps = str[3];// 取出我方操作
int bSx = Integer.parseInt(str[4]), bSy = Integer.parseInt(str[5]);//取出对手起点坐标
String bSteps = str[6];// 取出对手操作

在这里插入图片描述
1)取出地图

// 取出地图
int[][] g = new int[13][14];
int k = 0;
for (int i = 0; i < 13; i++) {for (int j = 0; j < 14; j++) {if(str[0].charAt(k) == '1')g[i][j] = 1;k++;}
}

2)取出两条蛇的路径

直接用之前在Play.java中写过的代码即可

在这里插入图片描述

//检验当前回合 蛇的长度是否增加
private  boolean check_tail_increasing(int step){if(step <= 10) return true;else return step % 3 == 1;
}
//返回蛇的身体
public List<Cell> getCells(int sx, int sy, String steps){List<Cell> res = new ArrayList<>();//对于四种操作0(w), 1(d), 2(s), 3(a)// 在行和列方向上的计算偏移量int[] dx = {-1, 0, 1, 0};int[] dy = {0, 1, 0, -1};int x = sx;int y = sy;int step = 0;//回合数char[] snacksteps = steps.toCharArray();res.add(new Cell(x,y));//添加起点//不断根据steps计算出整个蛇身体for (Character d : snacksteps) {x += dx[d - '0'];y += dy[d - '0'];res.add(new Cell(x,y));if(!check_tail_increasing(++step)){//如果蛇尾不增加 就删掉蛇尾res.remove(0);//O(N)}}return res;
}//取出蛇的轨迹
List<Cell> aCells = getCells(aSx, aSy, aSteps);
List<Cell> bCells = getCells(bSx, bSy, bSteps);for(Cell c : aCells) g[c.x][c.y] = 1;
for (Cell c : bCells) g[c.x][c.y] = 1;

3)判断可行的移动方向

枚举一下上右下左四个方向,一旦发现可以走,就设定移动方向。

// 判断可行的移动方向
// 对于四种方向0(↑), 1(→), 2(↓), 3(←)
// 在行和列方向上的计算偏移量
int[] dx = {-1, 0, 1, 0};
int[] dy = {0, 1, 0, -1};for (int i = 0; i < 4; i++) {int x = aCells.get(aCells.size() - 1).x + dx[i];//下一处xint y = aCells.get(aCells.size() - 1).y + dy[i];//下一处yif(x >= 0 && x < 13 && y >= 0 && y < 14 && g[x][y] == 0)return i;
}
return 0;//如果没有可行的方向 向上走--灭亡
10.2代码实现
package com.kob.botrunningsystem.utils;import java.util.ArrayList;
import java.util.List;public class Bot implements com.kob.botrunningsystem.utils.BotInterface{public static class Cell{private final int x;private final int y;public Cell(int x, int y) {this.x = x;this.y = y;}}//检验当前回合 蛇的长度是否增加private  boolean check_tail_increasing(int step){if(step <= 10) return true;else return step % 3 == 1;}//返回蛇的身体public List<Cell> getCells(int sx, int sy, String steps){List<Cell> res = new ArrayList<>();//对于四种操作0(w), 1(d), 2(s), 3(a)// 在行和列方向上的计算偏移量int[] dx = {-1, 0, 1, 0};int[] dy = {0, 1, 0, -1};int x = sx;int y = sy;int step = 0;//回合数char[] snacksteps = steps.toCharArray();res.add(new Cell(x,y));//添加起点//不断根据steps计算出整个蛇身体for (Character d : snacksteps) {x += dx[d - '0'];y += dy[d - '0'];res.add(new Cell(x,y));if(!check_tail_increasing(++step)){//如果蛇尾不增加 就删掉蛇尾res.remove(0);//O(N)}}return res;}@Overridepublic Integer nextMove(String input) {// 对input解码String[] str = input.split("#");String map = str[0];// 取出地图int aSx = Integer.parseInt(str[1]), aSy = Integer.parseInt(str[2]);//取出我方起点坐标String aSteps = str[3];// 取出我方操作int bSx = Integer.parseInt(str[4]), bSy = Integer.parseInt(str[5]);//取出对手起点坐标String bSteps = str[6];// 取出对手操作// 取出地图int[][] g = new int[13][14];int k = 0;for (int i = 0; i < 13; i++) {for (int j = 0; j < 14; j++) {if(map.charAt(k) == '1')g[i][j] = 1;k++;}}//取出蛇的轨迹List<Cell> aCells = getCells(aSx, aSy, aSteps);List<Cell> bCells = getCells(bSx, bSy, bSteps);for(Cell c : aCells) g[c.x][c.y] = 1;for (Cell c : bCells) g[c.x][c.y] = 1;// 判断可行的移动方向// 对于四种方向0(↑), 1(→), 2(↓), 3(←)// 在行和列方向上的计算偏移量int[] dx = {-1, 0, 1, 0};int[] dy = {0, 1, 0, -1};for (int i = 0; i < 4; i++) {int x = aCells.get(aCells.size() - 1).x + dx[i];//下一处xint y = aCells.get(aCells.size() - 1).y + dy[i];//下一处yif(x >= 0 && x < 13 && y >= 0 && y < 14 && g[x][y] == 0)return i;}return 0;//如果没有可行的方向 向上走--灭亡}
}
10.3应用

将两个bot修改替换为上面的代码

在这里插入图片描述
如果需要对Bot代码需要调试,只能通过println的方式,添加到原来bot中。

在这里插入图片描述
对于操作而言,需要去掉两端的括号。

此时测试,成功!

在这里插入图片描述
也可以人机对战

在这里插入图片描述
至此,这部分的代码全部完成。

这篇关于第七章---Bot代码的执行的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/531944

相关文章

C++使用栈实现括号匹配的代码详解

《C++使用栈实现括号匹配的代码详解》在编程中,括号匹配是一个常见问题,尤其是在处理数学表达式、编译器解析等任务时,栈是一种非常适合处理此类问题的数据结构,能够精确地管理括号的匹配问题,本文将通过C+... 目录引言问题描述代码讲解代码解析栈的状态表示测试总结引言在编程中,括号匹配是一个常见问题,尤其是在

JavaScript中的reduce方法执行过程、使用场景及进阶用法

《JavaScript中的reduce方法执行过程、使用场景及进阶用法》:本文主要介绍JavaScript中的reduce方法执行过程、使用场景及进阶用法的相关资料,reduce是JavaScri... 目录1. 什么是reduce2. reduce语法2.1 语法2.2 参数说明3. reduce执行过程

Java调用DeepSeek API的最佳实践及详细代码示例

《Java调用DeepSeekAPI的最佳实践及详细代码示例》:本文主要介绍如何使用Java调用DeepSeekAPI,包括获取API密钥、添加HTTP客户端依赖、创建HTTP请求、处理响应、... 目录1. 获取API密钥2. 添加HTTP客户端依赖3. 创建HTTP请求4. 处理响应5. 错误处理6.

使用 sql-research-assistant进行 SQL 数据库研究的实战指南(代码实现演示)

《使用sql-research-assistant进行SQL数据库研究的实战指南(代码实现演示)》本文介绍了sql-research-assistant工具,该工具基于LangChain框架,集... 目录技术背景介绍核心原理解析代码实现演示安装和配置项目集成LangSmith 配置(可选)启动服务应用场景

在MySQL执行UPDATE语句时遇到的错误1175的解决方案

《在MySQL执行UPDATE语句时遇到的错误1175的解决方案》MySQL安全更新模式(SafeUpdateMode)限制了UPDATE和DELETE操作,要求使用WHERE子句时必须基于主键或索引... mysql 中遇到的 Error Code: 1175 是由于启用了 安全更新模式(Safe Upd

Python中顺序结构和循环结构示例代码

《Python中顺序结构和循环结构示例代码》:本文主要介绍Python中的条件语句和循环语句,条件语句用于根据条件执行不同的代码块,循环语句用于重复执行一段代码,文章还详细说明了range函数的使... 目录一、条件语句(1)条件语句的定义(2)条件语句的语法(a)单分支 if(b)双分支 if-else(

MySQL数据库函数之JSON_EXTRACT示例代码

《MySQL数据库函数之JSON_EXTRACT示例代码》:本文主要介绍MySQL数据库函数之JSON_EXTRACT的相关资料,JSON_EXTRACT()函数用于从JSON文档中提取值,支持对... 目录前言基本语法路径表达式示例示例 1: 提取简单值示例 2: 提取嵌套值示例 3: 提取数组中的值注意

CSS3中使用flex和grid实现等高元素布局的示例代码

《CSS3中使用flex和grid实现等高元素布局的示例代码》:本文主要介绍了使用CSS3中的Flexbox和Grid布局实现等高元素布局的方法,通过简单的两列实现、每行放置3列以及全部代码的展示,展示了这两种布局方式的实现细节和效果,详细内容请阅读本文,希望能对你有所帮助... 过往的实现方法是使用浮动加

JAVA调用Deepseek的api完成基本对话简单代码示例

《JAVA调用Deepseek的api完成基本对话简单代码示例》:本文主要介绍JAVA调用Deepseek的api完成基本对话的相关资料,文中详细讲解了如何获取DeepSeekAPI密钥、添加H... 获取API密钥首先,从DeepSeek平台获取API密钥,用于身份验证。添加HTTP客户端依赖使用Jav

Java实现状态模式的示例代码

《Java实现状态模式的示例代码》状态模式是一种行为型设计模式,允许对象根据其内部状态改变行为,本文主要介绍了Java实现状态模式的示例代码,文中通过示例代码介绍的非常详细,需要的朋友们下面随着小编来... 目录一、简介1、定义2、状态模式的结构二、Java实现案例1、电灯开关状态案例2、番茄工作法状态案例