在ActiveMQ Artemis中的两个节点之间发送消息失败

如何解决在ActiveMQ Artemis中的两个节点之间发送消息失败

我已经使用共享存储HA策略通过JGroup协议配置了Artemis集群。当我禁用firewalld服务时,一切都可以正常工作,包括故障转移和故障回复。但是,启用后,firewalld服务消息无法从一个节点发送到另一节点。 我已经通过命令打开了所需的端口61616和8161

sudo firewall-cmd --zone=public --permanent --add-port=61616/tcp
sudo firewall-cmd --zone=public --permanent --add-port=8161/tcp
firewall-cmd --reload

master-broker.xml文件

<connectors>
         <connector name="netty-connector">tcp://172.16.20.129:61616</connector>
       </connectors>

       <!-- Acceptors -->
       <acceptors>
         <acceptor name="netty-acceptor">tcp://172.16.20.129:61616</acceptor>
       </acceptors>

       <!-- Clustering configuration -->
       <broadcast-groups>
         <broadcast-group name="Artemis-broadcast-group">
           <broadcast-period>5000</broadcast-period>
            <jgroups-file>test-jgroups-file_ping.xml</jgroups-file>
            <jgroups-channel>active_broadcast_channel</jgroups-channel>
            <connector-ref>netty-connector</connector-ref>
         </broadcast-group>
       </broadcast-groups>

       <discovery-groups>
         <discovery-group name="Artemis-discovery-group">
           <jgroups-file>test-jgroups-file_ping.xml</jgroups-file>
            <jgroups-channel>active_broadcast_channel</jgroups-channel>
            <refresh-timeout>10000</refresh-timeout>
         </discovery-group>
       </discovery-groups>

<!-- This is a symmetric cluster -->

       <cluster-connections>
         <cluster-connection name="Demo-Artemis-Cluster">
           <address></address>
           <connector-ref>netty-connector</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>2</notification-attempts>
           <discovery-group-ref discovery-group-name="Artemis-discovery-group"/>
         </cluster-connection>
       </cluster-connections>

test-jgroup-file_ping.xml

<config xmlns="urn:org:jgroups"
   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
   xsi:schemaLocation="urn:org:jgroups http://www.jgroups.org/schema/JGroups-3.0.xsd">
   <TCP loopback="true"
      recv_buf_size="20000000"
      send_buf_size="640000"
      discard_incompatible_packets="true"
      max_bundle_size="64000"
      max_bundle_timeout="30"
      enable_bundling="true"
      use_send_queues="false"
      sock_conn_timeout="300"

      thread_pool.enabled="true"
      thread_pool.min_threads="1"
      thread_pool.max_threads="10"
      thread_pool.keep_alive_time="5000"
      thread_pool.queue_enabled="false"
      thread_pool.queue_max_size="100"
      thread_pool.rejection_policy="run"

      oob_thread_pool.enabled="true"
      oob_thread_pool.min_threads="1"
      oob_thread_pool.max_threads="8"
      oob_thread_pool.keep_alive_time="5000"
      oob_thread_pool.queue_enabled="false"
      oob_thread_pool.queue_max_size="100"
      oob_thread_pool.rejection_policy="run"/>

   <FILE_PING location="/mnt/devops-nfs-share/shared-JGroup-data/file.ping.dir"/>
   <MERGE2 max_interval="30000"
      min_interval="10000"/>
   <FD_SOCK/>
   <FD timeout="10000" max_tries="5" />
   <VERIFY_SUSPECT timeout="1500"  />
   <BARRIER />
   <pbcast.NAKACK
      use_mcast_xmit="false"
      retransmit_timeout="300,600,1200,2400,4800"
      discard_delivered_msgs="true"/>
   <UNICAST timeout="300,1200" />
   <pbcast.STABLE stability_delay="1000" desired_avg_gossip="50000"
      max_bytes="400000"/>
   <pbcast.GMS print_local_addr="true" join_timeout="3000"
      view_bundling="true"/>
   <FC max_credits="2000000"
      min_threshold="0.10"/>
   <FRAG2 frag_size="60000"  />
   <pbcast.STATE_TRANSFER/>
   <pbcast.FLUSH timeout="0"/>
</config>

master-broker.xml的日志是

