সেটআপ

আশেপাশের সংযোগগুলি কীভাবে সেটআপ করবেন সে সম্পর্কে অনুগ্রহ করে নিকটবর্তী সংযোগগুলি পড়ুন৷

সংক্ষিপ্ত বার্তা

কাছাকাছি সংযোগগুলি তার ক্লায়েন্টদের দূরবর্তী ডিভাইসে সংযোগ স্থাপন না করে 131 বাইটের মধ্যে ডেটা পাঠাতে দেয়। কিভাবে 131 বাইটের মধ্যে বার্তা স্থানান্তর করতে হয় তা অনুগ্রহ করে নীচের প্রবাহটি দেখুন।

প্রকাশক

class Publisher {
  let connectionManager: ConnectionManager
  let advertiser: Advertiser

  init() {
    connectionManager = ConnectionManager(serviceID: <SERVICE_ID>, strategy: .pointToPoint)
    advertiser = Advertiser(connectionManager: connectionManager)
  }

  func startPublishing() {
    advertiser.startAdvertising(using: <MESSAGE_DATA>)
  }

  func stopPublishing() {
    advertiser.stopAdvertising()
  }
}

গ্রাহক

class Subscriber {
  let connectionManager: ConnectionManager
  let discoverer: Discoverer

  init() {
    connectionManager = ConnectionManager(serviceID: <SERVICE_ID>, strategy: .pointToPoint)

    discoverer = Discoverer(connectionManager: connectionManager)
    discoverer.delegate = self
  }

  func startSubscription() {
    discoverer.startDiscovery()
  }

  func stopSubscription() {
    discoverer.stopDiscovery()
  }
}

extension Subscriber: DiscovererDelegate {
  func discoverer(_ discoverer: Discoverer, didFind endpointID: EndpointID, with context: Data) {
    // A remote advertising endpoint is found.
    print(context)  // `context` is the published message data.
  }

  func discoverer(_ discoverer: Discoverer, didLose endpointID: EndpointID) {
    // A previously discovered endpoint has gone away.
  }
}

দীর্ঘ বার্তা

131 বাইটের চেয়ে বড় বার্তাগুলির জন্য, বার্তা স্থানান্তর করার জন্য ডিভাইসগুলির মধ্যে একটি সংযোগ স্থাপন করা প্রয়োজন৷ আশেপাশের সংযোগগুলি ব্যবহার করে কীভাবে বড় ডেটা স্থানান্তর করতে হয় তা অনুগ্রহ করে নীচের প্রবাহটি দেখুন৷

প্রকাশক

class Publisher {
  let connectionManager: ConnectionManager
  let advertiser: Advertiser

  init() {
    connectionManager = ConnectionManager(serviceID: <SERVICE_ID>, strategy: .pointToPoint)
    connectionManager.delegate = self

    advertiser = Advertiser(connectionManager: connectionManager)
    advertiser.delegate = self
  }

  func startPublishing() {
    advertiser.startAdvertising(using: <ENDPOINT_INFO>)
  }

  func stopPublishing() {
    advertiser.stopAdvertising()
  }
}

extension Publisher: ConnectionManagerDelegate {
  func connectionManager(
    _ connectionManager: ConnectionManager, didReceive data: Data, withID payloadID: PayloadID,
    from endpointID: EndpointID) {
    // We can ignore implementation, because we are the publisher.
  }

  func connectionManager(
    _ connectionManager: ConnectionManager, didReceive stream: InputStream,
    withID payloadID: PayloadID,
    from endpointID: EndpointID, cancellationToken token: CancellationToken) {
    // We can ignore implementation, because we are the publisher.
  }

  func connectionManager(
    _ connectionManager: ConnectionManager, didStartReceivingResourceWithID payloadID: PayloadID,
    from endpointID: EndpointID, at localURL: URL, withName name: String,
    cancellationToken token: CancellationToken) {
    // We can ignore implementation, because we are the publisher.
  }

  func connectionManager(
    _ connectionManager: ConnectionManager, didReceiveTransferUpdate update: TransferUpdate,
    from endpointID: EndpointID, forPayload payloadID: PayloadID) {
    // We can ignore implementation, because we are the publisher.
  }

  func connectionManager(
    _ connectionManager: ConnectionManager, didChangeTo state: ConnectionState,
    for endpointID: EndpointID) {
    switch state {
    case .connecting:
      // A connection to the remote endpoint is currently being established.
    case .connected:
      // We're connected! Can now start sending and receiving data.
      connectionManager.send(<MESSAGE_DATA>, to: [endpointID])
    case .disconnected:
      // We've been disconnected from this endpoint. No more data can be sent or received.
    case .rejected:
      // The connection was rejected by one or both sides.
    }
  }
}

extension Publisher: AdvertiserDelegate {
  func advertiser(
    _ advertiser: Advertiser, didReceiveConnectionRequestFrom endpointID: EndpointID,
    with context: Data, connectionRequestHandler: @escaping (Bool) -> Void) {
    // Automatically accept any incoming connection requests.
    connectionRequestHandler(true)
  }
}

গ্রাহক

class Subscriber {
  let connectionManager: ConnectionManager
  let discoverer: Discoverer

  init() {
    connectionManager = ConnectionManager(serviceID: <SERVICE_ID>, strategy: .pointToPoint)
    connectionManager.delegate = self

    discoverer = Discoverer(connectionManager: connectionManager)
    discoverer.delegate = self
  }

  func startSubscription() {
    discoverer.startDiscovery()
  }

  func stopSubscription() {
    discoverer.stopDiscovery()
  }
}

extension Subscriber: ConnectionManagerDelegate {
  func connectionManager(
    _ connectionManager: ConnectionManager, didReceive data: Data, withID payloadID: PayloadID,
    from endpointID: EndpointID) {
    // This always gets the full data of the payload.
    print(data)
  }

  func connectionManager(
    _ connectionManager: ConnectionManager, didReceive stream: InputStream,
    withID payloadID: PayloadID,
    from endpointID: EndpointID, cancellationToken token: CancellationToken) {
    // We can ignore implementation because we only care about bytes payloads.
  }

  func connectionManager(
    _ connectionManager: ConnectionManager, didStartReceivingResourceWithID payloadID: PayloadID,
    from endpointID: EndpointID, at localURL: URL, withName name: String,
    cancellationToken token: CancellationToken) {
    // We can ignore implementation because we only care about bytes payloads.
  }

  func connectionManager(
    _ connectionManager: ConnectionManager, didReceiveTransferUpdate update: TransferUpdate,
    from endpointID: EndpointID, forPayload payloadID: PayloadID) {
    // Bytes payloads are sent as a single chunk, so you'll receive TransferUpdate.success
    // immediately.
  }

  func connectionManager(
    _ connectionManager: ConnectionManager, didChangeTo state: ConnectionState,
    for endpointID: EndpointID) {
    switch state {
    case .connecting:
      // A connection to the remote endpoint is currently being established.
    case .connected:
      // We're connected! Can now start sending and receiving data.
    case .disconnected:
      // We've been disconnected from this endpoint. No more data can be sent or received.
    case .rejected:
      // The connection was rejected by one or both sides.
    }
  }
}

extension Subscriber: DiscovererDelegate {
  func discoverer(_ discoverer: Discoverer, didFind endpointID: EndpointID, with context: Data) {
    // An endpoint was found. We request a connection to it.
    discoverer.requestConnection(to: endpointID, using: <ENDPOINT_INFO>)
  }

  func discoverer(_ discoverer: Discoverer, didLose endpointID: EndpointID) {
    // A previously discovered endpoint has gone away.
  }
}