设置连接管理器
连接管理器处理所有连接事件,并且是 在设备之间传输数据的过程。无论是要展示广告 和发现。
首先,选择服务 ID 来唯一标识您的应用。最佳
练习时,请使用应用的软件包名称(例如 com.example.app
)。
接下来,根据您的用例选择策略。通过
您选择的策略决定了应用的连接拓扑(.cluster
、
.star
.pointToPoint
)。
初始化连接管理器并实现其委托方法:
Swift
import NearbyConnections
class Example {
let connectionManager: ConnectionManager
init() {
connectionManager = ConnectionManager(serviceID: "com.example.app", strategy: .cluster)
connectionManager.delegate = self
}
}
extension Example: ConnectionManagerDelegate {
func connectionManager(
_ connectionManager: ConnectionManager, didReceive verificationCode: String,
from endpointID: EndpointID, verificationHandler: @escaping (Bool) -> Void) {
// Optionally show the user the verification code. Your app should call this handler
// with a value of `true` if the nearby endpoint should be trusted, or `false`
// otherwise.
verificationHandler(true)
}
func connectionManager(
_ connectionManager: ConnectionManager, didReceive data: Data,
withID payloadID: PayloadID, from endpointID: EndpointID) {
// A simple byte payload has been received. This will always include the full data.
}
func connectionManager(
_ connectionManager: ConnectionManager, didReceive stream: InputStream,
withID payloadID: PayloadID, from endpointID: EndpointID,
cancellationToken token: CancellationToken) {
// We have received a readable stream.
}
func connectionManager(
_ connectionManager: ConnectionManager,
didStartReceivingResourceWithID payloadID: PayloadID,
from endpointID: EndpointID, at localURL: URL,
withName name: String, cancellationToken token: CancellationToken) {
// We have started receiving a file. We will receive a separate transfer update
// event when complete.
}
func connectionManager(
_ connectionManager: ConnectionManager,
didReceiveTransferUpdate update: TransferUpdate,
from endpointID: EndpointID, forPayload payloadID: PayloadID) {
// A success, failure, cancelation or progress update.
}
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.
}
}
}
开始广告
要开始投放广告,请初始化广告客户,实现其委托方法,
然后调用 startAdvertising(using:)
。
Swift
import NearbyConnections
class Example {
let connectionManager: ConnectionManager
let advertiser: Advertiser
init() {
connectionManager = ConnectionManager(serviceID: "com.example.app", strategy: .cluster)
connectionManager.delegate = self
advertiser = Advertiser(connectionManager: connectionManager)
advertiser.delegate = self
// The endpoint info can be used to provide arbitrary information to the
// discovering device (e.g. device name or type).
advertiser.startAdvertising(using: "My Device".data(using: .utf8)!)
}
}
extension Example: AdvertiserDelegate {
func advertiser(
_ advertiser: Advertiser, didReceiveConnectionRequestFrom endpointID: EndpointID,
with context: Data, connectionRequestHandler: @escaping (Bool) -> Void) {
// Accept or reject any incoming connection requests. The connection will still need to
// be verified in the connection manager delegate.
connectionRequestHandler(true)
}
}
开始发现
如需开始发现,请初始化发现器,实现其委托方法,
然后调用 startDiscovery()
。
Swift
import NearbyConnections
class Example {
let connectionManager: ConnectionManager
let discoverer: Discoverer
init() {
connectionManager = ConnectionManager(serviceID: "com.example.app", strategy: .cluster)
connectionManager.delegate = self
discoverer = Discoverer(connectionManager: connectionManager)
discoverer.delegate = self
discoverer.startDiscovery()
}
}
extension Example: DiscovererDelegate {
func discoverer(
_ discoverer: Discoverer, didFind endpointID: EndpointID, with context: Data) {
// An endpoint was found.
}
func discoverer(_ discoverer: Discoverer, didLose endpointID: EndpointID) {
// A previously discovered endpoint has gone away.
}
}