Блог

Главная - Вопросы по программированию - Как сформировать симметричный кластер из 3 узлов с группами обнаружения в ActiveMQ Artemis?

Как сформировать симметричный кластер из 3 узлов с группами обнаружения в ActiveMQ Artemis?

#kubernetes #activemq-artemis

#kubernetes #activemq-artemis

Вопрос:

Я создал StatefulSet в Kubernetes с тремя репликами. XML-файл override-broker выглядит следующим образом —

 <configuration xmlns="urn:activemq" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
               xsi:schemaLocation="urn:activemq /schema/artemis-configuration.xsd">
    <core xmlns="urn:activemq:core" xsi:schemaLocation="urn:activemq:core ">

        <cluster-user>admin</cluster-user>

        <cluster-password>admin</cluster-password>

        <acceptors>
            <acceptor name="stomp">tcp://0.0.0.0:61613?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=STOMP;useEpoll=true;stompConsumerCredits=1;stompEnableMessageId=true</acceptor>
        </acceptors>

        <connectors>
            <connector name="$HOSTNAME">tcp://$HOSTNAME.<service>.<namespace>.<domain>:61616</connector>
        </connectors>


        <broadcast-groups>
            <broadcast-group name="my-broadcast-group">
                <group-address>231.7.7.7</group-address>
                <group-port>9876</group-port>
                <broadcast-period>100</broadcast-period>
                <connector-ref>$HOSTNAME</connector-ref>
            </broadcast-group>
        </broadcast-groups>

        <discovery-groups>
            <discovery-group name="my-discovery-group">
                <group-address>231.7.7.7</group-address>
                <group-port>9876</group-port>
                <refresh-timeout>10000</refresh-timeout>
            </discovery-group>
        </discovery-groups>

        <cluster-connections>
            <cluster-connection name="my-artemis-cluster">
                <address></address>
                <connector-ref>$HOSTNAME</connector-ref>
                <check-period>1000</check-period>
                <connection-ttl>5000</connection-ttl>
                <min-large-message-size>50000</min-large-message-size>
                <call-timeout>5000</call-timeout>
                <retry-interval>500</retry-interval>
                <retry-interval-multiplier>1.0</retry-interval-multiplier>
                <max-retry-interval>5000</max-retry-interval>
                <initial-connect-attempts>-1</initial-connect-attempts>
                <reconnect-attempts>-1</reconnect-attempts>
                <use-duplicate-detection>true</use-duplicate-detection>
                <message-load-balancing>ON_DEMAND</message-load-balancing>
                <max-hops>1</max-hops>
                <confirmation-window-size>32000</confirmation-window-size>
                <call-failover-timeout>30000</call-failover-timeout>
                <notification-interval>1000</notification-interval>
                <notification-attempts>10</notification-attempts>
                <discovery-group-ref discovery-group-name="my-discovery-group"/>
            </cluster-connection>
        </cluster-connections>

        <address-settings>
            <address-setting match="/queue/#">
                <default-address-routing-type>ANYCAST</default-address-routing-type>
                <default-queue-routing-type>ANYCAST</default-queue-routing-type>
            </address-setting>
            <address-setting match="/topic/#">
                <default-address-routing-type>MULTICAST</default-address-routing-type>
                <default-queue-routing-type>MULTICAST</default-queue-routing-type>
            </address-setting>
            <address-setting match="#">
                <auto-delete-queues>false</auto-delete-queues>
                <auto-delete-jms-queues>false</auto-delete-jms-queues>
                <auto-delete-jms-topics>false</auto-delete-jms-topics>
                <auto-delete-addresses>false</auto-delete-addresses>
                <max-delivery-attempts>100</max-delivery-attempts>
                <expiry-delay>86400000</expiry-delay>
                <redelivery-delay>3000</redelivery-delay>
                <redelivery-delay-multiplier>1</redelivery-delay-multiplier>
                <redelivery-collision-avoidance-factor>0.15</redelivery-collision-avoidance-factor>
                <max-redelivery-delay>50000</max-redelivery-delay>
                <default-consumer-window-size>0</default-consumer-window-size>
                <redistribution-delay>3000</redistribution-delay>
            </address-setting>
        </address-settings>
        <wildcard-addresses>
            <routing-enabled>true</routing-enabled>
            <delimiter>/</delimiter>
            <any-words>#</any-words>
            <single-word>*</single-word>
        </wildcard-addresses>
    </core>
</configuration>

Проблема, которую я заметил, заключается в том, что, несмотря на настройку max-hops=1 , на вкладке Диаграмма отображаются только два узла, связанных друг с другом. Диаграмма в каждом узле выглядит примерно так —

  • узел-0: узел-0 связан с узлом-1
  • узел-1: узел-1 связан с узлом-0
  • узел-2: узел-2 связан с узлом-0

