使用 MultiPeer 框架将 NSData 发送给对等点答案

【问题标题】：Sending NSData to peers with MultiPeer framework使用 MultiPeer 框架将 NSData 发送给对等点
【发布时间】：2015-12-17 12:33:23
【问题描述】：

我已经成功地将 multiPeer 框架实现到我的应用程序中，并且可以轻松地将图像和字符串传递给其他设备。我的问题是当我尝试传递一个转换为 NSData 的 NSArray 时。当调用 multipeer didReceiveData 数据函数时，我总是会出现以下崩溃：

由于未捕获的异常'NSInvalidArgumentException'而终止应用程序，原因：'*** -[NSKeyedUnarchiver initForReadingWithData:]：无法理解的存档

以下是我发送数据的方式：

   var myNSData: NSData = NSKeyedArchiver.archivedDataWithRootObject(arrayOfNumbers)


        var error : NSError?

        self.session.sendData(myNSData, toPeers: self.session.connectedPeers,
            withMode: MCSessionSendDataMode.Reliable, error: &error)

        if error != nil {
            print("Error sending data: \(error?.localizedDescription)")
        }

这就是我尝试接收数据的方式：

    func session(session: MCSession!, didReceiveData data: NSData!,
    fromPeer peerID: MCPeerID!)  {
        // Called when a peer sends an NSData to us

        // This needs to run on the main queue
        dispatch_async(dispatch_get_main_queue()) {

  // can't convert data back NSArray without crash 
      var receivedArray:NSArray = NSKeyedUnarchiver.unarchiveObjectWithData(data) as! NSArray

【问题讨论】：

arrayOfNumbers 是如何声明的？在调用 sendData 之前 myNSData 是什么样的？
arrayOfNumbers 包含什么？是否所有元素都实现了 NSCoding？发送时的数据与接收时的数据是否不同？
@Dan arrayOfNumbers 是一个简单的 Ints NSArray，如下所示：arrayOfNumbers = [1,3,5,7,8]。这个 NSArray 声明如下： var arrayOfNumbers:NSArray = []
@Valentin arrayOfNumbers 包含 Ints。我在调用 sendData 之前测试了数组，并且将数组 Nsdata 转换回新数组工作正常。但是如果在 didReceieveData 函数中读取它会崩溃。我需要实施 NSCoding 吗？不知道如何
我尝试将字符串保存到数组而不是整数，但是当在 didRecieveData func 中读取数据时，我仍然得到与上面相同的崩溃报告

标签： ios swift

【解决方案1】：

确实，您没有提供确定问题所需的所有相关代码；但是，我可以这样说：（1）您使用数组的方法毫无意义。如果您愿意，我可以提供完美的图像广播代码；并且，(2) 尝试使用 NSValue 对数组进行编码，然后归档 NSValue 对象。

确实，您没有提供确定问题所需的所有相关代码；但是，我可以这样说：（1）您使用数组的方法毫无意义。我在下面为您提供了完美的图像广播代码；并且，(2) 尝试使用 NSValue 对数组进行编码，然后归档 NSValue 对象。

这是最好的方法：

在发送图像数据的 iOS 设备上：

- (void)captureOutput:(AVCaptureOutput *)captureOutput didOutputSampleBuffer:(CMSampleBufferRef)sampleBuffer fromConnection:(AVCaptureConnection *)connection
{
    CVImageBufferRef imageBuffer = CMSampleBufferGetImageBuffer(sampleBuffer);

    CVPixelBufferLockBaseAddress(imageBuffer,0);
    uint8_t *baseAddress = (uint8_t *)CVPixelBufferGetBaseAddress(imageBuffer);
    size_t bytesPerRow = CVPixelBufferGetBytesPerRow(imageBuffer);
    size_t width = CVPixelBufferGetWidth(imageBuffer);
    size_t height = CVPixelBufferGetHeight(imageBuffer);

    CGColorSpaceRef colorSpace = CGColorSpaceCreateDeviceRGB();
    CGContextRef newContext = CGBitmapContextCreate(baseAddress, width, height, 8, bytesPerRow, colorSpace, kCGBitmapByteOrder32Little | kCGImageAlphaPremultipliedFirst);
    CGImageRef newImage = CGBitmapContextCreateImage(newContext);


    UIImage *image = [[UIImage alloc] initWithCGImage:newImage scale:1 orientation:UIImageOrientationUp];
    CGImageRelease(newImage);
    CGContextRelease(newContext);
    CGColorSpaceRelease(colorSpace);
    CVPixelBufferUnlockBaseAddress(imageBuffer, 0);

    if (image) {
        NSData *data = UIImageJPEGRepresentation(image, 0.7);
        NSError *err;
        [((ViewController *)self.parentViewController).session sendData:data toPeers:((ViewController *)self.parentViewController).session.connectedPeers withMode:MCSessionSendDataReliable error:&err];
    }
}

在接收图像数据的 iOS 设备上：

typedef struct {
    size_t length;
    void *data;
} ImageCacheDataStruct;

- (void)session:(nonnull MCSession *)session didReceiveData:(nonnull NSData *)data fromPeer:(nonnull MCPeerID *)peerID
{
  dispatch_async(self.imageCacheDataQueue, ^{
        dispatch_semaphore_wait(self.semaphore, DISPATCH_TIME_FOREVER);
        const void *dataBuffer = [data bytes];
        size_t dataLength = [data length];
        ImageCacheDataStruct *imageCacheDataStruct = calloc(1, sizeof(imageCacheDataStruct));
        imageCacheDataStruct->data = (void*)dataBuffer;
        imageCacheDataStruct->length = dataLength;

        __block const void * kMyKey;
        dispatch_queue_set_specific(self.imageDisplayQueue, &kMyKey, (void *)imageCacheDataStruct, NULL);

        dispatch_sync(self.imageDisplayQueue, ^{
            ImageCacheDataStruct *imageCacheDataStruct = calloc(1, sizeof(imageCacheDataStruct));
            imageCacheDataStruct = dispatch_queue_get_specific(self.imageDisplayQueue, &kMyKey);
            const void *dataBytes = imageCacheDataStruct->data;
            size_t length = imageCacheDataStruct->length;
            NSData *imageData = [NSData dataWithBytes:dataBytes length:length];
            UIImage *image = [UIImage imageWithData:imageData];
            if (image) {
                dispatch_async(dispatch_get_main_queue(), ^{
                    [((ViewerViewController *)self.childViewControllers.lastObject).view.layer setContents:(__bridge id)image.CGImage];
                    dispatch_semaphore_signal(self.semaphore);
                });
            }
        });
    });
}

信号量和单独的 GCD 队列的原因很简单：您希望帧以相等的时间间隔显示。否则，视频一开始似乎会变慢，就在为了赶上速度而加快速度之前。我的方案确保每一帧都以相同的速度一个接一个地播放，而不考虑网络带宽瓶颈。

【讨论】：