Golang 在接入层长连接服务中的实践 黄欣 基础平台－架构部 目录 • 背景 • 架构 • 心得 目录 • 架构 • 心得 背景—why 长连接？ • 业务场景 – 大量实时计算 • 司机乘客撮合 • 实时计价 – 高频度的数据交互 • 坐标数据 • 计价数据 – App和服务端双向可达 • 上行（抢单） • 下行（派单） 背景—why golang？ • 开发效率 rsp || nil So easy, So efficient 心得—coding—实现 • what’s diff？ – conn svr • 常驻内存，内存中有个大连接对象map（资源问题） • 请求都是基于连接的(如果模块间存在资源的互相引用，当资源变更的情况 下，容易发生panic)（竟态问题） • 对象编程 – 封装：conn资源（包括goruntine）作为结构体封装起来，保证所有资源 statusLoop() 心得—profiling • Timer优化 • Channel使用优化 心得—timer优化 • 为什么需要优化？ – 万级别的连接 – 每个连接上大量的定时任务（心跳检测，注册检测，认证检测） 实际情况：当10w左右连接，什么数据不收发，只有定时器检测心跳超时，cpu 能耗掉一个core • 怎么优化？ – 特点： • 秒级别定时任务 • 范围最多60s – 方案：

类的加载、连接和初始化 类加载器 使用反射生成并操作对象 本节习题 Java 应用与开发 类加载和反射 王晓东 wangxiaodong@ouc.edu.cn 中国海洋大学 December 24, 2018 大纲 反射 类的加载、连接和初始化 类加载器 使用反射生成并操作对象 本节习题 学习目标 1. 理解什么是反射机制，通过常见场景认识反射的作用。 2. 掌握类的加载、连接和初始化概念。 大纲 反射 类的加载、连接和初始化 类加载器 使用反射生成并操作对象 本节习题 大纲 反射 类的加载、连接和初始化 类加载器 使用反射生成并操作对象 本节习题 大纲 反射 类的加载、连接和初始化 类加载器 使用反射生成并操作对象 本节习题 接下来⋯ 反射 类的加载、连接和初始化 类加载器 使用反射生成并操作对象 本节习题 大纲 反射 类的加载、连接和初始化 类加载器 使用反射生成并操作对象 全未知的类。换句话说，Java 程序可以加载一个运行时才 得知名称的类，获悉其完整构造（但不包括 methods 定义）， 并生成其对象实体、或对其 fields 设值、或唤起调用其 methods。 大纲 反射 类的加载、连接和初始化 类加载器 使用反射生成并操作对象 本节习题 反射机制 ▶ 反射机制是 Java 语言在运行时所拥有的一项自观能力。通 过这种能力可以彻底的了解自身的情况为下一步的动作做准 备。 ▶

9% 推送完成；10w 级，SLA 承诺 1w 实例上下线 3s，99.9% 推送完成；100w 级别，SLA 承诺 1w 实例上下线 9s 99.9% 推送完成。 规模：十万级服务/配置，百万级连接，具备强大扩展性。 15 > 简介 Nacos 生态 Nacos 几乎支持所有主流语言，其中 Java/Golang/Python 已经支持 Nacos 2.0 长链接协议，能 最大限度发挥 profiles.active}-${file-extension} 配置快照（Configuration Snapshot） Nacos 的客户端 SDK 会在本地生成配置的快照。当客户端无法连接到 Nacos Server 时，可以使 用配置快照显示系统的整体容灾能力。配置快照类似于 Git 中的本地 commit，也类似于缓存，会 在适当的时机更新，但是并没有缓存过期（expiration）的概念。 架构 1. Nacos 提供可视化的控制台，可以对配置进行发布、更新、删除、灰度、版本管理等功能。 2. SDK 可以提供发布配置、更新配置、监听配置等功能。 3. SDK 通过 GRPC 长连接监听配置变更，Server 端对比 Client 端配置的 MD5 和本地 MD5 是否相等，不相等推送配置变更。 4. SDK 会保存配置的快照，当服务端出现问题的时候从本地获取。 配置资源模型