[root@devops-centos-1 bin]# ./artemis run
     _        _               _
    / \  ____| |_  ___ __  __(_) _____
   / _ \|  _ \ __|/ _ \  \/  | |/  __/
  / ___ \ | \/ |_/  __/ |\/| | |\___ \
 /_/   \_\|   \__\____|_|  |_|_|/___ /
 Apache ActiveMQ Artemis 2.15.0


2020-09-28 10:45:46,892 INFO  [org.apache.activemq.artemis.integration.bootstrap] AMQ101000: Starting ActiveMQ Artemis Server
2020-09-28 10:45:46,938 INFO  [org.apache.activemq.artemis.core.server] AMQ221000: live Message Broker is starting with configuration Broker Configuration (clustered=true,journalDirectory=/mnt/devops-nfs-share/shared-JGroup-data/data/journal,bindingsDirectory=/mnt/devops-nfs-share/shared-JGroup-data/data/bindings,largeMessagesDirectory=/mnt/devops-nfs-share/shared-JGroup-data/data/large-messages,pagingDirectory=/mnt/devops-nfs-share/shared-JGroup-data/data/paging)    
2020-09-28 10:45:47,214 WARNING [org.jgroups.stack.Configurator] JGRP000014: TP.enable_bundling has been deprecated: will be ignored as bundling is on by default
2020-09-28 10:45:47,235 WARNING [org.jgroups.stack.Configurator] JGRP000014: UNICAST.setTimeout has been deprecated: not used anymore    
-------------------------------------------------------------------
GMS: address=devops-centos-1-7492,cluster=active_broadcast_channel,physical address=172.16.20.129:45293
-------------------------------------------------------------------
2020-09-28 10:45:50,320 WARNING [org.jgroups.protocols.pbcast.GMS] devops-centos-1-7492: JOIN(devops-centos-1-7492) sent to devops-centos-2-12055 timed out (after 3000 ms),on try 1
2020-09-28 10:45:53,326 WARNING [org.jgroups.protocols.pbcast.GMS] devops-centos-1-7492: JOIN(devops-centos-1-7492) sent to devops-centos-2-12055 timed out (after 3000 ms),on try 2
2020-09-28 10:45:56,331 WARNING [org.jgroups.protocols.pbcast.GMS] devops-centos-1-7492: JOIN(devops-centos-1-7492) sent to devops-centos-2-12055 timed out (after 3000 ms),on try 3
2020-09-28 10:45:56,638 SEVERE [org.jgroups.protocols.TCP] JGRP000029: devops-centos-1-7492: failed sending message to devops-centos-2-12055 (103 bytes): java.net.SocketTimeoutException: connect timed out,headers: GMS: GmsHeader[JOIN_REQ]: mbr=devops-centos-1-7492,UNICAST: DATA,seqno=4,TP: [cluster_name=active_broadcast_channel]
2020-09-28 10:45:57,607 SEVERE [org.jgroups.protocols.TCP] JGRP000036: devops-centos-1-7492: exception sending bundled msgs: java.net.SocketTimeoutException: connect timed out
2020-09-28 10:45:59,335 WARNING [org.jgroups.protocols.pbcast.GMS] devops-centos-1-7492: JOIN(devops-centos-1-7492) sent to devops-centos-2-12055 timed out (after 3000 ms),on try 4
2020-09-28 10:45:59,641 SEVERE [org.jgroups.protocols.TCP] JGRP000034: devops-centos-1-7492: failure sending message to devops-centos-2-12055: java.net.SocketTimeoutException: connect timed out
2020-09-28 10:45:59,943 SEVERE [org.jgroups.protocols.TCP] JGRP000029: devops-centos-1-7492: failed sending message to devops-centos-2-12055 (103 bytes): java.net.SocketTimeoutException: connect timed out,seqno=5,TP: [cluster_name=active_broadcast_channel]
2020-09-28 10:46:02,339 WARNING [org.jgroups.protocols.pbcast.GMS] devops-centos-1-7492: JOIN(devops-centos-1-7492) sent to devops-centos-2-12055 timed out (after 3000 ms),on try 5
2020-09-28 10:46:02,648 SEVERE [org.jgroups.protocols.TCP] JGRP000029: devops-centos-1-7492: failed sending message to devops-centos-2-12055 (103 bytes): java.net.SocketTimeoutException: connect timed out,seqno=6,TP: [cluster_name=active_broadcast_channel]
2020-09-28 10:46:03,611 SEVERE [org.jgroups.protocols.TCP] JGRP000036: devops-centos-1-7492: exception sending bundled msgs: java.net.SocketTimeoutException: connect timed out
2020-09-28 10:46:05,346 WARNING [org.jgroups.protocols.pbcast.GMS] devops-centos-1-7492: JOIN(devops-centos-1-7492) sent to devops-centos-2-12055 timed out (after 3000 ms),on try 6
2020-09-28 10:46:05,654 SEVERE [org.jgroups.protocols.TCP] JGRP000029: devops-centos-1-7492: failed sending message to devops-centos-2-12055 (103 bytes): java.net.SocketTimeoutException: connect timed out,seqno=7,TP: [cluster_name=active_broadcast_channel]
2020-09-28 10:46:08,350 WARNING [org.jgroups.protocols.pbcast.GMS] devops-centos-1-7492: JOIN(devops-centos-1-7492) sent to devops-centos-2-12055 timed out (after 3000 ms),on try 7
2020-09-28 10:46:08,658 SEVERE [org.jgroups.protocols.TCP] JGRP000034: devops-centos-1-7492: failure sending message to devops-centos-2-12055: java.net.SocketTimeoutException: connect timed out
2020-09-28 10:46:09,613 SEVERE [org.jgroups.protocols.TCP] JGRP000036: devops-centos-1-7492: exception sending bundled msgs: java.net.SocketTimeoutException: connect timed out
2020-09-28 10:46:11,354 WARNING [org.jgroups.protocols.pbcast.GMS] devops-centos-1-7492: JOIN(devops-centos-1-7492) sent to devops-centos-2-12055 timed out (after 3000 ms),on try 8
2020-09-28 10:46:11,661 SEVERE [org.jgroups.protocols.TCP] JGRP000034: devops-centos-1-7492: failure sending message to devops-centos-2-38597: java.net.SocketTimeoutException: connect timed out
2020-09-28 10:46:11,964 SEVERE [org.jgroups.protocols.TCP] JGRP000034: devops-centos-1-7492: failure sending message to devops-centos-2-12055: java.net.SocketTimeoutException: connect timed out
2020-09-28 10:46:13,616 SEVERE [org.jgroups.protocols.TCP] JGRP000036: devops-centos-1-7492: exception sending bundled msgs: java.net.SocketTimeoutException: connect timed out
2020-09-28 10:46:14,360 WARNING [org.jgroups.protocols.pbcast.GMS] devops-centos-1-7492: JOIN(devops-centos-1-7492) sent to devops-centos-2-12055 timed out (after 3000 ms),on try 9
2020-09-28 10:46:14,669 SEVERE [org.jgroups.protocols.TCP] JGRP000034: devops-centos-1-7492: failure sending message to devops-centos-2-12055: java.net.SocketTimeoutException: connect timed out
2020-09-28 10:46:15,615 SEVERE [org.jgroups.protocols.TCP] JGRP000036: devops-centos-1-7492: exception sending bundled msgs: java.net.SocketTimeoutException: connect timed out
2020-09-28 10:46:17,365 WARNING [org.jgroups.protocols.pbcast.GMS] devops-centos-1-7492: JOIN(devops-centos-1-7492) sent to devops-centos-2-12055 timed out (after 3000 ms),on try 10
2020-09-28 10:46:17,366 WARNING [org.jgroups.protocols.pbcast.GMS] devops-centos-1-7492: too many JOIN attempts (10): becoming singleton
2020-09-28 10:46:19,400 WARNING [org.jgroups.protocols.pbcast.FLUSH] devops-centos-1-7492: waiting for UNBLOCK timed out after 2000 ms
2020-09-28 10:46:19,419 INFO  [org.apache.activemq.artemis.core.server] AMQ221043: Protocol module found: [artemis-server]. Adding protocol support for: CORE
2020-09-28 10:46:19,420 INFO  [org.apache.activemq.artemis.core.server] AMQ221043: Protocol module found: [artemis-amqp-protocol]. Adding protocol support for: AMQP
2020-09-28 10:46:19,420 INFO  [org.apache.activemq.artemis.core.server] AMQ221043: Protocol module found: [artemis-hornetq-protocol]. Adding protocol support for: HORNETQ
2020-09-28 10:46:19,420 INFO  [org.apache.activemq.artemis.core.server] AMQ221043: Protocol module found: [artemis-mqtt-protocol]. Adding protocol support for: MQTT
2020-09-28 10:46:19,420 INFO  [org.apache.activemq.artemis.core.server] AMQ221043: Protocol module found: [artemis-openwire-protocol]. Adding protocol support for: OPENWIRE
2020-09-28 10:46:19,421 INFO  [org.apache.activemq.artemis.core.server] AMQ221043: Protocol module found: [artemis-stomp-protocol]. Adding protocol support for: STOMP
2020-09-28 10:46:19,482 INFO  [org.apache.activemq.artemis.core.server] AMQ221034: Waiting indefinitely to obtain live lock
2020-09-28 10:46:19,483 INFO  [org.apache.activemq.artemis.core.server] AMQ221035: Live Server Obtained live lock       
2020-09-28 10:46:20,251 INFO  [org.apache.activemq.artemis.core.server] 
2020-09-28 10:46:20,256 INFO  [org.apache.activemq.artemis.core.server] AMQ221007: Server is now live
2020-09-28 10:46:20,257 INFO  [org.apache.activemq.artemis.core.server] AMQ221001: Apache ActiveMQ Artemis Message Broker version 2.15.0 [artemis-master,nodeID=9bc1eb6d-015f-11eb-a1d5-0050569b585d]    
2020-09-28 10:46:20,942 INFO  [io.hawt.HawtioContextListener] Initialising hawtio services
2020-09-28 10:46:20,954 INFO  [io.hawt.system.ConfigManager] Configuration will be discovered via system properties
2020-09-28 10:46:20,956 INFO  [io.hawt.jmx.JmxTreeWatcher] Welcome to hawtio 1.5.12 : http://hawt.io/ : Don't cha wish your console was hawt like me? ;-)
2020-09-28 10:46:20,957 INFO  [io.hawt.jmx.UploadManager] Using file upload directory: /opt/J-sharedMasterbroker/tmp/uploads
2020-09-28 10:46:20,968 INFO  [io.hawt.web.AuthenticationFilter] Starting hawtio authentication filter,JAAS realm: "activemq" authorized role(s): "amq" role principal classes: "org.apache.activemq.artemis.spi.core.security.jaas.RolePrincipal"
2020-09-28 10:46:20,987 INFO  [io.hawt.web.JolokiaConfiguredAgentServlet] Jolokia overridden property: [key=policyLocation,value=file:/opt/J-sharedMasterbroker/etc/jolokia-access.xml]
2020-09-28 10:46:21,005 INFO  [io.hawt.web.RBACMBeanInvoker] Using MBean [hawtio:type=security,area=jmx,rank=0,name=HawtioDummyJMXSecurity] for role based access control
2020-09-28 10:46:21,080 INFO  [io.hawt.system.ProxyWhitelist] Initial proxy whitelist: [localhost,127.0.0.1,172.16.20.129]
2020-09-28 10:46:21,257 INFO  [org.apache.activemq.artemis] AMQ241001: HTTP Server started at http://0.0.0.0:8161
2020-09-28 10:46:21,258 INFO  [org.apache.activemq.artemis] AMQ241002: Artemis Jolokia REST API available at http://0.0.0.0:8161/console/jolokia
2020-09-28 10:46:21,258 INFO  [org.apache.activemq.artemis] AMQ241004: Artemis Console available at http://0.0.0.0:8161/console

