Mars筆記

官方文檔

啟動本地服務 cd 到 server文件夾中執(zhí)行 python start_server.py命令

Mars是微信提供的終端基礎組件,是跨平臺的

主要包括以下幾個部分
  • comm : 基礎庫,包括socket、線程、消息隊列、協(xié)程等基礎工具
  • Xlog : 通用日志模塊,提供高性能、高可用、安全性、容錯性的日志功能
  • SDT : 網(wǎng)絡診斷模塊
  • STN : 信令傳輸網(wǎng)絡模塊,負責終端與服務器的小數(shù)據(jù)信令通道。

消息核心流程:一個消息任務以startTask開始,onTaskEnd結束。中間通過StnCallBack::Req2Buf與StnCallBack::Buf2Resp分別處理客戶端的請求和響應的相關操作,比如數(shù)據(jù)處理,服務端響應和狀態(tài)檢測等等。

項目配置
  • 安裝 cmake 和 XCode 以及 python2.7.x
  • python build_ios.py 生成配置文件
  • 數(shù)據(jù)傳輸使用谷歌的protocol buffer
  • 添加依賴庫
    • CoreTelephony.framework
    • UIKit.framework
    • Foundation.framework
    • libz.tbd
    • SystemConfiguration.frmaework
    • libresolv9.tbd
    • mars.framework(由Mars提供的庫)

STN 網(wǎng)絡模塊初始化

  • 涉及初始化方法,在
    didFinishLaunchingWithOptions 中調用

在初始化時必須先調用setCallback方法,最后在調用onForegroundmakesureLongLinkConnect中間的順序可以隨意

注意:STN 默認是后臺,在初始化 STN 后需要主動調用一次BaseEvent.onForeground(true)

程序退出或進入后臺時,釋放STN
調用

mars::baseevent::OnDestroy();
- (void)setCallBack {
    mars::stn::SetCallback(mars::stn::StnCallBack::Instance());
    mars::app::SetCallback(mars::app::AppCallBack::Instance());
}

- (void) createMars {
    mars::baseevent::OnCreate();
}

- (void)setClientVersion:(UInt32)clientVersion {
    mars::stn::SetClientVersion(clientVersion);
}

- (void)setShortLinkDebugIP:(NSString *)IP port:(const unsigned short)port {
    std::string ipAddress([IP UTF8String]);
    mars::stn::SetShortlinkSvrAddr(port, ipAddress);
}

- (void)setShortLinkPort:(const unsigned short)port {
    mars::stn::SetShortlinkSvrAddr(port);
}

- (void)setLongLinkAddress:(NSString *)string port:(const unsigned short)port debugIP:(NSString *)IP {
    std::string ipAddress([string UTF8String]);
    std::string debugIP([IP UTF8String]);
    std::vector<uint16_t> ports;
    ports.push_back(port);
    mars::stn::SetLonglinkSvrAddr(ipAddress,ports,debugIP);
}

- (void)setLongLinkAddress:(NSString *)string port:(const unsigned short)port {
    std::string ipAddress([string UTF8String]);
    std::vector<uint16_t> ports;
    ports.push_back(port);
    mars::stn::SetLonglinkSvrAddr(ipAddress,ports);
}

數(shù)據(jù)處理

集成的時候加上日志打印 xlog,在 main中添加,因使用c++main.m,改為main.mm,方便排查問題

NSString* logPath = [[NSSearchPathForDirectoriesInDomains(NSDocumentDirectory, NSUserDomainMask, YES) objectAtIndex:0] stringByAppendingString:@"/log"];
        
        //     set do not backup for logpath
        const char* attrName = "com.apple.MobileBackup";
        u_int8_t attrValue = 1;
        setxattr([logPath UTF8String], attrName, &attrValue, sizeof(attrValue), 0, 0);
        
        //     init xlog
#if DEBUG
        xlogger_SetLevel(kLevelDebug);
        appender_set_console_log(true);
#else
        xlogger_SetLevel(kLevelInfo);
        appender_set_console_log(false);