example, an incoming HTTP request will not emit 'close'.) 当底层的文件描述符被关闭时触发此事件，并不是所有流都会触发这个事件。 （例如，一个连接进入的 HTTP request 流就不会触发'close'事件。） Event: 'fd' 事件：'fd' function (fd) { } Emitted when a file descriptor source streams are kept in sync by pausing and resuming as necessary. 用于将这个可读流和 destination 目标可写流连接起来，传入这个流中的数据 将会写入到 destination 流中。通过在必要时暂停和恢复流，来源流和目的流 得以保持同步。 Emulating the Unix cat command: 模拟 HTTPS net or http connection. 加密模块需要底层系统提供 OpenSSL 的支持。它提供了一种安全凭证的封装方 式，可以用于 HTTPS 安全网络以及普通 HTTP 连接。 It also offers a set of wrappers for OpenSSL's hash, hmac, cipher, decipher, sign and verify methods

中删除，保障了系 统安全性。 • 黑 黑 黑白 白 白名 名 名单 单 单机 机 机制 制 制：每个群组仅可接收相应群组的消息，保证群组间网络通信的隔离性；CA黑名单机 制可及时与作恶节点断开网络连接，保障了系统安全。 • 权 权 权限 限 限管 管 管理 理 理机 机 机制 制 制：基于分布式存储权限控制机制，灵活、细粒度地控制外部账户部署合约和创建、 插入、删除和更新用户表的权限。 • 支 新增SDK连接节点支持国密SSL，可配置是否启用 • 新增账号管理可冻结解冻私钥对应的账号 更 更 更改 改 改 • MySQL存储模式下，合约表的字段类型修改为mediumblob • 国密模式由编译选项修改为配置项 2.1. v2.5.0 9 FISCO BCOS Documentation, 发 发 发布 布 布 v2.5.0 • 更改节点只接受同一机构的SDK连接，可配置是否启用 build_chain脚本使用私钥为secp256k1的根证书和机构证书 • PBFTBackup的存储由LevelDB修改为RocksDB • 重构libdevcrypto模块，优化代码结构，使用TASSL实现国密和非国密TLS连接 • 优化存储模块openTable的锁实现 • 优化区块数据编码为并行 • 优化大对象析构耗时为异步 • 优化日志输出机制，降低日志输出对性能的影响 • 优化MHD和交易池模块的线程数，减少内存占用

