Configuración de un cliente MQTT Java

Inténtalo.
cliente.disconnect();
System.out.println("Disconnected from broker.");
} catch (MqtException e) {}
System.out.println("Error desconectado del corredor: " + e.getMessage());
e.printStackTrace();
}

MQTT 3.1.1

//paho mqttv3
import org.eclipse.paho.client.mqttv3.*;
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;
importar javax.net.ssl.SSLSocketFactory;
importar javax.net.ssl.SSLContext;
importar java.security.cert.Certificate Fábrica;
importar java.security.cert.X509Certificate;
importar java.security.KeyStore;
importa java.io. FileInputStream;
importar java.io.IOExcepcion;
importar java.security.cert.CertificateException;
importar java.security.NoSuch AlgorithmException;
importar javax.net.ssl.TrustManager Fábrica;
importar java.security.KeyManagementException;
importa java.util. Random;
importa java.util. Scanner;
clase pública MqttClientv3 {}
public static void main(String[] args) {
String client_id = "tu_client_id";
Hostip de cuerda = "public-mqtt-broker.bevywise.com";
TLS booleano = falso; / / / se hace realidad para Habilitar TLS
UT = verdadero;
String client_username = "Access-Key";
Criar cliente_password = "Access-Token";
boolean websocket_connection=false; //set true to Enable websocket
Tema de cuerda = ";
int qos = 0;
retenimiento booleano = falso;
Corredor de cuerdasUrl= "";
int port;
si (websocket_connection)
port= TLS ? 11433:10433;
más
port = TLS ? 8883 : 1883; // Use 8883 for SSL/TLS, 1883 for non-SSL

// Creación de una nueva instancia cliente MQTT
MqttClient client;
si (websocket_connection)
brokerUrl=String.format("%s:%d", TLS ? "ws" : "ws", hostip, port);
más
broker Url = String.format("%s:%d", TLS ? "ssl" : "tcp", hostip, port);

MemoryPersistence persistence = nuevo MemoryPersistence();
Inténtalo.
cliente = nuevo MqtClient(broker) Url, client_id, persistencia);
// Ajuste de los callbacks
client.setCallback(new MqttCallback() {
@Override
conexión de vacío público Perdido(Causa potencial) {
System.out.println("Connection lost: " + cause.getMessage());
cause.printStackTrace();
}
@Override
mensaje de vacío público Llegada (Tema de cuerda, mensaje de MqttMessage) lanza Excepción {}
System.out.println("Recibido mensaje sobre el tema: " + tema);
System.out.println("Message: " + nuevo String(message.getPayload()));
}
@Override
públicos Complete(IMqttDeliveryToken token) {
System.out.println("Message delivered successfully.");
}
});
// Opciones de conexión de configuración
MqttConnectOptions connOpts = nuevo MqttConnectOptions();
si (TLS) {
Inténtalo.
connOpts.setSocketFactory(getSocketFactory("/path/to/your/root.crt")); //
Reemplazar con su camino de certadura raíz
} catch (Exception e) {
System.out.println("Error setting up SSL socket factory: " + e.getMessage());
e.printStackTrace();
}
}
si
connOpts.setUserName(client_username);
connOpts.setPasword(client_password.toCharArray());
}
connOpts.setCleanSession(true);
// Conectarse con el corredor MQTT
System.out.println("Connecting to broker: " + brokerUrl);
cliente.connect(connOpts);
System.out.println("Connected");
// Ejemplo de tema para suscribirse
Suscríbete final de StringTema = "will_topic/device1";
// Subscribir a un tema
cliente.subscribe(subscribeTema);
// Publicar mensajes o subscribir/unsubscribir basado en la entrada del usuario
Scanner Scanner = nuevo Scanner (System.in);
mientras (verdad) {
System.out.println("1. Publish\n2. Subscribe\n3. Disconnect\n4. Unsubscribe");
int choice = scanner.nextInt();
scanner.nextLine(); // consume newline
interruptor (elección) {
Caso 1:
System.out.print("Enter Topic QoS(0/1/2) Retain(0/1) Count: ");
String[] entrada = escáner.nextLine().split(" ");
tópico = entrada[0];
qos = Integer.parseInt(input[1]);
retener = Integer.parseInt(input[2]) == 1;
int count = Integer.parseInt(input[3]);
para (int i = 0; i < count; i++) { String message="{\" temp\":" + (nuevo)
Random().nextInt(50) + 1) + ",\" presión\":" + (nuevo Random().nextInt(100) +
1) + ",\" estado\":" + (nuevo Random().nextInt(2)) + "}"
cliente.publish(topic, message.getBytes(), qos, keep);
System.out.println("Mensaje publicado: " + mensaje);
} catch (MqtException e) {}
System.out.println(" Mensaje de publicación de errores: " + e.getMessage());
e.printStackTrace();
}
Thread.sleep(6000); // 6 segundos
}
ruptura;
Caso 2:
System.out.print(" Enter Topic QoS(0/1/2): ");
String[] subInput = scanner.nextLine().split(");
tópico = subinput[0];
qos = Integer.parseInt(subInput[1]);
Inténtalo.
cliente.subscribe(topic, qos);
System.out.println(" Suscrito al tema: " + tema);
} catch (MqtException e) {}
System.out.println(" Error que se suscribe al tema: " + e.getMessage());
e.printStackTrace();
}
ruptura;
Caso 3:
Inténtalo.
cliente.disconnect();
System.out.println(" Desconectado del corredor". } catch (MqtException e) { System.out.println()Error desconexión
de corredor: " + e.getMessage());
e.printStackTrace();
}
ruptura;
Caso 4:
System.out.print() Introduzca el tema para darse de baja: ");
tópico = escáner.nextLine();
Inténtalo.
cliente.unsubscribe(topic);
System.out.println(" Describido del tema: " + tema);
} catch (MqtException e) {}
System.out.println(" Error que suscribe del tema: " + e.getMessage());
e.printStackTrace();
}
ruptura;
default:
System.out.println(" Elección inválida."); } } captura (MqttException Silencio InterruptedException e) { System.out.println("An
error ocurrido: " + e.getMessage());
e.printStackTrace();
}
}
// Método para crear fábrica de tomas SSL (si es necesario)
SSLSocket privado Factory getSocket Fábrica (CrtFile de cuerda) lanza Excepción
CertificadoFactory cf = CertificadoFactory.getInstance(" X.509"); FileInputStream caInput=new
FileInputStream(caCrtFile); X509Certificate caCert=(X509Certificate)
cf.generateCertificate(caInput); caInput.close(); KeyStore
keyStore=KeyStore.getInstance(KeyStore.getDefaultType());
keyStore.load(null, null); keyStore.setCertificateEntry("ca-certificate",
caCert); TrustManager Factory
tmf=TrustManagerFactory.getInstance(TrustManagerFactory.getDefaultAlgorithm());
tmf.init(keyStore); SSLContext context=SSLContext.getInstance("TLS");
context.init(null, tmf.getTrustManagers(), null); return
context.getSocketFactory(); }

