Menu

  • Home
  • Work
    • AI
    • Cloud
      • Virtualization
      • IaaS
      • PaaS
    • Architecture
    • BigData
    • Python
    • Java
    • Go
    • C
    • C++
    • JavaScript
    • PHP
    • Others
      • Assembly
      • Ruby
      • Perl
      • Lua
      • Rust
      • XML
      • Network
      • IoT
      • GIS
      • Algorithm
      • Math
      • RE
      • Graphic
    • OS
      • Linux
      • Windows
      • Mac OS X
    • Database
      • MySQL
      • Oracle
    • Mobile
      • Android
      • IOS
    • Web
      • HTML
      • CSS
  • Life
    • Cooking
    • Travel
    • Gardening
  • Gallery
  • Video
  • Music
  • Essay
  • Home
  • Work
    • AI
    • Cloud
      • Virtualization
      • IaaS
      • PaaS
    • Architecture
    • BigData
    • Python
    • Java
    • Go
    • C
    • C++
    • JavaScript
    • PHP
    • Others
      • Assembly
      • Ruby
      • Perl
      • Lua
      • Rust
      • XML
      • Network
      • IoT
      • GIS
      • Algorithm
      • Math
      • RE
      • Graphic
    • OS
      • Linux
      • Windows
      • Mac OS X
    • Database
      • MySQL
      • Oracle
    • Mobile
      • Android
      • IOS
    • Web
      • HTML
      • CSS
  • Life
    • Cooking
    • Travel
    • Gardening
  • Gallery
  • Video
  • Music
  • Essay

ActiveMQ代理网络无法连接的问题一例

15
Sep
2014

ActiveMQ代理网络无法连接的问题一例

By Alex
/ in Java
/ tags ActiveMQ
0 Comments
环境说明:ActiveMQ 5.10.0,Windows Server 2008 R2。
最近开发人员在做基于ActiveMQ的数据同步测试时,其中的一台AMQ服务器一直无法连接到代理网络中,久久找不到原因。
我检查了一下配置,各ActiveMQ服务器使用多播地址:multicast://default进行自动发现,配置文件很简单,看不出什么问题。
通过jConsole连接:
Shell
1
service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi

发现问题服务器上networkConnectors里面没有任何内容。
开启DEBUG级别的ActiveMQ日志,没有发现和建立代理网络连接有关的任何日志,估计问题服务器的网络存在问题,使用iperf监测网络上的多播数据报:
Shell
1
2
3
4
5
6
7
iperf -s  -u  -B 239.255.2.3 -p 6155  -i 1
------------------------------------------------------------
Server listening on UDP port 6155
Binding to local address 192.168.7.130
Receiving 1470 byte datagrams
UDP buffer size: 8.00 KByte (default)
------------------------------------------------------------

在问题服务器上,上述脚本没有任何输出,其它服务器上则不断收到多播数据报。并且,问题服务器上的绑定地址不是我们内网的192.168.0网段。打开网络连接查看,该IP是Vmware虚拟网卡的地址,尝试禁用虚拟网卡,重启后,一切恢复正常。考虑问题和多网卡有关——ActiveMQ在进行多播时,使用了错误的网卡。启用Vmware虚拟网卡并重启,然后打开MulticastDiscoveryAgent的TRACE日志:
INI
1
log4j.logger.org.apache.activemq.transport.discovery.multicast.MulticastDiscoveryAgent=TRACE,DataSync

监测到以下日志:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
[TRACE] [Thread-1] 2014-09-16 11:16:40 org.apache.activemq.transport.discovery.multicast.MulticastDiscoveryAgent.start(MulticastDiscoveryAgent.java:290)
start - discoveryURI = multicast://default
[TRACE] [Thread-1] 2014-09-16 11:16:40 org.apache.activemq.transport.discovery.multicast.MulticastDiscoveryAgent.start(MulticastDiscoveryAgent.java:302)
start - myHost = 239.255.2.3
[TRACE] [Thread-1] 2014-09-16 11:16:40 org.apache.activemq.transport.discovery.multicast.MulticastDiscoveryAgent.start(MulticastDiscoveryAgent.java:303)
start - myPort = 6155
[TRACE] [Thread-1] 2014-09-16 11:16:40 org.apache.activemq.transport.discovery.multicast.MulticastDiscoveryAgent.start(MulticastDiscoveryAgent.java:304)
start - group  = default
[TRACE] [Thread-1] 2014-09-16 11:16:40 org.apache.activemq.transport.discovery.multicast.MulticastDiscoveryAgent.start(MulticastDiscoveryAgent.java:305)
start - interface  = null
[TRACE] [Thread-1] 2014-09-16 11:16:40 org.apache.activemq.transport.discovery.multicast.MulticastDiscoveryAgent.start(MulticastDiscoveryAgent.java:306)
start - network interface  = null
[TRACE] [Thread-1] 2014-09-16 11:16:40 org.apache.activemq.transport.discovery.multicast.MulticastDiscoveryAgent.start(MulticastDiscoveryAgent.java:307)
start - join network interface  = null

