ตั้งค่า

โปรดดูวิธีตั้งค่าการเชื่อมต่อใกล้เคียงในการเชื่อมต่อใกล้เคียง

ข้อความสั้น

การเชื่อมต่อใกล้เคียงช่วยให้ไคลเอ็นต์ส่งข้อมูลได้ภายใน 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 ไบต์ จะต้องสร้างการเชื่อมต่อระหว่างอุปกรณ์เพื่อโอนข้อความ โปรดดูขั้นตอนการโอนข้อมูลขนาดใหญ่โดยใช้การเชื่อมต่อ Wi-Fi ระยะใกล้ด้านล่าง

ผู้เผยแพร่โฆษณา

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.
  }
}