MQTT 5

//paho mqttv5
import org.eclipse.paho.mqttv5.client.IMqtClient;
import org.eclipse.paho.mqttv5.client. MqttClient;
import org.eclipse.paho.mqttv5.client.MqtConnectionOptions;
import org.eclipse.paho.mqttv5.client.persist.MemoryPersistence;
import org.eclipse.paho.mqttv5.common.MqtException;
importa org.eclipse.paho.mqttv5.common.MqttMesage;
import org.eclipse.paho.mqttv5.common.packet.MqtProperties;
import org.eclipse.paho.mqttv5.client.MqttCallback;
import org.eclipse.paho.mqttv5.client.MqtDisconnectResponse;
importar org.eclipse.paho.mqttv5.client.IMqttoToken;
importar javax.net.ssl.SSLSocketFactory;
importar javax.net.ssl.SSLContext;
importar java.security.cert.Certificate Fábrica;
importar java.security.cert.X509Certificate;
importar java.security.KeyStore;
importa java.io. FileInputStream;
importar java.io.IOExcepcion;
importar java.security.cert.CertificateException;
importar java.security.NoSuch AlgorithmException;
importar javax.net.ssl.TrustManager Fábrica;
importar javax.net.ssl.KeyManagerFactory;
importar java.security.KeyManagementException;
importa java.util. Lista;
importa java.util. Random;
importa java.util. Scanner;
clase pública MqttClientv5 {}
vacío estático público principal(String[] args)throws Excepción{
String client_id = "tu_client_id";
Hostip de cuerda = "public-mqtt-broker.bevywise.com";
UT = verdadero;
String client_username = "Access-Key";
Criar cliente_password = "Access-Token";
boolean websocket_connection=false; //set true to Enable websocket
Tema de cuerda = ";
int qos = 0;
retenimiento booleano = falso;
Corredor de cuerdasUrl= "";
int port;
si (websocket_connection)
port= 10433;
más
port = 1883; // Use 8883 for SSL/TLS, 1883 for non-SSL

// Creación de una nueva instancia cliente MQTT
MqttClient client;
si (websocket_connection)
brokerUrl=String.format("%s:%d", "ws", hostip, port);
más
broker Url = String.format("%s:%d", "tcp", hostip, port);

MemoryPersistence persistence = nuevo MemoryPersistence();
Inténtalo.
cliente = nuevo MqtClient(broker) Url, client_id, persistencia);
// Ajuste de los callbacks
client.setCallback(new MqttCallback() {
@Override
vacío público desconectado(MqttDisconnectResponse disconnectResponse) {
System.out.println("Disconnected from broker.");
}
@Override
vacío público mqtt ErrorOccurrido(Excepción MqtException) {
System.out.println("MQTT Error: " + excepción.getMessage());
excepción.printStackTrace();
}
@Override
mensaje de vacío público Llegada (Tema de cuerda, mensaje de MqttMessage) lanza Excepción {}
System.out.println("Recibido mensaje sobre el tema: " + tema);
System.out.println("Message: " + nuevo String(message.getPayload()));
}
@Override
públicos Complete(IMqttToken token) {
System.out.println("Message delivered successfully.");
}
@Override
public void authPacketArrived(int reasonCode, MqtProperties properties) {}
System.out.println("Auth packet llegó con el código de la razón: " + reasonCode);
}
@Override
conexión de vacío públicoCompleta(reconexión de boomlean, servidor de String) {
System.out.println("Connected to broker: " + serverURI);
}
// Opciones de conexión de configuración
MqttConnectionOptions connOpts = nuevo MqttConnectionOptions();
si (TLS) {
Inténtalo.
connOpts.setSocketFactory(getSocketFactory("/path/to/your/root.crt")); //
Reemplazar con su camino de certadura raíz
} catch (Exception e) {
System.out.println("Error setting up SSL socket factory: " + e.getMessage());
e.printStackTrace();
}
}
si
connOpts.setUserName(client_username);
connOpts.setPasword(client_password.getBytes()); // Convertir en byte array
}
connOpts.setCleanStart(verdad); // Inicio limpio para MQTTv5
connOpts.setMaxInflight(50);
// Conectarse con el corredor MQTT
System.out.println("Connecting to broker: " + brokerUrl);
cliente.connect(connOpts);
System.out.println("Connected");
// Ejemplo de tema para suscribirse
Suscríbete final de StringTema = "will_topic/device1";
// Subscribir a un tema
cliente.subscribe(subscribeTema, qos);
// Publicar mensajes o subscribir/unsubscribir basado en la entrada del usuario
Scanner Scanner = nuevo Scanner (System.in);
mientras (verdad) {
System.out.println("1. Publish\n2. Subscribe\n3. Disconnect\n4. Unsubscribe");
int choice = scanner.nextInt();
scanner.nextLine(); // consume newline
interruptor (elección) {
Caso 1:
System.out.print("Enter Topic QoS(0/1/2) Retain(0/1) Count: ");
String[] entrada = escáner.nextLine().split(" ");
tópico = entrada[0];
qos = Integer.parseInt(input[1]);
retener = Integer.parseInt(input[2]) == 1;
int count = Integer.parseInt(input[3]);
para (int i = 0; i < count; i++) { //String message="{\" temp\":" + (nueva)
Random().nextInt(50) + 1) + ",\" presión\":" + (nuevo Random().nextInt(100) +
1) + ",\" estado\":" + (nuevo Random().nextInt(2)=0 "ON" : "OFF" ) + "}" ;
Mensaje de String="mundohello" ; MqttMessage mqttMesage=new
MqttMessage(message.getBytes()); mqttMessage.setQos(qos);
mqttMessage.setRetained(retain); System.out.println("Mesage: "+mensaje);
cliente.publish(topic, mqttMessage);
System.out.println(" Packet: "+i+" - sent"); } break; case 2: System.out.print("Enter Topic QoS(0/1/2): ");
entrada = escáner.nextLine().split(");
tópico = entrada[0];
qos = Integer.parseInt(input[1]);
cliente.subscribe(topic, qos);
ruptura;
Caso 3:
cliente.disconnect();
System.out.println(" Desconectado del corredor."); retorno; caso 4: System.out.print("Enter Topic: ");
tópico = escáner.nextLine();
cliente.unsubscribe(topic);
ruptura;
default:
System.out.println(" Elección inválida. Por favor, inténtelo de nuevo. (MqttException e) { System.out.println("Error
conectar a MQTT broker: " + e.getMessage());
e.printStackTrace();
}
}
SSLSocket privado Factory getSocket Fábrica(Arrastre de cuerda) lanza Excepción
CertificadoFactory cf = CertificadoFactory.getInstance(" X.509"); FileInputStream fis=new
FileInputStream(rootCertPath); X509Certificate caCert=(X509Certificate)
cf.generateCertificate(fis); fis.close(); KeyStore
ks=KeyStore.getInstance("JKS"); ks.load(null, null);
ks.setCertificateEntry("ca-certificate", caCert); TrustManager Factory
tmf=TrustManagerFactory.getInstance("SunX509"); tmf.init(ks); SSLContext
sslContext=SSLContext.getInstance("TLSv1.2"); sslContext.init(null,
tmf.getTrustManagers(), null); volver sslContext.getSocketFactory(); } }