webSocket and LKDBHelper的使用说明

时间：2022-05-03 06:58:07

socketket与lkdbhelper来处理数据

客户需求：

当我们有需要从自己的后台推送消息给我们的用户时，用户需要实时的接收到来自我们的推送消息。前提是没有使用第三方的推送框架，那么这个使用websocket来接收消息，app端把接收到的消息存储在本地的数据库，让我们直接从数据库去读取数据。

SocketRocket是facebook基于socket进行的二次封装。下面是它的下载地址:

facebook/SocketRocket

LKDBHelper-SQLite-ORM这个第三方库，全自动的插入,查询,更新,删除。 是对sqlite的封装，使开发者不必关心sqlite复杂的语句。这个是github的下载地址:

li6185377/LKDBHelper-SQLite-ORM

从上面的需求中可以分析出做的事情，有2件事需要做。

一、Socket连接获取到后台推送的数据

SocketRocket提供的官方接口：

@interface SRWebSocket : NSObject

// 初始化方法，这只是一种还有很多种，具体请自己看

- (instancetype)initWithURLRequest:(NSURLRequest *)request;

// 代理方法

@property (nonatomic, weak) id <SRWebSocketDelegate> delegate;

// 打开socket

- (void)open;

// 关闭socket

- (void)close;

// 发送数据NSData

- (void)sendData:(nullable NSData *)data error:(NSError **)error;

// Send a UTF8 String 发送字符串数据

- (void)sendString:(NSString *)string error:(NSError **)error;

@end

Socket连接流程:

建议对这个第三方的库进行再一次封装，以便以后需要改换成其它的第三方库，只需要修改此处，而不必去整个工程的修改。

1.发送socket建立连接请求

代码:

/**

 *  Socket建立连接

 */

- (void)connectSocket

{

    //此地址不代表真实地址

    NSString *url = @"xsp://push.lala.com:8888";

    //初始化

    self.socket = [[SRWebSocket alloc] initWithURL:[NSURL URLWithString:url]];

    //设置代理

    self.socket.delegate = self;

    //打开socket连接

    [self.socket open];

}

2.从代理方法中收到连接情况，比如心跳报文等。在这个代理方法里面处理接收到的数据保存到本地数据库中

#pragma mark -- SocketDelegate

/**

 *  收到服务器的消息

 *

 *  @param webSocket socket

 *  @param message  收到服务器的消息，有可能是字符串，或是NSData数据

 */

- (void)webSocket:(SRWebSocket *)webSocket didReceiveMessage:(id)message

{

    NSError *error = nil;

    NSString *receiveMessage = (NSString *)message;

    //如果数据不能解析，很有可能是后台传的时候有tab键或是空格，找后台排查，或者就用字符替换掉这些多余的字符

    NSData *data = [receiveMessage dataUsingEncoding:NSUTF8StringEncoding];

    //NSJSONReadingAllowFragments不管外层的类型是什么

    NSDictionary *responseObj = [NSJSONSerialization JSONObjectWithData:data options:NSJSONReadingAllowFragments error:&error];

     NSString *type = responseObj[@"type"];

    //这里的代码不准确，主要是根据后台的返回类型来处理

    NSUInteger index = [NSString stringWithFormat:@"%@",type];

    switch (index) {

        case 0:

        {

            //心跳报文

        }

            break;

        case 1:

        {

            //推送的消息1,处理数据，保存到数据库

        }

            break;

        case 2:

        {

            //推送的消息2,处理数据，保存到数据库

        }

            break;

        default:

            break;

    }

}

3.断开连接

/**

 *  Socket断开连接

 *  分为服务器断开和客户端断开

 *  此处为客户端断开

 */

- (void)discononectSocket

{

    //关闭socket连接

    [self.socket close];

    self.socket = nil;

    self.socket.delegate = nil;

}

SocketRocket 提供的代理方法:

@protocol SRWebSocketDelegate <NSObject>

- (void)webSocket:(SRWebSocket *)webSocket didReceiveMessage:(id)message;

@optional

//socket连接成功

- (void)webSocketDidOpen:(SRWebSocket *)webSocket;

