Message：
接着写
.h
1 /*! 2 * @Author Dylan. 3 * 4 * callback Block 5 */ 6 typedef void(^sendSuccess)(); 7 typedef void(^sendFailure)(id); 8 9 /*! 10 * sendMessageBy model 11 */ 12 - (void)sendMessage: (ADMessageModel *)message 13 sendSuccess: (sendSuccess)success 14 sendFailure: (sendFailure)failure; 15 16 /*! 17 * @Author Dylan. 18 * 19 * unRead Msg 20 */ 21 @property (nonatomic, strong) NSMutableDictionary * unReadMsg; 22 23 /*! 24 * @Author Dylan. 25 * 26 * new Msg 27 */ 28 @property (nonatomic, copy) void (^newMessage) (id); 29 30 31 @end
.m
1 #pragma mark - initData 2 - (void)initData { 3 // 可做数据持久化 4 self.unReadMsg = [NSMutableDictionary dictionary]; 5 } 6 7 #pragma mark Methods 8 - (void)sendMessage: (ADMessageModel *)message 9 sendSuccess: (sendSuccess)success 10 sendFailure: (sendFailure)failure { 11 12 // set callback block 13 self.success = success; 14 self.failure = failure; 15 16 NSXMLElement * body = [NSXMLElement elementWithName:@"body"]; 17 [body setStringValue:message.body]; 18 19 //生成XML消息文档 20 NSXMLElement *mes = [NSXMLElement elementWithName:@"message"]; 21 //消息类型 22 [mes addAttributeWithName:@"type" stringValue:@"chat"]; 23 //发送给谁 24 [mes addAttributeWithName:@"to" stringValue:message.to]; 25 //由谁发送 26 [mes addAttributeWithName:@"from" stringValue:message.from]; 27 //组合 28 [mes addChild:body]; 29 //发送消息 30 [[self xmppStream] sendElement:mes]; 31 } 32 33 #pragma mark - delegeteMethods 34 - (void)xmppStream:(XMPPStream *)sender didReceiveMessage:(XMPPMessage *)message { 35 36 NSString * body = [[message elementForName:@"body"] stringValue]; 37 NSString * from = [[message attributeForName:@"from"] stringValue]; 38 39 if (body != nil) { 40 41 NSMutableDictionary * msgDict = [NSMutableDictionary dictionary]; 42 ADMessageModel * model = [[ADMessageModel alloc] init]; 43 model.body = body; 44 model.from = from; 45 [msgDict setValue:model forKey:[ADCurrentTime getCurrentTime]]; 46 47 if ([from isEqualToString:[[NSUserDefaults standardUserDefaults] stringForKey:CURRENT_CHAT]]) { 48 49 self.newMessage(msgDict); 50 } else { 51 // not current chat 52 if ([_unReadMsg.allKeys containsObject:from]) { 53 [_unReadMsg[from] addObject:model]; 54 } else { 55 [_unReadMsg setValue:[NSMutableArray arrayWithObject:msgDict] forKey:from]; 56 } 57 } 58 59 } 60 } 61 62 @end