Как получить информацию о клиентском подключении в HiveMQ Client? (MQTT) - PullRequest
Новая
       34

Как получить информацию о клиентском подключении в HiveMQ Client? (MQTT)

0 голосов
/ 09 июня 2019

Я пишу основной класс, который создаст несколько клиентов и проверит их подписку и публикацию.Я хотел бы отобразить информацию о подключении клиентов, например данные и время подключения, clientId, clientIP, используемые для подключения, независимо от того, подключены они корректно или нет.Я новичок в использовании таких инструментов, как Logger, поэтому я не уверен, как бы я это сделал.Я оставил ссылку на издание сообщества HiveMQ (брокер) и клиента.Я хотел бы отобразить эту информацию в своем основном классе в клиентском проекте HiveMQ, но в выпуске сообщества есть файл журнала под названием event.log, который содержит именно ту информацию, которую я хочу отобразить.Я оставил изображение ниже.

HiveMQ:

https://github.com/hivemq/hivemq-community-edition https://github.com/hivemq/hivemq-mqtt-client

В hivemq-community-edition есть файл event.log, содержащий информацию, которую яЯ хотел бы показать.Он был сгенерирован, когда я строю проект как проект Gradle, поэтому он не будет найден, если вы не импортировали его в Eclipse и не встроили в Gradle, поэтому я оставил скриншот того, как он выглядит.

event.log

Код в моем основном классе в HiveMQ Client: 

package com.main;

import java.util.UUID;

import com.hivemq.client.mqtt.MqttGlobalPublishFilter;
import com.hivemq.client.mqtt.datatypes.MqttQos;
import com.hivemq.client.mqtt.mqtt5.Mqtt5BlockingClient;
import com.hivemq.client.mqtt.mqtt5.Mqtt5BlockingClient.Mqtt5Publishes;
import com.hivemq.client.mqtt.mqtt5.Mqtt5Client;
import com.hivemq.client.mqtt.mqtt5.message.publish.Mqtt5Publish;
import java.util.logging.Logger;
import java.util.NoSuchElementException;

import java.util.logging.Level;
import java.util.concurrent.TimeUnit;


public class Main {

    private static final Logger LOGGER = Logger.getLogger(Main.class.getName());  // Creates a logger instance 


    public static void main(String[] args) {

                Mqtt5BlockingClient client1 = Mqtt5Client.builder()
            .identifier(UUID.randomUUID().toString()) // the unique identifier of the MQTT client. The ID is randomly generated between 
            .serverHost("localhost")  // the host name or IP address of the MQTT server. Kept it 0.0.0.0 for testing. localhost is default if not specified.
            .serverPort(1883)  // specifies the port of the server
            .buildBlocking();  // creates the client builder

            client1.connect();  // connects the client
            System.out.println("Client1 Connected");
            System.out.println(client1.toString());


            String testmessage = "How is it going!";
            byte[] messagebytesend = testmessage.getBytes();   // stores a message as a byte array to be used in the payload 

    try {  

        Mqtt5Publishes publishes = client1.publishes(MqttGlobalPublishFilter.ALL);  // creates a "publishes" instance thats used to queue incoming messages

            client1.subscribeWith()  // creates a subscription 
            .topicFilter("test1/#")  // filters to receive messages only on this topic (# = Multilevel wild card, + = single level wild card)
            .qos(MqttQos.AT_LEAST_ONCE)  // Sets the QoS to 2 (At least once) 
            .send(); 
            System.out.println("The client1 has subscribed");


            client1.publishWith()  // publishes the message to the subscribed topic 
            .topic("test/pancakes/topic")   // publishes to the specified topic
            .qos(MqttQos.AT_LEAST_ONCE)  
            .payload(messagebytesend)  // the contents of the message 
            .send();
            System.out.println("The client1 has published");


            Mqtt5Publish receivedMessage = publishes.receive(5,TimeUnit.SECONDS).get(); // receives the message using the "publishes" instance waiting up to 5 seconds                                                                          // .get() returns the object if available or throws a NoSuchElementException 


         byte[] tempdata = receivedMessage.getPayloadAsBytes();    // converts the "Optional" type message to a byte array 
         System.out.println();
         String getdata = new String(tempdata); // converts the byte array to a String 
         System.out.println(getdata);


    }

    catch (InterruptedException e) {    // Catches interruptions in the thread 
        LOGGER.log(Level.SEVERE, "The thread was interrupted while waiting for a message to be received", e);
        }

    catch (NoSuchElementException e){
        System.out.println("There are no received messages");   // Handles when a publish instance has no messages 
    }

    client1.disconnect();  
    System.out.println("Client1 Disconnected");

    }

}

1 Ответ

4 голосов
/ 11 июня 2019

Вы можете получить информацию о клиенте с помощью метода getConfig например, 

Mqtt5ClientConfig config = client.getConfig();
config.getClientIdentifier();

Для получения информации о текущем соединении используйте getConnectionConfig например, 

Optional<Mqtt5ClientConnectionConfig> connectionConfig = config.getConnectionConfig();
if (connectionConfig.isPresent()) {
    MqttClientTransportConfig transportConfig = connectionConfig.get().getTransportConfig();
}

Вы также можете использовать прослушиватели, которые уведомляются, когда клиент подключен или отключен, например, 

Mqtt5Client.builder()
        .addConnectedListener(context -> System.out.println("connected"))
        .addDisconnectedListener(context -> System.out.println("disconnected"))
        ...
...