//

- (void)webSocket:(SRWebSocket *)webSocket didReceiveMessageWithString:(NSString *)string;

- (void)webSocket:(SRWebSocket *)webSocket didReceiveMessageWithData:(NSData *)data;

- (void)webSocket:(SRWebSocket *)webSocket didFailWithError:(NSError *)error;

- (void)webSocket:(SRWebSocket *)webSocket didCloseWithCode:(NSInteger)code reason:(nullable NSString *)reason wasClean:(BOOL)wasClean;

@end

服务器中断连接, Socket关闭连接

/**

 *  Socket关闭连接

 *

 *  @param webSocket <#webSocket description#>

 *  @param code      描述

 *  @param reason    原因

 *  @param wasClean  <#wasClean description#>

 */

- (void)webSocket:(SRWebSocket *)webSocket didCloseWithCode:(NSInteger)code reason:(NSString *)reason wasClean:(BOOL)wasClean

{

    self.socket.delegate = nil;

    self.socket = nil;

    NSLog(@"socket close原因: %@,",reason);

}

Socket连接失败,客户端断网会调用



/**

 *  Socket连接失败,客户端断网会调用

 *

 *  @param webSocket <#webSocket description#>

 *  @param error     失败原因

 */

- (void)webSocket:(SRWebSocket *)webSocket didFailWithError:(NSError *)error

{

    NSLog(@"客户端网络异常:%@",error);

}

暂未使用到

//暂未使用到

- (void)webSocket:(SRWebSocket *)webSocket didReceivePong:(NSData *)pongPayload

{

}

到这里基本就把Socket的连接和可以接收到服务器的数据了，现在就需要把收到的数据存到本地数据库了。

二、把接受到的信息存储到本地的数据库中

在准备数据库之前需要了解怎么做呢？

1.首先是数据模型

2.把数据转换成模型存储数据库

1.创建一个继承自NSObject的类，如:SQliteModel

#import <Foundation/Foundation.h>

#import <YYModel.h>

@interface SQliteModel : NSObject <YYModel>

@end


注: 此处添加`YYModel`是为了方便好数据转模型，虽然lkdbhelper里面有映射的方法，个人不是很习惯。

2.给模型添加字段 SQliteModel.h

#import <Foundation/Foundation.h>

#import <YYModel.h>

#import <LKDBHelper.h>

@interface ptInfo : NSObject <YYModel>

/**发送者名字*/

@property (nonatomic, copy) NSString *sendName;

/**发送头像*/

@property (nonatomic, copy) NSString *headUrl;

@end

@interface SQliteModel : NSObject <YYModel>

/**用户ID*/

@property (nonatomic, copy) NSString *userID;

/**当前时间*/

@property (nonatomic, copy) NSString *ptime;

/**用户名字*/

@property (nonatomic, copy) NSString *userName;

/**联系方法*/

@property (nonatomic, copy) NSString *userPhone;

@property (nonatomic, strong) ptInfo *info;

@end

3.实现方法 SQliteModel.m

#import "SQliteModel.h"

@implementation ptInfo

@end

@implementation SQliteModel

+ (NSDictionary<NSString *,id> *)modelCustomPropertyMapper

{

    return @{@"userID":@"id",@"ptInfo":@"info"};

}

+ (NSDictionary<NSString *,id> *)modelContainerPropertyGenericClass

{

    return @{@"info":[ptInfo class]};

}

/**

 *

 *  @return 是否将父实体类的属性也映射到SQLITE库中

 */

+ (BOOL)isContainParent

{

    return YES;

}

/**

 * 设置数据库的表名，在查询的时候可以根据表名来查询

 * 我在使用的时候不知道为什么不成功。总是提示sqlite语法错误

 */

+ (NSString *)getTableName

{

    return @"SQLiteModel";

}

/**

 * 设置表的单个主键

 */

+ (NSString *)getPrimaryKey

{

    return @"userID";

}

@end

4.Model模型已经准备好了，接下来就是准备开始创建数据库、保存、查询、删除等。

在需要使用的地方包含模型#import "SQliteModel.h"就可以使用了。

