膨胀螺栓型号,深海之战下载,牛烽网
用socket可以实现像qq那样发送即时消息的功能。客户端和服务端需要建立长连接，在长连接的情况下，发送消息。客户端可以发送心跳包来检测长连接。
在ios开发中使用socket，一般都是用第三方库asyncsocket，不得不承认这个库确实很强大。下载地址cocoaasyncsocket
。
特性
asyncsocket类是支持tcp的。
asyncudpsocket是支持udp的。
asyncsocket是封装了cfsocket和cfsteam的tcp/ip socket网络库。它提供了异步操作，本地cocoa类的基于delegate的完整支持。主要有以下特性：
asyncudpsocket是udp/ip socket网络库，包装自cfsocket。它的工作很像tcp版本，只不过是用于处理udp的。它包括基于非阻塞队列的发送接收操作，完整的委托支持，基于runloop，自包含的类，以及支持ipv4和ipv6。
使用asyncsocket的时候可以做一层封装，根据需求提供几个接口出来。比如：连接、断开连接、发送消息等等。还有接受消息，接受到的消息可以通过通知、代理、block等传出去。
下面简单介绍一下对asyncsocket使用.一般来说，一个用户只需要建立一个socket长连接，所以可以用单例类方便使用。
定义单列类：lgsocketserve
lgsocketserve.h
#import <foundation/foundation.h>
#import "asyncsocket.h"
@interface lgsocketserve : nsobject<asyncsocketdelegate>
+ (lgsocketserve *)sharedsocketserve;
@end
#import "lgsocketserve.h"
@implementation lgsocketserve
static lgsocketserve *socketserve = nil;
#pragma mark public static methods
+ (lgsocketserve *)sharedsocketserve {
@synchronized(self) {
if(socketserve == nil) {
socketserve = [[[self class] alloc] init];
}
}
return socketserve;
}
+(id)allocwithzone:(nszone *)zone
{
@synchronized(self)
{
if (socketserve == nil)
{
socketserve = [super allocwithzone:zone];
return socketserve;
}
}
return nil;
}
@end
lgsocketserve.h
// socket连接
- (void)startconnectsocket;
lgsocketserve.m
//自己设定
#define host @"192.168.0.1"
#define port 8080
//设置连接超时
#define time_out 20
- (void)startconnectsocket
{
self.socket = [[asyncsocket alloc] initwithdelegate:self];
[self.socket setrunloopmodes:[nsarray arraywithobject:nsrunloopcommonmodes]];
if ( ![self socketopen:host port:port] )
{
}
}
- (nsinteger)socketopen:(nsstring*)addr port:(nsinteger)port
{
if (![self.socket isconnected])
{
nserror *error = nil;
[self.socket connecttohost:addr onport:port withtimeout:time_out error:&error];
}
return 0;
}
lgsocketserve.h
- (void)onsocket:(asyncsocket *)sock didconnecttohost:(nsstring *)host port:(uint16)port
{
//这是异步返回的连接成功，
nslog(@"didconnecttohost");
//通过定时器不断发送消息，来检测长连接
self.hearttimer = [nstimer scheduledtimerwithtimeinterval:2 target:self selector:@selector(checklongconnectbyserve) userinfo:nil repeats:yes];
[self.hearttimer fire];
}
// 心跳连接
-(void)checklongconnectbyserve{
// 向服务器发送固定可是的消息，来检测长连接
nsstring *longconnect = @"connect is here";
nsdata *data = [longconnect datausingencoding:nsutf8stringencoding];
[self.socket writedata:data withtimeout:1 tag:1];
}
断开连接
1，用户手动断开连接
lgsocketserve.h
-(void)cutoffsocket
{
self.socket.userdata = socketofflinebyuser;
[self.socket disconnect];
}
2，wifi断开，socket断开连接
lgsocketserve.m
nslog(@" willdisconnectwitherror %ld err = %@",sock.userdata,[err description]);
if (err.code == 57) {
self.socket.userdata = socketofflinebywificut;
}
}
重新连接
socket断开之后会回调：
lgsocketserve.m
nslog(@"7878 sorry the connect is failure %ld",sock.userdata);
if (sock.userdata == socketofflinebyserver) {
// 服务器掉线，重连
[self startconnectsocket];
}
else if (sock.userdata == socketofflinebyuser) {
// 如果由用户断开，不进行重连
return;
}else if (sock.userdata == socketofflinebywificut) {
// wifi断开，不进行重连
return;
}
}
发送消息
lgsocketserve.h
//设置写入超时 -1 表示不会使用超时
#define write_time_out -1
- (void)sendmessage:(id)message
{
//像服务器发送数据
nsdata *cmddata = [message datausingencoding:nsutf8stringencoding];
[self.socket writedata:cmddata withtimeout:write_time_out tag:1];
}
//发送消息成功之后回调
- (void)onsocket:(asyncsocket *)sock didwritedatawithtag:(long)tag
{
}
接受消息
lgsocketserve.m
#define max_buffer 1024
//发送消息成功之后回调
- (void)onsocket:(asyncsocket *)sock didwritedatawithtag:(long)tag
{
//读取消息
[self.socket readdatawithtimeout:-1 buffer:nil bufferoffset:0 maxlength:max_buffer tag:0];
}
//接受消息成功之后回调
- (void)onsocket:(asyncsocket *)sock didreaddata:(nsdata *)data withtag:(long)tag
{
//服务端返回消息数据量比较大时，可能分多次返回。所以在读取消息的时候，设置max_buffer表示每次最多读取多少，当data.length < max_buffer我们认为有可能是接受完一个完整的消息，然后才解析
if( data.length < max_buffer )
{
//收到结果解析...
nsdictionary *dic = [nsjsonserialization jsonobjectwithdata:data options:nsjsonreadingmutableleaves error:nil];
nslog(@"%@",dic);
//解析出来的消息，可以通过通知、代理、block等传出去
}
[self.socket readdatawithtimeout:read_time_out buffer:nil bufferoffset:0 maxlength:max_buffer tag:0];
出错处理
lgsocketserve.m
nslog(@" willdisconnectwitherror %ld err = %@",sock.userdata,[err description]);
if (err.code == 57) {
self.socket.userdata = socketofflinebywificut;
}
}
}
使用
导入#import “lgsocketserve.h”
//发送消息 @"hello world"只是举个列子，具体根据服务端的消息格式
[socketserve sendmessage:@"hello world"];
如对本文有疑问，请在下面进行留言讨论，广大热心网友会与你互动！！ 点击进行留言回复
我要评论
网友评论