iOS即时通信之XMPP框架的使用及原理简介

@property (nonatomic, strong)XMPPvCardTempModule *vCard;//电子名片模块

@property (nonatomic, strong)

XMPPReconnect *reconnect;// 自动连接模块

    //添加自动连接模块

    _reconnect = [[XMPPReconnectalloc]init];

    [_reconnect activate:_xmppStream];

@property (nonatomic, strong)XMPPRosterCoreDataStorage *rosterStorage;//花名册数据存储

@property (nonatomic, strong)XMPPRoster *roster;//花名册模块

    //添加花名册模块【获取好友列表】

    _rosterStorage = [[XMPPRosterCoreDataStoragealloc]init];

    _roster = [[XMPPRosteralloc]initWithRosterStorage:_rosterStorage];

    [_roster activate:_xmppStream];

//方法一:    通过上下文  获取好友数据

    // 1.获取对象管理上下文【关联到数据库XMPPRoster.sqlite】

    NSManagedObjectContext *context =rosterStorage.mainThreadManagedObjectContext;

    // 2.FetchRequest【查哪张表】通过实体(相当于表)查找

    NSFetchRequest *request = [NSFetchRequestfetchRequestWithEntityName:@"XMPPUserCoreDataStorageObject"];

    // 3.设置过滤和排序

    // 过滤当前登录用户的好友

    NSString *jid = [WCUserInfosharedWCUserInfo].jid;

    NSPredicate *pre = [NSPredicatepredicateWithFormat:@"streamBareJidStr = %@",jid];

    request.predicate = pre;

    //排序

    NSSortDescriptor *sort = [NSSortDescriptorsortDescriptorWithKey:@"displayName"ascending:YES];

    request.sortDescriptors = @[sort];

    // 4.执行请求获取数据集合(集合里面的元素都是XMPPUserCoreDataStorageObject类型)

    self.friends = [contextexecuteFetchRequest:requesterror:nil];

    NSLog(@"%@",self.friends);

<NSFetchedResultsControllerDelegate>协议

{

    NSFetchedResultsController *_resultsContrl;

}

#pragma mark 当数据的内容发生改变后，会调用这个方法

-(void)controllerDidChangeContent:(NSFetchedResultsController *)controller{

    WCLog(@"数据发生改变");

    //刷新表格

    [self.tableViewreloadData];

}

-(NSInteger)tableView:(UITableView *)tableView numberOfRowsInSection:(NSInteger)section{

    return_resultsContrl.fetchedObjects.count;

}

- (UITableViewCell *)tableView:(UITableView *)tableView cellForRowAtIndexPath:(NSIndexPath *)indexPath

{

    staticNSString *ID =@"ContactCell";

    UITableViewCell *cell = [tableViewdequeueReusableCellWithIdentifier:ID];

    // 获取对应好友

    //XMPPUserCoreDataStorageObject *friend =self.friends[indexPath.row];

    XMPPUserCoreDataStorageObject *friend = _resultsContrl.fetchedObjects[indexPath.row];//通过传控制器获取的好友实体对象

    //    sectionNum

    //    “0”- 在线

    //    “1”- 离开

    //    “2”- 离线

    switch ([friend.sectionNumintValue]) {//好友对象的状态

        case 0:

            cell.detailTextLabel.text =@"在线";

            break;

        case 1:

            cell.detailTextLabel.text =@"离开";

            break;

        case 2:

            cell.detailTextLabel.text =@"离线";

            break;

        default:

            break;

    }

    cell.textLabel.text = friend.jidStr;//jid的类型是xxx@aaa.com

    return cell;

}

openfire服务器删除好友后,下面这个方法会接收到删除好友的消息后,花名册模块就会吧数据库roster.sqlite相应的好友删除

-(void)controllerDidChangeContent:(NSFetchedResultsController *)controller,

// 删除好友,  实现这个方法，cell往左滑就会有个delete