Хотя ожидается, что во всех узлах диаграмма должна быть следующей —

  • узел-<i>: узел-0 связан с узлом-1; узел-1 связан с узлом-2; узел-0 связан с узлом-2

Комментарии:

1. Какую версию ActiveMQ Artemis вы используете? Просматриваете ли вы вкладку диаграммы на веб-консоли?

2. @JustinBertram Я использую 2.14.0-alpine. Да, я просматриваю вкладку диаграммы на веб-консоли.

Ответ №1:

Я мог бы решить эту проблему, создав новый соединитель —

 <acceptors>
            <acceptor name="netty">tcp://$HOSTNAME.<service>.<namespace>.<domain>:61617</acceptor>
</acceptors>
<connectors>
            <connector name="netty">tcp://$HOSTNAME.<service>.<namespace>.<domain>:61617</connector>
</connectors>

Затем использовал netty соединитель как connector-ref в discovery-group и cluster-connection 

 <configuration xmlns="urn:activemq" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
               xsi:schemaLocation="urn:activemq /schema/artemis-configuration.xsd">
    <core xmlns="urn:activemq:core" xsi:schemaLocation="urn:activemq:core ">

        <cluster-user>admin</cluster-user>

        <cluster-password>admin</cluster-password>

        <acceptors>
            <acceptor name="netty">tcp://$HOSTNAME.<service>.<namespace>.<domain>:61617</acceptor>
        </acceptors>

        <connectors>
            <connector name="netty">tcp://$HOSTNAME.<service>.<namespace>.<domain>:61617</connector>
        </connectors>


        <broadcast-groups>
            <broadcast-group name="my-broadcast-group">
                <group-address>231.7.7.7</group-address>
                <group-port>9876</group-port>
                <broadcast-period>100</broadcast-period>
                <connector-ref>netty</connector-ref>
            </broadcast-group>
        </broadcast-groups>

        <discovery-groups>
            <discovery-group name="my-discovery-group">
                <group-address>231.7.7.7</group-address>
                <group-port>9876</group-port>
                <refresh-timeout>10000</refresh-timeout>
            </discovery-group>
        </discovery-groups>

        <cluster-connections>
            <cluster-connection name="my-artemis-cluster">
                <address></address>
                <connector-ref>netty</connector-ref>
                <check-period>1000</check-period>
                <connection-ttl>5000</connection-ttl>
                <min-large-message-size>50000</min-large-message-size>
                <call-timeout>5000</call-timeout>
                <retry-interval>500</retry-interval>
                <retry-interval-multiplier>1.0</retry-interval-multiplier>
                <max-retry-interval>5000</max-retry-interval>
                <initial-connect-attempts>-1</initial-connect-attempts>
                <reconnect-attempts>-1</reconnect-attempts>
                <use-duplicate-detection>true</use-duplicate-detection>
                <message-load-balancing>ON_DEMAND</message-load-balancing>
                <max-hops>1</max-hops>
                <confirmation-window-size>32000</confirmation-window-size>
                <call-failover-timeout>30000</call-failover-timeout>
                <notification-interval>1000</notification-interval>
                <notification-attempts>10</notification-attempts>
                <discovery-group-ref discovery-group-name="my-discovery-group"/>
            </cluster-connection>
        </cluster-connections>

        <address-settings>
            <address-setting match="/queue/#">
                <default-address-routing-type>ANYCAST</default-address-routing-type>
                <default-queue-routing-type>ANYCAST</default-queue-routing-type>
            </address-setting>
            <address-setting match="/topic/#">
                <default-address-routing-type>MULTICAST</default-address-routing-type>
                <default-queue-routing-type>MULTICAST</default-queue-routing-type>
            </address-setting>
            <address-setting match="#">
                <auto-delete-queues>false</auto-delete-queues>
                <auto-delete-jms-queues>false</auto-delete-jms-queues>
                <auto-delete-jms-topics>false</auto-delete-jms-topics>
                <auto-delete-addresses>false</auto-delete-addresses>
                <max-delivery-attempts>100</max-delivery-attempts>
                <expiry-delay>86400000</expiry-delay>
                <redelivery-delay>3000</redelivery-delay>
                <redelivery-delay-multiplier>1</redelivery-delay-multiplier>
                <redelivery-collision-avoidance-factor>0.15</redelivery-collision-avoidance-factor>
                <max-redelivery-delay>50000</max-redelivery-delay>
                <default-consumer-window-size>0</default-consumer-window-size>
                <redistribution-delay>3000</redistribution-delay>
            </address-setting>
        </address-settings>
        <wildcard-addresses>
            <routing-enabled>true</routing-enabled>
            <delimiter>/</delimiter>
            <any-words>#</any-words>
            <single-word>*</single-word>
        </wildcard-addresses>
    </core>
</configuration>