储天行

善于解决生产中遇到的问题，

偏爱设计开发优雅的程序结构，

习惯于用自动化技术简化研发过程，

自我肯定于在服务7*24无故障运行和团队高效协作。

chutianxing@hotmail.com

https://tech.memorz.com

个人优势

自2002年毕业以来，我持续投身于Java系统的设计和开发工作，累积了20年的丰富经验。在这段时间中，我在一家初创公司服务了16年，期间主导设计并开发了一款创新的分布式应用开发框架（Distributed Application Framework），该框架在过去10年中成功应用于生产环境。它在团队职责分配、降低开发门槛、规范代码编写、提升工作效率、定位故障与瓶颈、以及保证系统无故障运行方面均展现出色的性能。此外，我还积极涉猎服务部署、数据库运维、需求与产品设计等领域，横跨从前端（使用Thymeleaf）到后端的全栈开发，并在从客户端（Android）到服务器端的多方位工作中积累了宝贵经验。

关于DAF

它是我设计开发的一个分布式应用开发和运行框架，具备负载均衡、远程配置、调用栈Tracking、模块维度和接口维度调用频度和响应时间分析、 Host维度硬件信息收集、外部接口网关等功能和特性。已通过十年的生产环境验证，并在生产中不断升级进化。

运行时

runtime

每个Group包含若干个功能完全一致的Node，每个Node是一个独立进程，占用一个通讯端口。 Node是实现/完成特定接口功能的实体，一个Group中包含多少个Node取决于请求的频度和压力。

从Group外部发往该Group的请求可以被任一活动的Node接收和处理，被任一Node处理的结果等效于该Group中其他任一Node的处理结果。 在运行时由哪一个Node接收和处理请求取决于Group内各Node的负载压力。

如果Group内Node运行不依赖任何外部资源，向Group中添加Node可以提高Group的数据处理能力。

上图展示了两个Group A和B的调用关系，比如我们有这样一个服务：输入用户会话id和一段密文，输出解密后的明文。Group A负责通过用户会话id获取解密所用的密钥，然后将密钥和密文发往Group B，Group B负责对密文进行解密。 在运行时，当Group A的Node I首次接收到用户请求(Step.1)需要调用Group B时，需要向admin节点查询(Step.2)Group B内的Node信息，查询结果会缓存在Node I中，以便后续的用户请求可以直接使用，缓存的数据会定时从admin节点进行更新。这样做的好处是：如果admin节点出现短暂的故障，整个网络仍然可以正常运行。

调用栈


code: "NA"
responseTimeStack {
  ngLabel: "SafeboxNG"
  ngVersion: "0.0.1"
  ip: "10.140.0.5"
  port: 8000
  action: "DecryptCipher"
  actVersion: "0.0.1"
  time: 829
  children {
    ngLabel: "EncrypterNG"
    ngVersion: "0.0.1"
    ip: "10.140.0.5"
    port: 8004
    action: "Decrypt"
    actVersion: "0.0.1"
    time: 811
  }
}
body {
  type_url: "type.googleapis.com/DecryptCipherResponse"
  value: "hello world"
}

为了方便定位系统内部瓶颈，DAF内置了调用栈记录功能，并将调用栈数据放置在应答头中返回给调用方。从系统外部发起的一个请求， 都可以在对应的应答头中看到整个调用链，定位出系统性能瓶颈。

还是用解密数据为例：

1. 请求发往SafeboxNG[version:0.0.1]，接口名称为DecryptCipher[version:0.0.1]。

2. SafeboxNG的节点在获得用户解密私钥后，将密文和私钥发往EncrypterNG[0.0.1]，接口名称为Decrypt[0.0.1]。

3. EncrypterNG的节点对密文进行解密，将耗用的时间811ms(在应答头中)和解密出来的明文(在应答体中)组成应答返回给SafeboxNG节点。

