在 Kubernetes 中使用多播的 ActiveMQ 代理网络

Question

我已经部署了带有 statefulset 对象的 ActiveMQ 代理 pod。 activeMQ的配置如下：

<networkConnectors>
  <networkConnector uri="multicast://default" dynamicOnly="true" networkTTL="3" duplex="true" prefetchSize="1" decreaseNetworkConsumerPriority="false" />
</networkConnectors>
<transportConnectors>
  <!-- DOS protection, limit concurrent connections to 1000 and frame size to 100MB -->
  <transportConnector name="amqp" uri="amqp://0.0.0.0:5672?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600&amp;wireFormat.allowNonSaslConnections=true" discoveryUri="multicast://default"/>
</transportConnectors>

为了测试，只有 2 个 pods、activemq-0 和 activemq-1。使用 Wireshark 分析数据包表明多播发现正在运行。但是经纪人不会在他们之间转发消息。这是 activemq-0 的日志：

    2020-07-14 09:17:32,943 | INFO  | Establishing network connection from vm://localhost to amqp://activemq-1.activemqsvc.default.svc.cluster.local:5672 | org.apache.activemq.network.DiscoveryNetworkConnector | Notifier-MulticastDiscoveryAgent-listener:DiscoveryNetworkConnector:NC:BrokerService[localhost]
2020-07-14 09:18:02,463 | WARN  | Transport Connection to: tcp://172.17.0.7:37174 failed: org.apache.activemq.transport.InactivityIOException: Channel was inactive for too (>30000) long: tcp://172.17.0.7:37174 | org.apache.activemq.broker.TransportConnection.Transport | AmqpInactivityMonitor Async Task: java.util.concurrent.ThreadPoolExecutor$Worker@54f96489[State = -1, empty queue]

Answer 1

并非所有 CNI 插件都支持多播。

我知道支持它的一个 CNI 是 WeaveNet 所以你可能要考虑使用它。

其他方法是使用：

hostNetwork: true
dnsPolicy: ClusterFirstWithHostNet

如 this SO answer 中所建议。

在 Kubernetes 中使用多播的 ActiveMQ 代理网络

Network of ActiveMQ brokers using Multicast inside Kubernetes

docker

networking

kubernetes

activemq

multicast