Swift / Kotlin MQTT örneği

import CocoaMQTT

let topic = "your-project/sensors/temperature"

// 8883 portundan özel ConnectMQ broker’ınıza bağlan (Her istemcinin benzersiz bir client ID’si olmalı)
let mqtt = CocoaMQTT(clientID: "ios-" + UUID().uuidString, host: "YOUR_BROKER_HOST", port: 8883)
mqtt.keepAlive = 30
// ConnectMQ panelinizdeki kullanıcı adı ve parola
mqtt.username = "YOUR_USERNAME"
mqtt.password = "YOUR_PASSWORD"
// TLS: broker sertifikasını sistemin CA deposu doğrular
mqtt.enableSSL = true

// Bağlantı kurulduğunda çalışır
mqtt.didConnectAck = { mqtt, _ in
    // Sıcaklık topic’ine abone ol
    mqtt.subscribe(topic, qos: .qos1)
    // JSON formatında bir ölçüm yayınla
    mqtt.publish(topic, withString: #"{"temperature":21.5}"#, qos: .qos1)
}
// Abone olunan topic’teki her mesaj için çalışır
mqtt.didReceiveMessage = { _, message, _ in
    print(message.topic, message.string ?? "")
}
_ = mqtt.connect()

import com.hivemq.client.mqtt.MqttGlobalPublishFilter
import com.hivemq.client.mqtt.datatypes.MqttQos
import com.hivemq.client.mqtt.mqtt5.Mqtt5Client
import java.util.UUID

fun main() {
    val topic = "your-project/sensors/temperature"

    // 8883 portundan özel ConnectMQ broker’ınıza bağlan (Her istemcinin benzersiz bir client ID’si olmalı)
    val client = Mqtt5Client.builder()
        .identifier("android-" + UUID.randomUUID())
        .serverHost("YOUR_BROKER_HOST")
        .serverPort(8883)
        // TLS: broker sertifikasını sistemin CA deposu doğrular
        .sslWithDefaultConfig()
        // ConnectMQ panelinizdeki kullanıcı adı ve parola
        .simpleAuth().username("YOUR_USERNAME").password("YOUR_PASSWORD".toByteArray()).applySimpleAuth()
        .automaticReconnectWithDefaultConfig()
        .buildBlocking()
    client.connect()

    // Abone olunan topic’teki her mesaj için çalışır
    client.toAsync().publishes(MqttGlobalPublishFilter.ALL) { p ->
        println("${p.topic}: ${String(p.payloadAsBytes)}")
    }
    // Sıcaklık topic’ine abone ol
    client.subscribeWith().topicFilter(topic).qos(MqttQos.AT_LEAST_ONCE).send()
    // JSON formatında bir ölçüm yayınla
    client.publishWith().topic(topic).qos(MqttQos.AT_LEAST_ONCE)
        .payload("""{"temperature":21.5}""".toByteArray()).send()
}