Откройте для себя работающий брокер сообщений ActiveMQ, использующий многоадресную IP-рассылку

Брокер Apache ActiveMQ поддерживает обнаружение с многоадресной IP-рассылкой. Эта функция активируется в стандартной демонстрационной конфигурации (см. Ниже). Я хотел бы реализовать функцию обнаружения на других языках (Delphi / Free Pascal). Есть ли какой-нибудь минимальный пример кода или вводная страница в сети, которая показывает, как это будет реализовано в Java?

Если я правильно понимаю, многоадресная рассылка вызовет ответ брокера сообщений, который содержит информацию об IP и порте брокера сообщений. Но я не могу понять, какой порт нужно указать клиенту ( документация ActiveMQ).

Однако я не вижу, какой порт должен использовать многоадресный клиент.

<!-- Create a TCP transport that is advertised on via an IP multicast
              group named default. -->
  <transportConnector name="openwire" uri="tcp://localhost:61616"
                      discoveryUri="multicast://default"/>
  ...

Обновление: я нашел http://docs.oracle.com/javase/tutorial/networking/datagrams/broadcasting.html и пытаюсь использовать этот пример кода.

1 ответ

Решение

Лучшим источником документации всегда является сам код. Если вы посмотрите на источник в SVN для ActiveMQ и просмотрите пакет org.apache.activemq.transports.discovery, у вас должно быть действительно хорошее понимание того, как работают биты обнаружения, также порты по умолчанию все находятся в коде.

svn co https://svn.apache.org/repos/asf/activemq/trunk activemq

Другие вопросы по тегам