4. SafeboxNG节点再将耗用时间829ms与来自EncrypterNG的调用栈结合为一个整体并放置在应答头中。

调用时间栈数据结构:

// 时间栈
message TimeStack {
    reserved 9 to 100;
    string ngLabel = 1; //单元标签 [必须含有]
    string ngVersion = 2; //单元版本 [必须含有]
    string ip = 3; //执行者ip [必须含有]
    int32 port = 4; //执行者端口 [必须含有]
    string action = 5; //方法名 [必须含有]
    string actVersion = 6; //
    int64 time = 7; //操作耗用时间,单位ms [必须含有]
    repeated TimeStack children = 8; //子操作栈 [可以含有]
}

获取配置和节点状态统计

get_config

在节点启动时，节点会从admin节点获取通信配置数据，配置数据的颗粒度是Group，Group内Node使用同样的配置。 也可以在节点本地使用配置文件，本地配置文件中的通信配置数据会覆写远程配置数据。

在同一个Host上部署多个节点，admin节点会分发可用端口，避免出现端口冲突，因此不建议在节点的本地配置文件中设置服务端口号。 可用的端口范围可以在admin节点内进行配置。

部署admin节点是部署DAF应用的第一步，只有在admin节点启动后，才可以部署其他Group的节点。 admin节点由于无关业务，可以长时间不间断运行(以年记)。

节点在运行时会每隔10s向admin节点发送接口统计数据(ping)，admin如果长时间未收到某节点的接口统计数据会认为该节点已下线。 admin收集的各节点接口统计数据用Group进行划分整理，作为负载均衡的依据。

一个节点组统计数据示例 