-(void)tableView:(UITableView *)tableView commitEditingStyle:(UITableViewCellEditingStyle)editingStyle forRowAtIndexPath:(NSIndexPath *)indexPath{

    if (editingStyle ==UITableViewCellEditingStyleDelete) {

        WCLog(@"删除好友");

        XMPPUserCoreDataStorageObject *friend =_resultsContrl.fetchedObjects[indexPath.row];

        XMPPJID *freindJid = friend.jid;

        [[WCXMPPTool sharedWCXMPPTool].roster removeUser:freindJid];

    }

}

-(BOOL)textFieldShouldReturn:(UITextField *)textField{

    // 添加好友

    // 1.获取好友账号

    NSString *user = textField.text;

    WCLog(@"%@",user);

    // 判断这个账号是否为手机号码

    if(![textField isTelphoneNum]){

        //提示

        [self showAlert:@"请输入正确的手机号码"];

        return YES;

    }

    //判断是否添加自己

    if([user isEqualToString:[WCUserInfosharedWCUserInfo].user]){

        [self showAlert:@"不能添加自己为好友"];

        return YES;

    }

    NSString *jidStr = [NSStringstringWithFormat:@"%@@%@",user,domain];

    XMPPJID *friendJid = [XMPPJIDjidWithString:jidStr];

    //判断好友是否已经存在

    if([[WCXMPPToolsharedWCXMPPTool].rosterStorageuserExistsWithJID:friendJidxmppStream:[WCXMPPToolsharedWCXMPPTool].xmppStream]){

        [self showAlert:@"当前好友已经存在"];

        return YES;

    }

    // 2.发送好友添加的请求

    // 添加好友,xmpp有个叫订阅

    [[WCXMPPToolsharedWCXMPPTool].rostersubscribePresenceToUser:friendJid];

    return YES;

}

-(void)showAlert:(NSString *)msg{

    UIAlertView *alert = [[UIAlertViewalloc]initWithTitle:@"温馨提示"message:msgdelegate:nilcancelButtonTitle:@"谢谢"otherButtonTitles:nil,nil];

    [alert show];

}

@end

// 消息模块

消息功能模块-------"XMPPMessageArchiving.h"

消息数据存储------"XMPPMessageArchivingCoreDataStorage.h"

消息实体对象-------XMPPMessageArchiving_Message_CoreDataObject.h

最近联系人实体对象------XMPPMessageArchiving_Contact_CoreDataObject.h

#pragma mark 加载XMPPMessageArchiving数据库的数据显示在表格

-(void)loadMsgs{

    // 上下文

    NSManagedObjectContext *context = [WCXMPPToolsharedWCXMPPTool].msgStorage.mainThreadManagedObjectContext;

    // 请求对象

    NSFetchRequest *request = [NSFetchRequestfetchRequestWithEntityName:@"XMPPMessageArchiving_Message_CoreDataObject"];

    // 过滤、排序

    // 1.当前登录用户的JID的消息

    // 2.好友的Jid的消息

    NSPredicate *pre = [NSPredicatepredicateWithFormat:@"streamBareJidStr = %@ AND bareJidStr = %@",[WCUserInfosharedWCUserInfo].jid,self.friendJid.bare];

    NSLog(@"%@",pre);

    request.predicate = pre;

    // 时间升序

    NSSortDescriptor *timeSort = [NSSortDescriptorsortDescriptorWithKey:@"timestamp"ascending:YES];

    request.sortDescriptors = @[timeSort];

    // 查询

    _resultsContr = [[NSFetchedResultsControlleralloc]initWithFetchRequest:requestmanagedObjectContext:contextsectionNameKeyPath:nilcacheName:nil];

    NSError *err = nil;

    // 代理

    _resultsContr.delegate =self;

    [_resultsContr performFetch:&err];

    NSLog(@"%@",_resultsContr.fetchedObjects);

    if (err) {

        WCLog(@"%@",err);

    }

}

#pragma mark -表格的数据源

-(NSInteger)tableView:(UITableView *)tableView numberOfRowsInSection:(NSInteger)section{

    return_resultsContr.fetchedObjects.count;

}

