iOS开发利用系统推送Notifaction和轮询实现简单聊天系统

首页 > 代码库 > iOS开发利用系统推送Notifaction和轮询实现简单聊天系统

iOS开发利用系统推送Notifaction和轮询实现简单聊天系统

2024-07-17 03:19:06 221人阅读

话不多说，先看一下做好的聊天软件界面：

首先在StoryBoard里拖了一个UItableView和一个view用来输入文字或者语音，右边的按钮用来切换文字和语音：

聊天里有三种id：

orderID ：聊天id

messageID ：每条消息的ID

sessionID ：每个订单的会话ID，如果为空通过orderID请求。

然后在viewDidLoad里做一些界面上的操作和一些初始化的操作：
1.设置一下tableview的headView

2.初始化录音、用户头像、获取订单详情

<strong>   </strong><span style="font-size:14px;"> //初始换录音
    [self initRecord];
    //获取用户头像
    [self getHeadImg];
    //获取订单详情
    [self getOrderDetailInfo];</span>

3.在viewWillAppear里：

a.注册了一些键盘和聊天消息的通知

b.启动了一个20秒的NSTimer轮询获取聊天消息
c.self.chatArray读取数据库的聊天消息，如果数组为空返回，如果不为空刷新tableview

d .如果是从评价页面过来，刷新订单状态

4.看一下轮询消息的代码：

<span style="font-size:14px;">#pragma mark - 轮询消息
- (void)runLoopMessage {
    SpeakType speaker = [YCChatInfo getSpeakerPassengerBy:self.orderInfo.bigType];
    [[YCReceiveMessageCenter defaultMessageCenter] getMessageListBySpeaker:speaker
                                     isRemote:NO
                                    andPushId:nil];
}</span>

第一句代码是获取会话类型，这里定义了一个枚举值，主要有以下几个角色：

//会话类型
enum SpeakType {
    //Business
    YCDriverType     = 11,
    YCPassenger      = 12,
    YCSystem         = 13,      //v5.2.2 增加系统角色
    YCLoctionAutoReply  = 14,  //v5.2.2添加本地自动回复
    YCDriverAutoReply   = 15,  //v5.2.2添加司机自动回复 司机角色
    YCLoctionUpdateVersionReply = 16, //v5.2.2 未知消息类型回复 【提示不支持的消息类型。请升级】
};
typedef NSInteger SpeakType;

