Bonjour

• 官方鏈接

NetService

• 一種使用多播DNS廣播其可用性的網絡服務

NetServiceBrowser

• 一種使用多播DNS查找網絡上發(fā)布的服務的網絡服務瀏覽器

應用

該技術目前我們公司，是用于發(fā)現通局域網中的設備。然后通過socket 去實現投屏、和手機遙控的功能

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:
服務的域。要解析默認域，傳入一個空字符串(@"")。如果要將解析限制在本地域，請使用@"local."。
如果您正在創(chuàng)建此對象來解析您的應用程序之前存儲的信息的服務，您應該將此設置為最初發(fā)現該服務的域。
您也可以使用NSNetServiceBrowser對象來獲取一個可能的域列表，您可以在其中發(fā)現和解析服務。

- type:
類型必須同時包含服務類型和傳輸層信息。為了確保mDNS響應器搜索服務，而不是主機，在服務名稱和傳輸層名稱前面加上一個下劃線字符(“_”)。例如，要在TCP上搜索HTTP服務，可以使用字符串“_http._tcp.”。請注意，字符串末尾的句點字符是必需的，它表明域名是絕對名稱。

- name:
要解析的服務的名稱

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("服務啟動失敗")
        return
    }
service?.delegate = self

主要區(qū)別是有無端口，不指定端口的話，他們的發(fā)布方式不同

• 發(fā)布服務

//指定端口的發(fā)布方式
 service?.publish()
//這種方式會主動的分配一個端口（指定了端口不生效）
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])
//拿到解析結果
 func netServiceDidResolveAddress(_ sender: NetService)
//解析出錯
func netService(_ sender: NetService, didNotResolve errorDict: [String : NSNumber]) 
//服務停止
func netServiceDidStop(_ sender: NetService) 
//給定服務的TXT記錄已經更新
func netService(_ sender: NetService, didUpdateTXTRecord data: Data) 
//當客戶端連接到由Bonjour管理的服務時調用
func netService(_ sender: NetService, didAcceptConnectionWith inputStream: InputStream, outputStream: OutputStream) 

服務端的總體代碼

import UIKit

class YMServiceHomeVC: UIViewController {
    var service:NetService?
    let port:Int32 = 6688
    let type:String = "_db_controller123._tcp."
    
    override func viewDidLoad() {
        super.viewDidLoad()
        title = "服務端"
        publish()
    }
    
    @IBAction func startSocket(_ sender: Any) {
        let vc = YMServiceMsgBoardVC()
        vc.port = Int(port)
        navigationController?.pushViewController(vc, animated: true)
    }
    //發(fā)布服務
    func publish(){
        service = NetService(domain: "local.", type: type, name: "riverliBonjour", port: port)
        if service == nil {
            print("服務啟動失敗")
            return
        }
        service?.delegate = self
        //傳遞額外的數據
        let data = NetService.data(fromTXTRecord:["Allenzhan":("Allen".data(using: .utf8))!])
        let status = service?.setTXTRecord(data)
        if status == true {
            print("設置TXT 文案成功")
        }else{
            print("設置TXT 文案失敗")
        }
        
        service?.publish()
        //這種方式會主動的分配一個端口
        //        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("結束搜索")
    }


    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 設置代理以便監(jiān)聽數據的解析
        service.delegate = self
//這里要設置解析超時時間 0 的話是永久。這里服務端也可以發(fā)布成功后設置，但是客戶端最好自己設置一下，不然怕不能解析到數據
        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 {
          //獲取記錄的數據（服務端用來傳遞我們需要的數據）
            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("結束搜索")
    }


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

關于mDNS 可以參考mDNS