nodeGroups {
  ngLabel: "EncrypterNG"
  ngVersion: "0.0.1"
  nodes {
    ip: "10.140.0.5"
    port: 8003
    ngLabel: "EncrypterNG"
    ngVersion: "0.0.1"
    recordTime: 1657681211312
    nodeStatus {
      collectTime: 1657681211312
      nodeStatus: ON
      interfaceStatus {
        action: "Decrypt"
        actVersion: "0.0.1"
      }
      interfaceStatus {
        action: "Encrypt"
        actVersion: "0.0.1"
      }
    }
    pid: "29699"
  }
}
nodeGroups {
  ngLabel: "BawsNG"
  ngVersion: "0.0.1"
  nodes {
    ip: "10.140.0.4"
    port: 8002
    ngLabel: "BawsNG"
    ngVersion: "0.0.1"
    recordTime: 1657681214189
    nodeStatus {
      collectTime: 1657681214189
      nodeStatus: READY
    }
    pid: "19754"
  }
}
nodeGroups {
  ngLabel: "TransactionPullNG"
  ngVersion: "0.0.1"
  nodes {
    ip: "10.140.0.4"
    port: 8008
    ngLabel: "TransactionPullNG"
    ngVersion: "0.0.1"
    recordTime: 1657681216397
    nodeStatus {
      collectTime: 1657681216397
      nodeStatus: ON
      interfaceStatus {
        action: "PullLosData"
        actVersion: "0.0.1"
      }
      interfaceStatus {
        action: "PullCandleData"
        actVersion: "0.0.1"
        avaiCostsPerMin: 2
        avaiHitsPerMin: 114
      }
      interfaceStatus {
        action: "PullOrder"
        actVersion: "0.0.1"
      }
      interfaceStatus {
        action: "PullExcCurrencyData"
        actVersion: "0.0.1"
        avaiHitsPerMin: 6
      }
    }
    pid: "4807"
  }
}
nodeGroups {
  ngLabel: "AssetAdminNG"
  ngVersion: "0.0.1"
  nodes {
    ip: "10.140.0.2"
    port: 8001
    ngLabel: "AssetAdminNG"
    ngVersion: "0.0.1"
    recordTime: 1657681211031
    nodeStatus {
      collectTime: 1657681211031
      nodeStatus: ON
      interfaceStatus {
        action: "NewIssueTask"
        actVersion: "0.0.1"
      }
    }
    pid: "18006"
  }
}
nodeGroups {
  ngLabel: "SafeboxNG"
  ngVersion: "0.0.1"
  nodes {
    ip: "10.140.0.5"
    port: 8002
    ngLabel: "SafeboxNG"
    ngVersion: "0.0.1"
    recordTime: 1657681212709
    nodeStatus {
      collectTime: 1657681212709
      nodeStatus: ON
      interfaceStatus {
        action: "CipherAck"
        actVersion: "0.0.1"
      }
      interfaceStatus {
        action: "DecryptCipher"
        actVersion: "0.0.1"
      }
      interfaceStatus {
        action: "GetUser"
        actVersion: "0.0.1"
      }
      interfaceStatus {
        action: "GetCipher"
        actVersion: "0.0.1"
      }
      interfaceStatus {
        action: "SendCode"
        actVersion: "0.0.1"
      }
      interfaceStatus {
        action: "SaveData"
        actVersion: "0.0.1"
      }
      interfaceStatus {
        action: "ClearCipher"
        actVersion: "0.0.1"
      }
      interfaceStatus {
        action: "FaceRecognize"
        actVersion: "0.0.1"
      }
      interfaceStatus {
        action: "VerifyCode"
        actVersion: "0.0.1"
      }
    }
    pid: "3906"
  }
}
nodeGroups {
  ngLabel: "SmsNG"
  ngVersion: "0.0.1"
  nodes {
    ip: "10.140.0.4"
    port: 8001
    ngLabel: "SmsNG"
    ngVersion: "0.0.1"
    recordTime: 1657681214953
    nodeStatus {
      collectTime: 1657681214953
      nodeStatus: ON
      interfaceStatus {
        action: "SendConfirmCodeToUser"
        actVersion: "0.0.1"
      }
      interfaceStatus {
        action: "SendSmsToUser"
        actVersion: "0.0.1"
      }
    }
    pid: "9484"
  }
}
nodeGroups {
  ngLabel: "NoticeTgNG"
  ngVersion: "0.0.1"
  nodes {
    ip: "10.140.0.4"
    port: 8004
    ngLabel: "NoticeTgNG"
    ngVersion: "0.0.1"
    recordTime: 1657681208149
    nodeStatus {
      collectTime: 1657681208149
      nodeStatus: ON
      interfaceStatus {
        action: "SendMessage"
        actVersion: "0.0.1"
      }
    }
    pid: "9917"
  }
}
nodeGroups {
  ngLabel: "ADMIN"
  ngVersion: "0.0.1"
  nodes {
    ip: "10.140.0.4"
    port: 8000
    ngLabel: "ADMIN"
    ngVersion: "0.0.1"
    recordTime: 1657681211699
    nodeStatus {
      collectTime: 1657681211699
      nodeStatus: ON
      interfaceStatus {
        action: "getcfg"
        actVersion: "0.0.1"
      }
      interfaceStatus {
        action: "getport"
        actVersion: "0.0.1"
      }
      interfaceStatus {
        action: "whereis"
        actVersion: "0.0.1"
        avaiHitsPerMin: 156
      }
      interfaceStatus {
        action: "ping"
        actVersion: "0.0.1"
        avaiHitsPerMin: 84
      }
    }
    pid: "30149"
  }
}
nodeGroups {
  ngLabel: "RobotNG"
  ngVersion: "0.0.1"
  nodes {
    ip: "10.140.0.2"
    port: 8000
    ngLabel: "RobotNG"
    ngVersion: "0.0.1"
    recordTime: 1657681209355
    nodeStatus {
      collectTime: 1657681209355
      nodeStatus: ON
      interfaceStatus {
        action: "QueryDnhRecord"
        actVersion: "0.0.1"
        avaiCostsPerMin: 12
        avaiHitsPerMin: 6
      }
      interfaceStatus {
        action: "MarketData"
        actVersion: "0.0.1"
        avaiHitsPerMin: 57336
      }
    }
    pid: "27885"
  }
}
nodeGroups {
  ngLabel: "ChartsNG"
  ngVersion: "0.0.1"
  nodes {
    ip: "10.140.0.2"
    port: 8004
    ngLabel: "ChartsNG"
    ngVersion: "0.0.1"
    recordTime: 1657681208659
    nodeStatus {
      collectTime: 1657681208659
      nodeStatus: ON
      interfaceStatus {
        action: "PetLosList"
        actVersion: "0.0.1"
      }
      interfaceStatus {
        action: "MarketDataRec"
        actVersion: "0.0.1"
        avaiHitsPerMin: 52314
      }
      interfaceStatus {
        action: "CandleList"
        actVersion: "0.0.1"
      }
      interfaceStatus {
        action: "ExcCurrencyRec"
        actVersion: "0.0.1"
        avaiCostsPerMin: 3
        avaiHitsPerMin: 36
      }
      interfaceStatus {
        action: "SubscribeCharts"
        actVersion: "0.0.1"
      }
    }
    pid: "26285"
  }
}
nodeGroups {
  ngLabel: "TransAgentNG"
  ngVersion: "0.0.1"
  nodes {
    ip: "10.140.0.2"
    port: 8009
    ngLabel: "TransAgentNG"
    ngVersion: "0.0.1"
    recordTime: 1657681214709
    nodeStatus {
      collectTime: 1657681214708
      nodeStatus: ON
      interfaceStatus {
        action: "NewTransaction"
        actVersion: "0.0.1"
      }
      interfaceStatus {
        action: "QueryNeedSignTransaction"
        actVersion: "0.0.1"
      }
      interfaceStatus {
        action: "QueryTransaction"
        actVersion: "0.0.1"
      }
      interfaceStatus {
        action: "SignTransaction"
        actVersion: "0.0.1"
      }
    }
    pid: "19128"
  }
}
nodeGroups {
  ngLabel: "KeyStoreNG"
  ngVersion: "0.0.1"
  nodes {
    ip: "10.140.0.5"
    port: 8007
    ngLabel: "KeyStoreNG"
    ngVersion: "0.0.1"
    recordTime: 1657681210971
    nodeStatus {
      collectTime: 1657681210971
      nodeStatus: ON
      interfaceStatus {
        action: "SysPreSetSymmetricKey"
        actVersion: "0.0.1"
      }
      interfaceStatus {
        action: "GetAccountIdByCode"
        actVersion: "0.0.1"
      }
      interfaceStatus {
        action: "GetSignature"
        actVersion: "0.0.1"
        avaiHitsPerMin: 12
      }
      interfaceStatus {
        action: "SysSetSymmetricKey"
        actVersion: "0.0.1"
      }
    }
    pid: "1473"
  }
}
nodeGroups {
  ngLabel: "IbConnectorNG"
  ngVersion: "0.0.1"
  nodes {
    ip: "10.140.0.5"
    port: 8001
    ngLabel: "IbConnectorNG"
    ngVersion: "0.0.1"
    recordTime: 1657681207934
    nodeStatus {
      collectTime: 1657681207933
      nodeStatus: ON
      interfaceStatus {
        action: "OrderStatus"
        actVersion: "0.0.1"
      }
      interfaceStatus {
        action: "MarketData"
        actVersion: "0.0.1"
        avaiHitsPerMin: 222
      }
      interfaceStatus {
        action: "SubscribeData"
        actVersion: "0.0.1"
      }
      interfaceStatus {
        action: "GetOrder"
        actVersion: "0.0.1"
      }
      interfaceStatus {
        action: "IsMarketOpen"
        actVersion: "0.0.1"
        avaiHitsPerMin: 6
      }
      interfaceStatus {
        action: "OpenOrder"
        actVersion: "0.0.1"
      }
    }
    pid: "24031"
  }
}
nodeGroups {
  ngLabel: "HttpProxyNG"
  ngVersion: "0.0.1"
  nodes {
    ip: "10.140.0.4"
    port: -1
    ngLabel: "HttpProxyNG"
    ngVersion: "0.0.1"
    recordTime: 1657681216374
    nodeStatus {
      collectTime: 1657681216374
      nodeStatus: READY
    }
    pid: "23553"
  }
}
}