4.1 创建并保存到数据库

 case 1:

        {

            //推送的消息1,处理数据，保存到数据库

            //获取到的数据为字典

            NSDictionary *dict = responseObj[@"data"];

            //数据转为模型

            SQliteModel *firstModel = [SQliteModel yy_modelWithDictionary:dict];

            //保存模型

           BOOL isSaved = [firstModel saveToDB];

        }

            break;

保存的时候返回一个BOOL值来判断是否保存数据库成功

多种查询语句的公式如下:

★注意：

单条件:

@"rowid = 1"  或者  @{@"rowid":@1}

多条件：

@“rowid = 1 and sex = 0"  或者    @{@"rowid":@1,@"sex":@0}

如果是or类型的条件，则只能用字符串的形式：@"rowid = 1 or sex = 0"

in条件：

@"rowid in (1,2,3)"   或者     @{@"rowid":@[@1,@2,@3]}

多条件带in：@"rowid in (1,2,3) and sex=0 "   或者    @{@"rowid":@[@1,@2,@3],@"sex":@0}

时间也只能用字符串：

@"date >= '2013-04-01 00:00:00'"

like也只能用字符串：

@"userName like '%%JY%%'"

因为这个只是写一个流程和思路，所有请按照实际的需求来写代码，不要完全按照我的这个顺序，因为我是全都写在一个- (void)viewDidLoad 方法里面，如果完全这样写是不行滴哟!!!!

- (void)viewDidLoad {

    [super viewDidLoad];

    NSString *userID = @"12345";

    LKDBHelper *allHelper = [SQliteModel getUsingLKDBHelper];

    SQliteModel *model = [[SQliteModel alloc] init];

    //1.查询

    //1.1 删除所有的表

    [allHelper dropAllTable];

    //1.2 插入数据

    model.userID = @"1129";

    model.userName = @"我是锤锤";

    model.userPhone = @"18786642655";

    model.ptime = @"2016-11-15";

    [model saveToDB];

    //1.3 另一种插入方式

    model.userPhone = @"1399998888";

    [allHelper insertToDB:model];

    //1.4查询的方式

    /**

     * 第一个参数是查询的条件

     * orderBy:第二个参数是排序是以时间为降序

     * offset:0代表从第0个位置开始，比如在加载更多的时候会用到

     * count:0代表所有的，非0代表一共查询多少行数据

     */

    NSMutableArray *array = @[].mutableCopy;

    array = [SQliteModel searchWithWhere:[NSString stringWithFormat:@"userID=%@",userID] orderBy:@"ptime desc" offset:0 count:0];

    if (array.count>0) {

        //将查询到的数据保存到本地的数组中

        //这样看起来有没有很熟悉的感觉?是不是简单多了

        //多说一句，因为我这里并没有写的很详细。请在哪里需要用到的进行自己选择，千万不要看都不看就直接按照我的顺序来炒，那样是不行滴哟。

        //各种组合的查询我后面会给出参考的地址，有需要的请参考。

        self.dataSource = array;

    }

    //查询符合条件的条数

    NSInteger rowCount=[SQliteModel rowCountWithWhere:@"userID=2250"];

    NSLog(@"rowCount %ld",rowCount);

    //2.更新,带条件更新

    //根据userID来进行更新

    [SQliteModel updateToDB:model where:@{@"userID":model.userID}];

    //3.删除

   NSString * user=[allHelper searchSingle:[SQliteModel class] where:@{@"userPhone":@"12345678911"} orderBy:nil];

    BOOL ishas=[allHelper isExistsModel:user];

    if (ishas) {

        [allHelper deleteToDB:user];

    }

    //删除多条

    BOOL isDeleteMore=[allHelper deleteWithClass:[SQliteModel class] where:@"userName=1239"];

    if (isDeleteMore) {

        NSLog(@"符合条件的都被删除");

    }

}

参考资料:http://www.cnblogs.com/wujy/p/4522493.html

代码下载地址

如果有什么问题请在下方留言，也可以直接Email。

Email:marlonxlj@163.com

相关文章