可以看到,多播的地址、端口、组都是正确的,后面还有一些interface、network interface、join network interface,看着好像和网卡设置有关,查看MulticastDiscoveryAgent的源代码:
Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
public void start() throws Exception {
        
    if (started.compareAndSet(false, true)) {            
                    
        if (group == null || group.length() == 0) {
            throw new IOException("You must specify a group to discover");
        }
        String type = getType();
        if (!type.endsWith(".")) {
            LOG.warn("The type '" + type + "' should end with '.' to be a valid Discovery type");
            type += ".";
        }
        
        if (discoveryURI == null) {
            discoveryURI = new URI(DEFAULT_DISCOVERY_URI_STRING);
        }
        
        if (LOG.isTraceEnabled())
              LOG.trace("start - discoveryURI = " + discoveryURI);                                
          
          String myHost = discoveryURI.getHost();
          int    myPort = discoveryURI.getPort();
            
          if( DEFAULT_HOST_STR.equals(myHost) )
              myHost = DEFAULT_HOST_IP;                      
          
          if(myPort < 0 )
            myPort = DEFAULT_PORT;                
          
          if (LOG.isTraceEnabled()) {
              LOG.trace("start - myHost = " + myHost);
              LOG.trace("start - myPort = " + myPort);      
              LOG.trace("start - group  = " + group );                        
              LOG.trace("start - interface  = " + mcInterface );
              LOG.trace("start - network interface  = " + mcNetworkInterface );
              LOG.trace("start - join network interface  = " + mcJoinNetworkInterface );
          }    
          
        this.inetAddress = InetAddress.getByName(myHost);
        this.sockAddress = new InetSocketAddress(this.inetAddress, myPort);
        mcast = new MulticastSocket(myPort);
        mcast.setLoopbackMode(loopBackMode);
        mcast.setTimeToLive(getTimeToLive());
        if (mcJoinNetworkInterface != null) {
            mcast.joinGroup(sockAddress, NetworkInterface.getByName(mcJoinNetworkInterface));
        }
        else {
            mcast.joinGroup(inetAddress);
        }
        mcast.setSoTimeout((int)keepAliveInterval);
        if (mcInterface != null) {
            mcast.setInterface(InetAddress.getByName(mcInterface));
        }
        if (mcNetworkInterface != null) {
            mcast.setNetworkInterface(NetworkInterface.getByName(mcNetworkInterface));
        }
        runner = new Thread(this);
        runner.setName(this.toString() + ":" + runner.getName());
        runner.setDaemon(true);
        runner.start();
        doAdvertizeSelf();
    }
}

可以看到,ActiveMQ对JDK标准类java.net.MulticastSocket的实例mcast进行了网卡相关的设置,相关方法的用途如下:
Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
/**
* 加入指定网络接口上的多播组。
* @param mcastaddr 准备加入的多播地址
* @param netIf 指定用于接收多播数据报的本地网络接口。
* 如果不指定,将使用setInterface(InetAddress)、setNetworkInterface(NetworkInterface)所指定的接口
*/
public void joinGroup(SocketAddress mcastaddr, NetworkInterface netIf) throws IOException;
/**
* 设置相关受影响方法使用的多播网络接口,对于多重网络的主机有意义
* @param inf IP地址对象
*/
public void setInterface(InetAddress inf) throws SocketException;
/**
* 设置发送多播数据报使用的网络接口
* @param netIf 网络接口对象
*/
public void setNetworkInterface(NetworkInterface netIf) throws SocketException;

MulticastDiscoveryAgent根据自身的属性配置情况来调用上述的方法,但是在ActiveMQ官方文档中,并没有找到interface、networkInterface等属性如何在XML中配置的说明,跟踪MulticastDiscoveryAgent的创建过程:
Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
protected DiscoveryAgent doCreateDiscoveryAgent(URI uri) throws IOException {
    try {
        
          if (LOG.isTraceEnabled()) {      
           LOG.trace("doCreateDiscoveryAgent: uri = " + uri.toString());              
        }
        
        MulticastDiscoveryAgent mda = new MulticastDiscoveryAgent();          
        
        mda.setDiscoveryURI(uri);            
                    
        // allow MDA's params to be set via query arguments  
        // (e.g., multicast://default?group=foo            
        Map options = URISupport.parseParameters(uri);        
        IntrospectionSupport.setProperties(mda, options);
        
        return mda;
        
    } catch (Throwable e) {
        throw IOExceptionSupport.create("Could not create discovery agent: " + uri, e);
    }
}