奴隶经纪人的日志是

[root@devops-centos-2 bin]# ./artemis run
     _        _               _
    / \  ____| |_  ___ __  __(_) _____
   / _ \|  _ \ __|/ _ \  \/  | |/  __/
  / ___ \ | \/ |_/  __/ |\/| | |\___ \
 /_/   \_\|   \__\____|_|  |_|_|/___ /
 Apache ActiveMQ Artemis 2.15.0


2020-09-28 11:05:41,421 INFO  [org.apache.activemq.artemis.integration.bootstrap] AMQ101000: Starting ActiveMQ Artemis Server
2020-09-28 11:05:41,449 INFO  [org.apache.activemq.artemis.core.server] AMQ221000: backup Message Broker is starting with configuration Broker Configuration (clustered=true,pagingDirectory=/mnt/devops-nfs-share/shared-JGroup-data/data/paging)
2020-09-28 11:05:41,457 INFO  [org.apache.activemq.artemis.core.server] AMQ221032: Waiting to become backup node
2020-09-28 11:05:41,457 INFO  [org.apache.activemq.artemis.core.server] AMQ221033: ** got backup lock
2020-09-28 11:05:41,502 INFO  [org.apache.activemq.artemis.core.server] AMQ221012: Using AIO Journal
2020-09-28 11:05:41,545 INFO  [org.apache.activemq.artemis.core.server] AMQ221057: Global Max Size is being adjusted to 1/2 of the JVM max size (-Xmx). being defined as 1,073,741,824
2020-09-28 11:05:41,785 INFO  [org.apache.activemq.hawtio.branding.PluginContextListener] Initialized activemq-branding plugin    
-------------------------------------------------------------------
GMS: address=devops-centos-2-55890,physical address=172.16.24.85:43241
-------------------------------------------------------------------
2020-09-28 11:05:41,841 INFO  [org.apache.activemq.hawtio.plugin.PluginContextListener] Initialized artemis-plugin plugin
2020-09-28 11:05:42,167 INFO  [io.hawt.HawtioContextListener] Initialising hawtio services
2020-09-28 11:05:42,179 INFO  [io.hawt.system.ConfigManager] Configuration will be discovered via system properties
2020-09-28 11:05:42,181 INFO  [io.hawt.jmx.JmxTreeWatcher] Welcome to hawtio 1.5.12 : http://hawt.io/ : Don't cha wish your console was hawt like me? ;-)
2020-09-28 11:05:42,183 INFO  [io.hawt.jmx.UploadManager] Using file upload directory: /opt/J-sharedSlavebroker/tmp/uploads
2020-09-28 11:05:42,193 INFO  [io.hawt.web.AuthenticationFilter] Starting hawtio authentication filter,JAAS realm: "activemq" authorized role(s): "amq" role principal classes: "org.apache.activemq.artemis.spi.core.security.jaas.RolePrincipal"
2020-09-28 11:05:42,212 INFO  [io.hawt.web.JolokiaConfiguredAgentServlet] Jolokia overridden property: [key=policyLocation,value=file:/opt/J-sharedSlavebroker/etc/jolokia-access.xml]
2020-09-28 11:05:42,232 INFO  [io.hawt.web.RBACMBeanInvoker] Using MBean [hawtio:type=security,name=HawtioDummyJMXSecurity] for role based access control
2020-09-28 11:05:42,307 INFO  [io.hawt.system.ProxyWhitelist] Initial proxy whitelist: [localhost,172.16.24.85,devops-centos-2.com]
2020-09-28 11:05:43,163 INFO  [org.apache.activemq.artemis] AMQ241001: HTTP Server started at http://localhost:8161    
2020-09-28 11:05:43,163 INFO  [org.apache.activemq.artemis] AMQ241004: Artemis Console available at http://localhost:8161/console
2020-09-28 11:05:44,818 WARNING [org.jgroups.protocols.pbcast.GMS] devops-centos-2-55890: JOIN(devops-centos-2-55890) sent to devops-centos-1-7492 timed out (after 3000 ms),on try 1
2020-09-28 11:05:47,822 WARNING [org.jgroups.protocols.pbcast.GMS] devops-centos-2-55890: JOIN(devops-centos-2-55890) sent to devops-centos-1-7492 timed out (after 3000 ms),on try 2
2020-09-28 11:05:50,090 SEVERE [org.jgroups.protocols.TCP] JGRP000029: devops-centos-2-55890: failed sending message to devops-centos-1-7492 (103 bytes): java.net.SocketTimeoutException: connect timed out,headers: GMS: GmsHeader[JOIN_REQ]: mbr=devops-centos-2-55890,seqno=3,TP: [cluster_name=active_broadcast_channel]
2020-09-28 11:05:50,825 WARNING [org.jgroups.protocols.pbcast.GMS] devops-centos-2-55890: JOIN(devops-centos-2-55890) sent to devops-centos-1-7492 timed out (after 3000 ms),on try 3
2020-09-28 11:05:51,131 SEVERE [org.jgroups.protocols.TCP] JGRP000034: devops-centos-2-55890: failure sending message to devops-centos-1-7492: java.net.SocketTimeoutException: connect timed out
2020-09-28 11:05:52,091 SEVERE [org.jgroups.protocols.TCP] JGRP000036: devops-centos-2-55890: exception sending bundled msgs: java.net.SocketTimeoutException: connect timed out
2020-09-28 11:05:53,829 WARNING [org.jgroups.protocols.pbcast.GMS] devops-centos-2-55890: JOIN(devops-centos-2-55890) sent to devops-centos-1-7492 timed out (after 3000 ms),on try 4    
2020-09-28 11:06:03,147 SEVERE [org.jgroups.protocols.TCP] JGRP000034: devops-centos-2-55890: failure sending message to devops-centos-1-7492: java.net.SocketTimeoutException: connect timed out
2020-09-28 11:06:04,095 SEVERE [org.jgroups.protocols.TCP] JGRP000036: devops-centos-2-55890: exception sending bundled msgs: java.net.SocketTimeoutException: connect timed out
2020-09-28 11:06:05,844 WARNING [org.jgroups.protocols.pbcast.GMS] devops-centos-2-55890: JOIN(devops-centos-2-55890) sent to devops-centos-1-7492 timed out (after 3000 ms),on try 8
2020-09-28 11:06:06,149 SEVERE [org.jgroups.protocols.TCP] JGRP000034: devops-centos-2-55890: failure sending message to devops-centos-1-18963: java.net.SocketTimeoutException: connect timed out
2020-09-28 11:06:06,451 SEVERE [org.jgroups.protocols.TCP] JGRP000034: devops-centos-2-55890: failure sending message to devops-centos-1-7492: java.net.SocketTimeoutException: connect timed out
2020-09-28 11:06:08,098 SEVERE [org.jgroups.protocols.TCP] JGRP000029: devops-centos-2-55890: failed sending message to devops-centos-1-7492 (103 bytes): java.net.SocketTimeoutException: connect timed out,seqno=9,TP: [cluster_name=active_broadcast_channel]
2020-09-28 11:06:08,847 WARNING [org.jgroups.protocols.pbcast.GMS] devops-centos-2-55890: JOIN(devops-centos-2-55890) sent to devops-centos-1-7492 timed out (after 3000 ms),on try 9
2020-09-28 11:06:09,153 SEVERE [org.jgroups.protocols.TCP] JGRP000034: devops-centos-2-55890: failure sending message to devops-centos-1-7492: java.net.SocketTimeoutException: connect timed out
2020-09-28 11:06:10,098 SEVERE [org.jgroups.protocols.TCP] JGRP000036: devops-centos-2-55890: exception sending bundled msgs: java.net.SocketTimeoutException: connect timed out
2020-09-28 11:06:11,851 WARNING [org.jgroups.protocols.pbcast.GMS] devops-centos-2-55890: JOIN(devops-centos-2-55890) sent to devops-centos-1-7492 timed out (after 3000 ms),on try 10
2020-09-28 11:06:11,851 WARNING [org.jgroups.protocols.pbcast.GMS] devops-centos-2-55890: too many JOIN attempts (10): becoming singleton
2020-09-28 11:06:13,869 WARNING [org.jgroups.protocols.pbcast.FLUSH] devops-centos-2-55890: waiting for UNBLOCK timed out after 2000 ms
2020-09-28 11:06:13,893 INFO  [org.apache.activemq.artemis.core.server] AMQ221043: Protocol module found: [artemis-server]. Adding protocol support for: CORE
2020-09-28 11:06:13,893 INFO  [org.apache.activemq.artemis.core.server] AMQ221043: Protocol module found: [artemis-amqp-protocol]. Adding protocol support for: AMQP
2020-09-28 11:06:13,893 INFO  [org.apache.activemq.artemis.core.server] AMQ221043: Protocol module found: [artemis-hornetq-protocol]. Adding protocol support for: HORNETQ
2020-09-28 11:06:13,894 INFO  [org.apache.activemq.artemis.core.server] AMQ221043: Protocol module found: [artemis-mqtt-protocol]. Adding protocol support for: MQTT
2020-09-28 11:06:13,894 INFO  [org.apache.activemq.artemis.core.server] AMQ221043: Protocol module found: [artemis-openwire-protocol]. Adding protocol support for: OPENWIRE
2020-09-28 11:06:13,894 INFO  [org.apache.activemq.artemis.core.server] AMQ221043: Protocol module found: [artemis-stomp-protocol]. Adding protocol support for: STOMP
2020-09-28 11:06:13,943 INFO  [org.apache.activemq.artemis.core.server] AMQ221109: Apache ActiveMQ Artemis Backup Server version 2.15.0 [9bc1eb6d-015f-11eb-a1d5-0050569b585d] started,waiting live to fail before it gets active
2020-09-28 11:06:23,946 WARN  [org.apache.activemq.artemis.core.server] AMQ222137: Unable to announce backup,retrying: ActiveMQConnectionTimedOutException[errorType=CONNECTION_TIMEDOUT message=AMQ219012: Timed out waiting to receive initial broadcast from cluster]            at org.apache.activemq.artemis.core.client.impl.ServerLocatorImpl.executeDiscovery(ServerLocatorImpl.java:767) [artemis-core-client-2.15.0.jar:2.15.0]       at org.apache.activemq.artemis.core.client.impl.ServerLocatorImpl.createSessionFactory(ServerLocatorImpl.java:655) [artemis-core-client-2.15.0.jar:2.15.0]   at org.apache.activemq.artemis.core.client.impl.ServerLocatorImpl.connect(ServerLocatorImpl.java:549) [artemis-core-client-2.15.0.jar:2.15.0] at org.apache.activemq.artemis.core.client.impl.ServerLocatorImpl.connect(ServerLocatorImpl.java:528) [artemis-core-client-2.15.0.jar:2.15.0] at org.apache.activemq.artemis.core.server.cluster.BackupManager$BackupConnector$1.run(BackupManager.java:267) [artemis-server-2.15.0.jar:2.15.0] at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:42) [artemis-commons-2.15.0.jar:2.15.0]  at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:31) [artemis-commons-2.15.0.jar:2.15.0]     at org.apache.activemq.artemis.utils.actors.ProcessorBase.executePendingTasks(ProcessorBase.java:65) [artemis-commons-2.15.0.jar:2.15.0]  at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [rt.jar:1.8.0_265]
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [rt.jar:1.8.0_265]
        at org.apache.activemq.artemis.utils.ActiveMQThreadFactory$1.run(ActiveMQThreadFactory.java:118) [artemis-commons-2.15.0.jar:2.15.0]