以上是调用admin节点getngstz接口获取到的数据体(剔除应答头)。

数据体由N个nodeGroups组成，每个nodeGroup可包含M个node。


nodeGroups {
  ngLabel: "xxxNG" // 节点组名称
  ngVersion: "x.x.x" // 节点组版本
  nodes { // 节点
    ip: "xxx.xxx.xxx.xxx" // 节点ip
    port: xxxx // 节点端口，"-1"表示未开启DAF远程调用端口
    ngLabel: "xxxNG"
    ngVersion: "x.x.x"
    recordTime: xxxxx // 节点状态统计时间
    nodeStatus {
      collectTime: xxxxx // 节点状态汇报时间
      nodeStatus: ON // 节点状态
      interfaceStatus { // 接口状态
        action: "xxxxxx" // 接口名称
        actVersion: "x.x.x" // 接口版本
        jams: "xx" // 当前正在处理的请求个数，如果为0则不显示该行
        avaiCostsPerMin: xx // 接口过去一分钟平均耗时(ms)，如果为0则不显示该行(例如过去一分钟平均响应时间小于0ms或无调用)。
        avaiHitsPerMin: xx // 接口过去一分钟平均调用次数，如果为0则不显示该行(例如过去一分钟无调用)。
      }
    }
    pid: "xxxx" // 节点进程号
  }
}

