Artemis消息路由

Question

我正在使用ActiveMQ Artemis 2.17.0，并且面临路由问题。

我实现了一个插件，它记录了before消息路由，我看到一些消息从topic.private.abc.task.v1路由到topic.abc.rawmessage.v1。

没有转移设置，主题和队列由生产者和消费者动态创建。有一个将目标集群化.*.>映射到虚拟主题的设置

private TransportConfiguration getServerTransportConfiguration() {
    Map<String, Object> extraProps = new HashMap<>();
    extraProps.put("virtualTopicConsumerWildcards", "clustered.*.>;2");
    Map<String, Object> params = new HashMap<>();
    params.put("scheme", "tcp");
    params.put("port", port);
    params.put("host", hostname);
    return new TransportConfiguration("org.apache.activemq.artemis.core.remoting.impl.netty.NettyAcceptorFactory", params, "netty-acceptor", extraProps);
}

topic.private.abc.task.v1和topic.abc.rawmessage.v1都是有效的主题，但它们不应该被链接。

什么能解释这种行为？

    @Override
    public void beforeMessageRoute(Message message, RoutingContext context, boolean direct, boolean rejectDuplicates) throws ActiveMQException {
        Map<String, Object> map = new HashMap<>();
        map.put("RoutingContext", new RoutingContextLogView(context));
        logger.info(mapper.writeValueAsString(map));
        ActiveMQServerPlugin.super.beforeMessageRoute(message, context, direct, rejectDuplicates);
    }

public class RoutingContextLogView {
    private RoutingContext routingContext;

    public RoutingContextLogView(RoutingContext routingContext) {
        this.routingContext = routingContext;
    }

    public String getAddress() {
        return routingContext.getAddress() != null ? routingContext.getAddress().toString() : null;
    }

    public String getPreviousAddress() {
        return routingContext.getPreviousAddress() != null ? routingContext.getPreviousAddress().toString() : null;
    }

    public String getRoutingType() {
        return routingContext.getRoutingType() != null ? routingContext.getRoutingType().name() : null;
    }

    public String getPreviousRoutingType() {
        return routingContext.getPreviousRoutingType() != null ? routingContext.getPreviousRoutingType().name() : null;
    }
}

Answer 1

代理在内部使用的routingcontexthtml" target="_blank">对象是可重用的。这样做是出于性能原因，以防止无论如何都必须为每个路由操作重新创建routingcontext。正如人们可能猜到的那样，路由消息是代理中非常常见的操作，因此尽可能优化它是值得的。重用routingcontext意味着创建和丢弃的对象更少，这意味着需要清理的垃圾更少，这意味着代理的停顿更少，总体性能更好。

这里的previousaddress与当前消息的路由地址不同，这不是问题。它只是意味着上下文不会被重新用于此路由操作，因此将被清除。顾名思义，BeforeMessageRoute方法是在执行任何路由逻辑之前调用的（例如，清除RoutingContext)。如果使用AfterMessageRoute检查RoutingContext，那么您应该看到它被清除并填充了正确的详细信息。

消息“发送”和消息“路由”（两者都有插件挂钩）是相关但不同的操作。响应客户端操作“发送”消息。发送总是导致路由。但是，并不是所有的路由都是发送的结果。由于不涉及发送的内部代理操作（例如，在集群中移动消息、使消息过期、将无法传递的消息取消到死信地址、使用转移等），消息可以被路由。

我要提醒您不要检查内部代理状态（可能很微妙），当其他一切都表明代理正常运行时，不要假设存在问题。在本例中，您说您“面临路由问题”，并且“一些消息从topic.private.abc.task.v1路由到topic.abc.rawmessage.v1”，而实际上没有路由问题，消息实际上并没有从topic.private.abc.rawmessage.v1路由到topic.abc.rawmessage.v1。据我所见，实际上一切都正常运转。