2020-09-28 11:06:34,450 WARN  [org.apache.activemq.artemis.core.server] AMQ222137: Unable to announce backup,retrying: ActiveMQConnectionTimedOutException[errorType=CONNECTION_TIMEDOUT message=AMQ219012: Timed out waiting to receive initial broadcast from cluster]
        at org.apache.activemq.artemis.core.client.impl.ServerLocatorImpl.executeDiscovery(ServerLocatorImpl.java:767) [artemis-core-client-2.15.0.jar:2.15.0]
        at org.apache.activemq.artemis.core.client.impl.ServerLocatorImpl.createSessionFactory(ServerLocatorImpl.java:655) [artemis-core-client-2.15.0.jar:2.15.0]
        at org.apache.activemq.artemis.core.client.impl.ServerLocatorImpl.connect(ServerLocatorImpl.java:549) [artemis-core-client-2.15.0.jar:2.15.0]
        at org.apache.activemq.artemis.core.client.impl.ServerLocatorImpl.connect(ServerLocatorImpl.java:528) [artemis-core-client-2.15.0.jar:2.15.0]
        at org.apache.activemq.artemis.core.server.cluster.BackupManager$BackupConnector$1.run(BackupManager.java:267) [artemis-server-2.15.0.jar:2.15.0]
        at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:42) [artemis-commons-2.15.0.jar:2.15.0]
        at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:31) [artemis-commons-2.15.0.jar:2.15.0]
        at org.apache.activemq.artemis.utils.actors.ProcessorBase.executePendingTasks(ProcessorBase.java:65) [artemis-commons-2.15.0.jar:2.15.0]
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [rt.jar:1.8.0_265]
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [rt.jar:1.8.0_265]
        at org.apache.activemq.artemis.utils.ActiveMQThreadFactory$1.run(ActiveMQThreadFactory.java:118) [artemis-commons-2.15.0.jar:2.15.0]

