统一消息系统

<pre><code>

import org.eclipse.paho.client.mqttv3.MqttClient;

import org.eclipse.paho.client.mqttv3.MqttException;

import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;

import org.eclipse.paho.client.mqttv3.MqttCallback;

import org.eclipse.paho.client.mqttv3.MqttMessage;

public class MessagePushPlatform {

private static final String BROKER_URL = "tcp://broker.hivemq.com:1883";

private static final String CLIENT_ID = "message_push_client";

public static void main(String[] args) {

try {

MqttClient client = new MqttClient(BROKER_URL, CLIENT_ID);

client.setCallback(new MqttCallback() {

@Override

public void connectionLost(Throwable cause) {

System.out.println("Connection lost!");

}

@Override

public void messageArrived(String topic, MqttMessage message) throws Exception {

System.out.println("Message received: " + new String(message.getPayload()));

}

@Override

public void deliveryComplete(IMqttDeliveryToken token) {

System.out.println("Message delivered successfully.");

}

});

client.connect();

System.out.println("Connected to MQTT Broker");

// 订阅主题

client.subscribe("test/topic");

System.out.println("Subscribed to topic 'test/topic'");

// 发布消息

MqttMessage message = new MqttMessage("Hello, MQTT".getBytes());

client.publish("test/topic", message);

System.out.println("Published message to 'test/topic'");

client.disconnect();

System.out.println("Disconnected from MQTT Broker");

} catch (MqttException e) {

e.printStackTrace();

}

}

}

统一管理各个系统的账号

</code></pre>