mqtt服务端转发a客户端消息给b客户端 java代码

以下是一个简单的Java代码示例，演示如何在MQTT服务端上将消息从一个客户端转发到另一个客户端。

import org.eclipse.paho.client.mqttv3.*;
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;

public class MqttServer {
    private static final String BROKER_URL = "tcp://localhost:1883";
    private static final String CLIENT_ID = "server";
    private static final String TOPIC = "test";
    private static final int QOS = 1;

    public static void main(String[] args) throws MqttException {
        // 创建 MQTT 客户端
        MqttClient mqttClient = new MqttClient(BROKER_URL, CLIENT_ID, new MemoryPersistence());

        // 创建消息转发器
        mqttClient.setCallback(new MqttCallback() {
            @Override
            public void connectionLost(Throwable throwable) {
                System.out.println("连接丢失");
            }

            @Override
            public void messageArrived(String topic, MqttMessage mqttMessage) throws Exception {
                // 接收到消息时转发给另一个客户端
                String payload = new String(mqttMessage.getPayload());
                String newTopic = "another_client/topic";
                mqttClient.publish(newTopic, new MqttMessage(payload.getBytes()));
            }

            @Override
            public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) {
                System.out.println("消息投递完成");
            }
        });

        // 连接 MQTT 服务端
        MqttConnectOptions options = new MqttConnectOptions();
        options.setCleanSession(true);
        mqttClient.connect(options);
        mqttClient.subscribe(TOPIC, QOS);

        // 循环等待消息
        while (true) {
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

在上面的代码中，我们创建了一个名为 `MqttServer` 的类作为 MQTT 服务端。在 `main()` 方法中，我们首先创建了一个 MQTT 客户端，并设置了一个消息转发器，用于接收从一个客户端发布的消息，并将其转发给另一个客户端。

在转发器的 `messageArrived()` 方法中，我们将接收到的消息的负载提取出来，并使用 `mqttClient.publish()` 方法将其发布到另一个客户端的主题上。

最后，在循环中我们使用 `Thread.sleep()` 方法等待消息的到来。你可以将 `MqttServer` 类部署到你的 MQTT 服务器上，并在另一个客户端上订阅 `another_client/topic` 主题来接收转发的消息。