从第14行可以看到,ActiveMQ会解析URI中的所有参数,并利用反射机制设置到MulticastDiscoveryAgent对象中,因此,只需要将需要设置的属性附到URI参数中即可:
XHTML
1
2
3
4
5
6
7
8
<broker xmlns="http://activemq.apache.org/schema/core" brokerName="dataSyncBroker" dataDirectory="D:/amq/datasync/data">
    <networkConnectors>
        <networkConnector uri="multicast://default?joinNetworkInterface=net13&networkInterface=net13&interface=192.168.0.89" dynamicOnly="true" networkTTL="3" prefetchSize="1"
            decreaseNetworkConsumerPriority="true" />
    </networkConnectors>
    <transportConnectors>
        <transportConnector name="openwire" uri="tcp://0.0.0.0:61616" discoveryUri="multicast://default" />
    </transportConnectors>

至此,问题解决。
总结:ActiveMQ的自动代理发现机制比较方便、灵活,但是受客户环境影响较大(网络结构、防火墙等),如果AMQ代理的IP地址固定或基本不会增减,可以考虑使用静态的代理网络。
← Miaow.Bubble
Next Post →

Leave a Reply Cancel reply

Your email address will not be published. Required fields are marked *

You may use these HTML tags and attributes: <a href="" title=""> <abbr title=""> <acronym title=""> <b> <blockquote cite=""> <cite> <code class="" title="" data-url=""> <del datetime=""> <em> <i> <q cite=""> <strike> <strong> <pre class="" title="" data-url=""> <span class="" title="" data-url="">

Related Posts

  • 基于JMS的ActiveMQ Java客户端示例
  • ActiveMQ知识集锦
  • 使用Atomikos来进行分布式事务(XA)开发
  • Spring对JMS的支持
  • 基于CMS接口的ActiveMQ CPP客户端示例

Recent Posts

  • 人工智能知识 - 编程(二)
  • 人工智能知识 - 编程(一)
  • 人工智能知识 - 智能体
  • 人工智能知识 - Transformers和大模型
  • 人工智能知识 - 主要应用领域
ABOUT ME

汪震 | Alex Wong

江苏淮安人,现居北京。目前供职于腾讯云,专注国际售后AI落地。

GitHub:gmemcc

Git:git.gmem.cc

Email:gmemjunk@gmem.cc@me.com

ABOUT GMEM

绿色记忆是我的个人网站,域名gmem.cc中G是Green的简写,MEM是Memory的简写,CC则是我的小天使彩彩名字的简写。

我在这里记录自己的工作与生活,同时和大家分享一些编程方面的知识。

GMEM HISTORY
v2.00:微风
v1.03:单车旅行
v1.02:夏日版
v1.01:未完成
v0.10:彩虹天堂
v0.01:阳光海岸
MIRROR INFO
Meta
  • Log in
  • Entries RSS
  • Comments RSS
  • WordPress.org
Recent Posts
  • 人工智能知识 - 编程(二)
    这一篇承接人工智能知识 - 编程(一)。前一篇已经梳理 AI 训练与推理编程的横向工程栈;本篇进入重点框架详解与 ...
  • 人工智能知识 - 编程(一)
    这一篇专门处理 AI 训练、微调、推理与部署中的编程栈问题。前几篇分别讲了机器学习基础、任务版图、Transfo ...
  • 人工智能知识 - 智能体
    这一篇处理模型之外的系统层问题,包括上下文工程、Harness Engineering、检索增强生成(RAG)与 ...
  • 人工智能知识 - Transformers和大模型
    这一篇聚焦现代大模型主线,内容从 Transformer 架构出发,延伸到语言模型、多模态模型、预训练与微调,以 ...
  • 人工智能知识 - 主要应用领域
    这一篇从任务视角进入现代 AI 的几个核心应用方向,重点讨论自然语言处理、计算机视觉、语音和音频处理、搜索/推荐 ...
  • 人工智能知识 - 算法和机器学习
    这一篇从常用算法进入机器学习基础概念、经典机器学习与神经网络,重点讨论“模型如何被构造、训练、评估与正则化”。前 ...
  • 人工智能知识 - 数学基础
    这一篇整理 AI 所需的数学基础,包括基础数学、线性代数、微积分与概率论统计。它回答的核心问题是:模型里的向量、 ...
  • 人工智能知识 - 简介
    这一篇作为整套 AI 总纲的导论,先回答更根本的问题,不急于进入公式和具体模型细节:什么叫智能,人工智能究竟在试 ...
  • 多语言敏感信息检测模型训练日志
    这篇文章记录一个多语言敏感信息识别项目的完整训练日志。它关注的是工程路径本身:原始 AI 合成语料如何被清洗成可 ...
  • DevPod on Kubernetes: turning devcontainer.json into a persistent remote workspace
    DevPod is an open source workspace manager ...
  • OpenClaw: Architecture, Components, and Deployment Notes
    Four Months, 343,000 Stars On November 24, 2025, ...
  • Replacing Docker Desktop with Colima on macOS
    Colima is one of the cleanest ways ...
  • Kubernetes GPU Sharing
    GPU sharing in Kubernetes depends on what ...
  • Investigating and Solving the Issue of Failed Certificate Request with ZeroSSL and Cert-Manager
    In this blog post, I will walk ...
  • A Comprehensive Study of Kotlin for Java Developers
    Introduction Purpose of the Study Understanding the Mo ...
  • LangChain: Architecture, LCEL, Agents, LangGraph, Retrieval, and Production Patterns
    LangChain is no longer best understood as ...
  • Kubernetes Migration
    Migrating a Kubernetes cluster from one cloud ...
  • Terraform: a practical guide to infrastructure as code
    Terraform is an infrastructure-as-code tool. You describ ...
