主要更新

#227 增加调度、定时器相关便捷工具，使用 HashedWheelTimer 来模拟 ScheduledExecutorService 调度

 public void test() {
     // 每分钟调用一次
     TaskKit.runIntervalMinute(() -> log.info("tick 1 Minute"), 1);
     // 每 2 分钟调用一次
     TaskKit.runIntervalMinute(() -> log.info("tick 2 Minute"), 2);
 ​
     // 每 2 秒调用一次
     TaskKit.runInterval(() -> log.info("tick 2 Seconds"), 2, TimeUnit.SECONDS);
     // 每 30 分钟调用一次
     TaskKit.runInterval(() -> log.info("tick 30 Minute"), 30, TimeUnit.MINUTES);
 ​
     //【示例 - 移除任务】每秒调用一次，当 hp 为 0 时就移除当前 TimerListener
     TaskKit.runInterval(new IntervalTaskListener() {
         int hp = 2;
 ​
         @Override
         public void onUpdate() {
             hp--;
             log.info("剩余 hp:2-{}", hp);
         }
 ​
         @Override
         public boolean isActive() {
             // 当返回 false 则表示不活跃，会从监听列表中移除当前 TimerListener
             return hp != 0;
         }
     }, 1, TimeUnit.SECONDS);
 ​
     //【示例 - 跳过执行】每秒调用一次，当 triggerUpdate 返回值为 true，即符合条件时才执行 onUpdate 方法
     TaskKit.runInterval(new IntervalTaskListener() {
         int hp;
 ​
         @Override
         public void onUpdate() {
             log.info("current hp:{}", hp);
         }
 ​
         @Override
         public boolean triggerUpdate() {
             hp++;
             // 当返回值为 true 时，会执行 onUpdate 方法
             return hp % 2 == 0;
         }
     }, 1, TimeUnit.SECONDS);
 ​
     //【示例 - 指定线程执行器】每秒调用一次
     // 如果有耗时的任务，比如涉及一些 io 操作的，建议指定执行器来执行当前回调（onUpdate 方法），以避免阻塞其他任务。
     ExecutorService executorService = TaskKit.getCacheExecutor();
 ​
     TaskKit.runInterval(new IntervalTaskListener() {
         @Override
         public void onUpdate() {
             log.info("执行耗时的 IO 任务，开始");
 ​
             try {
                 TimeUnit.SECONDS.sleep(3);
             } catch (InterruptedException e) {
                 throw new RuntimeException(e);
             }
 ​
             log.info("执行耗时的 IO 任务，结束");
         }
 ​
         @Override
         public Executor getExecutor() {
             // 指定执行器来执行当前回调（onUpdate 方法），以避免阻塞其他任务。
             return executorService;
         }
     }, 1, TimeUnit.SECONDS);
 ​
     TimeUnit.SECONDS.sleep(20);
 }

#225 新增插件 - 业务线程监控

详细文档 https://www.yuque.com/iohao/game/zoqabk4gez3bckis

 BarSkeletonBuilder builder = ...;
 // 业务线程监控插件，将插件添加到业务框架中
 var threadMonitorInOut = new ThreadMonitorInOut();
 builder.addInOut(threadMonitorInOut);
 ​
 ​

打印预览

 业务线程[RequestMessage-8-1] 共执行了 1 次业务，平均耗时 1 ms, 剩余 91 个任务未执行
 业务线程[RequestMessage-8-2] 共执行了 1 次业务，平均耗时 1 ms, 剩余 0 个任务未执行
 业务线程[RequestMessage-8-3] 共执行了 1 次业务，平均耗时 1 ms, 剩余 36 个任务未执行
 业务线程[RequestMessage-8-4] 共执行了 1 次业务，平均耗时 1 ms, 剩余 0 个任务未执行
 业务线程[RequestMessage-8-5] 共执行了 1 次业务，平均耗时 1 ms, 剩余 88 个任务未执行
 业务线程[RequestMessage-8-6] 共执行了 1 次业务，平均耗时 1 ms, 剩余 0 个任务未执行
 业务线程[RequestMessage-8-7] 共执行了 7 次业务，平均耗时 1 ms, 剩余 56 个任务未执行
 业务线程[RequestMessage-8-8] 共执行了 1 次业务，平均耗时 1 ms, 剩余 0 个任务未执行