然后根据会话类型去请求聊天list接口，然后请求成功后对数据进行处理：

        //isRemote 点击推送栏消息
        if (response && [response[@"ret_code"] integerValue] == 200) {
            NSArray *array = response[@"result"];
            id topVC = [[YCAppDelegate sharedDelegate] topViewController];
            __block NSString *orderID = nil;
            __block NSString *dType = nil;
            [array enumerateObjectsUsingBlock:^(NSDictionary *result, NSUInteger idx, BOOL *stop) {
                NSString *type = [self controlMessageDispatch:result];
                dType = type;
       <span style="white-space:pre">		</span>//此处省略五百字
            }
        } else {
            DLog(@"轮询数据失败 response = %@, error = %@", response, error);
        }

如果code == 200的时候证明请求成功，然后用数组取出所有的聊天消息，然后用enumerateObjectsUsingBlock方法便利数组里每个元素，每个元素即一条聊天消息。然后通过controlMessageDispatch来获取消息的类型（dType）：

typedef NS_ENUM(NSInteger, ClassType) {
   OrderClass = 1,
   ChatClass = 2,
   UserClass = 3,
};

第一个是订单类型消息，第二个是聊天类型消息，第三个是账户消息。

如果是订单消息，根据type去判断是什么状态，然后去发不同的Notification。如果是聊天类型把result传入：

- (void)receiveChatMessage:(id)object

方法，然后有一个消息状态字段kChatRepeatState，如果kChatRepeatState == 20，表示已读消息，直接返回。如果不是，用content初始化YCChatInfo：

NSDictionary *content = dic[@"content"];
YCChatInfo *item;
item = [[YCChatInfo alloc] initWithDictionary:content];

然后去判断ChatType，有以下几种：

//聊天 类型
enum ChatType {
    ChatText       = 1,
    ChatImage      = 2,
    ChatAudio      = 3,
    ChatPOI        = 4,
    ChatMix        = 5, //混合内容
    ChatCard       = 6,//v5.2.2卡片消息
    ChatUpdateHint     = 701 //v5.2.2不支持类型升级提示
    
};
typedef NSInteger ChatType;

如果是语音消息，需要异步先去请求下载语音消息，下载完后先显示到界面上同事置为未读消息然后再储存到数据库里，然后回到主线程发NotifactionName：kChatMessageNotification通知聊天界面接收到聊天信息，展示到界面后然后存到数据库中:

[[NSNotificationCenter defaultCenter] postNotificationName:kChatMessageNotification
                                                    object:nil
                                                  userInfo:@{@"chatInfo" : chatInfo}];
[self.chatStore insertChat:chatInfo];

这里上次有个bug，聊天消息去重之后一直收不到语音消息，就是因为我先把新聊天消息先插入数据，然后再去发通知，导致往界面上显示聊天消息是总是显示不上去。

如果是文字消息，把state置为MessageRead已读，然后发Notifaction通知聊天页面，然后存到数据库，如果是其他消息类型，把content改为“不支持的消息类型|您的当前版本过低,点击升级客户端”，然后在发出通知，存到数据库里。

如果是第三种账户消息，显示小红点，然后发Notifaction通知viewcontroller消息中心有新消息。

接着获取到dType后

//首先判断是否是推送消息, 且判断该条点击的推送id进入的
                if (isRemote && [pushId isEqualToString:result[@"id"]]) {
                    if (!orderID && ([type isEqualToString:@"new_chat"] ||
                                     [type isEqualToString:@"DRIVER_ARRIVE"] ||
                                     [type isEqualToString:@"RECEPTION_DRIVER"]||
                                     [type isEqualToString:@"SERVICE_DONE"])) {
                        if ([type isEqualToString:@"new_chat"]) {
                            orderID = result[@"content"][@"topic"];
                        } else if (![topVC isKindOfClass:[YCSelectDriverViewController class]] &&
                                   ([type isEqualToString:@"DRIVER_ARRIVE"] ||
                                    [type isEqualToString:@"RECEPTION_DRIVER"] ||
                                    [type isEqualToString:@"SERVICE_DONE"])) {
                                       orderID = result[@"content"][@"order_id"];
                        }
                    }
                }
            }];
            if (orderID) {
                if ([DefaultValueForKey(kShowWelcome) boolValue]) {
                    if (![topVC isKindOfClass:[YCWelcomeVC class]]) {
                        [[NSNotificationCenter defaultCenter] postNotificationName:kRemotePushVC
                                                                            object:nil
                                                                          userInfo:@{@"orderID" : orderID,
                                                                                     @"type":dType}];
                    }
                }
            }

首先判断是否是推送消息, 且判断该条点击的推送id进入的，如果orderID不存在且如果type是新聊天消息或司机已到达或者司机接单或者服务结束就进入if判断里，然后在判断type是不是聊天，如果是聊天orderID是content里的topic字段，如果不是新聊天且当前最顶层ViewController不是YCSelectDriverViewController类且type是司机已到达或者司机接单或者服务结束就进入if判断里，orderID是content里的order_id字段。

如果orderID存在的情况下先判断欢迎页面是不是显示过，然后再判断当前最顶层ViewController不是欢迎页类，然后就发出Notifaction，然后通知view跳转到指定的ViewController页面。

当接收到聊天消息，经过一系列数据处理后，发出通知，然后YCChatViewController里会接到通知调用- (void)receiveMessage:(NSNotification *)notification方法：

- (void)receiveMessage:(NSNotification *)notification {
    YCChatInfo *chatInfo  = notification.userInfo[@"chatInfo"];
    //如果此时来的消息不输入当前会话 页面不进行操作
    NSString *string1 = [[NSString alloc] initWithFormat:@"%@", chatInfo.orderID];
    NSString *string2 = [[NSString alloc] initWithFormat:@"%@", self.orderInfo.serverOrderId];
    if (![string1 isEqualToString:string2]) {
        return ;
    }
    NSInteger messageID = chatInfo.messageID;
    YCChatStore *chatStore = [[YCChatStore alloc]init];
    BOOL isNotRepeat = [chatStore selectDBwithMessageID:messageID];
    if (!isNotRepeat) {
        return;
    }
    [self insertRowToTableViewByIndexPath:chatInfo isSend:NO];
}