TOPLINKS
  • Zitahli's blue 91 people like this
  • 梦中的婚礼 64 people like this
  • 汪静好 61 people like this
  • 那年我一岁 36 people like this
  • 为了爱 28 people like this
  • 小绿彩 26 people like this
  • 彩虹姐姐的笑脸 24 people like this
  • 杨梅坑 6 people like this
  • 亚龙湾之旅 1 people like this
  • 汪昌博 people like this
  • 2013年11月香山 10 people like this
  • 2013年7月秦皇岛 6 people like this
  • 2013年6月蓟县盘山 5 people like this
  • 2013年2月梅花山 2 people like this
  • 2013年淮阴自贡迎春灯会 3 people like this
  • 2012年镇江金山游 1 people like this
  • 2012年徽杭古道 9 people like this
  • 2011年清明节后扬州行 1 people like this
  • 2008年十一云龙公园 5 people like this
  • 2008年之秋忆 7 people like this
  • 老照片 13 people like this
  • 火一样的六月 16 people like this
  • 发黄的相片 3 people like this
  • Cesium学习笔记 90 people like this
  • IntelliJ IDEA知识集锦 59 people like this
  • Bazel学习笔记 38 people like this
  • 基于Kurento搭建WebRTC服务器 38 people like this
  • PhoneGap学习笔记 32 people like this
  • NaCl学习笔记 32 people like this
  • 使用Oracle Java Mission Control监控JVM运行状态 29 people like this
  • 基于Calico的CNI 27 people like this
  • Ceph学习笔记 27 people like this
Tag Cloud
ActiveMQ AspectJ CDT Ceph Chrome CNI Command Cordova Coroutine CXF Cygwin DNS Docker eBPF Eclipse ExtJS F7 FAQ Groovy Hibernate HTTP IntelliJ IO编程 IPVS JacksonJSON JMS JSON JVM K8S kernel LB libvirt Linux知识 Linux编程 LOG Maven MinGW Mock Monitoring Multimedia MVC MySQL netfs Netty Nginx NIO Node.js NoSQL Oracle PDT PHP Redis RPC Scheduler ServiceMesh SNMP Spring SSL svn Tomcat TSDB Ubuntu WebGL WebRTC WebService WebSocket wxWidgets XDebug XML XPath XRM ZooKeeper 亚龙湾 单元测试 学习笔记 实时处理 并发编程 彩姐 性能剖析 性能调优 文本处理 新特性 架构模式 系统编程 网络编程 视频监控 设计模式 远程调试 配置文件 齐塔莉
Recent Comments
  • 杨松涛 on snmp4j学习笔记
  • kaka on Cilium学习笔记
  • JackZhouMine on Cesium学习笔记
  • 陈黎 on 通过自定义资源扩展Kubernetes
  • qg on Istio中的透明代理问题
  • heao on 基于本地gRPC的Go插件系统
  • 黄豆豆 on Ginkgo学习笔记
  • cloud on OpenStack学习笔记
  • 5dragoncon on Cilium学习笔记
  • Archeb on 重温iptables
  • C/C++编程:WebSocketpp(Linux + Clion + boostAsio) – 源码巴士 on 基于C/C++的WebSocket库
  • jerbin on eBPF学习笔记
  • point on Istio中的透明代理问题
  • G on Istio中的透明代理问题
  • 绿色记忆:Go语言单元测试和仿冒 on Ginkgo学习笔记
  • point on Istio中的透明代理问题
  • 【Maven】maven插件开发实战 – IT汇 on Maven插件开发
  • chenlx on eBPF学习笔记
  • Alex on eBPF学习笔记
  • CFC4N on eBPF学习笔记
  • 李运田 on 念爷爷
  • yongman on 记录一次KeyDB缓慢的定位过程
  • Alex on Istio中的透明代理问题
©2005-2026 Gmem.cc | Powered by WordPress | 京ICP备18007345号-2