emlog怎么做视频网站,北京建设官方网站,营销型网站开发公司,湘潭响应式网站建设 磐石网络引言 有图有真相#xff0c;那短视频就更是真相了。下面是三大语言的短视频。
Java源码版云控示例#xff1a;
Java源码版云控示例在线视频
Net源码版云控示例#xff1a;
Net源码版云控示例在线视频亚丁号-知识付费平台 支付后可见 扫码付费可见
Python源码版云控示例…引言 有图有真相那短视频就更是真相了。下面是三大语言的短视频。
Java源码版云控示例
Java源码版云控示例在线视频
Net源码版云控示例
Net源码版云控示例在线视频亚丁号-知识付费平台 支付后可见 扫码付费可见
Python源码版云控示例
Pythont源码版云控示例在线视频亚丁号-知识付费平台 支付后可见 扫码付费可见
核心技术各个编程语言的WebSocket技术。
JavaNettey、NetFleck、PythonTornado、Autojs自带的WS.都 写了很多代码感觉还是Java 的Nettey强大用到的技术做个罗列。
Java
1.java版本 JDK864bit 2.开发IDE IntelliJ IDEA 2020.1.1 3.Web框架 SpringB oot2.6.4 4.模板框架 Thymeleaf 2.2.2 (Spring推荐款个人感觉不好用) 5.UI框架BootStrap3 6.数据库框架Hibernate5.3.1 7.WebSocket 框架 Nettey 4.1.65 8.Json框架 Gson2.8.8 9.Zip压缩框架 zip4j2.9.1 10.数据库Mysql56 11.错误日志 spring自带的 12.其他 java的反射记录日志、 spring 的拦截器判断session、简化实体类插件lombok
Python
1.Python版本 python3.764bit 2.开发IDE Pycharm 3.Web框架 Flask 2.2.5 4.模板框架Flask自带的Jinja2 3.1.2 5.UI框架BootStrap3 6.数据库框架SQLAlchemy 2.0.16 7.WebSocket 框架 Tornado 6.2 8.Json框架 ujson5.7.0 9.Zip压缩框架ZIPP 3.15.0 10.数据库Mysql56
NET(C#)
1.Net版本 Net Core3.1 后继会升级至NET7 2.IDE visual studio 2022 3.Web框架 Net Core3.1 MVC 4.UI框架BootStrap3 5.数据库框架Dapper 2.0.78 6.WebSocket 框架 Fleck 1.1 7.Json框架 8.Zip压缩框架 dotnetzip 1.16.0 9.数据库Mysql56
技术篇 这里以Python为例子进行讲解。
核心技术通信技术 核心技术就是WebSocket。2011年WebSocket API被W3C定为标准。WebSocket使得客户端和服务器之间的数据交换变得更加简单允许服务端主动向客户端推送数据。在WebSocket API中浏览器和服务器只需要完成一次握手两者之间就直接可以创建持久性的连接并进行双向数据传输。
最主要还解决Ajax轮询带来的延迟和服务器性能损耗。
本软件服务端建立WS服务器客户端进行连接连接成功后进行双工通信服务端发送任务客户端发送【ping】。客户端是Autojs7.服务端采用了Java、net和Python多种语言的支持。网页JS连接服务端网上一大堆故此很容易然autojs的对面的技术控看过来。这里的技术很精彩。
本软件重点解决2大问题
一、热更
单JS脚本不可能解决所以问题找图工作就不行因此客户端执行project势在必行然项目的更新必然是个大问题。本项目完美解决服务端发送项目的事宜无论是自动阅读的js还是自动阅读的project都进行完美热更。
二、断线重连
服务器宕机、WS服务重启或客户端重启都需要再次链接WS服务然再次链接的WebSocket对象与之前的对象不一致导致客户端无法发送任务和命令。
此项目已经解决再次链接的问题且WS为同一个对象
服务端(Python) 项目结构 严格按照Python项目的命名规则进行包的命名其中的一些方法为了迎合Net的写法故此首字母大写了。 从上到下依次介绍
1.controller文件夹是控制器见名知意 2.dao是数据访问层 3.demo是一些示例的demo发布的时候可以删除 4.entity是实体类这个仿照Net的叫法里面有po和vo文件夹. 5.framework这个是核心框架,在框架章节会详细介绍。 6.service项目的dao与controller交互的层理论上controller层是不准写业务代码和sql语句的 7.static 存放的是js脚本和css类和图片等信息 8.templates存放的是html页面上面的图我使用的是【project】模式static和templates必须这么起名Python Flask就这么查询和要求的。
requirements.txt文件 在Pycharm的终端执行pip freeze requirements.txt命令生成。requirements.txt文件。 后端Python框架 整个项目的核心项目的基础文件基础框架功能不是很多大家多多海涵 功能如下
1.数据加密目前采用的是Base64.UI端使用统一的Ajax方法Post数据Java端使用统一的方法接收参数(会解密参数)。示例 2.自动构建实体类 3.自动写操作日志 通过反射方法进行日志的记录。
Logger(description 访问用户管理页面)
1.BaseController提供各种写Json的方法同时也提供是否加密的算法 2.BaseDataAccess提供HIB5的数据库访问session 3.提供数据库返回多参数方法统一对象ResultEntity 4.提供各种操作的工具类 前端UI框架 前端技术主要是BootStrap3和Jquery2其中BS3封装的HPlugins框架公司不知道在哪里搞到的JQ2 我自己封装了一下形成yadinghao.js文件配合BS3的H使用。
UI H4.9 下载地址
百度网盘 请输入提取码 提取码6666 JS 自定义的JS框架yadinghao.js使用JQ进行了2次封装。主要是针对Ajax的get和post进行了封装。 1、主要使用AjaxPost方法请求地址、请求参数、回调函数、是否同步和是否加密。调用示例 2、另一个主要封装插件 这个插件基本每个页面都使用 。默认是加密的没有做出参数。
3、另外封装的就是toast 这个最常用 4、还有一些其他小方法大家自行观看 吧。 数据库Hib 数据使用的是Mysql,版本是5.6.DBMS使用的是Navicat15.数据库设计工具是powerdegisn15.
数据访问使用的是Hibernate5数据量不是很大且开发效率高于MyBatis.配置文件需要在resources 下Spring就自动寻了。 WebSocket 代码位置 ws是本软件的核心故此将其代码单独存放路径是com.yadinghao.service.websocket包下面的都是和ws相关的代码。真像如下 核心思想 1.构建在线列表存放服务端页面和客户端手机 2.认证通过的设备才可以加入到在线列表需要客户端提起注册 3.认证通过的设备会通知到服务端注册认证页面。页面可以进行发布命令和任务操作。 4.客户端接收任务或命令进行执行操作 5.客户端掉线后服务端会依据IP和端口号对设备进离线操作 6.客户端掉线后未触发服务端离线操作会丢失ping服务器的数据服务端会依据ping的时间对客户端进行离线操作 7.重点服务端可自定义上传脚本和AJ7的项目AJ7的格式是zip的autojs只能解压zip。上传的8.js和project版本高于客户端的版本则直接更新 核心页面 1.WS开启页面 2.云控设备页面 3.云控任务页面 核心代码 服务端启动WS代码 启动代码
package com.yadinghao.service.websocket;import com.yadinghao.framework.entity.ResultEntity;
import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.*;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import io.netty.handler.codec.http.HttpObjectAggregator;
import io.netty.handler.codec.http.HttpServerCodec;
import io.netty.handler.codec.http.websocketx.WebSocketServerProtocolHandler;
import io.netty.handler.codec.http.websocketx.extensions.compression.WebSocketServerCompressionHandler;import java.net.InetSocketAddress;public class WebSocketBusiness {EventLoopGroup bossGroup null;EventLoopGroup workerGroup null;Channel channel null;public ResultEntity startWebSocket(String wsAddress, String userId) throws InterruptedException {ResultEntity resultEntitynew ResultEntity();String[] split wsAddress.replace(ws:\\, ).replace(\\, ).replace(ws://, ).split(:);String ipAddress split[0];String strPort split[1].trim();int portInteger.parseInt(strPort);bossGroup new NioEventLoopGroup();workerGroup new NioEventLoopGroup();ServerBootstrap b new ServerBootstrap();b.group(bossGroup, workerGroup).channel(NioServerSocketChannel.class).localAddress(new InetSocketAddress(ipAddress, port)).childHandler(new ChannelInitializerSocketChannel() {Overridepublic void initChannel(SocketChannel ch) throws Exception {ChannelPipeline pipeline ch.pipeline();pipeline.addLast(new HttpServerCodec()); // HTTP 协议解析用于握手阶段pipeline.addLast(new HttpObjectAggregator(65536)); // HTTP 协议解析用于握手阶段pipeline.addLast(new WebSocketServerCompressionHandler()); // WebSocket 数据压缩扩展pipeline.addLast(new WebSocketServerProtocolHandler(/, null, true)); // WebSocket 握手、控制帧处理pipeline.addLast(new WebSocketHandler(wsAddress,userId));}});ChannelFuture f b.bind().sync();channel f.channel();resultEntity.setReturnValue(true);return resultEntity;}/*** 关闭NettyWebSocket* param primary_key* param userId* return*/public ResultEntity closeWebSocket(String primary_key, String userId){ResultEntity resultEntitynew ResultEntity();try {if (channel ! null) {channel.close();workerGroup.shutdownGracefully();bossGroup.shutdownGracefully();}resultEntity.setReturnValue(true);return resultEntity;} catch (Exception e) {resultEntity.setReturnValue(false);resultEntity.setMessage(e.getMessage());return resultEntity;}}
} Handler代码就是监听 Overrideprotected void channelRead0(ChannelHandlerContext ctx, WebSocketFrame frame) throws Exception {try {if (frame instanceof TextWebSocketFrame) { // 此处仅处理 Text FrameChannel channel ctx.channel();String request ((TextWebSocketFrame) frame).text();System.out.println(request);JsonObject jsonObject new Gson().fromJson(request, JsonObject.class);String category jsonObject.get(category).getAsString();if (android.equals(category)) {JsonObject jsonData jsonObject.getAsJsonObject(data);String action jsonData.get(action).getAsString();String deviceToken jsonData.get(device_token).getAsString();if (connect.equals(action)) {//System.out.println(deviceToken);OnlineDeviceEntity onlineDeviceEntity WebSocketService.builderDevice(deviceToken, channel, category, this.wsAddress, this.userId);WebSocketService.onlineDevices.add(onlineDeviceEntity);//通知UI所有设备连接WebSocketService.notifyServerPage(this.serverPageToken, deviceToken, WebSocketUtils.getIpAddress(channel));//通知客户端已经链接WebSocketService.notifyClient(channel); //2023-05-14 by zhangyu DL} else if (log.equals(action)) {//System.out.println(deviceToken);
// OnlineDeviceEntity onlineDeviceEntity WebSocketService.getOnlineDeviceEntity(deviceToken);
// if(onlineDeviceEntitynull){
// //非法客户端 T下线
// ctx.channel().close();
// }else {
//
// }String level jsonData.get(level).getAsString();String message jsonData.get(message).getAsString();//通知UI所有设备连接WebSocketService.notifyLogMessage(this.serverPageToken, deviceToken, message,level);} else if (close.equals(action)) {//通知UI所有设备连接WebSocketService.notifyServerPageDeviceOffline(this.serverPageToken, deviceToken); //S}else if (ping.equals(action)) {OnlineDeviceEntity onlineDeviceEntity WebSocketService.getOnlineDeviceEntity(deviceToken);if(onlineDeviceEntitynull){ctx.channel().close();}else {onlineDeviceEntity.setLAST_PING_DATE(Tools.getNowDateTime());//ctx.channel().writeAndFlush(new TextWebSocketFrame(WebSocketJson.jsonPingMessage()));}}else {//请求非法终端连接ctx.channel().close();}} else if (web.equals(category)) {String stringData jsonObject.get(data).getAsString();//二级数据JsonObject jsonData new Gson().fromJson(stringData, JsonObject.class);String action jsonData.get(action).getAsString();String deviceToken jsonData.get(device_token).getAsString();if (authed.equals(action)) {OnlineDeviceEntity onlineDeviceEntity WebSocketService.builderDevice(deviceToken, channel, category, this.wsAddress, this.userId);WebSocketService.onlineDevices.add(onlineDeviceEntity);channel.writeAndFlush(new TextWebSocketFrame(WebSocketJson.jsonAuthedMessage()));}}else if (gui.equals(category)){System.out.println(category);}}} catch (Exception ex) {System.out.println(channelRead0ex.getMessage());}}
客户端连接服务器并进行认证
if (connect.equals(action)) {//System.out.println(deviceToken);OnlineDeviceEntity onlineDeviceEntity WebSocketService.builderDevice(deviceToken, channel, category, this.wsAddress, this.userId);WebSocketService.onlineDevices.add(onlineDeviceEntity);//通知UI所有设备连接WebSocketService.notifyServerPage(this.serverPageToken, deviceToken, WebSocketUtils.getIpAddress(channel));//通知客户端已经链接WebSocketService.notifyClient(channel); //2023-05-14 by zhangyu DL}
客户端连接服务器日志代else if (log.equals(action)) {System.out.println(deviceToken);OnlineDeviceEntity onlineDeviceEntity WebSocketService.getOnlineDeviceEntity(deviceToken);if(onlineDeviceEntitynull){//非法客户端 T下线ctx.channel().close();}else {}String level jsonData.get(level).getAsString();String message jsonData.get(message).getAsString();//通知UI所有设备连接WebSocketService.notifyLogMessage(this.serverPageToken, deviceToken, message,level);} 服务端页面代码
UI代码 input typehidden idPAGE_TOKEN namePAGE_TOKEN th:value${PAGE_TOKEN} /input typehidden idWS_ADDRESS nameWS_ADDRESS th:value${WS_ADDRESS} /div idtoolbarbutton classbtn idRegisterDevice_table_taskspan classglyphicon glyphicon-comment/span 发布任务/buttonbutton classbtn idRegisterDevice_table_commandspan classglyphicon glyphicon-comment/span 发布命令/buttonbutton classbtn idRegisterDevice_table_checkspan classglyphicon glyphicon-check/span 审核通过/buttonbutton classbtn idRegisterDevice_table_updatespan classglyphicon glyphicon-pencil/span 改别名/buttonbutton classbtn idRegisterDevice_table_deletespan classglyphicon glyphicon-remove/span 删除/buttonbutton classbtn idRegisterDevice_table_logspan classglyphicon glyphicon-envelope/span 日志/buttonbutton classbtn idRegisterDevice_table_address监听地址ws://192.168.101.2:9103/buttonbutton classbtn是否连接WS地址span stylecolor:red idConnection_Status否/span/button/divtable idRegisterDevice_table data-mobile-responsivetrue data-show-columnstrue/table
JS代码let device_log [] //设备日志
let page_token CloudControlDevicePage;
let is_open_modalfalse
let page_device_token //区别传输过来的CreateWebSocket()
//创建websockt
function CreateWebSocket() {let ws_address $(#WS_ADDRESS).val();if (ws_address || ws_address undefined || ws_address undefined) {alert(开启监听ws地址失败因为ws地址为空...)} else {$(#RegisterDevice_table_address).text(当前监听地址 ws_address);webSocket new WebSocket(ws_address);webSocket.onopen WebSokectOnOpen;webSocket.onmessage WebSocketOnMessage;webSocket.onclose WebSocketOnClose;}
}
//建立连接事件
function WebSokectOnOpen() {page_token $(#PAGE_TOKEN).val();let authentication_message {\action\: \authed\, \device_token\: \ page_token \}let scriptJson { category: web, data: authentication_message }webSocket.send(JSON.stringify(scriptJson));
}
//监听事件
function WebSocketOnMessage(event) {//监听来自客户端的数据 let deviceJson JSON.parse(event.data)let device_token deviceJson.deviceTokenlet ws_categorydeviceJson.category.toString()let rows;if (ws_category device) {let device_token deviceJson.deviceTokenif (device_token undefined || device_token undefined) {return;}let ip_address String(deviceJson.ipAddress)let is_online String(deviceJson.isOnline)let allTableData $(#RegisterDevice_table).bootstrapTable(getData);//获取表格的所有内容行for (let i 0; i allTableData.length; i) {let ui_device_token allTableData[i][DEVICE_TOKEN]if (device_token ui_device_token) {rows {index: i, //更新列所在行的索引field: DEVICE_IS_ONLINE, //要更新列的fieldvalue: is_online //要更新列的数据 span stylecolor:green;font-size:18px;在线/span}//更新表格数据$(#RegisterDevice_table).bootstrapTable(updateCell, rows);rows {index: i, //更新列所在行的索引field: DEVICE_CLIENT_IP, //要更新列的fieldvalue: ip_address //要更新列的数据 span stylecolor:green;font-size:18px;在线/span}//更新表格数据$(#RegisterDevice_table).bootstrapTable(updateCell, rows);}}} else if (ws_category log) {if (device_token undefined || device_token undefined) {return;}let logMessage String(deviceJson.message)let logLevel String(deviceJson.level)let log_array device_token logMessage logLeveldevice_log.push(log_array)if (is_open_modal) {//yw9zcfbdulqwme9que9imdu2zjm1otq1zwvjnzk2ntqwotyw//alert(page_device_token)if (device_token.toLowerCase() page_device_token.toLowerCase()) {if (logLevel log) {$(#logView).append(span class\f18 blue\ logMessage br//span)} else if (logLevel warn) {$(#logView).append(span class\f18 yellow\ logMessage br//span)} else if (logLevel info) {$(#logView).append(span class\f18 green\ logMessage br//span)} else if (logLevel error) {$(#logView).append(span class\f18 red\ logMessage br//span)} else {$(#logView).append(span class\f18\ logMessage br//span)}}}} else if (ws_category authed) {let authedMessage deviceJson.message;$.showSuccessToast(authedMessage);$(#Connection_Status).text(是)}}function WebSocketOnClose() {//监听来自客户端的数据let ws_address $(#WS_ADDRESS).val();$.showWaringToast(请到【云控服务管理】页面开启 ws_address服务);
}
java代码 controller
显示UI代码 RequestMapping(value ManageRegisterDevice)public String ManageRegisterDevice(HttpServletRequest request,Model model) {String userIdgetUserId(request);WsAddressEntity wsAddressEntitynew WsAddressDataAccess().findWsAddressEntity(userId);if(wsAddressEntity.LISTEN_ADDRESS!null){String PAGE_TOKEN CloudControlDevicePage userId;model.addAttribute(PAGE_TOKEN, PAGE_TOKEN);model.addAttribute(WS_ADDRESS, wsAddressEntity.WEB_SOCKET_ADDRESS);}model.addAttribute(SOFT_NAME, ConfigService.getPlatformConfig().SOFT_NAME);model.addAttribute(SITE_TITLE, ConfigService.getPlatformConfig().SITE_TITLE);model.addAttribute(KEY_WORD, ConfigService.getPlatformConfig().KEY_WORD);model.addAttribute(DESCRIPTON, ConfigService.getPlatformConfig().DESCRIPTON);return back/cloud/ManageRegisterDevice;}
Handler离线代码 Overridepublic void channelInactive(ChannelHandlerContext ctx) throws Exception {Channel channel ctx.channel();String ipAddressWebSocketUtils.getIpAddress(channel);OnlineDeviceEntity entity WebSocketService.getOnlineDeviceEntityByIP(ipAddress);if(entity null){System.out.println(不在在线设备中);}else{String userId entity.USER_ID;String serverToken WebSocketUtils.DEVICE_PAGE_TOKEN userId;String deviceToken entity.DEVICE_TOKEN;WebSocketService.removeOnlineDeviceEntity(entity);WebSocketService.notifyServerPageDeviceOffline(serverToken, deviceToken);}}
WebAPI 对外提供给移动端的方法。方法返回的都是统一的数据格式json字符串。Json格式依据不同的业务而不同。对外AIP都在Controller下 移动端的就存放在mobile文件夹下。 对外方法函数签名如下
1.String AppFindRecommendSoft() 查询系统推荐的软件
1.String AppFindRandomAd(HttpServletRequest request) 查询系统随机发放的广告目前仅仅读取管理员发布的。
1.String AppFindCloudList(HttpServletRequest request) 查询云控自动阅读app集合
1.String AppRegisterDevice(HttpServletRequest request) 2.String AppRegisterIsCheckIn(HttpServletRequest request)
客户端Autojs7 客户端是Aj7的项目
核心架构 通信技术 1、核心通信技术就是wsautojs7以上才支持ws。Ws客户端连接服务端一点也不难代码如下 function testWSAddress(ws_address){let ws web.newWebSocket(ws_address);let result_wsws.on(open, (res, ws) {log(WebSocket已连接);result_ws true;}).on(failure, (err, res, ws) {log(WebSocket连接失败);console.error(err);result_ws false;})sleep(3000)return result_ws
}
console.show()
toastLog(testWSAddress(ws_addressws://192.168.3.170:8686))
上述代码主要是判断客户端是否连接到服务器。这个是很有必要的Python语言的Flask创建的服务器就是无法连接。
测试网站WebSocket在线测试工具
2、登录、UI显示和下载等网络技术使用的是http的get和post。安卓要求网络访问是线程模型。HTTP请求代码示例 function initializeRegisterStatus(){var result_threads threads.disposable();threads.start(function () {try {//let rootUrl adenStorage.get(rootUrl);//顶级域名let device_token adenTools.getDeviceToken()let url_address rootUrl /cloud/AppRegisterIsCheckInvar response http.post(url_address, {device_token: device_token});var json response.body.json();if (response.statusCode 200) {if (json.success || json.success true) {adenStorage.put(AppRegisterIsCheckIn, true);dict_result [true, json.message]} else {console.log(json.message)dict_result [false, json.message]}} else if (response.statusCode 404) {console.log(注册服务访问服务器出现404错误)dict_result [false, 注册服务访问服务器出现404错误]}else {console.log(发生未知错误请联系开发人员或者稍候再试...)dict_result [false, 发生未知错误请联系开发人员或者稍候再试...]}} catch (error) {console.log(检测注册服务出现错误可能是服务器地址不正确参考错误 error);dict_result [false, 检测注册服务出现错误可能是服务器地址不正确参考错误]adenBase.adenStorage().put(AppRegisterIsCheckIn, false); }result_threads.setAndNotify(dict_result);});result_threads result_threads.blockedGet()if (result_threads[0] false) {adenBase.adenStorage().put(AppRegisterIsCheckIn, false); }else{adenBase.adenStorage().put(AppRegisterIsCheckIn, true); }
}
框架技术 就是Autojs的UI技术在配合一些脚本通信、脚本引擎和多线程等技术。
项目结构 项目采用autojsPro7版本创建的项目名称叫YadinghaoHunter项目启动js是HunterFrame.js项目名称和启动js均可以修改。不想服务器生邀请码就修改主类的登录信息打包已经设置好了放到手机端的autojs App下即可。具体项目结果如下图 从上到下依次介绍
1.build 打包(生成APK)时候自动生成的. 2.config是核心配置主要是软件版本和根地址 3.image是项目所用到的图片包含找图使用的 4.log是项目记录日志的插件 5.page是项目所有单读页面的文件夹 1.plugin是项目工具文件夹 1.repository 是项自动阅读App的插件仓储 2.res打包(生成APK)时候自动生成的. 3.Test作者测试文件夹可以删除 4.打包.docx 在AutojsPro7下如何打包 5.免登修改.docx 源码模式下无限制安装打包成已经登录模式。 6.HunerFrame.js APP的主类也是启动类负责调用各个page和plugins。使用require调用插件类如下图 1.project.json autojsPro7创建项目自动生成的配置文件 2.YadinghaoHunter.code-workspace VSCode的工程文件
网络访问 重点中的重点安卓要求网络访问必须是子线程多线程不能影响主线程及阻塞主线程所以这里就涉及一个回调的问题。AutojsPro回掉采用var result_threads threads.disposable();定义后result_threads就可在线程内调用 result_threads可以接收线程返回的对象我的这个示例是字典类型 dict_result [true, json.message]
dict_result [false, 注册服务访问服务器出现404错误]
将线程内的字典对象给result_threads
result_threads.setAndNotify(dict_result);
在线程外部将变转换下
result_threads result_threads.blockedGet()
这样在线程外部就可以调用result_threads回调结果了
if (result_threads[0] false) 这样就可判断字典的返回值了。具体代码如下示例是读取云控服务器是否对设备审核通过
脚本通信 由于是项目所以存在很多单独的文件文件之间进行通信就显得非常必要。
1.变量通信 将要显示或判断的值记录到手机的storages - 本地存储中这样就可以在其他地方进行调用。本地XML、Json和SQLite3原理是一样的只是api写法不一样。
1.脚本通知 这个功能还是比较好用的示例代码子界面广播事件
events.broadcast.emit(ui_refresh, UI刷新);
主界面函数
/** * UI刷新事件 */ events.broadcast.on(ui_refresh, function (message) { initializeUIRight() });
脚本引擎 官方API肯定比我说的好这里主要是讲解下应用场景。
一、主框架Frame启动子页面这类的启动和require不一样引用的类还得引用。
engines.execScriptFile(./Page/Login.js); 下图是Login.js页面 二、在云控启动js和project中应用尤其是启动project。必须指定资源路径否则找图将失败。 adenTools.engineProjectFilefunction(projectId,appName,dataFileFullName,projectExecPath) {let zipFileName appNameprojectId .ziplet zipFileFullName projectExecPath zipFileName// 压缩文件路径files.copy(dataFileFullName, zipFileFullName)let outputDir projectExecPath/appNameprojectId; // 解压路径 执行路径加项目名称和ID$zip.unzip(zipFileFullName, outputDir);let projectJsonFileoutputDir/project.jsonlet adenProjectJsonJSON.parse(files.read(projectJsonFile))let mainJsNameadenProjectJson.mainlet mainjSFileoutputDir/mainJsNamescriptEngine engines.execScriptFile(mainjSFile, {path : outputDir});return scriptEngine
} WebSocket 核心思想 根据配置的WS地址自动连接WS服务器若连接不上则尝试连接。当连接上时候。客户端发送连接信息若连接成则反馈已经连接的信息。客户端依据连接信息等待服务端发送的指令。
测试连接 根据配置的WS地址软件 提供测试WS地址的功能同时此功能也是断线重连的基础功能此功能需要注意的地方是保证测试或断线重连的WS地址是一个内存对象是一个具体代码如下
/*** 测试地址* param {URL websocket地址} ws_address * returns */
CloudControl.testWSAddress function (ws_address) {try {var result_threads threads.disposable();threads.start(function () {let dict_result []try {let ws web.newWebSocket(ws_address);let result_ws falselet message ws.on(open, (res, ws) {result_ws true;}).on(failure, (err, res, ws) {result_ws false;message err;})sleep(1000)if (result_ws false || result_ws false) {dict_result [false, message]} else {dict_result [true, ws]}result_threads.setAndNotify(dict_result);}catch (error) {dict_result [false, error]result_threads.setAndNotify(dict_result);}});result_threads result_threads.blockedGet()return result_threads} catch (e) {toastLog(testWSAddress方法发生异常 e)return [false, testWSAddress方法发生异常 e]}
}
连接认证认证信息 根据配置的WS地址软件会连接服务器连接服务器后会发送认证信息服务器接收认证后反馈信息。具体代码如下 let authentication_message { action: connect, device_token: adenTools.getDeviceToken() }let scriptJson { category: android, data: authentication_message } //入服务器认证ws.send(JSON.stringify(scriptJson)); 客户端向服务器发送一段JSON认证信息认证信息需要包含设备的Token信息Token信息是在服务器有记录的必须携带防止乱发乱认证。 接收命令预定义 命令目前是预定义三个息屏、打开微信和显示桌面。获取源码自定义追加即可。
服务器发送命令的方式和发送任务的方式是一致的 。 接收任务自动阅读App的Js或Project 此功能是此软件的核心功能。服务端发送任务客户端执行服务端发送的任务是js或者是project找图。
Js任务接收到服务端发送的Json数据进行类别判断后对Js文件进行判断判断本地是否存在判断版本之后进行下载。
adenTools.downLoadScript(downUrl, tempFolder, fileName)下载文件注意downUrl 要严格遵守MVC资源请求的命名大小写和反斜杠都要注意
Zip任务zip文件有如下的要求
文件名必须是汉语拼音或者是英文的不能是中文的因为AutoJs解压缩不支持汉语。 Zip文件必须是AutojsPro创建的项目且压缩zip时候Project.json文件必须在压缩包的第一层 Zip文件必须是正版文件不能是修改扩展名的文件 客户端接收到zip文件后进行解压判断判断文件是不是AutoJsPro创建的Project。 处理完毕zip文件后就是执行Project使用engines执行。需要注意的是engines执行的文件和主文件是相互不影响的也就是说执行的Js或者Project里面的信息外面无法直接获取外部的ws等信息执行的脚本也获取不到。脚本运行时间可以用脚本通信技术解决。
断线重连 服务端重启、客户端掉线或客户端进程被Kill等操作。客户端会重新连接服务端若服务器性能不高且不希望手机耗电多则可以设置尝试次数。
Ping消息 当客户端与服务端连接后确保双方都在线则需要客户端与服务端互ping一般的WS框架都提供此功能。我们这里是自己实现的因为有其他操作故此自我实现ping的消息
let message { action: ping, device_token: device_token }
let scriptJson { category: android, data: message }
相对严谨ping也带上token下图是云控调用ping功能。 客户端定期ping服务器服务器根据ping保证客户端在线如超过设定未ping服务器则认为掉线。 定时更新服务端LAST_PING_DATE属性保证设备在线。
发送日志 服务端显示日志是必要的可以查看设备的运行状态设备发送日志是根据ws地址空将日志发送至服务器需要对日志类进行封装。 if (isSendLog || isSendLogtrue){threads.start(function () {let authentication_message { action: log, level: level, message: loginfo, device_token: getDeviceToken() }let scriptJson { category: android, data: authentication_message }let ws web.newWebSocket(ws_address);ws.send(JSON.stringify(scriptJson));ws.close(1000, log);});} 业务篇 这里是云控版介绍故此不赘述非云控的其他功能。
客户端 运行模式 客户端App提供三种运行模式兼容模式、找图模式和云控模式。云控配置只能在云控模式打开。即云控模式接收的是云端下发的脚本。
兼容模式即传统的找元素模型兼容各个设备是原始的薅羊毛专业版。
找图模式除了使用元素定位还使用坐标定位和找图功能这2个技术都是依赖手机分辨率的。所以此模式只兼容特定机型OPPR9sk该款手机是开发者使用机型
云控模式:服务端推送脚本完全自定义脚本。脚本具有何种功能手机就执行何种功能 云控配置注册服务 只有在云控模式下才可以使用的页面。配置页面如下图所示 是否开启云控一般都要开启开启后将自动连接云控服务器
是否发送日志如使用熟练服务器是免费版的化则不开启因为会影响服务器性能
是否无线尝试连接断线宕机都会自动连接如果是无限次数会耗费一些电量
尝试次数:不开启无限尝试连接才起到作用
尝试时间间隔(单位秒)无论何种模式都需要配置
设备注册地址服务端生成的http地址。
云控服务器WS地址服务端生成的WS地址
注册是否通过检查注册状态
测试连接WS服务按钮测试WS地址是否正确
注册设备按钮将设备信息发送至服务端等待服务端审核服务端审核通过才可以WS连接
保存配置按钮先保存后测试和注册
下载脚本 客户端App会手动下载云端脚本下载过的脚本被执行云控任务的时候就不需要再次下载提升执行效率。
自动连接 【云控配置】页面是否开启云控选项开启的时候客户端App将会自动连接【云控配置】云控服务器WS地址中的WS地址连接原则也是依据配置。 断线重连 当服务器WS断线、宕机或客户端重启等操作客户端会依据【云控配置】进行重连服务器下图是服务端未开启的示例 下图是断线重连的日志过程示意图 执行任务 最核心的也是最关键的客户端执行服务端自定义的任务,执行单JS文件或者ZIP的解压后项目文件。 客户端接收任务-客户端解析任务-下载脚本-执行脚本-监听脚本。
服务端 生成注册地址 设备必须注册为合法设备才能够发送任务、发送命令、客户端发ping和客户端日志。设备注册地址是由【设备注册地址】页面生成生成后将地址复制粘贴至客户端的云控配置页面进行注册。
生成页面点击生成再点击提交即可。 生成WS地址 重点中的重点每个用户只能创建一个WS地址。此WS地址是所以客户端连接的地址创建规则就是以ws开始((OO))ブ本机IP和端口号为中间体和http地址类似。创建完成后可以使用互联网的ws测试地址测试一下是否开通。 重点是地址名称无所谓。新增后WS地址直接开启。 可以根据需求就行实际操作。
任务管理 新增任务稍微复杂一些。任务区分单JS和AutoJsPro创建的项目。AutoJsPro创建项目Project使用ZIP格式进行压缩压缩成ZIP有如下要求
文件名必须是汉语拼音或者是英文的不能是中文的因为AutoJs解压缩不支持汉语。 Zip文件必须是AutojsPro创建的项目且压缩zip时候Project.json文件必须在压缩包的第一层下图是示例
Zip文件必须是正版文件不能是修改扩展名的文件 脚本名称重名无所谓但是必须与被阅读的App名称一致
脚本类型上传文件的类型是JS还是ZIP(zip解压后是project)
脚本使用机型默认是全机型选择下拉可自定义。
脚本编码就是脚本顺序或者自定义也好
脚本版本热更的关键格式是1.1.1 三位的格式。
脚本运行时间客户端脚本被执行的时间单位分钟
脚本文件这个是附件格式是JS和ZIP
更新日志非强制填写
主界面功能介绍 删除就是将上传的脚本删掉不影响已经下载和执行的客户端
更版和新增一样就是版本号要高于原始版本附件必须上传
历史版本查看当前脚本的历史记录即何时更版过
云控设备管理 重点中的重点、核心中的核心、关键中关键。云控设备管理是本软件的关键节点云控设备管理是本软件的关键节点云控设备管理是本软件的关键节点重要的事情说三遍。云控设备重点核心关键在那里有如下几点
任务和命令下发的页面 设备是否在线页面 设备运行日志页面 设备审核 有图有真相看图说话 发布任务选择在线设备发送预定义的任务发送后可以查看执行日志。下图是发布任务的界面 发布命令选择在线设备发送预定义的命令。 审核通过审核待审的设备 改别名非常重要的功能就十几个设备无所谓都能记得账然而工作室有几百个设备这时候设备别名就很重要了。 进阶篇(二次开发) Autojs客户端开发(脚本开发) 核心框架 最主要的就是修改免登和发布项目中含免登和发布的文件。如果想要修改项目信息则按照下面步骤进行
1、YadinghaoHunter文件夹名称修改成你想要的
2、修改工程名称和启动类名称
3、修改project.json内的启动类和公司信息
4、修改BaseConfig.js内的信息。soft_Version、root_Url和soft_Name。其他信息是否修正自己决定。soft_Version决定是否升级root_Url决定flash加载页面、云端脚本下载页面、推荐页面、升级页、登录功能和云控注册功能。soft_Name就是显示客户端的名称。 5、Plugin下的Tools.js是整体项目的工具类比如万能找图、滑动找元素、点击元素、监听ws等超级功能。其中构建找图方法会经常用到adenTools.buildImageArray(精选, ./Image/快手, 3);构建小图之后在大图里找小图little_image_array。
adenTools.clickAreaForFindImage(little_image_array)下图是示例代码 脚本开发JS 一般情况下但Js脚本都是兼容所以机型的。
直接将repository/ single/KSA.js文件复制一份修改就可以。 1.appName字段 2、ClickVideo方法修改一下修改成自己App进入的方法 1.改一下WS地址改成你自己的。 单文件是可以运行的 配置读取移动端本地没有则按照默认配置。
项目开发AutoJsPro的项目 复制YadinghaoKS.Zip将其解压然后将YadinghaoKS改成你想要的名字例如YadinghaoKSJS。再将其工程名称修改,例如YadinghaoKSJS.code-workspace在将启动类修改成KSJSFrame.js。 双击工程启动项目修改project.json第19行和20行 19行改成启动项目名称20行改成你自己想要的合理名。修改内部的方法是非常简单的有如下几个地方需要修该
1、appName字段修改成你要运行的App名称如快手极速版 2、修改ClickVideo方法一下修改成自己App进入的方法
3、修改保持自动阅读方法改成你自己的保持方法。
4、关键一步在执行任务的时间函数里修改自己的任务时间函数是adenTools.mod(parseInt(minute), 8) 0。其中最主要的任务就是签到和体现。下图是时间函数和App的任务。 5、里面涉及到找图方法已经在上面的章节描述过
Python服务端开发 构建页面 使用的是Flask MVC技术UI是Jinja2技术Flask推荐Jinja2其实也是Flask默认的。项目结构如下 将创建的页面放到指定位置back是后台页面文件夹front是前台页面。将创建好的html页面放到指定的文件夹里样式表、JS和UI复制其中的一个页面的就可以下图是示例 JS文件、CCS文件和Image文件都在static下。
构建JavaScript JS文件夹如下所示复制一个JS即可进行修改。 Js也区分前台和后台其中后台为了方便调用同样也进行了封装写了个yadinghao.js文件作为JS的基础类。
JS文件里面的方法有很多具体参考文件 构建DataAccess 构建数据访问之前还需要构建数据实体类。下图所示是实体类文件夹结构: 将对应的实体类放入到指定的文件夹然后在创建数据访问层。实体的创建采用的是sqlalchemy,对象相对简单。 from sqlalchemy import Column, String, Date
from sqlalchemy.orm import declarative_base
Base declarative_base()class RandomInfoEntity(Base):__tablename__ ad_random_infoAD_ID Column(String, primary_keyTrue)FILE_ID Column(String)AD_NAME Column(String)AD_TYPE Column(String)AD_CLICK_URL Column(String)AD_PATH Column(String)USER_ID Column(String)CREATOR Column(String)CREATEDATE Column(Date)IS_DEL Column(String)U_TIME Column(Date)
sqlalchemy下的数据访问也很简单常规的2项分页查询和增删改 # region 查询单体对象AutoLogdef query(self, primary_key_value):查询对象:param primary_key_value: 业务主键值:return: 返回对象实体session self.sqlalchemy_session()try:entity session.query(RandomInfoEntity).filter_by(AD_IDprimary_key_value).first()session.close()return entityexcept Exception as e:session.rollback()return None, e# endregion
构建Controller Controller的创建可以复制其他的页面。Python Flask的Controller得编写蓝印。编写完成后需要在启动类中实例化具体代码如下
Advertisement Blueprint(Advertisement, __name__)
app.register_blueprint(Advertisement, url_prefix/back/ad)
将位置存放正确就算放不对也能访问但是不好找。下图是controller的使用图参考一下还不自信就看看代码 Advertisement Blueprint(Advertisement, __name__)
# 创建日志记录器
logger logging.getLogger(__name__)
daoRandomInfoDataAccess()Advertisement.route(/manage_randominfo)
Advertisement.route(/ManageAd)
def ManageWsAddress():return render_template(back/ad/ManageRandomInfo.html, **FrameConfig().system_config()) 资源篇 源码下载 Python版源码链接 百度网盘 请输入提取码
提取码eklb 环境软件下载 Python安装环境所需软件链接
百度网盘 请输入提取码
提取码n4zt
