#import "LoginViewController.h"
#import "XMPPManager.h"@interface LoginViewController ()<XMPPStreamDelegate>
@property (weak, nonatomic) IBOutlet UITextField *userNameTes;
@property (weak, nonatomic) IBOutlet UITextField *passwordTes;@end@implementation LoginViewController- (void)viewDidLoad {[super viewDidLoad];//添加代理方法
    [[XMPPManager sharedXMPPManager].stream addDelegate:self delegateQueue:dispatch_get_main_queue()];
}#pragma mark ---实现XMPPStreamDelegate中的代理方法//认证登录成功的代理方法
-(void)xmppStreamDidAuthenticate:(XMPPStream *)sender
{NSLog(@"登录成功");//登陆成功进入好友聊天页面
    [self dismissViewControllerAnimated:YES  completion:nil];}
//认证登录失败的代理方法
-(void)xmppStream:(XMPPStream *)sender didNotAuthenticate:(DDXMLElement *)error
{NSLog(@"登录失败%@",error);
}- (IBAction)loginWithUserNameAndPassword:(id)sender {//登录
    [[XMPPManager sharedXMPPManager] loginWithUserName:self.userNameTes.text passWord:self.passwordTes.text];}@end

#import "RegisterViewController.h"
#import "XMPPManager.h"@interface RegisterViewController () <XMPPStreamDelegate>
@property (weak, nonatomic) IBOutlet UITextField *userNameTes;
@property (weak, nonatomic) IBOutlet UITextField *passwordTes;@end@implementation RegisterViewController- (void)viewDidLoad {[super viewDidLoad];//给stream 设置代理监测注册是否成功
    [[XMPPManager sharedXMPPManager].stream addDelegate:self delegateQueue:dispatch_get_main_queue()];
}#pragma mark ---实现XMPPStreamDelegate中的代理方法//注册成功
-(void)xmppStreamDidRegister:(XMPPStream *)sender
{NSLog(@"注册成功");//注册成功 进入登陆页面
    [self.navigationController popViewControllerAnimated:YES];
}
//注册失败
-(void)xmppStream:(XMPPStream *)sender didNotRegister:(DDXMLElement *)error
{NSLog(@"注册失败");
}- (IBAction)registerWithUserNameAndPassword:(id)sender {//注册[[XMPPManager sharedXMPPManager] registerWithUserName:self.userNameTes.text passWord:self.passwordTes.text];}@end

#import <Foundation/Foundation.h>
#import "XMPPFramework.h"@interface XMPPManager : NSObject<XMPPStreamDelegate>//声明一个'通道'属性 为了其他类中能够访问到
@property(nonatomic,strong)XMPPStream *stream;//与好友有关的操作
@property(nonatomic,strong)XMPPRoster *roster;//与聊天信息有关的  聊天信息托管上下文
@property(nonatomic,strong)NSManagedObjectContext *context;//信息归档  聊天信息归档对象
@property(nonatomic,strong)XMPPMessageArchiving *messageAchiving;#pragma mark ---获取一个单例对象
+(XMPPManager *)sharedXMPPManager;#pragma mark ---登录
-(void)loginWithUserName:(NSString *)userName passWord:(NSString *)passWord;#pragma mark ---注册
-(void)registerWithUserName:(NSString *)userName passWord:(NSString *)passWord;#pragma mark ---删除好友
-(void)removeFriendName:(NSString *)name;@end

#import "XMPPManager.h"

//枚举
typedef NS_ENUM(NSUInteger,connectToSeverType){connectToSeverLogin,connectToSeverRegister};//枚举
//typedef enum : NSUInteger {
//    <#MyEnumValueA#>,
//    <#MyEnumValueB#>,
//    <#MyEnumValueC#>,
//} <#MyEnum#>;@interface XMPPManager ()//登录用户名
@property(nonatomic,strong)NSString *LoginuserName;
//登录密码
@property(nonatomic,strong)NSString *loginPassWord;
//注册名
@property(nonatomic,strong)NSString *registerUserName;
//注册密码
@property(nonatomic,strong)NSString *registerPassWord;
//用来表示访问服务器的目的(登录或注册)
@property(nonatomic,assign)connectToSeverType connectPurpose;@end@implementation XMPPManager#pragma mark ---获取一个单例对象
+(XMPPManager *)sharedXMPPManager
{static XMPPManager *manager = nil;static dispatch_once_t onceToken;dispatch_once(&onceToken, ^{manager = [[XMPPManager alloc] init];});return manager;}//重写XMPPManager的init方法,是为了创建 通道(xmppStream)
//init方法
- (instancetype)init
{self = [super init];if (self) {//初始化通道self.stream = [[XMPPStream alloc] init];//指定其连接的服务器IP地址self.stream.hostName = kHostName;//指定服务器端口  默认为5222//端口号 是制定当前连接的是什么服务self.stream.hostPort = kHostPort;//给stream设置代理,来检测链接状态和认证状态
        [self.stream addDelegate:self delegateQueue:dispatch_get_main_queue()];//初始化管理好友对象roster(与好友相关的操作)XMPPRosterCoreDataStorage *storage = [XMPPRosterCoreDataStorage sharedInstance];self.roster = [[XMPPRoster alloc] initWithRosterStorage:storage dispatchQueue:dispatch_get_main_queue()];//在管道上激活对象
        [self.roster activate:self.stream];//初始化messageAchiving对象XMPPMessageArchivingCoreDataStorage *messageStroge = [XMPPMessageArchivingCoreDataStorage sharedInstance];self.messageAchiving = [[XMPPMessageArchiving alloc] initWithMessageArchivingStorage:messageStroge dispatchQueue:dispatch_get_main_queue()];//激活
        [self.messageAchiving activate:self.stream];//托管上下文对象self.context = messageStroge.mainThreadManagedObjectContext;}return self;
}#pragma mark ---登录
-(void)loginWithUserName:(NSString *)userName passWord:(NSString *)passWord
{self.loginPassWord = userName;self.LoginuserName = userName;//此时将枚举属性的值设为connectToSeverLoginself.connectPurpose = connectToSeverLogin;//链接
    [self linkConnect];}//链接的方法
-(void)linkConnect
{//在真正链接之前,需要告诉服务器你是谁,//XMPPJID在Xmpp中身份的唯一标识XMPPJID *myJID = nil;switch (self.connectPurpose) {case connectToSeverLogin:{myJID = [XMPPJID jidWithUser:self.LoginuserName domain:kDomin resource:kResource];break;}case connectToSeverRegister:{myJID = [XMPPJID jidWithUser:self.registerUserName domain:kDomin resource:kResource];break;}default:break;}
//    XMPPJID *myJID = [XMPPJID jidWithUser:self.LoginuserName domain:kDomin resource:kResource];//将自己的JID设置到Stream通道上self.stream.myJID = myJID;//开始链接if ([self.stream isConnected] || [self.stream isConnecting]) {//先断开
        [self disconnectToSever];}//连接到服务器NSError *error = nil;[self.stream connectWithTimeout:30.0 error:&error];if (error) {NSLog(@"error:%@",error);}}//断开链接
-(void)disconnectToSever{//设置下线状态元素XMPPPresence *pressence = [XMPPPresence presenceWithType:@"unavailable"];//将stream上的状态改为下线
    [self.stream sendElement:pressence];//断开链接
    [self.stream disconnect];}#pragma mark ---注册
-(void)registerWithUserName:(NSString *)userName passWord:(NSString *)passWord
{self.registerPassWord = passWord;self.registerUserName = userName;//将枚举值设为注册self.connectPurpose = connectToSeverRegister;//链接
    [self linkConnect];
}#pragma mark ---XMPPStreamDelegate的方法
//链接成功
-(void)xmppStreamDidConnect:(XMPPStream *)sender
{NSLog(@"连接成功");//进行认证switch (self.connectPurpose) {case connectToSeverLogin://如果链接的目的是登录,这里需要一个登录的passWord
            [self.stream authenticateWithPassword:self.loginPassWord error:nil];break;case connectToSeverRegister://如果链接的目的是注册,这里需要一个注册的passWord
            [self.stream registerWithPassword:self.registerPassWord error:nil];break;default:break;}}
//链接失败
-(void)xmppStreamDidDisconnect:(XMPPStream *)sender withError:(NSError *)error
{NSLog(@"连接失败%@",error);
}
//链接超时
-(void)xmppStreamConnectDidTimeout:(XMPPStream *)sender
{NSLog(@"链接超时");}
//认证成功
-(void)xmppStreamDidAuthenticate:(XMPPStream *)sender
{NSLog(@"认证成功");//设置上线状态XMPPPresence *presence = [XMPPPresence presenceWithType:@"available"];[self.stream sendElement:presence];}#pragma mark ---删除好友
-(void)removeFriendName:(NSString *)name
{//根据username和域名,创建一个jidXMPPJID *friendJid = [XMPPJID jidWithString:[NSString stringWithFormat:@"%@@%@",name,kDomin ]];//取消对好友的监听
    [self.roster unsubscribePresenceFromUser:friendJid];//将好友移除
    [self.roster removeUser:friendJid];}@end

#import "RosterTableViewController.h"
#import "XMPPManager.h"
#import "ChatTableViewController.h"@interface RosterTableViewController ()<XMPPRosterDelegate,UIAlertViewDelegate,XMPPStreamDelegate>//所有好友
@property(nonatomic,strong)NSMutableArray *allRoster;//请求者的jid
@property(nonatomic,strong)XMPPJID *requestJid;@end//存放所有的好友
@implementation RosterTableViewController- (void)viewDidLoad {[super viewDidLoad];//对数组进行初始化self.allRoster = [NSMutableArray array];//通过代理协议,获取好友
    [[XMPPManager sharedXMPPManager].roster addDelegate:self delegateQueue:dispatch_get_main_queue()];//监听好友的状态  通过代理协议的形式
    [[XMPPManager sharedXMPPManager].stream addDelegate:self delegateQueue:dispatch_get_main_queue()];}#pragma mark ---实现XMPPRosterDelegate协议中的方法
//开始获取好友
-(void)xmppRosterDidBeginPopulating:(XMPPRoster *)sender
{NSLog(@"开始获取好友");}
//正在获取好友  有几个好友这个放法就会执行几次
-(void)xmppRoster:(XMPPRoster *)sender didReceiveRosterItem:(DDXMLElement *)item
{NSLog(@"%@",item);//to 订阅了别人//from 别人订阅了你//both 互为好友NSString *subscription = [[item attributeForName:@"subscription"] stringValue];if ([subscription isEqualToString:@"from"] || [subscription isEqualToString:@"both"]) {//获取好友的jid字符串NSString *jidStr = [[item attributeForName:@"jid" ] stringValue];//获取好友的jidXMPPJID *frienfJid = [XMPPJID jidWithString:jidStr];//如果之前加过了,表示好友已经存在if ([_allRoster containsObject:frienfJid ]) {return;}//将好友对象(frienfJid) 添加到数组中
        [self.allRoster addObject:frienfJid];//插入行//插入到最后一行NSIndexPath *indexPath = [NSIndexPath indexPathForRow:self.allRoster.count - 1 inSection:0];[self.tableView insertRowsAtIndexPaths:@[indexPath] withRowAnimation:UITableViewRowAnimationAutomatic];}}//结束获取好友
-(void)xmppRosterDidEndPopulating:(XMPPRoster *)sender
{NSLog(@"好友获取结束");
}//获取好友请求
-(void)xmppRoster:(XMPPRoster *)sender didReceivePresenceSubscriptionRequest:(XMPPPresence *)presence
{NSLog(@"获取好友请求!");self.requestJid =  presence.from;UIAlertView *alert = [[UIAlertView alloc] initWithTitle:@"好友请求" message:_requestJid.user delegate:self cancelButtonTitle:@"Cancel" otherButtonTitles:@"OK", nil];[alert show];}-(void)alertView:(UIAlertView *)alertView clickedButtonAtIndex:(NSInteger)buttonIndex
{switch (buttonIndex) {case 0://点击拒绝按钮
          [[XMPPManager sharedXMPPManager].roster rejectPresenceSubscriptionRequestFrom:self.requestJid];break;case 1://接受请求按钮
            [[XMPPManager sharedXMPPManager].roster acceptPresenceSubscriptionRequestFrom:self.requestJid andAddToRoster:NO];break;default:break;}self.requestJid = nil;
}#pragma mark --实现XMPPStreamDelegate中的方法
//监听好友的状态
-(void)xmppStream:(XMPPStream *)sender didReceivePresence:(XMPPPresence *)presence
{//监测好友的状态NSString *presenceType =  presence.type;if ([presenceType isEqualToString:@"available"]) {NSLog(@"好友在线状态!");}  else if ([presenceType isEqualToString:@"unavailable"])NSLog(@"好友处于下线状态!");}#pragma mark - Table view data source- (NSInteger)numberOfSectionsInTableView:(UITableView *)tableView {// Return the number of sections.return 1;
}- (NSInteger)tableView:(UITableView *)tableView numberOfRowsInSection:(NSInteger)section {// Return the number of rows in the section.return self.allRoster.count;
}- (UITableViewCell *)tableView:(UITableView *)tableView cellForRowAtIndexPath:(NSIndexPath *)indexPath {UITableViewCell *cell = [tableView dequeueReusableCellWithIdentifier:@"roster" forIndexPath:indexPath];XMPPJID *friendJid = _allRoster[indexPath.row];cell.textLabel.text = friendJid.user;return cell;
}// Override to support conditional editing of the table view.
- (BOOL)tableView:(UITableView *)tableView canEditRowAtIndexPath:(NSIndexPath *)indexPath {// Return NO if you do not want the specified item to be editable.return YES;
}// Override to support editing the table view.
- (void)tableView:(UITableView *)tableView commitEditingStyle:(UITableViewCellEditingStyle)editingStyle forRowAtIndexPath:(NSIndexPath *)indexPath {if (editingStyle == UITableViewCellEditingStyleDelete) {//删除数据源XMPPJID *jid = _allRoster[indexPath.row];[[XMPPManager sharedXMPPManager]removeFriendName:jid.user];[self.allRoster removeObjectAtIndex:indexPath.row];[tableView deleteRowsAtIndexPaths:@[indexPath] withRowAnimation:UITableViewRowAnimationFade];} else if (editingStyle == UITableViewCellEditingStyleInsert) {// Create a new instance of the appropriate class, insert it into the array, and add a new row to the table view
    }
}#pragma mark - Navigation// In a storyboard-based application, you will often want to do a little preparation before navigation
- (void)prepareForSegue:(UIStoryboardSegue *)segue sender:(id)sender {//获取点击的cellUITableViewCell *cell = (UITableViewCell *)sender;NSIndexPath *indexPah =  [self.tableView indexPathForCell:cell];ChatTableViewController *chatVC =  (ChatTableViewController *)segue.destinationViewController;chatVC.chatToJid = _allRoster[indexPah.row];}@end

#import <UIKit/UIKit.h>
#import "XMPPManager.h"@interface ChatTableViewController : UITableViewController@property(nonatomic,strong)XMPPJID *chatToJid;@end

#import "ChatTableViewController.h"
#import "XMPPManager.h"@interface ChatTableViewController ()<XMPPStreamDelegate>//信息数组
@property(nonatomic,strong)NSMutableArray *allMessages;
- (IBAction)sendMessage:(UIBarButtonItem *)sender;@end@implementation ChatTableViewController- (void)viewDidLoad {[super viewDidLoad];//初始化数组self.allMessages = [NSMutableArray array];//设置代理
    [[XMPPManager sharedXMPPManager].stream addDelegate:self delegateQueue:dispatch_get_main_queue()];//显示历史记录
    [self parseMesage];}#pragma mark --实现协议中的方法
//已经接受好友发送的信息
-(void)xmppStream:(XMPPStream *)sender didReceiveMessage:(XMPPMessage *)message
{NSLog(@"已经接受信息:%@",message);[self parseMesage];
}-(void)parseMesage
{//查询请求NSFetchRequest *fetchRequest = [[NSFetchRequest alloc] init];NSEntityDescription *entity = [NSEntityDescription entityForName:@"XMPPMessageArchiving_Message_CoreDataObject" inManagedObjectContext:[XMPPManager sharedXMPPManager].context];[fetchRequest setEntity:entity];// Specify criteria for filtering which objects to fetch//谓词  查询条件NSPredicate *predicate = [NSPredicate predicateWithFormat:@"bareJidStr == %@ AND streamBareJidStr == %@", _chatToJid.bare,[XMPPManager sharedXMPPManager].stream.myJID.bare];[fetchRequest setPredicate:predicate];// Specify how the fetched objects should be sorted//排序NSSortDescriptor *sortDescriptor = [[NSSortDescriptor alloc] initWithKey:@"timestamp"ascending:YES];[fetchRequest setSortDescriptors:[NSArray arrayWithObjects:sortDescriptor, nil]];NSError *error = nil;NSArray *fetchedObjects = [[XMPPManager sharedXMPPManager].context executeFetchRequest:fetchRequest error:&error];if (fetchedObjects == nil) {NSLog(@"没有聊天记录!");} else {//清空之前的聊天记录
        [self.allMessages removeAllObjects];[self.allMessages addObjectsFromArray:fetchedObjects];[self.tableView reloadData];if (_allMessages.count == 0) {return;}NSIndexPath *indexPath = [NSIndexPath indexPathForRow:self.allMessages.count -1 inSection:0];[self.tableView selectRowAtIndexPath:indexPath animated:YES scrollPosition:UITableViewScrollPositionBottom];}
}
#pragma mark - Table view data source- (NSInteger)numberOfSectionsInTableView:(UITableView *)tableView {
#warning Incomplete implementation, return the number of sectionsreturn 1;
}- (NSInteger)tableView:(UITableView *)tableView numberOfRowsInSection:(NSInteger)section {
#warning Incomplete implementation, return the number of rowsreturn _allMessages.count;
}- (UITableViewCell *)tableView:(UITableView *)tableView cellForRowAtIndexPath:(NSIndexPath *)indexPath {UITableViewCell *cell = [tableView dequeueReusableCellWithIdentifier:@"chat" forIndexPath:indexPath];XMPPMessageArchiving_Message_CoreDataObject *message = _allMessages[indexPath.row];if (message.isOutgoing == YES) {  //自己发的cell.detailTextLabel.text = message.body;cell.textLabel.text = @"";} else {cell.textLabel.text = message.body;cell.detailTextLabel.text = @"";}return cell;
}#pragma mark --给好友发送消息
- (IBAction)sendMessage:(UIBarButtonItem *)sender {//发送给谁消息(Jid)XMPPMessage *message = [XMPPMessage messageWithType:@"chat" to:self.chatToJid];//设置发送内容[message addBody:@"你好!"];//开始发送
    [[XMPPManager sharedXMPPManager].stream sendElement:message];}
//信息发送成功
-(void)xmppStream:(XMPPStream *)sender didSendMessage:(XMPPMessage *)message
{NSLog(@"信息发送成功:%@",message);[self parseMesage];}
//信息发送失败
-(void)xmppStream:(XMPPStream *)sender didFailToSendMessage:(XMPPMessage *)message error:(NSError *)error
{NSLog(@"信息发送失败:%@",error);}@end