其他更新

废废弃 InternalKit，使用 TaskKit 代替

HeadMetadata 新增 cloneAll 方法

增加 ThreadExecutorRegion 线程执行器管理域接口；

• 新增 UserThreadExecutorRegion 实现，执行器具体数量是不大于 Runtime.getRuntime().availableProcessors() 的 2 次幂。

• 新增 SimpleThreadExecutorRegion 实现，执行器的数量与 Runtime.getRuntime().availableProcessors() 相同。

默认为 UserThreadExecutorRegion 和 SimpleThreadExecutorRegion 提供了单例实现，即使在同一进程中启动了多个逻辑服，也不会创建过多线程执行器，而是使用同一个。

<dependency>
    <groupId>com.iohao.game</groupId>
    <artifactId>run-one-netty</artifactId>
    <version>${ioGame.version}</version>
</dependency>

框架整体预览导图

ioGame 网络游戏服务器框架简介

• 无锁异步化、事件驱动的架构设计；轻量级，无需依赖任何第三方中间件或数据库就能支持集群、分布式
• 通过 ioGame 可以很容易的搭建出一个集群无中心节点、集群自动化、多进程的分步式游戏服务器
• 包体小、启动快、内存占用少、更加的节约、无需配置文件、提供了优雅的路由访问权限控制
• 让开发者使用一套业务代码，无需改动，支持多种连接方式：WebSocket、TCP、UDP
• 让开发者用一套业务代码，能轻松切换和扩展不同的通信协议：Protobuf、JSON
• 近原生的性能；业务框架在单线程中平均每秒可以执行 1152 万次业务逻辑
• 代码即联调文档、JSR380 验证、断言 + 异常机制 = 更少的维护成本
• 框架具备智能的同进程亲和性；开发中，业务代码可定位与跳转
• 架构部署灵活性与多样性：既可相互独立，又可相互融合
• 可同时与同类型的多个游戏逻辑服通信并得到数据
• 逻辑服之间可相互跨进程、跨机器进行通信
• 支持玩家对游戏逻辑服进行动态绑定
• 能与任何其他框架做融合共存
• 对 webMVC 开发者友好
• 无 spring 强依赖
• 零学习成本

ioGame 由 [网络通信框架] 和 [业务框架] 组成。

/** 请求 */
@ProtobufClass
@FieldDefaults(level = AccessLevel.PUBLIC)
public class HelloReq {
    String name;
}

@ActionController(1)
public class DemoAction {
    @ActionMethod(0)
    public HelloReq here(HelloReq helloReq) {
        HelloReq newHelloReq = new HelloReq();
        newHelloReq.name = helloReq.name + ", I'm here ";
        return newHelloReq;
    }
}

┏━━━━━ Debug. [(DemoAction.java:4).here] ━━━ [cmd:1 - subCmd:0 - cmdMerge:65536]
┣ userId : 888
┣ 参数: helloReq : HelloReq(name=塔姆)
┣ 响应: HelloReq(name=塔姆, I'm here )
┣ 时间: 0 ms (业务方法总耗时)
┗━━━━━ Debug [DemoAction.java] ━━━ [当前线程:RequestMessage-8-1] 

Debug. [(DemoAction.java:4).here]：
    表示执行业务的是 DemoAction 类下的 here 方法，4 表示业务方法所在的代码行数。
    在工具中点击控制台的 DemoAction.java:4 这条信息，就可以跳转到对应的代码中（快速导航到对应的代码），这是一个开发良好体验的开始！
userId :  
    当前发起请求的 用户 id。
参数 :  
    通常是游戏前端传入的值。
响应：
    通常是业务方法返回的值 ，业务框架会把这个返回值推送到游戏前端。
时间：
    执行业务方法总耗时，我们可根据业务方法总耗时的时长来优化业务。
路由信息：[cmd - subCmd]
    路由是唯一的访问地址。