- (UITableViewCell *)tableView:(UITableView *)tableView cellForRowAtIndexPath:(NSIndexPath *)indexPath

{

    static NSString *ID =@"ChatCell";

    UITableViewCell *cell = [tableViewdequeueReusableCellWithIdentifier:ID];

    if (!cell) {

        cell = [[UITableViewCellalloc]initWithStyle:UITableViewCellStyleSubtitlereuseIdentifier:ID];

    }

    // 获取聊天消息对象

    XMPPMessageArchiving_Message_CoreDataObject *msg = _resultsContr.fetchedObjects[indexPath.row];

    // 判断是图片还是纯文本

    NSString *chatType = [msg.messageattributeStringValueForName:@"bodyType"];

    if ([chatType isEqualToString:@"image"]) {

        //下图片显示

        [cell.imageViewsd_setImageWithURL:[NSURLURLWithString:msg.body]placeholderImage:[UIImageimageNamed:@"DefaultProfileHead_qq"]];

        cell.textLabel.text =nil;

    }else if([chatTypeisEqualToString:@"text"]){

        //显示消息

        if ([msg.outgoingboolValue]) {//自己发

            cell.textLabel.text = msg.body;

        }else{//别人发的

            cell.textLabel.text = msg.body;

        }

        cell.imageView.image =nil;

    }

//    //显示消息

//    if ([msg.outgoing boolValue]) {//自己发

//        cell.textLabel.text = [NSString stringWithFormat:@"Me: %@",msg.body];

//    }else{//别人发的

//        cell.textLabel.text = [NSString stringWithFormat:@"Other: %@",msg.body];

//    }

    return cell;

}

#pragma mark ResultController的代理

-(void)controllerDidChangeContent:(NSFetchedResultsController *)controller{

    // 刷新数据

    [self.tableViewreloadData];

    [selfscrollToTableBottom];

}

#pragma mark TextView的代理

-(void)textViewDidChange:(UITextView *)textView{

    //获取ContentSize

    CGFloat contentH = textView.contentSize.height;

    NSLog(@"textView的content的高度 %f",contentH);

    // 大于33，超过一行的高度/小于68高度是在三行内

    if (contentH > 33 && contentH < 68 ) {

        self.inputViewHeightConstraint.constant = contentH +18;

    }

    NSString *text = textView.text;

    // 换行就等于点击了的send

    if ([text rangeOfString:@"\n"].length !=0) {

        NSLog(@"发送数据 %@",text);

        // 去除换行字符

        text = [text stringByTrimmingCharactersInSet:[NSCharacterSetwhitespaceAndNewlineCharacterSet]];

        [selfsendMsgWithText:textbodyType:@"text"];

        //清空数据

        textView.text = nil;

        // 发送完消息 把inputView的高度改回来

        self.inputViewHeightConstraint.constant =50;

    }else{

        NSLog(@"%@",textView.text);

    }

}

#pragma mark 发送聊天消息

-(void)sendMsgWithText:(NSString *)text bodyType:(NSString *)bodyType{

    XMPPMessage *msg = [XMPPMessagemessageWithType:@"chat"to:self.friendJid];

    //text 纯文本

    //image 图片

    [msg addAttributeWithName:@"bodyType"stringValue:bodyType];

    // 设置内容

    [msg addBody:text];

     NSLog(@"%@",msg);

    [[WCXMPPToolsharedWCXMPPTool].xmppStreamsendElement:msg];

}

#pragma mark 滚动到底部

-(void)scrollToTableBottom{

    NSInteger lastRow =_resultsContr.fetchedObjects.count -1;

    if (lastRow < 0) {

        //行数如果小于0，不能滚动

        return;

    }

    NSIndexPath *lastPath = [NSIndexPathindexPathForRow:lastRowinSection:0];

    [self.tableViewscrollToRowAtIndexPath:lastPathatScrollPosition:UITableViewScrollPositionBottomanimated:YES];

}

#pragma mark 选择图片

