主要更新

[#138] 提供协议碎片的工具类，方便协议碎片在广播时的使用

代码中演示了协议碎片相关的使用，通过工具类，可以让一些基础类型在使用上更简便。 对应的包装类中，都提供了静态 of 方法；

框架支持的包装类可到 框架支持的自动装箱、拆箱基础类型 查询。

 ... ... 省略部分代码
 private static void test() {
   // 给客户端广播一个 int 值 : 1
   var bizData = WrapperKit.of(1);
 ​
   // 广播上下文
   CmdInfo cmdInfo = CmdInfo.getCmdInfo(DemoBroadcastCmd.cmd, DemoBroadcastCmd.broadcastMsg);
   BroadcastContext broadcastContext = BrokerClientHelper.getBroadcastContext();
   broadcastContext.broadcast(cmdInfo, bizData);
 ​
   // 给客户端广播一个 bool 值 : true
   var bizDataBoolean = WrapperKit.of(true);
   broadcastContext.broadcast(cmdInfo, bizDataBoolean);
 ​
   // 对象列表演示
   DemoBroadcastMessage broadcastMessage = new DemoBroadcastMessage();
   broadcastMessage.msg = "broadcast hello，" + counter.longValue();
   List<DemoBroadcastMessage> list = new ArrayList<>();
   list.add(broadcastMessage);
   var bizDataList = WrapperKit.ofListByteValue(list);
   broadcastContext.broadcast(cmdInfo, bizDataList);
 ​
   // int 列表
   var bizDataIntList = IntValueList.of(List.of(1, 3, 5, 7));
   broadcastContext.broadcast(cmdInfo, bizDataIntList);
 ​
   ... ... 省略部分代码
   其他类同，不全部介绍了。
 }

[#133] 向指定对外服上的用户广播数据

示例参考代码

 ... ...省略部分代码
 private static void extracted(String externalId) {
     var bizData = new DemoBroadcastMessage();
     broadcastMessage.msg = "broadcast hello！" ;
 ​
     // 广播消息的路由
     CmdInfo cmdInfo = ...;
     ResponseMessage responseMessage = BarMessageKit.createResponseMessage(cmdInfo, bizData);
     
     // 指定游戏对外服广播
     HeadMetadata headMetadata = responseMessage.getHeadMetadata();
     int sourceClientId = MurmurHash3.hash32(externalId);
     headMetadata.setSourceClientId(sourceClientId);
 ​
     // 广播上下文
     BroadcastContext broadcastContext = BrokerClientHelper.getBroadcastContext();
     broadcastContext.broadcast(responseMessage);
 }

容错设置

IoGameGlobalConfig.brokerSniperToggleAK47 = boolean；

 Broker（游戏网关）转发消息容错配置
       游戏逻辑服与游戏对外服通信时，如果没有明确指定要通信游戏对外服，游戏网关则会将消息转发到所有的游戏对外服上。
       如果指定了游戏对外服的，游戏网关则会将消息转发到该游戏对外服上，而不会将消息转发到所有的对外服上。
  
       当为 true 时，开启容错机制
           表示开发者在发送消息时，如果指定了游戏对外服的，
           但【游戏网关】中没有找到所指定的【游戏对外服】，则会将消息转发到所有的游戏对外服上，
           这么做的目的是，即使开发者填错了指定的游戏对外服，也能保证消息可以送达到游戏对外服。
  
       当为 false 时，关闭容错机制
           表示在【游戏网关】中找不到指定的【游戏对外服】时，则不管了。
  
       支持的通讯方式场景
           广播、推送 
           获取游戏对外服的数据与扩展 
   
 另一种叙述版本
       作用：
           在游戏逻辑服发送广播时，支持指定游戏对外服来广播；
           如果你能事先知道所要广播的游戏对外服，那么在广播时通过指定游戏对外服，可以避免一些无效的转发。
  
           为了更好的理解的这个配置的作用，这里将作一些比喻：
           1. 将广播时指定的游戏对外服，看作是目标
           2. 将发送广播的游戏逻辑服，看作是命令
           3. 而 Broker（游戏网关）职责是对消息做转发，可看成是一名射击员；射击员手上有两把枪，分别是狙击枪和 AK47。
  
           狙击枪的作用是单点目标，而 AK47 的作用则是扫射多个目标（就是所有的游戏对外服）。
  
       场景一：
           当设置为 true 时，表示射击员可以将手中的狙击切换为 AK47，什么意思呢？
           意思就是如果在【游戏网关】中没有找到所指定的【游戏对外服】，则将广播数据发送给【所有的游戏对外服】。（换 AK 来扫射）
           这么做的目的是，即使开发者填错了指定的游戏对外服，也能保证消息可以送达到游戏对外服。
  
       场景二：
           当设置为 false 时，表示找不到指定的【游戏对外服】时，则不管了。

[#131] 获取指定对外服上数据的接口

参考使用示例，通过 RequestCollectExternalMessage 请求对象，可以指定游戏对外服id；

 @UtilityClass
 public class ExternalCommunicationKit {
     /**
      * 设置元信息到游戏对外服
      * 
 <pre>
      *     之后所有 action 的 FlowContext 中会携带上这个元信息对象，
      *     不建议在元信息保存过多的信息，因为会每次传递。
      * </pre>
 *
      * @param attachment  元信息
      * @param flowContext flowContext
      */
     public void setAttachment(Attachment attachment, FlowContext flowContext) {
         // 不做 null 判断，只做个 userId 的检测
         long userId = attachment.getUserId();
 ​
         if (userId <= 0) {
             throw new RuntimeException("userId <= 0");
         }
 ​
         // 得到游戏对外服 id
         RequestMessage request = flowContext.getRequest();
         HeadMetadata headMetadata = request.getHeadMetadata();
         int sourceClientId = headMetadata.getSourceClientId();
 ​
         var requestCollectExternalMessage = new RequestCollectExternalMessage()
                 // 根据业务码，调用游戏对外服与业务码对应的业务实现类 （AttachmentDataExternalBizRegion）
                 .setBizCode(ExternalBizCodeCont.attachment)
                 // 元信息
                 .setData(attachment)
                 // 指定游戏对外服
                 .setSourceClientId(sourceClientId);
 ​
         BrokerClientHelper
                 // 【游戏逻辑服】与【游戏对外服】通讯上下文
                 .getInvokeExternalModuleContext()
                 .invokeExternalModuleCollectMessage(requestCollectExternalMessage);
     }
 }

容错设置

IoGameGlobalConfig.brokerSniperToggleAK47 = boolean；

下版本预告

[#122] 同进程亲和性

同进程亲和性简单说明

 架构由三部分组成：1.游戏对外服、2.Broker（游戏网关）、3.游戏逻辑服；三者既可相互独立，又可相互融合；
 ​
 当我们使用同进程亲和性这一特性将三者部署在一起后，三者是通过内存进行传输的，不需要经过网络传输，数据传输速度极快。

特别说明

 这里特别说明一下，并不是说要将三者部署在一起才有这个效果；
 为方便理解，现在把三者用字母代替，A.游戏对外服、B.Broker（游戏网关）、C.游戏逻辑服
 ​
 ABC ：三者在一个进程中，他们之间使用内存通信；
 AB + C ：【游戏对外服和游戏网关】在一个进程中，他们之间使用内存通信；
 A + BC ：【游戏网关和游戏逻辑服】在一个进程中，他们之间使用内存通信；

另外，如果我们启动了同类型的多个游戏逻辑服

 【游戏网关】会优先选择与同进程的那个游戏逻辑服进行通信，使用内存通信；
 在同进程中没有找到时，会在同类型的多个游戏逻辑服中随机选出一个通信。

<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]
    路由是唯一的访问地址。