579. (ios/swift5) [간단 소스] NWConnection 사용해 Broker 브로커 MQTT 메시지 subscribe 구독 방법

---

[개발 환경 설정]

​

개발 툴 : XCODE

개발 언어 : SWIFT5

​

 

---

[소스 코드]

 

// --------------------------------------------------------------------------------------
[개발 및 테스트 환경]
// --------------------------------------------------------------------------------------

- 언어 : Swift


- 개발 툴 : Xcode


- NWConnection 설명 :

  >> NWConnection 는 로컬 엔드포인트와 원격 엔드포인트 간의 양방향 데이터 연결 (TCP , UDP) 을 수행할 수 있습니다

  >> NWConnection 를 사용하기 위해서는 import Network 패키지 호출 정의가 필요합니다

  >> NWParameters 설정 가능 옵션 : 

   - tls
   - tcp
   - dtls
   - udp
   - quic
   - quicDatagram

// --------------------------------------------------------------------------------------






// --------------------------------------------------------------------------------------
[소스 코드]
// --------------------------------------------------------------------------------------

// ------------------------------------------------------------
// MARK: - [SEARCH FAST] : observableSubscribe : 특정 토픽 TOPIC 구독 수행 실시
// ------------------------------------------------------------
static var SUBSCRIBE_ERROR_LOG = ""
func observableSubscribe(topic:String, qos: UInt8, completion: @escaping (Bool)->()) {
    
    /*
    // -----------------------------------------
    [observableSubscribe 메소드 설명]
    // -----------------------------------------
    1. 특정 토픽 TOPIC 구독 수행 실시
    // -----------------------------------------
    2. 호출 방법 :
        
        C_Broker_Mqtt_NMConnection_Client_Module().observableSubscribe(topic: "hello", qos: 0){(sendResult) in
            
            S_Log._F_(description: "MQTT 토픽 구독 완료 상태 확인", data: ["\(sendResult)"])

            if sendResult == true {
            
            }
            else {
            S_Log._F_(description: "MQTT 토픽 구독 에러 메시지", data: ["\(C_Broker_Mqtt_NMConnection_Client_Module.SUBSCRIBE_ERROR_LOG)"])
            }
            
        }
        
    // -----------------------------------------
    3. 필요 import :
        
        import Network
    // -----------------------------------------
    */
    
    
    // [변수 선언]
    C_Broker_Mqtt_NMConnection_Client_Module.SUBSCRIBE_ERROR_LOG = ""
    
    
    // [로직 처리 수행]
    DispatchQueue.global().sync {

        if C_Broker_Mqtt_NMConnection_Client_Module.connection != nil && C_Util().stringNotNull(str: topic) && qos >= 0 {
            
            S_Log._F_(description: "MQTT 특정 토픽 Subscribe 구독 수행", data: ["TOPIC :: \(topic)", "QOS :: \(qos)"])
            

            // ---------------------------------------------
            // MARK: [패킷 데이터 전송 수행]
            // ---------------------------------------------
            //*
            var packet = [UInt8]()
            
            // [Fixed Header] : [고정 헤더 영역]
            packet.append(0x82) // SUBSCRIBE control packet type

            // [Variable Header] : [가변 헤더 영역]
            let packetIdentifier: UInt16 = 1 // [Packet Identifier (고유 ID)]
            let packetIdentifierMSB = UInt8((packetIdentifier >> 8) & 0xFF)
            let packetIdentifierLSB = UInt8(packetIdentifier & 0xFF)
            var variableHeader: [UInt8] = [packetIdentifierMSB, packetIdentifierLSB]

            // [Payload] : [메시지 전송 페이로드]
            let topicBytes = self.encodeString(topic) // [Topic 이름 UTF-8 인코딩]
            let qosByte = qos // [QoS Level]
            var payload: [UInt8] = topicBytes + [qosByte]

            // [Remaining Length]
            let remainingLength = variableHeader.count + payload.count
            packet.append(contentsOf: self.encodeRemainingLength(remainingLength))

            // [Variable Header + Payload 추가]
            packet.append(contentsOf: variableHeader)
            packet.append(contentsOf: payload)
            // */
            // ---------------------------------------------
            

            C_Broker_Mqtt_NMConnection_Client_Module.connection?.send(content: Data(packet), completion: .contentProcessed { error in
                if let error = error {
                    C_Broker_Mqtt_NMConnection_Client_Module.SUBSCRIBE_ERROR_LOG = "[Error] : Mqtt Topic Send Message Error"
                    
                    S_Log._D_(description: "MQTT 특정 토픽 구독 에러", data: [
                        "M_LOG :: \(C_Broker_Mqtt_NMConnection_Client_Module.SUBSCRIBE_ERROR_LOG)",
                        "Description :: \(error)"
                    ])
                    
                    // [콜백 반환]
                    completion(false)
                    return
                    
                } else {
                    S_Log._D_(description: "MQTT 특정 토픽 구독 성공", data: [ "TOPIC :: \(topic)" ])
                    
                    // [콜백 반환]
                    completion(true)
                    return
                    
                }
            })
            
        }
        else {
            C_Broker_Mqtt_NMConnection_Client_Module.SUBSCRIBE_ERROR_LOG = "[Error] : Topic Input Send Message Is Null"
            
            S_Log._D_(description: "MQTT 특정 토픽 구독 에러", data: [
                "M_LOG :: \(C_Broker_Mqtt_NMConnection_Client_Module.SUBSCRIBE_ERROR_LOG)"
            ])
            
            // [콜백 반환]
            completion(false)
            return
        }
        
    }

}

// --------------------------------------------------------------------------------------

---