// 1、通道管理器类  在服务器之间创建通道
@property(nonatomic,strong)XMPPStream * XMPPStream;// 好友关系（好友花名册，添加好友信息）2、 用户类
@property(nonatomic,strong)XMPPRoster * XMPPRoSter;// 这两个属性是聊天记录用到的
// XMPP的CoreData存储的类

@property(nonatomic,strong)XMPPMessageArchiving * achivimg;@property(nonatomic,strong)NSManagedObjectContext * context;// 创建单例 放进不会重复初始化的东西+(instancetype)defaultManager;// 登陆-(void)loginWithUserName:(NSString *)userName andPassWorld:(NSString *)password;// 注册-(void)registerWithUserName:(NSString *)userName andPassword:(NSString *)password;

-(id)init{self = [super init];if (self) {// 初始化自己的通道管理器类
        self.XMPPStream =[[XMPPStream alloc]init];// 服务器的名字，（在openfire后台管理里面看）
        self.XMPPStream.hostName = @"127.0.0.1";// 设置端口号， 默认是5222self.XMPPStream.hostPort = 5222;// 设置代理在主线程里面
        [self.XMPPStream addDelegate:self delegateQueue:(dispatch_get_main_queue())];XMPPRosterCoreDataStorage * coreDataStorage =[XMPPRosterCoreDataStorage sharedInstance];// 初始化用户管理self.XMPPRoSter = [[XMPPRoster alloc]initWithRosterStorage:coreDataStorage dispatchQueue:(dispatch_get_main_queue())];// 在主线程中添加代理方法
        [self.XMPPRoSter addDelegate:self delegateQueue:(dispatch_get_main_queue())];// 将用户类放进通道管理器类里面
        [self.XMPPRoSter activate:self.XMPPStream];XMPPMessageArchivingCoreDataStorage * coreData = [XMPPMessageArchivingCoreDataStorage sharedInstance];self.achivimg =[[XMPPMessageArchiving alloc]initWithMessageArchivingStorage:coreData dispatchQueue:(dispatch_get_main_queue())];// 将消息类放进管理器通道类里面
        [self.achivimg activate:self.XMPPStream];self.context = coreData.mainThreadManagedObjectContext;}return self;
}

-(void)connectionWithUserName:(NSString *)userName andPassWord:(NSString *)passwod{// 在发生登录注册的时候，需要让我的通道类连接断掉，防止出现连接混乱的情况if ([self.XMPPStream isConnected]) {// 仅允许一个终端在线登录（不允许重复登录）
        [self.XMPPStream disconnect];}self.password = passwod;// 3、XMPPJId 保存的是一些用户的信息// 这个类当这个通道和服务器连接，保存的是一些用户的信息// 可以知道是给别人发消息，还是别人发来的消息
XMPPJID * jid =[XMPPJID jidWithUser:userName domain:@"127.0.0.1" resource:@"iOS"]; // 可以知道是发送消息还是接收消息// 在jid保存到XMPPStream里面self.XMPPStream.myJID = jid;// 让通道管理器类建立连接
    [self.XMPPStream connectWithTimeout:1.0f error:nil];}

// 当连接成功
-(void)xmppStreamDidConnect:(XMPPStream *)sender
{switch (self.myConnectMode) {case connectIsLogin:[self.XMPPStream authenticateWithPassword:self.password error:nil];break;case connectIsRefister:[self.XMPPStream registerWithPassword:self.password error:nil];break;default:break;}}

// 连接失败-(void)xmppStreamDidDisconnect:(XMPPStream *)sender withError:(NSError *)error
{}

// 将要失去连接-(void)xmppStreamWillConnect:(XMPPStream *)sender
{}

// 登录成功执行的方法
-(void)xmppStreamDidAuthenticate:(XMPPStream *)sender
{// 连接成功后发送消息，发送有效消息，上线消息XMPPPresence * presence =[XMPPPresence presenceWithType:@"available"];// 上线的消息通过XMPPStream 发送
    [[XMPPManager defaultManager].XMPPStream sendElement:presence];NSLog(@"登录成功");AppDelegate * app = [UIApplication sharedApplication].delegate;RootViewController * roster =[[UIStoryboard storyboardWithName:@"Main" bundle:nil]instantiateViewControllerWithIdentifier:@"rootVC"];app.window.rootViewController = roster;}

- (IBAction)LoginAction:(id)sender {// 调用XMPPManager里面的登录注册的方法// 调用XMPP里面的登录注册的方法获取用户名密码
    [[XMPPManager defaultManager]loginWithUserName:self.nameTextFild.text andPassWorld:self.passwordTextFild.text];}