第一句话是获取通知里传的聊天消息内容，然后拿chatinfo里的orderID和通过获取订单详情的接口里获得的orderID做比较，如果orderID不一致，直接return。如果一直就去YCChatStore里的selectDBwithMessageID方法里查询数据库是否有相同的messageID存在，如果存在直接return，如果不存在就插入界面

- (NSIndexPath *)insertRowToTableViewByIndexPath:(YCChatInfo *)chatInfo isSend:(BOOL)isSend {
    NSIndexPath *indexPath;
    [self.chatArray addObject:chatInfo];
    
    indexPath = [NSIndexPath indexPathForRow:[self.chatArray count] - 1
                                   inSection:0];
    void(^ScrollBlock)() = ^{
        DLog(@"%d",indexPath.row);
        [self.tableView scrollToRowAtIndexPath:indexPath
                              atScrollPosition:UITableViewScrollPositionBottom
                                      animated:YES];
    };
    [self.tableView insertRowsAtIndexPaths:@[indexPath]
                          withRowAnimation:YCTableViewRowAnimationFromBottom
                                completion:^{
                                    if (isSend) {
                                        ScrollBlock();
                                    }
    }];
    
    if (!isSend) {
        ScrollBlock();
    }
    
    return indexPath;
}

- (void)scrollToRowAtIndexPath:(NSIndexPath *)indexPath atScrollPosition:(UITableViewScrollPosition)scrollPosition animated:(BOOL)animated这个方法是把第几个indexpath滑动到tableview的最底部，

- (void)insertRowsAtIndexPaths:(NSArray *)indexPaths
withRowAnimation:(YCTableViewRowAnimation)animation
completion:(void(^)(void))animationCompletion

这是插入时候的一个动画效果。

简单介绍一下聊天系统里边所有model、view、controller相关类的名字和功能：

MODEL：

YCChatInfo：主要定义了聊天接口里所有用到字段的定义，聊天相关的枚举信息和聊天消息的一些BOOL判断。

YCChatStore ：主要是对聊天数据进行数据库的建表、插入、删除、查询、去重、更新等操作。

YCChatRequest ：封装了聊天相关的网络请求。

YCChatRecord：主要是录音相关的一些封装，包括开始录音、结束录音、获取录音时长、音频格式转化、以及通过SessionID获取音频路径。

YCReceiveMessageCenter：相当于NotifactionCenter，是聊天消息处理的一个消息中心，所有接受的聊天消息和发送的聊天消息都会经过MessageCenter处理。

Views：

YCChatTableView ：继承tableview的类，里边重写了tableview的插入动画，就是每次来新消息时候的插入动画。

YCChatBaseCell ：聊天里所有的cell都继承自此cell（文字、语音，未来还可能包括图片、地理位置等等）里边主要定义了聊天时间的Label、背景图片、头像、司机名、发送时候的loading

YCChatAudioCell ：语音聊天cell，包括播放按钮、小红点提示、录音时间label

YCChatImageCell ：系统中暂时没有用到，可能是为以后聊天可以发图片做准备

YCChatTextCell ：发送文字聊天cell

YCHeadView ：头像cell

YCRecordView ：聊天界面中按住说话的view

YCOrderRecordView ：这个是下单中按住说话的view跟聊天系统没关系

YCPlayButton ：播放音频按钮

YCChatDriverAcceptCardCell ：5.2.3版本新增预订成功卡片

YCChatJourneyStartCell ： 5.2.3版本新增司机已出发、司机已就位卡片

YCChatUpdatHintCell ：不支持类型，升级提示

Controllers：

YCChatViewController ：聊天的主界面

YCChatMenuViewController：聊天右侧的按钮

YCShareJourneyCardVC：预订成功卡片的详细页

YCChatMapVC：聊天卡片里的地图

声明：以上内容来自用户投稿及互联网公开渠道收集整理发布，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任，若内容有误或涉及侵权可进行投诉：投诉/举报工作人员会在5个工作日内联系你，一经查实，本站将立刻删除涉嫌侵权内容。

联系
我们

首页 > 代码库 > iOS开发利用系统推送Notifaction和轮询实现简单聊天系统

iOS开发利用系统推送Notifaction和轮询实现简单聊天系统

看完仍有疑问？有类似问题直接问程序猿