#endif
        appender_open(kAppednerAsync, [logPath UTF8String], "Test", "");
  • 開啟一個任務
// ChannelType_LongConn  通道 有長鏈、短鏈或者兩者
// IM_CMD_LOGIN  CIMID號,自定義表示那種任務
// LONG_LINK_HOST_PROT  長鏈地址
// CGIURL  短鏈地址
CGITask * task = [[CGITask alloc] initAll:ChannelType_LongConn AndCmdId:IM_CMD_LOGIN AndCGIUri:CGIURL AndHost:LONG_LINK_HOST_PROT];
    [[NetworkService sharedInstance] startTask:task ForUI:self];

task 中關鍵字

  • taskid 任務的唯一標識,自動生成
  • channel_select 標識是長連接還是短連接獲取兩者,屬性有:
    • ChannelType_ShortConn, ChannelType_LongConn, ChannelType_All
  • cgi 短連的utl, 短連的必填
  • cmid: 長連的cgi命令號,用于標識長連請求的cgi 如: IM_CMD_LOGIN
  • 發(fā)送數(shù)據(jù)requestSendData 向服務端發(fā)送數(shù)據(jù),這里是發(fā)起登錄請求

- (NSData *)requestSendData{
    // 自定義的一個pb解析類,和自定義些參數(shù)
    ImLogin * login = [[ImLogin alloc] init];
    Head * heads = [[Head alloc] init];
    heads.cmd = IM_CMD_LOGIN; 
    heads.seq = 1; 
    heads.version = 200; 
    heads.flag = 0;
    //  這里是做登錄的,傳相應的參數(shù)給服務端
    login.head = heads;
    login.no = @"ABC";
    login.token = @"abcd";
    login.timestamp = 829374432;
    login.devId = 37489237434;
    login.role = ROLE;
    login.platformId = 1;
   //  將數(shù)據(jù)轉為data
    NSData * data = [login data];
    return data;
}
  • 收到服務返回
- (int)onPostDecode:(NSData *)responseData{
    NSError * error;
// 登錄pb解析類,解析數(shù)據(jù)
    ImLoginRes * loginRes = [ImLoginRes parseFromData:responseData error:&error];
   // 這里返回 200 表示登錄成功
    if (loginRes.code == 200) {
        dispatch_async(dispatch_get_main_queue(), ^{
            NSInteger uid = loginRes.uid;
            self.uids = loginRes.uid;
            if (self.iMLoginUserIdBlock) {
                self.iMLoginUserIdBlock(uid);
            }
        });
        // 可做登錄后的事,如:保存消息偏移量或發(fā)起消息同步等
    }
    return loginRes.code == 200 ? 0 : -1;
}
- (int)onTaskEnd:(uint32_t)tid errType:(uint32_t)errtype errCode:(uint32_t)errcode{
    return 0;
}
  • 修改心跳設置

longlink_packer.cc

修改這個方法
uint32_t (*longlink_noop_interval)() = []() -> uint32_t { return 1 * 60 * 1000; };return為0時,會執(zhí)行Mars自己的心跳邏輯

  • 設置用戶名
    為保持心跳的連接頻率,需設置用戶名,否則Mars會降低請求的頻率
AccountInfo AppCallBack::GetAccountInfo() {
    AccountInfo info;
    info.username = "wxy";
    info.uin = 11984;
    return info;
}
  • 出現(xiàn)C++方法中未定義的錯誤
    修改 Build Setting -> Apple Clang - Language - c++
    修改地方.png
最后編輯于
?著作權歸作者所有,轉載或內容合作請聯(lián)系作者
【社區(qū)內容提示】社區(qū)部分內容疑似由AI輔助生成,瀏覽時請結合常識與多方信息審慎甄別。
平臺聲明:文章內容(如有圖片或視頻亦包括在內)由作者上傳并發(fā)布,文章內容僅代表作者本人觀點,簡書系信息發(fā)布平臺,僅提供信息存儲服務。

相關閱讀更多精彩內容

友情鏈接更多精彩內容