-(void)xmppStreamDidRegister:(XMPPStream *)sender
{UIAlertView * alertView =[[UIAlertView alloc]initWithTitle:@"提示" message:@"恭喜您注册成功" delegate:self cancelButtonTitle:@"取消" otherButtonTitles:@"确定", nil];[alertView show];LoginViewController * longinVC =[[UIStoryboard storyboardWithName:@"Main" bundle:nil]instantiateViewControllerWithIdentifier:@"loginVC"];[self showViewController:longinVC sender:nil];}

// 获取好友列表-(void)xmppRoster:(XMPPRoster *)sender didReceiveRosterItem:(DDXMLElement *)item
{// 通过获取好友列表这个方法有助于获得各个好友的信息，通过item获取if ([[[item attributeForName:@"subscription"]stringValue]isEqualToString:@"both"]) {// 获取item里面节点的数据NSString * jidStr =[[item attributeForName:@"jid"]stringValue];// 通过在item里面获取到的数据初始化一个XMPPJIDXMPPJID * jid =[XMPPJID jidWithString:jidStr];// 把这个jid放到数据源数组里面
        [self.dataArray addObject:jid];// 使界面中的信息能够自动下翻[self.tableView insertRowsAtIndexPaths:@[[NSIndexPath indexPathForRow:self.dataArray.count - 1 inSection:0]] withRowAnimation:UITableViewRowAnimationAutomatic];}
}

/ 开始获取好友列表-(void)xmppRosterDidBeginPopulating:(XMPPRoster *)sender
{NSLog(@"开始获取");
}// 结束获取好友列表-(void)xmppRosterDidEndPopulating:(XMPPRoster *)sender
{NSLog(@"结束获取");
}

// 收到好友的请求的代理方法-(void)xmppRoster:(XMPPRoster *)sender didReceivePresenceSubscriptionRequest:(XMPPPresence *)presence
{// 获取来自于好友的请求self.fromJID = presence.from;// 弹框
    UIAlertView * view =[[UIAlertView alloc]initWithTitle:@"收到好友请求" message:@"加我为好友吧~~" delegate:self cancelButtonTitle:@"残忍拒绝" otherButtonTitles:@"乐意加入", nil];[view show];}

-(void)alertView:(UIAlertView *)alertView clickedButtonAtIndex:(NSInteger)buttonIndex
{switch (buttonIndex) {case 0:// 拒绝来自fromJID的加入
            [self.XMPPRoSter rejectPresenceSubscriptionRequestFrom:self.fromJID];break;// 接受来自fromJID的数据case 1:[self.XMPPRoSter acceptPresenceSubscriptionRequestFrom:self.fromJID andAddToRoster:YES];break;default:break;}
}

// 获取发送的信息数据
-(NSArray *)findData
{NSFetchRequest *fetchRequest = [[NSFetchRequest alloc] init];NSEntityDescription *entity = [NSEntityDescription entityForName:@"XMPPMessageArchiving_Message_CoreDataObject" inManagedObjectContext:[XMPPManager defaultManager].context];[fetchRequest setEntity:entity];// Specify criteria for filtering which objects to fetch//bareJidStr 参数代表的是和我聊天的人//streamBareJidStr 参数代表的是我自己NSPredicate *predicate = [NSPredicate predicateWithFormat:@"bareJidStr = %@ AND streamBareJidStr = %@",  self.toJid.bare, [XMPPManager defaultManager].XMPPStream.myJID.bare];[fetchRequest setPredicate:predicate];// Specify how the fetched objects should be sortedNSSortDescriptor *sortDescriptor = [[NSSortDescriptor alloc] initWithKey:@"timestamp"ascending:YES];[fetchRequest setSortDescriptors:[NSArray arrayWithObjects:sortDescriptor, nil]];NSError *error = nil;NSArray *fetchedObjects = [[XMPPManager defaultManager].context executeFetchRequest:fetchRequest error:&error];if (fetchedObjects == nil) {// 查询的数据不存在则返回一个数组return [NSArray array];}else{// 返回查询的数据return fetchedObjects;}}

// 接收消息时
-(void)xmppStream:(XMPPStream *)sender didReceiveMessage:(XMPPMessage *)message
{[self.dataArray removeAllObjects];[self.dataArray setArray:[self findData]];[self.tableView reloadData];// 代码自动滚动[self.tableView scrollToRowAtIndexPath:[NSIndexPath indexPathForItem:self.dataArray.count - 1 inSection:0] atScrollPosition:UITableViewScrollPositionBottom animated:YES];}

// 发送时遵循的代理-(void)xmppStream:(XMPPStream *)sender didSendMessage:(XMPPMessage *)message
{[self.dataArray removeAllObjects];[self.dataArray setArray:[self findData]];[self.tableView reloadData];// 代码自动滚动[self.tableView scrollToRowAtIndexPath:[NSIndexPath indexPathForItem:self.dataArray.count - 1 inSection:0] atScrollPosition:UITableViewScrollPositionBottom animated:YES];
}