接口定义

node_encrypter.xml

...
<xwork>
    <include file="xwork-default.xml"/>

    <package name="Encrypt" namespace="Encrypt">
        <action name="0.0.1" class="org.barsf.encrypter.action.EncryptAction">
        </action>
    </package>

    <package name="Decrypt" namespace="Decrypt">
        <action name="0.0.1" class="org.barsf.encrypter.action.DecryptAction">
        </action>
    </package>
</xwork>

encrypter_cm_core.proto

...
// 加密
message EncryptRequest {
    bytes data = 1; // 明文
    bytes key = 2; // 密钥
}
message EncryptResponse {
    bytes encryptedData = 1; // 加密后的密文
}

// 解密
message DecryptRequest {
    bytes encryptedData = 1; // 密文
    bytes key = 2; // 密钥
}
message DecryptResponse{
    bytes data = 1; // 解密后的明文
}

node_encrypter.xml定义了接口的处理action，即当一个action请求被接收后，具体交由哪一个action进行处理和返回应答。

encrypter_cm_core.proto定义了接口的请求和应答数据封装结构。

工作经历 博大正方 | 九城集团 | 蓬天 | 大头无线 | 爱锋乐 | 中谷金科

中谷金科 服务器端研发负责人 2011.10-2023.09

小金理财

