在Java中，使用EMQ X MQTT代理可以實現消息路由。EMQ X是一款高性能、高擴展性的MQTT消息服務器，支持多種消息路由策略。以下是實現消息路由的幾種方法：

1. 基于主題的路由：

EMQ X支持基于主題的發布/訂閱模式。你可以將消息發布到一個主題，然后讓多個客戶端訂閱該主題。EMQ X會根據主題將消息路由到所有訂閱了該主題的客戶端。

示例：

// 發布消息
MqttClient publisher = new MqttClient("tcp://localhost:1883", "publisher");
MqttMessage message = new MqttMessage("topic/test", "Hello, EMQ X!".getBytes());
publisher.publish(message);

// 訂閱消息
MqttClient subscriber = new MqttClient("tcp://localhost:1883", "subscriber");
subscriber.setCallback(new MqttCallback() {
    @Override
    public void messageArrived(String topic, MqttMessage message) {
        System.out.println("Received message: " + new String(message.getPayload()));
    }

    // 其他回調方法留空
    @Override
    public void connectionLost(Throwable cause) {}

    @Override
    public void deliveryComplete(IMqttDeliveryToken token) {}
});
subscriber.connect();
subscriber.subscribe("topic/test");

2. 基于消息屬性的路由：

EMQ X支持在發布消息時設置消息屬性。你可以根據這些屬性來路由消息。例如，你可以使用msgKey屬性來表示消息的鍵，然后在訂閱時根據msgKey來過濾消息。

示例：

// 發布消息
MqttClient publisher = new MqttClient("tcp://localhost:1883", "publisher");
MqttMessage message = new MqttMessage("topic/test", "Hello, EMQ X!".getBytes());
message.setAttribute("msgKey", "key1");
publisher.publish(message);

// 訂閱消息
MqttClient subscriber = new MqttClient("tcp://localhost:1883", "subscriber");
subscriber.setCallback(new MqttCallback() {
    @Override
    public void messageArrived(String topic, MqttMessage message) {
        String msgKey = new String(message.getAttribute("msgKey"));
        if ("key1".equals(msgKey)) {
            System.out.println("Received message with key1: " + new String(message.getPayload()));
        }
    }

    // 其他回調方法留空
    @Override
    public void connectionLost(Throwable cause) {}

    @Override
    public void deliveryComplete(IMqttDeliveryToken token) {}
});
subscriber.connect();
subscriber.subscribe("topic/test");

3. 使用橋接：

EMQ X支持橋接功能，可以將一個MQTT集群的消息路由到另一個MQTT集群。這樣，你可以將消息從一個MQTT代理發布到一個主題，然后讓另一個MQTT代理訂閱該主題。

示例：

首先，配置源集群和目標集群的連接信息：

Map<String, String> sourceCluster = new HashMap<>();
sourceCluster.put("broker", "tcp://source-broker:1883");
sourceCluster.put("username", "user1");
sourceCluster.put("password", "password1");

Map<String, String> targetCluster = new HashMap<>();
targetCluster.put("broker", "tcp://target-broker:1883");
targetCluster.put("username", "user2");
targetCluster.put("password", "password2");

然后，使用橋接客戶端將源集群的消息路由到目標集群：

MqttBridge bridge = new MqttBridge(sourceCluster, targetCluster);
bridge.start();

這樣，當你在源集群發布一個消息時，橋接客戶端會將消息路由到目標集群。