CocoaAsyncSocket例子

在项目中用到了tcp/udp，写了个工具类，备忘，也算是对开源的一点贡献。

封装了工具类LocalSocketClient，内容如下，其中有些方法和变量是我的项目中用到了，阅读时你直接跳过就好了。

LocalSocketClient.h

[cpp]
@inte易做图ce LocalSocketClient : NSObject<AsyncSocketDelegate,AsyncUdpSocketDelegate> 
@property (retain,nonatomic) NSString* yunhoAddress; 
@property int yunhoPort; 
 
@property (retain,nonatomic)  AsyncSocket *socket; 
 
 
 
@property (retain,nonatomic)     NSString* mIP; 
@property int mPort; 
@property BOOL isConnected; 
 
 
 
 
+(LocalSocketClient*)share; 
- (void) connectToHost; 
- (void) connectToHost:(NSString*)host port:(int)port ; 
- (void) disconnectTcp ; 
-(void)sendSearchBroadcast; 
-(void)sendToUDPServer:(NSString*) msg address:(NSString*)address port:(int)port; 
- (void)sendMtalkMessage:(NSString*)ctalk_xml ; 
 
@end 

@inte易做图ce LocalSocketClient : NSObject<AsyncSocketDelegate,AsyncUdpSocketDelegate>
@property (retain,nonatomic) NSString* yunhoAddress;
@property int yunhoPort;

@property (retain,nonatomic)  AsyncSocket *socket;

@property (retain,nonatomic)     NSString* mIP;
@property int mPort;
@property BOOL isConnected;

+(LocalSocketClient*)share;
- (void) connectToHost;
- (void) connectToHost:(NSString*)host port:(int)port ;
- (void) disconnectTcp ;
-(void)sendSearchBroadcast;
-(void)sendToUDPServer:(NSString*) msg address:(NSString*)address port:(int)port;
- (void)sendMtalkMessage:(NSString*)ctalk_xml ;

@end

LocalSocketClient.m

[cpp] 
#import "LocalSocketClient.h"  
 
#define CTALK_SEARTH @"<ctalk id=\"%@\" xmlns=\"urn:xmpp:ctalk:1\"><search/></ctalk>"  
#define CTALK_STANDARD_HEADER @"<ctalk id=\"%@\" xmlns=\"urn:xmpp:ctalk:1\">"  
#define SOCKET_TIMEOUT -1 //当timeout，socket会断开  
#define BCPORT 9001  
 
 
@implementation LocalSocketClient{ 
@private 
 
     
     
} 
@synthesize isConnected; 
@synthesize yunhoAddress; 
@synthesize yunhoPort; 
 
@synthesize socket; 
 
 
@synthesize mIP; 
@synthesize mPort; 
 
 
static LocalSocketClient* localSocketClient; 
 
+(LocalSocketClient*)share{ 
    if (localSocketClient==nil) { 
        localSocketClient =[[LocalSocketClient alloc] init]; 
    } 
    return localSocketClient; 
} 
 
-(id)init{ 
    if (self=[super init]) { 
       
         
    } 
    return self; 
} 
 
#pragma mark udp  
-(void)sendSearchBroadcast{ 
    NSString* bchost=@"255.255.255.255"; 
    [self sendToUDPServer:[NSString stringWithFormat:CTALK_SEARTH,@"1231-12312-4214-234"] address:bchost port:BCPORT]; 
} 
-(void)sendToUDPServer:(NSString*) msg address:(NSString*)address port:(int)port{ 
    AsyncUdpSocket *udpSocket=[[[AsyncUdpSocket alloc]initWithDelegate:self]autorelease]; 
    NSLog(@"---address:%@,port:%d,msg:%@",address,port,msg); 
    //receiveWithTimeout is necessary or you won't receive anything  
    [udpSocket receiveWithTimeout:10 tag:2]; //  
    [udpSocket enableBroadcast:YES error:nil]; 
    NSData *data=[msg dataUsingEncoding:NSUTF8StringEncoding]; 
    [udpSocket sendData:data toHost:address port:port withTimeout:10 tag:1]; 
} 
-(BOOL)onUdpSocket:(AsyncUdpSocket *)sock didReceiveData:(NSData *)data withTag:(long)tag fromHost:(NSString *)host port:(UInt16)port{ 
    NSString* rData= [[[NSString alloc] initWithData:data encoding:NSUTF8StringEncoding] 
                      autorelease]; 
    NSLog(@"onUdpSocket:didReceiveData:---%@",rData); 
 
 
    return YES; 
} 
-(void)onUdpSocket:(AsyncUdpSocket *)sock didNotSendDataWithTag:(long)tag dueToError:(NSError *)error{ 
    NSLog(@"didNotSendDataWithTag----"); 
 
     
} 
-(void)onUdpSocket:(AsyncUdpSocket *)sock didNotReceiveDataWithTag:(long)tag dueToError:(NSError *)error{ 
    NSLog(@"didNotReceiveDataWithTag----"); 
 
} 
-(void)onUdpSocket:(AsyncUdpSocket *)sock didSendDataWithTag:(long)tag{ 
    NSLog(@"didSendDataWithTag----"); 
 
} 
-(void)onUdpSocketDidClose:(AsyncUdpSocket *)sock{ 
    NSLog(@"onUdpSocketDidClose----"); 
} 
 
 
- (void) connectToHost{ 
     
    [self connectToHost:mIP port:mPort]; 
     
     
} 
 
#pragma mark tcp  
- (void) connectToHost:(NSString*)host port:(int)port { 
    socket = [[AsyncSocket alloc] initWithDelegate:self]; 
 
    [socket disconnect]; 
 
    NSLog(@"tcp connecting to host:%@,port:%d",host,port); 
    @try { 
        [socket connectToHost:host onPort:port error:nil]; 
        [socket readDataWithTimeout:SOCKET_TIMEOUT tag:1]; 
 
    } 
    @catch (NSException *exception) { 
        NSLog(@"connect exception %@,%@", [exception name], [exception description]); 
 
    } 
} 
- (void) disconnectTcp { 
    if ([socket isConnected]) { 
        [socket disconnect]; 
    } 
} 
- (void)onSocket:(AsyncSocket *)sock didConnectToHost:(NSString *)host port:(UInt16)port{ 
    NSLog(@"did connect to host %@:%d", host, port); 
    isConnected=YES; 
    [NSThread detachNewThreadSelector:@selector(keepActivityST) toTarget:self withObject:nil]; 
     
} 

补充：移动开发 , 其他 ,

上一个：cocos2d-x 2.x 进度条CCProgressTimer
下一个：CCLayerColor 设置圆角 ，CCLayerColor Rounded Rectangle Drawing