RTMP协议蓝牙传输数据
RTMP传统定义
rtmp协议中基本的数据单元被称为消息（message）结构一般为：
- 时戳：4 byte，单位毫秒。超过最大值后会翻转。
- 长度：消息负载的长度。
- 类型ID：Type Id 一部分ID范围用于rtmp的控制信令。还有一部分可以供上层使用，rtmp只是透 传。这样可以方便的在rtmp上进行扩展。
- 消息流ID：Message Stream ID，用于区分不同流的消息。
消息结构
消息在网络中传输时，会被分割成很多小的消息块，进行传输，增加传输的效率，而这些消息块是由消息头+消息体组成，消息头就是制定的标识消息的协议，消息体就是所传输的消息内容。
RTMP在蓝牙中的定义
手机蓝牙传输数据，无法保证双方手机时间同步，因此刨除时间戳定义改为固定字符串，因此messageHeader定义为：
struct message_header
{
uint32_t magic;//magic number, 0x98765432
uint32_t total;//包长度，从这一字段头算起
uint32_t msgid;//消息ID
uint32_t seqnum;//客户端使用,自增量
uint32_t version;//协议版本，目前为1
};
将需要传输的数据添加message_header
//GPBMEssage为protobuf库里的类,请参考上篇文章
-(NSMutableData*)returnData:(GPBMessage*)req messageId:(int)messageId {
NSString *header=[NSString stringWithFormat:@"98765432%08lx%08x%08lx00000001",(unsigned long)req.data.length+20,messageId,(unsigned long)++self.header_count];
Byte bytes[40];
int j=0;
for(int i=0;i*2+1<header.length;i++)
{
int int_ch; /// 两位16进制数转化后的10进制数
const char* hex_char=[[header substringWithRange:NSMakeRange(i*2, 2)] UTF8String];
int_ch = (int)strtoul(hex_char, 0, 16);
// DLog(@"int_ch=%d",int_ch);
bytes[j] = int_ch; ///将转化后的数放入Byte数组里
j++;
}
NSMutableData *data = [[NSMutableData alloc] init];
[data appendBytes:bytes length:j];
[data appendData:req.data];
return data;
}
接受到数据后，需要把长度小于message_header长度的数据进行拼包，并解析message_header结构
//解析数据message_header结构
-(void)parseSocketReceiveData:(NSData*)data result:(void (^)(NSData*result ,int messageId,int hearderId))resultBlock finish:(void(^)())finishBlockMessage{
if (_halfData.length>0) {
[_halfData appendData:data];
data=[_halfData copy];
_halfData =[[NSMutableData alloc]init];
}else{
data=[data copy];
}
if (data.length<20) {
[_halfData appendData:data];
if (finishBlockMessage) {
finishBlockMessage();
}
return;
}
Byte *testByte = (Byte*)[data bytes];
int length=(int) ((testByte[4] & 0xFF<<24)
| ((testByte[5] & 0xFF)<<16)
| ((testByte[6] & 0xFF)<<8)
| ((testByte[7] & 0xFF)));
int messageId=(int) ((testByte[8] & 0xFF<<24)
| ((testByte[9] & 0xFF)<<16)
| ((testByte[10] & 0xFF)<<8)
| ((testByte[11] & 0xFF)));
int headerId=(int)((testByte[12] & 0xFF<<24)
| ((testByte[13] & 0xFF)<<16)
| ((testByte[14] & 0xFF)<<8)
| ((testByte[15] & 0xFF)));
if(length==data.length){
if (resultBlock) {
resultBlock([data subdataWithRange:NSMakeRange(20, length-20)],messageId,headerId);
}
if (finishBlockMessage) {
finishBlockMessage();
}
}else if(length<data.length){
if (resultBlock) {
resultBlock([data subdataWithRange:NSMakeRange(20, length-20)],messageId,headerId);
}
[self parseSocketReceiveData:[data subdataWithRange:NSMakeRange(length, data.length-length)] result:resultBlock finish: finishBlockMessage];
}else{
[_halfData appendData:data];
if (finishBlockMessage) {
finishBlockMessage();
}
}
}
小结
rtmp协议虽然加快了数据传输的效率，一定程度上的安全，但是并不是特别的安全，为避免攻击者攻击，一些安全措施还是有必要的，在这里不过多介绍，有兴趣自己调研。
最后
代码具体实现地址
代码中具体实现了两个棋类游戏，包括在线对战，人机对战（算法不错哦），蓝牙对战。
代码编写不易，喜欢的请点赞，谢谢！
