基于Telegram二次开发 --- MTProtoKit 架构

MTProtoTelegram 的核心协议,旨在支持多种传输协议;当前版本的 Telegram-iOS 仅支持 TCP 传输;HTTP 传输已于 2018 年删除;VoIP 模块 libtgvoip 支持 UDP 和 TCP 传输。

Telegram-iOS 在 Network 内置了用于冷启动的种子地址:

let seedAddressList: [Int: [String]]
seedAddressList = [
    1: ["149.154.175.50", "2001:b28:f23d:f001::a"],  
    2: ["149.154.167.50", "2001:67c:4e8:f002::a"],    
    3: ["149.154.175.100", "2001:b28:f23d:f003::a"],  
    4: ["149.154.167.91", "2001:67c:4e8:f004::a"],    
    5: ["149.154.171.5", "2001:b28:f23f:f005::a"]     
]

如果二次开发是部署在自己的服务器上,可以在 Network 对地址进行更改;需要注意,默认端口是 443

context.setSeedAddressSetForDatacenterWithId(id, seedAddressSet: MTDatacenterAddressSet(addressList: ips.map { MTDatacenterAddress(ip: $0, port: 443, preferForMedia: false, restrictToTcp: false, cdn: false, preferForProxy: false, secret: nil) }))

可以在 这里 更改端口地址。


MTProto 简介

对于这个 MTProto 官方文档给出如下定义:

The protocol is designed for access to a server API from applications running on mobile devices. It must be emphasized that a web browser is not such an application.

也就是说,MTProto 是一个 Telegram 自定义的通讯协议,用于移动端 App 与服务器交互数据使用。这里还特别指出了,一个浏览器不能算是移动端 App,所以这个协议不适用于 HTML5 之类的网页客户端。

现在我们大体知道了,MTProto 是一种协议,那么 MTProtoKit 就是对该协议实现的封装,使得我们能够更方便的使用这样的协议。

MTProtoKit 在 Telegram 中的架构

image.png
  • 有一个依赖链可以让 UI 控制器访问 Network 模块;大多数控制器依赖于 Accountdata model,它是 AccountUnauthorizedAccount 的实例。
  • Account classes 公开其 Network 实例字段以供控制器发送请求。
public class UnauthorizedAccount {
    ...
    public let network: Network
    ...
}

public class Account {
    ...
    public let network: Network
    ...
}
  • Network 封装与 MTProtoKit 模块的所有交互,并将 RPC 请求-响应对 建模为 Signals
/* Code snippets from Network.swift */
public final class Network: NSObject, MTRequestMessageServiceDelegate {
    ...
    func background() -> Signal<Download, NoError>
    
    public func request<T>(
        _ data: (FunctionDescription, Buffer, DeserializeFunctionResponse<T>), 
        tag: NetworkRequestDependencyTag? = nil, 
        automaticFloodWait: Bool = true
        ) -> Signal<T, MTRpcError>
    ...
}

// a Signal operator to retry a RPC
public func retryRequest<T>(signal: Signal<T, MTRpcError>) -> Signal<T, NoError>

/* A code snippet to request login code from `Authorization.swift` */
// construct an MTProto API object
let sendCode = 
    Api.functions.auth.sendCode(
        flags: 0, 
        phoneNumber: phoneNumber, 
        currentNumber: nil, 
        apiId: apiId, 
        apiHash: apiHash)
// send the API via `network`
account.network.request(sendCode, automaticFloodWait: false)
  • MTProtoKit 模块实现了端点信息、授权数据、连接生命周期、连接和协议加密等所有复杂逻辑

MTProtoKit 核心类

  • MTContext:它是大多数 MTProtoKit 类的上下文,通过共享和维护所有数据中心的重要数据,例如地址、授权信息等;它在当前设计中不是单例,所以可以有多个实例。
  • MTProto:它是向特定数据中心发送消息的核心管理器;它主要负责管理消息服务(MTMessageService),给予消息服务适当的运行上下文(MTContext),并且负责传输由消息服务所构建的消息事务(MTMessageTransaction)。
  • MTTcpTransport:它管理一个 TCP 连接;一个 MTProto 实例最多可以存在一个传输活动。
  • MTMessageService:消息服务,它是一个 Objective-C 协议,这个协议是 MTProto 的一个 Observer,也就是说,它会监听 MTProto 所有发布的事件,定义了处理 RPC 的方法,以此来控制自身实现逻辑;一个 MTProto 实例可以有多个 MTMessageService 实例。
  • MTMessageTransaction:消息事务,这是非常高级的一个特性,它内部保持了一系列需要发送的消息,并提供了一个所有消息发送完毕的回调。
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容