Bonjour
NetService
- 一種使用多播DNS廣播其可用性的網(wǎng)絡(luò)服務(wù)
NetServiceBrowser
- 一種使用多播DNS查找網(wǎng)絡(luò)上發(fā)布的服務(wù)的網(wǎng)絡(luò)服務(wù)瀏覽器
應(yīng)用
該技術(shù)目前我們公司，是用于發(fā)現(xiàn)通局域網(wǎng)中的設(shè)備活孩。然后通過socket 去實(shí)現(xiàn)投屏途乃、和手機(jī)遙控的功能
NetService 詳解
- 初始化的兩種方式
- (instancetype)initWithDomain:(NSString *)domain
type:(NSString *)type
name:(NSString *)name;
- (instancetype)initWithDomain:(NSString *)domain
type:(NSString *)type
name:(NSString *)name
port:(int)port;
字段分析：
- domain:
服務(wù)的域。要解析默認(rèn)域幻枉，傳入一個(gè)空字符串(@"")碰声。如果要將解析限制在本地域，請(qǐng)使用@"local."熬甫。
如果您正在創(chuàng)建此對(duì)象來解析您的應(yīng)用程序之前存儲(chǔ)的信息的服務(wù)胰挑，您應(yīng)該將此設(shè)置為最初發(fā)現(xiàn)該服務(wù)的域。
您也可以使用NSNetServiceBrowser對(duì)象來獲取一個(gè)可能的域列表罗珍，您可以在其中發(fā)現(xiàn)和解析服務(wù)洽腺。
- type:
類型必須同時(shí)包含服務(wù)類型和傳輸層信息。為了確保mDNS響應(yīng)器搜索服務(wù)覆旱，而不是主機(jī)蘸朋，在服務(wù)名稱和傳輸層名稱前面加上一個(gè)下劃線字符(“_”)。例如扣唱，要在TCP上搜索HTTP服務(wù)藕坯，可以使用字符串“_http._tcp.”。請(qǐng)注意噪沙，字符串末尾的句點(diǎn)字符是必需的炼彪，它表明域名是絕對(duì)名稱。
- name:
要解析的服務(wù)的名稱
var service:NetService?
let port:Int32 = 6689
let type:String = "_db_controller123._tcp"
service = NetService(domain: "local.", type: type, name: "riverliBonjour", port: port)
if service == nil {
print("服務(wù)啟動(dòng)失敗")
return
}
service?.delegate = self
主要區(qū)別是有無端口正歼，不指定端口的話辐马，他們的發(fā)布方式不同
- 發(fā)布服務(wù)
//指定端口的發(fā)布方式
service?.publish()
//這種方式會(huì)主動(dòng)的分配一個(gè)端口（指定了端口不生效）
service?.publish(options: .listenForConnections)
- NetServiceDelegate
//將要發(fā)布
optional func netServiceWillPublish(_ sender: NetService)
//發(fā)布成功
optional func netServiceDidPublish(_ sender: NetService)
//發(fā)布失敗
optional func netService(_ sender: NetService, didNotPublish errorDict: [String : NSNumber])
//拿到解析結(jié)果
func netServiceDidResolveAddress(_ sender: NetService)
//解析出錯(cuò)
func netService(_ sender: NetService, didNotResolve errorDict: [String : NSNumber])
//服務(wù)停止
func netServiceDidStop(_ sender: NetService)
//給定服務(wù)的TXT記錄已經(jīng)更新
func netService(_ sender: NetService, didUpdateTXTRecord data: Data)
//當(dāng)客戶端連接到由Bonjour管理的服務(wù)時(shí)調(diào)用
func netService(_ sender: NetService, didAcceptConnectionWith inputStream: InputStream, outputStream: OutputStream)
服務(wù)端的總體代碼
import UIKit
class YMServiceHomeVC: UIViewController {
var service:NetService?
let port:Int32 = 6688
let type:String = "_db_controller123._tcp."
override func viewDidLoad() {
super.viewDidLoad()
title = "服務(wù)端"
publish()
}
@IBAction func startSocket(_ sender: Any) {
let vc = YMServiceMsgBoardVC()
vc.port = Int(port)
navigationController?.pushViewController(vc, animated: true)
}
//發(fā)布服務(wù)
func publish(){
service = NetService(domain: "local.", type: type, name: "riverliBonjour", port: port)
if service == nil {
print("服務(wù)啟動(dòng)失敗")
return
}
service?.delegate = self
//傳遞額外的數(shù)據(jù)
let data = NetService.data(fromTXTRecord:["Allenzhan":("Allen".data(using: .utf8))!])
let status = service?.setTXTRecord(data)
if status == true {
print("設(shè)置TXT 文案成功")
}else{
print("設(shè)置TXT 文案失敗")
}
service?.publish()
//這種方式會(huì)主動(dòng)的分配一個(gè)端口
// service?.publish(options: .listenForConnections)
// service?.resolve(withTimeout: 0.0)
}
}
extension YMServiceHomeVC: NetServiceDelegate{
func netServiceWillPublish(_ sender: NetService) {
print("將要發(fā)布")
}
func netServiceDidPublish(_ sender: NetService) {
print("發(fā)布成功")
}
}
客戶端
NetServiceBrowser
info.plist 配置
image.png
- 初始化
let port:Int32 = 1234
let type:String = "_db_controller123._tcp"
var seviceBrowser:NetServiceBrowser?
func createClient() {
seviceBrowser = NetServiceBrowser.init()
seviceBrowser?.delegate = self
//加入runloop 如果在子線程的話
// seviceBrowser?.schedule(in: RunLoop.current, forMode: .common)
seviceBrowser?.searchForServices(ofType: type, inDomain: "local.")
}
- 代理NetServiceBrowserDelegate
func netServiceBrowserWillSearch(_ browser: NetServiceBrowser){
print("開始搜索")
}
func netServiceBrowserDidStopSearch(_ browser: NetServiceBrowser){
print("結(jié)束搜索")
}
func netServiceBrowser(_ browser: NetServiceBrowser, didNotSearch errorDict: [String : NSNumber]){
print("沒有搜索到: error", errorDict)
}
func netServiceBrowser(_ browser: NetServiceBrowser, didFindDomain domainString: String, moreComing: Bool){
print("搜索到 Domain：" + domainString + "-- morecoming:" ,moreComing)
}
func netServiceBrowser(_ browser: NetServiceBrowser, didFind service: NetService, moreComing: Bool){
print("搜索到 service：" , service , "-- morecoming:" ,moreComing)
services.append(service)
//這里要給sevice 設(shè)置代理以便監(jiān)聽數(shù)據(jù)的解析
service.delegate = self
//這里要設(shè)置解析超時(shí)時(shí)間 0 的話是永久。這里服務(wù)端也可以發(fā)布成功后設(shè)置局义，但是客戶端最好自己設(shè)置一下喜爷，不然怕不能解析到數(shù)據(jù)
service.resolve(withTimeout: 5)
}
func netServiceBrowser(_ browser: NetServiceBrowser, didRemoveDomain domainString: String, moreComing: Bool){
print("刪除 Domain：" + domainString + "-- morecoming:" ,moreComing)
}
func netServiceBrowser(_ browser: NetServiceBrowser, didRemove service: NetService, moreComing: Bool){
print("刪除 service：" , service , "-- morecoming:" ,moreComing)
}
- NetServiceDelegate
func netServiceDidResolveAddress(_ sender: NetService){
print("----------")
print(sender)
if let ipAddresses = sender.addresses {
//獲取記錄的數(shù)據(jù)（服務(wù)端用來傳遞我們需要的數(shù)據(jù)）
let data = sender.txtRecordData()
let dict = NetService.dictionary(fromTXTRecord: data!)
print(dict)
for ipData in ipAddresses {
//解析ip
let ipStr = IPFrom(data: ipData);
print("ipstr = " + ipStr)
if ipStr.count > 0 {
dataSource.append((ipStr,sender.port))
tableView.reloadData()
}
}
}
print(sender.domain)
print(sender.hostName)
print(sender.name)
print(sender.port)
print("----------")
}
- 客戶端所有代碼
import UIKit
class YMClientHomeVC: UIViewController {
@IBOutlet weak var tableView: UITableView!
let port:Int32 = 1234
let type:String = "_db_controller123._tcp"
var services:[NetService] = [NetService]()
var seviceBrowser:NetServiceBrowser?
var dataSource:[(String,Int)] = [(String,Int)]()
override func viewDidLoad() {
super.viewDidLoad()
title = "客戶端"
createClient()
}
func createClient() {
seviceBrowser = NetServiceBrowser.init()
seviceBrowser?.delegate = self
// seviceBrowser?.schedule(in: RunLoop.current, forMode: .common)
seviceBrowser?.searchForServices(ofType: type, inDomain: "local.")
}
}
extension YMClientHomeVC:NetServiceBrowserDelegate{
func netServiceBrowserWillSearch(_ browser: NetServiceBrowser){
print("開始搜索")
}
func netServiceBrowserDidStopSearch(_ browser: NetServiceBrowser){
print("結(jié)束搜索")
}
func netServiceBrowser(_ browser: NetServiceBrowser, didNotSearch errorDict: [String : NSNumber]){
print("沒有搜索到: error", errorDict)
}
func netServiceBrowser(_ browser: NetServiceBrowser, didFindDomain domainString: String, moreComing: Bool){
print("搜索到 Domain：" + domainString + "-- morecoming:" ,moreComing)
}
func netServiceBrowser(_ browser: NetServiceBrowser, didFind service: NetService, moreComing: Bool){
print("搜索到 service：" , service , "-- morecoming:" ,moreComing)
services.append(service)
service.delegate = self
service.resolve(withTimeout: 5)
}
func netServiceBrowser(_ browser: NetServiceBrowser, didRemoveDomain domainString: String, moreComing: Bool){
print("刪除 Domain：" + domainString + "-- morecoming:" ,moreComing)
}
func netServiceBrowser(_ browser: NetServiceBrowser, didRemove service: NetService, moreComing: Bool){
print("刪除 service：" , service , "-- morecoming:" ,moreComing)
}
}
extension YMClientHomeVC: NetServiceDelegate {
func netServiceDidResolveAddress(_ sender: NetService){
print("----------")
print(sender)
if let ipAddresses = sender.addresses {
let data = sender.txtRecordData()
let dict = NetService.dictionary(fromTXTRecord: data!)
print(dict)
for ipData in ipAddresses {
let ipStr = IPFrom(data: ipData);
print("ipstr = " + ipStr)
if ipStr.count > 0 {
dataSource.append((ipStr,sender.port))
tableView.reloadData()
}
}
}
print(sender.domain)
print(sender.hostName)
print(sender.name)
print(sender.port)
print("----------")
}
func netService(_ sender: NetService, didNotResolve errorDict: [String : NSNumber]) {
print("--------netService didNotResolve:", errorDict, "--------")
}
func netServiceDidStop(_ sender: NetService) {
print("--------netServiceDidStop", "--------")
}
func netService(_ sender: NetService, didUpdateTXTRecord data: Data) {
print("--------netService didUpdateTXTRecord", "--------")
}
func netService(_ sender: NetService, didAcceptConnectionWith inputStream: InputStream, outputStream: OutputStream) {
print("--------netService didAcceptConnectionWith", "--------")
}
// MARK: util 獲取ip地址
func IPFrom(data: Data) -> String {
let dataIn: NSData = data as NSData
var storage = sockaddr_storage()
dataIn.getBytes(&storage, length: MemoryLayout<sockaddr_storage>.size)
if Int32(storage.ss_family) == AF_INET {
let addr4 = withUnsafePointer(to: &storage) {
$0.withMemoryRebound(to: sockaddr_in.self, capacity: 1) {
$0.pointee
}
}
let ipString = String(cString: inet_ntoa(addr4.sin_addr), encoding: .ascii) ?? ""
return ipString
}
return ""
}
}
extension YMClientHomeVC:UITableViewDelegate,UITableViewDataSource{
func tableView(_ tableView: UITableView, numberOfRowsInSection section: Int) -> Int {
return dataSource.count
}
func tableView(_ tableView: UITableView, cellForRowAt indexPath: IndexPath) -> UITableViewCell {
let cell = UITableViewCell.init(style: .default, reuseIdentifier: "reuseID")
cell.textLabel?.text = dataSource[indexPath.row].0 + ":" + "\(dataSource[indexPath.row].1)"
return cell
}
func tableView(_ tableView: UITableView, didSelectRowAt indexPath: IndexPath) {
let vc = YMClientMsgBoardVC()
vc.ipStr = dataSource[indexPath.row].0
vc.port = dataSource[indexPath.row].1
navigationController?.pushViewController(vc, animated: true)
}
}
關(guān)于mDNS 可以參考mDNS