-(void)addBtnClick{

    UIImagePickerController *imagePicker = [[UIImagePickerControlleralloc]init];

    imagePicker.sourceType =UIImagePickerControllerSourceTypePhotoLibrary;

    imagePicker.delegate = self;

    [selfpresentViewController:imagePickeranimated:YEScompletion:nil];

}

#pragma mark 选取后图片的回调

-(void)imagePickerController:(UIImagePickerController *)picker didFinishPickingMediaWithInfo:(NSDictionary *)info{

    NSLog(@"%@",info);

    // 隐藏图片选择器的窗口

    [selfdismissViewControllerAnimated:YEScompletion:nil];

    // 获取图片

    UIImage *image = info[UIImagePickerControllerOriginalImage];

    // 把图片发送到文件服务器

    //http post put

    /**

     * put实现文件上传没post那烦锁，而且比POST快

     * put的文件上传路径就是下载路径

     *文件上传路径http://localhost:8080/imfileserver/Upload/Image/ + "图片名【程序员自已定义】"

     */

    // 1.取文件名用户名 +时间(201412111537)年月日时分秒

    NSString *user = [WCUserInfosharedWCUserInfo].user;

    NSDateFormatter *dataFormatter = [[NSDateFormatteralloc]init];

    dataFormatter.dateFormat = @"yyyyMMddHHmmss";

    NSString *timeStr = [dataFormatter stringFromDate:[NSDate date]];

    // 针对我的服务，文件名不用加后缀

    NSString *fileName = [user stringByAppendingString:timeStr];

    // 2.拼接上传路径

    NSString *uploadUrl = [@"http://localhost:8080/imfileserver/Upload/Image/"stringByAppendingString:fileName];

    // 3.使用HTTP put上传

#warning 图片上传请使用jpg格式因为我写的服务器只接接收jpg

    [self.httpTooluploadData:UIImageJPEGRepresentation(image,0.75)url:[NSURLURLWithString:uploadUrl]progressBlock:nilcompletion:^(NSError *error) {

        if (!error) {

            NSLog(@"上传成功");

            [self sendMsgWithText:uploadUrl bodyType:@"image"];

        }

    }];

    // 图片发送成功，把图片的URL传Openfire的服务

}

-(void)dealloc{

    [selfteardownXmpp];

}

#pragma mark 释放xmppStream相关的资源

-(void)teardownXmpp{

    // 移除代理

    [_xmppStreamremoveDelegate:self];

    // 停止模块

    [_reconnect deactivate];

    [_vCarddeactivate];

    [_avatardeactivate];

    [_rosterdeactivate];

    [_msgArchivingdeactivate];

    // 断开连接

    [_xmppStream disconnect];

    // 清空资源

    _reconnect = nil;

    _vCard = nil;

    _vCardStorage =nil;

    _avatar = nil;

    _roster = nil;

    _rosterStorage =nil;

    _msgArchiving =nil;

    _msgStorage = nil;

    _xmppStream = nil;

}

#pragma mark 接收到好友消息时调用的代理方法

-(void)xmppStream:(XMPPStream *)sender didReceiveMessage:(XMPPMessage *)message{

    WCLog(@"%@",message);

    //如果当前程序不在前台，发出一个本地通知

    if([UIApplicationsharedApplication].applicationState !=UIApplicationStateActive){

        WCLog(@"在后台");

        //本地通知

        UILocalNotification *localNoti = [[UILocalNotificationalloc] init];

        // 设置内容

        localNoti.alertBody = [NSStringstringWithFormat:@"%@\n%@",message.fromStr,message.body];

        // 设置通知执行时间

        localNoti.fireDate = [NSDatedate];

        //声音

        localNoti.soundName = @"default";

        //执行

        [[UIApplicationsharedApplication] scheduleLocalNotification:localNoti];

        //{"aps":{'alert':"zhangsan\n have dinner":'sound':'default',badge:'12'}}

    }

}

//好友在线状态改变的代理方法

-(void)xmppStream:(XMPPStream *)sender didReceivePresence:(XMPPPresence *)presence{

    //XMPPPresence 在线 离线

    //presence.from 消息是谁发送过来

}