Как напрямую связать rocketmq и rocketmq?

Question

У меня есть две сети (такие как NETWORK -A а также NETWORK -B). Теперь я развернул rocketmq-a в NETWORK-A и развернул ракету MQ-B в NETWORK-B, как напрямую связать rocketmq-a и rocketmq-b?

Answer 1

Согласно вашему комментарию, у вас есть два кластера rocketmq, и одно сообщение должно копироваться в другой кластер rocketmq.

Так что это репликация сообщений.

у вас есть два варианта:

1. Реализовать перехват сообщения

2. Используйте плагин MessageStore, который расширяет AbstractPluginMessageStore и загрузите его, используя конфигурацию брокера

Им обоим необходимо реализовать репликацию самостоятельно.

---

Однако, если вы сделаете их одной и той же брокерской группой, это очень легко.

Просто сделайте rocketmq-b рабом rocketmq-a и разместите их в другом машинном отделении.

Тогда rocketmq-b будет выполнять только операции чтения и всегда реплицировать данные из master