Python (Twisted) でサーバーを作成しました。サーバーに接続してサーバーにデータを送信しましたが、サーバーからデータを取得しておらず、NSStreamEventHasBytesAvailable が呼び出されていません。
これは私がサーバーに接続する方法です:
CFStreamCreatePairWithSocketToHost(NULL, (CFStringRef)@"localhost", 3000, &readStream, &writeStream);
inputStream = (NSInputStream *)readStream;
outputStream = (NSOutputStream *)writeStream;
[inputStream setDelegate:self];
[outputStream setDelegate:self];
[inputStream scheduleInRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode];
[outputStream scheduleInRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode];
[inputStream open];
[outputStream open];
ここに問題があります:
-(void)stream:(NSStream *)theStream handleEvent:(NSStreamEvent)streamEvent
{
NSString *event;
switch (streamEvent)
{
case NSStreamEventHasBytesAvailable:
event = @"NSStreamEventHasBytesAvailable";
if (theStream == inputStream)
{
uint8_t buffer[1024];
int len;
while ([inputStream hasBytesAvailable])
{
NSLog(@"input =====%@",inputStream);
len = [inputStream read:buffer maxLength:1024];
NSLog(@"len -=======%d",len);
if (len > 0)
{
NSMutableString *output = [[NSMutableString alloc] initWithBytes:buffer length:len encoding:NSUTF8StringEncoding];
NSLog(@"Received data--------------------%@", output);
}
}
}
break;
}
}
これはサーバー側のコードです:
from twisted.internet.protocol import Factory, Protocol
from twisted.internet import reactor
class IphoneChat(Protocol):
def connectionMade(self):
self.factory.clients.append(self)
print "clients are ", self.factory.clients
def connectionLost(self, reason):
self.factory.clients.remove(self)
def dataReceived(self, data):
a = data.split(':')
print a
if len(a) > 1:
command = a[0]
content = a[1]
msg = ""
if command == "msg":
msg = content
print msg
def message(self, message):
self.transport.write(message + '\n')
for c in self.factory.clients:
c.message(msg)
factory = Factory()
factory.protocol = IphoneChat
factory.clients = []
reactor.listenTCP(650, factory)
print "Iphone Chat server started"
reactor.run()
私はたくさん試してみましたが、解決策は見つかりませんでした。それは私の時間を殺しているので、誰かがそれに取り組んでいるなら、私を導き、サンプルコードを投稿してください. 前もって感謝します。