带领5人团队，设计开发小金理财服务器后端服务，整个系统由多个子系统组成：用户中心、存管账户、支付系统、资产管理、基础服务、管理和监控等。 整个系统运行在DAF框架之上。

  • 用户中心：除用户基础信息外，还留存用户银行卡和存管账户、支付系统、资产管理系统的摘要信息。
  • 存管账户：先后对接新浪金融、恒丰银行一期和二期存管系统。
  • 支付系统：先后对接招商银行、恒丰银行、华夏银行、中信银行、易联、安捷、ChinaPay、银联等多条代付和代收通道完成用户充值和提现业务。
  • 资产管理：实现投资标的的生命周期管理和投资用户的投资、变现、撮合等业务操作，完成每日资产和收益清算，最高管理超过40亿资产和日内亿级的资产交易。除了自身的资产项外还对接趣分期和现金巴士的消费贷项目，趣分期和现金巴士调用我方系统，提供借款人信息，还款计划及实际还款项目信息，我方产生对应资产募集资金并实时根据还款调整资产项目和用户投资。
    • 一期对接：趣分期和现金巴士将在本地生成前一天的借款和还款数据，并制作成Excel报表上传至我们的服务器。我们的服务器将自动进行项目有效性检查和数据录入，处理结果将展示在网页列表中，供财务和运营人员进行审核、处理账目。
    • 二期对接：趣分期和现金巴士将通过API调用方式，与我们的服务器实时互动，用于生成消费贷资产项、录入还款计划和处理还款事务。我们的系统将对这些资产进行资金募集，并根据借款人的还款情况实时调整资产金额和投资者资金的匹配。此外，我们还将提供API接口，供趣分期和现金巴士查询相关联的数据。
  • 基础服务：包含用户身份验真、短信服务、微信服务、银行卡号段识别等子模块。
  • 管理和监控：包含客服信息支持、用户银行卡反洗钱、全局服务监控和审计子模块。

小金理财是我们自己研发和运营的理财APP，借助阿里金融云的ECS、RDS、DRDS、LVS、OSS、VPN和堡垒机等服务，基本实现了自动化运维。

大头无线 服务器端研发总监 2005.09-2010.11

收集大头

负责手机大头服务器端的设计和研发，系统由用户 、资讯、邮件、音乐、搜索等功能模块组成。手机大头是运行在诺基亚Symbian平台上的手机客户端软件。

  • 资讯：通过各大资讯门户网站的RSS获取最新资讯，然后使用定制化或智能模板从内容页面中抽取正文内容和图片。
  • 邮件：使用用户提供的用户名和密码，通过SMTP和POP3协议与邮件服务提供商服务器进行交互，获取邮件内容和附件进行展示或发送用户编辑的邮件内容。
  • 音乐：将用户输入的搜索关键字发送到百度音乐搜索引擎，获取音乐列表。然后服务器下载用户所选的音乐mp3文件，进行音频压缩，再缓存并返还给用户。这些缓存和持久化的音乐压缩文件可以更快得响应相同的用户搜索内容。
  • 资讯搜索：将用户输入的搜索关键字发送到百度资讯搜索引擎，获取资讯标题和摘要列表。在用户在客户端上点击某资讯条目后，服务器从互联网获取该资讯正文页面，通过文字权重等算法，去除广告、超链等杂讯，抽取页面中的正文内容(plain text)返还给客户端。

各个模块通过web service接口与用户接入点代理进行通讯，在大头工作的这段经历启发我设计和开发了初代DAF开发框架。

其他

时间区间可能不准确

由于我自己的失误，导致之前的求职简历文档丢失，以往相对短期的工作经历时间段已经模糊，下面列举的时间段不准确可能与真实情况有月级别的误差，但工作单位和内容无误。

杭州爱锋乐网络技术有限公司
2011.01-2011.10 研发工程师 设计开发群聊软件"群群"消息投递系统。
蓬天信息系统有限公司
2004.09-2005.09 研发工程师 外派新华社开发新华社稿件审核和内容管理平台。
九城网络技术集团有限公司
2003.03-2004.03 研发工程师 参与开发海关监控系统，维护海关通关报文接收系统。
北京博大正方软件技术有限公司
2002.09-2003.03 研发工程师 参与开发企业内部使用的OA平台。

教育经历

北京工业大学
1998.09-2002.06 电子信息工程 本科 2001年获院系二等奖学金
北京六中
1992.09-1998.06
北京大翔凤小学
1990.09-1992.06
洛阳广文路小学
1988.09-1990.06
洛阳青岛路小学
1986.09-1988.06