MQTT
एमक्यूटीटी का कार्यान्वयन

जावा में प्रकाशित / ग्राहक का उदाहरण

sts / ग्रहण में डायनामिक वेब प्रोजेक्ट बनाएं। ग्रहण पाहो जार को डाउनलोड करने के लिए यहाँ से क्लिक करें और webcontent-> webinf-> folder-> lib में जार फ़ाइल डाउनलोड करें और चिपकाएँ

उदाहरण प्रकाशित करें

 String broker = "tcp://localhost:1883"; 
String topicName = "test/topic";
int qos = 1;

 MqttClient mqttClient = new MqttClient(broker,String.valueOf(System.nanoTime()));
//Mqtt ConnectOptions is used to set the additional features to mqtt message

  MqttConnectOptions connOpts = new MqttConnectOptions();

    connOpts.setCleanSession(true); //no persistent session 
    connOpts.setKeepAliveInterval(1000);


MqttMessage message = new MqttMessage("Ed Sheeran".getBytes());

// यहाँ एड शीरन एक संदेश है

    message.setQos(qos);     //sets qos level 1
    message.setRetained(true); //sets retained message 

MqttTopic topic2 = mqttClient.getTopic(topicName);

    mqttClient.connect(connOpts); //connects the broker with connect options
    topic2.publish(message);    // publishes the message to the topic(test/topic)

उदाहरण के लिए सदस्यता लें

//We're using eclipse paho library  so we've to go with MqttCallback 
 MqttClient client = new MqttClient("tcp://localhost:1883","clientid");
     client.setCallback(this);
MqttConnectOptions mqOptions=new MqttConnectOptions();
     mqOptions.setCleanSession(true);
     client.connect(mqOptions);      //connecting to broker 
        client.subscribe("test/topic"); //subscribing to the topic name  test/topic

//Override methods from MqttCallback interface
@Override
public void messageArrived(String topic, MqttMessage message) throws Exception {
        System.out.println("message is : "+message);
    }
.
.//other override methods 
.