我有一个简单的客户端和服务器应用程序与CocoaAsyncSocket一起使用。我可以使用客户端连接到服务器，并且可以在客户端之间来回传递数据，并且委托方法似乎可以正确触发。我的问题是我只能将数据发送回传递给委托方法之一的（AsyncSocket *）对象。接受连接时，我将套接字添加到NSMutableArray，但是稍后，如果我尝试使用套接字，写入将失败。所以
[connectedSockets addObject:newSocket];
//then later
[[connectedSockets objectAtIndex:i] writeData:someData withTimeout:-1 tag:0];
不起作用。下面是服务器和客户端的代码。最初的通信确实有效，但是当我的通知被调用时，即使NSLog语句测试了阵列中的套接字并获得了正确的IP地址和端口号，也没有发送任何数据：
服务器：
- (id)init
{
self = [super init];
if (self) {
listenSocket = [[AsyncSocket alloc] initWithDelegate:self];
[listenSocket setRunLoopModes:[NSArray arrayWithObject:NSRunLoopCommonModes]];
[listenSocket acceptOnPort:42381 error:nil];
connectedSockets = [[NSMutableArray alloc] init];
newNotificationDictArray = [[NSMutableArray alloc] init];
updateNotificationDictArray = [[NSMutableArray alloc] init];
[[NSNotificationCenter defaultCenter] addObserver:self
selector:@selector(newJobNotification:)
name:@"NewJob"
object:nil];
}
return self;
}
-(void)onSocketDidDisconnect:(AsyncSocket *)sock
{
[connectedSockets removeObject:sock];
}
- (void)onSocket:(AsyncSocket *)sock willDisconnectWithError:(NSError *)err
{
[connectedSockets removeObject:sock];
}
- (void)onSocket:(AsyncSocket *)sock didAcceptNewSocket:(AsyncSocket *)newSocket
{
[connectedSockets addObject:newSocket];
}
- (void)onSocket:(AsyncSocket *)sock didConnectToHost:(NSString *)host port:(UInt16)port
{
if ([newNotificationDictArray count] > 0) {
NSMutableData *data = [[NSMutableData alloc] init];
NSKeyedArchiver *archiver = [[NSKeyedArchiver alloc] initForWritingWithMutableData:data];
[archiver encodeObject:newNotificationDictArray forKey:@"DictArray"];
[archiver finishEncoding];
[archiver release];
[sock writeData:data withTimeout:-1 tag:0];
[data release];
}
[sock readDataWithTimeout:-1 tag:0];
}
- (void)onSocket:(AsyncSocket *)sock didWriteDataWithTag:(long)tag
{
[sock readDataWithTimeout:-1 tag:0];
}
- (void)onSocket:(AsyncSocket *)sock didReadData:(NSData *)data withTag:(long)tag
{
[sock readDataWithTimeout:-1 tag:0];
}
-(void) newJobNotification: (NSNotification *) notification
{
NSDictionary *dict = [notification userInfo];
[newNotificationDictArray addObject:dict];
[updateNotificationDictArray addObject:dict];
NSMutableData *updateData = [[NSMutableData alloc] init];
NSKeyedArchiver *archiver = [[NSKeyedArchiver alloc] initForWritingWithMutableData:updateData];
[archiver encodeObject:updateNotificationDictArray forKey:@"DictArray"];
[archiver finishEncoding]
[updateNotificationDictArray removeAllObjects];
[archiver release];
NSLog(@"Attempting to write to %@:%i", [[connectedSockets objectAtIndex:0] connectedHost], [[connectedSockets objectAtIndex:0] connectedPort])
[[connectedSockets objectAtIndex:0] writeData:updateData withTimeout:-1 tag:0];
}
然后客户：
- (id)init
{
self = [super init];
if (self) {
socket = [[AsyncSocket alloc] initWithDelegate:self];
}
return self;
}
-(void) connectToHost: (NSString *) address
{
}
-(BOOL)onSocketWillConnect:(AsyncSocket *)sock
{
[sock retain];
[socket readDataWithTimeout:-1 tag:0];
return YES;
}
-(void)onSocket:(AsyncSocket *)sock didConnectToHost:(NSString *)host port:(UInt16)port
{
NSLog(@"Did Connect on port %i", [sock connectedPort]);
}
-(void) disconnectFromRemoteHost
{
[socket disconnect];
}
-(void)onSocketDidDisconnect:(AsyncSocket *)sock
{
NSLog(@"Did Disconnect");
}
- (void)onSocket:(AsyncSocket *)sock willDisconnectWithError:(NSError *)err
{
NSLog(@"Disconnect Error: %@", [err localizedDescription]);
}
- (void)onSocket:(AsyncSocket *)sock didWriteDataWithTag:(long)tag
{
[socket readDataWithTimeout:-1 tag:0];
}
- (void)onSocket:(AsyncSocket *)sock didReadData:(NSData *)data withTag:(long)tag
{
NSKeyedUnarchiver *unarchiver = [[NSKeyedUnarchiver alloc] initForReadingWithData:data];
NSArray *dictArray = [[unarchiver decodeObjectForKey:@"DictArray"] retain];
[unarchiver finishDecoding];
[unarchiver release];
for (NSDictionary *dict in dictArray) {
if ([[dict objectForKey:@"Kind"] isEqualTo:@"New"])
[[NSNotificationCenter defaultCenter] postNotificationName:@"NewJob" object:self userInfo:dict];
else if ([[dict objectForKey:@"Kind"] isEqualTo:@"Update"])
[[NSNotificationCenter defaultCenter] postNotificationName:@"JobUpdate" object:self userInfo:dict];
}
[socket readDataWithTimeout:-1 tag:0];
}
帮助我stackoverflow，您是我唯一的希望！
最佳答案
我发现您发布的代码有2个潜在问题。第一个似乎不太可能引起您的问题，但是无论如何我都会发布它。在您的客户代码中，您具有：
-(BOOL)onSocketWillConnect:(AsyncSocket *)sock
{
[sock retain];
[socket readDataWithTimeout:-1 tag:0];
return YES;
}
我不确定为什么您会在这里保留“袜子”。您已经拥有创建的套接字的保留副本，这似乎可能导致泄漏。
至于第二个问题，这很可能是您失败的原因，这就是我认为正在发生的事情。查看有关AsyncSocket的文档，我看到以下内容：
但是，AsyncSocket不是线程安全的。您只能在以下位置调用AsyncSocket上的方法：
在其上配置套接字的线程/运行循环。如果您发现自己在哪个线程上
与运行AsyncSocket的线程不同，您需要调用一个
AsyncSocket上的方法，则必须使用诸如performSelector：onThread：之类的方法来确保
该方法在AsyncSocket的线程上调用（从而保持线程安全）。
您的接收通知并触发“稍后”写入的代码可能在另一个线程中，因此即使通过该线程有效，该写入也无法完成您期望的操作。如果需要线程安全，AsyncSocket文档会继续建议您使用GCDAsyncSocket。