log('stats: ' + JSON.stringify(stats)); }); }); 当执行动作繁杂时，强烈建议使用异步方式调用此类。同步方式在其完成之前将会阻挡一切随后的动作，这代 表搁置所有连接。 fs.rename(path1, fs.rename(path1, fs.rename(path1, fs.rename(path1, path2, path2, path2, path2, [callback]) lstat(path, [callback]) [callback]) [callback]) [callback]) 利用路径异步读取属性(lstat(2))。如果这个文件参数是一个符号连接，则返回该符号连接的属性。回调函数的第 二个参数是 fs.Stats 对象。(err, stats) fs.fstat(fd, fs.fstat(fd, fs.fstat(fd, fs.fstat(fd, 共同学习 NodeJS，欢迎加入。 27 异步建立连接(link(2))。只传递异常给回调函数。 fs.linkSync(dstpath, fs.linkSync(dstpath, fs.linkSync(dstpath, fs.linkSync(dstpath, srcpath) srcpath) srcpath) srcpath) 同步建立连接(link(2))。 fs.symlink(linkdata

支持Channel Message v2协议 • 节点连接支持域名配置 • 部署合约的二进制长度放宽至256K • 交易出错打印更全面的日志 • build_chain.sh生成的SDK证书名更名为sdk.crt和sdk.key • 为提升性能进行了代码实现细节的调整 • 降低了节点内存的占用 修 修 修复 复 复 • 修复了在某种场景下channel连接抛异常的错误 兼 兼 兼容 容 容性 性 0-rc3新 特性 • v2.0.0-rc3 Release Note 3.4.1 变 变 变更 更 更描 描 描述 述 述 新 新 新特 特 特性 性 性 • 分布式存储：新增支持底层通过数据库连接池直连MySQL • 分布式存储：新增支持RocksDB引擎，搭建新链时存储默认采用RocksDB 3.3. v2.0.0 15 FISCO BCOS Documentation, 发 发 发布 系统运行过程中，可通过监控系统对各种运行指标进行监控，对系统的健康程度进行评估，当出现故障 时发出告警通知，便于运维快速反应，进行处理。 监控的维度包括基础环境监控,如CPU占比、系统内存占比和增长、磁盘IO情况、网络连接数和流量等。 区块链系统监控包括如区块高度、交易量和虚拟机计算量，共识节点出块投票情况等。 接口监控包括如接口调用计数、接口调用耗时情况、接口调用成功率等。 监控数据可以通过日志或网络接口进行

中删除，保障了系 统安全性。 • 黑 黑 黑白 白 白名 名 名单 单 单机 机 机制 制 制：每个群组仅可接收相应群组的消息，保证群组间网络通信的隔离性；CA黑名单机 制可及时与作恶节点断开网络连接，保障了系统安全。 • 权 权 权限 限 限管 管 管理 理 理机 机 机制 制 制：基于分布式存储权限控制机制，灵活、细粒度地控制外部账户部署合约和创建、 插入、删除和更新用户表的权限。 • 支 支持Channel Message v2协议 • 节点连接支持域名配置 • 部署合约的二进制长度放宽至256K • 交易出错打印更全面的日志 • build_chain.sh生成的SDK证书名更名为sdk.crt和sdk.key • 为提升性能进行了代码实现细节的调整 • 降低了节点内存的占用 修 修 修复 复 复 • 修复了在某种场景下channel连接抛异常的错误 兼 兼 兼容 容 容性 性 0-rc3新 特性 • v2.0.0-rc3 Release Note 2.6.1 变 变 变更 更 更描 描 描述 述 述 新 新 新特 特 特性 性 性 • 分布式存储：新增支持底层通过数据库连接池直连MySQL • 分布式存储：新增支持RocksDB引擎，搭建新链时存储默认采用RocksDB • 分布式存储：新增CRUD接口支持，控制台1.0.3以上版本提供类SQL语句读写区块链数据

支持Channel Message v2协议 • 节点连接支持域名配置 • 部署合约的二进制长度放宽至256K • 交易出错打印更全面的日志 • build_chain.sh生成的SDK证书名更名为sdk.crt和sdk.key • 为提升性能进行了代码实现细节的调整 • 降低了节点内存的占用 修 修 修复 复 复 • 修复了在某种场景下channel连接抛异常的错误 兼 兼 兼容 容 容性 性 0-rc3新 特性 • v2.0.0-rc3 Release Note 3.5.1 变 变 变更 更 更描 描 描述 述 述 新 新 新特 特 特性 性 性 • 分布式存储：新增支持底层通过数据库连接池直连MySQL • 分布式存储：新增支持RocksDB引擎，搭建新链时存储默认采用RocksDB 16 Chapter 3. 版 版 版本 本 本及 及 及兼 兼 兼容 容 容 FISCO BCOS 系统运行过程中，可通过监控系统对各种运行指标进行监控，对系统的健康程度进行评估，当出现故障 时发出告警通知，便于运维快速反应，进行处理。 监控的维度包括基础环境监控,如CPU占比、系统内存占比和增长、磁盘IO情况、网络连接数和流量等。 区块链系统监控包括如区块高度、交易量和虚拟机计算量，共识节点出块投票情况等。 接口监控包括如接口调用计数、接口调用耗时情况、接口调用成功率等。 监控数据可以通过日志或网络接口进行