有什么方法可以在不禁用防火墙服务的情况下发送消息。

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐


使用本地python环境可以成功执行 import pandas as pd import matplotlib.pyplot as plt # 设置字体 plt.rcParams[&#39;font.sans-serif&#39;] = [&#39;SimHei&#39;] # 能正确显示负号 p
错误1:Request method ‘DELETE‘ not supported 错误还原:controller层有一个接口,访问该接口时报错:Request method ‘DELETE‘ not supported 错误原因:没有接收到前端传入的参数,修改为如下 参考 错误2:cannot r
错误1:启动docker镜像时报错:Error response from daemon: driver failed programming external connectivity on endpoint quirky_allen 解决方法:重启docker -&gt; systemctl r
错误1:private field ‘xxx‘ is never assigned 按Altʾnter快捷键,选择第2项 参考:https://blog.csdn.net/shi_hong_fei_hei/article/details/88814070 错误2:启动时报错,不能找到主启动类 #
报错如下,通过源不能下载,最后警告pip需升级版本 Requirement already satisfied: pip in c:\users\ychen\appdata\local\programs\python\python310\lib\site-packages (22.0.4) Coll
错误1:maven打包报错 错误还原:使用maven打包项目时报错如下 [ERROR] Failed to execute goal org.apache.maven.plugins:maven-resources-plugin:3.2.0:resources (default-resources)
错误1:服务调用时报错 服务消费者模块assess通过openFeign调用服务提供者模块hires 如下为服务提供者模块hires的控制层接口 @RestController @RequestMapping(&quot;/hires&quot;) public class FeignControl
错误1:运行项目后报如下错误 解决方案 报错2:Failed to execute goal org.apache.maven.plugins:maven-compiler-plugin:3.8.1:compile (default-compile) on project sb 解决方案:在pom.
参考 错误原因 过滤器或拦截器在生效时,redisTemplate还没有注入 解决方案:在注入容器时就生效 @Component //项目运行时就注入Spring容器 public class RedisBean { @Resource private RedisTemplate&lt;String
使用vite构建项目报错 C:\Users\ychen\work&gt;npm init @vitejs/app @vitejs/create-app is deprecated, use npm init vite instead C:\Users\ychen\AppData\Local\npm-
参考1 参考2 解决方案 # 点击安装源 协议选择 http:// 路径填写 mirrors.aliyun.com/centos/8.3.2011/BaseOS/x86_64/os URL类型 软件库URL 其他路径 # 版本 7 mirrors.aliyun.com/centos/7/os/x86
报错1 [root@slave1 data_mocker]# kafka-console-consumer.sh --bootstrap-server slave1:9092 --topic topic_db [2023-12-19 18:31:12,770] WARN [Consumer clie
错误1 # 重写数据 hive (edu)&gt; insert overwrite table dwd_trade_cart_add_inc &gt; select data.id, &gt; data.user_id, &gt; data.course_id, &gt; date_format(
错误1 hive (edu)&gt; insert into huanhuan values(1,&#39;haoge&#39;); Query ID = root_20240110071417_fe1517ad-3607-41f4-bdcf-d00b98ac443e Total jobs = 1
报错1:执行到如下就不执行了,没有显示Successfully registered new MBean. [root@slave1 bin]# /usr/local/software/flume-1.9.0/bin/flume-ng agent -n a1 -c /usr/local/softwa
虚拟及没有启动任何服务器查看jps会显示jps,如果没有显示任何东西 [root@slave2 ~]# jps 9647 Jps 解决方案 # 进入/tmp查看 [root@slave1 dfs]# cd /tmp [root@slave1 tmp]# ll 总用量 48 drwxr-xr-x. 2
报错1 hive&gt; show databases; OK Failed with exception java.io.IOException:java.lang.RuntimeException: Error in configuring object Time taken: 0.474 se
报错1 [root@localhost ~]# vim -bash: vim: 未找到命令 安装vim yum -y install vim* # 查看是否安装成功 [root@hadoop01 hadoop]# rpm -qa |grep vim vim-X11-7.4.629-8.el7_9.x
修改hadoop配置 vi /usr/local/software/hadoop-2.9.2/etc/hadoop/yarn-site.xml # 添加如下 &lt;configuration&gt; &lt;property&gt; &lt;name&gt;yarn.nodemanager.res