1

在之前的 Stack Overflow 问题中，人们在构建我的 Akka 套接字服务器时向我展示了我的方式的错误非常有帮助，实际上我现在有一个 Akka 套接字客户端，它可以使用以下框架发送消息：

消息长度：4 字节消息类型：4 字节消息负载：（长度）字节

这是我用来发送消息的 iOS 代码：

 NSInputStream *inputStream;
    NSOutputStream *outputStream;

    CFReadStreamRef readStream;
    CFWriteStreamRef writeStream;
    CFStreamCreatePairWithSocketToHost(NULL, (CFStringRef)@"localhost", 9999, &readStream, &writeStream);
    inputStream = (__bridge_transfer NSInputStream *)readStream;
    outputStream = (__bridge_transfer NSOutputStream *)writeStream;

    [inputStream setDelegate:self];
    [outputStream setDelegate:self];

    [inputStream scheduleInRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode];
    [outputStream scheduleInRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode];

   // [inputStream open];
    [outputStream open];
    NSLog(@"NSData raw zombie is %d bytes.", [rawZombie length]);
    uint32_t length = (uint32_t)htonl([rawZombie length]);
    uint32_t messageType = (uint32_t)htonl(1);        

    NSLog(@"Protobuf byte size %d", zombieSighting->ByteSize());

    [outputStream write:(uint8_t *)&length maxLength:4];
    [outputStream write:(uint8_t *)&messageType maxLength:4];
    [outputStream write:(uint8_t *)[rawZombie bytes] maxLength:length];

    [outputStream close];

'rawZombie' 变量（NSData *）来自以下方法：

- (NSData *)getDataForZombie:(kotancode::ZombieSighting *)zombie {
    std::string ps = zombie->SerializeAsString();
    NSLog(@"raw zombie string:\n[%s]", ps.c_str());
    return [NSData dataWithBytes:ps.c_str() length:ps.size()];
}

我看到的症状是我收到了由 iOS 发送的消息，它的长度是正确的，消息类型 (1) 也是正确的，并且正文很好。使用 Scala protobufs 的 Akka 服务器对消息进行反序列化，并完美地打印出消息上的所有值。问题是，在我收到该消息后，Akka 服务器立即认为它收到了另一条消息（显然，更多数据进入了流中）。每次运行 iOS 应用程序时，最后的数据都不相同。

例如，以下是来自两个连续消息接收的一些跟踪输出：

received message of length 45 and type 1
name:Kevin
lat: 41.007
long: 21.007
desc:This is a zombie
zombie type:FAST
received message of length 7 and type 4
received message of length 45 and type 1
name:Kevin
lat: 41.007
long: 21.007
desc:This is a zombie
zombie type:FAST
received message of length 164 and type 1544487554

所以你可以看到，在 Akka 服务器收到正确的消息数据之后，它也收到了一些随机的任意废话。鉴于我的 Akka 客户端可以正常工作而没有这种额外的任意废话，我假设我将 protobuf 对象写入 NSStream 的方式有问题...任何人都可以发现我的愚蠢错误，因为我确信那是什么正在这里发生。

4

1 回答 1

2

该死的地狱。我不敢相信我没有看到这个。在这里的代码行中：

[outputStream write:(uint8_t *)[rawZombie bytes] maxLength:length]

我使用值“长度”作为要传输的最大字节数。不幸的是，该值已经翻转了它的“endian”顺序，以准备通过网络传输。我用 [rawZombie length] 替换了“长度”，它就像一个魅力。

:(

于 2013-02-03T20:25:46.963 回答