啟動本地服務 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方法,最后在調用onForeground和makesureLongLinkConnect中間的順序可以隨意
注意: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
