ActiveMQ静态网络连接

淩亂°似流年 2021-10-14 05:28 387阅读 0赞

## 前言 ##

使用静态网络连接（static networkConnector）可以将多个broker连接起来，作为一个集群对外提供服务。  
我们假定有amq1和amq2配置了静态网络连接，那么当一个消费者连接到amq2，当生产者发送消息到amq1时，amq2将会作为amq1的一个消费者，将消息转移到amq2，然后投递给连接到amq2的消费者；反之亦然。对于queue，由于一条消息只能被一个消费者消费，所以在上面的情形下，消息将被转移到amq2，然后投递给连接到amq2的消费者；对于topic，amq2从amq1复制消息，然后投递给消费者。

## 配置 ##

这里准备2台activemq，这里分别以activemq1和activemq2称之。

### activemq1修改 ###

1.修改brokerName为amq1;  
2.修改openwire端口为61616，其他的transportConnector删除；  
3.在destinationPolicy增加下面的配置

<policyEntry queue=">" enableAudit="false">
        <networkBridgeFilterFactory>
            <conditionalNetworkBridgeFilterFactory replayWhenNoConsumers="true"/>
        </networkBridgeFilterFactory>
    </policyEntry>

这是针对queue的配置。该配置是为了解决消息回流的问题。replayWhenNoConsumers=true表示没有消费者时将消息回流到原始的broker。enableAudit=false为了防止消息回流后被当做重复消息而不被分发。

### activemq2修改 ###

1.修改brokerName为amq2，2个不要冲突。  
2.修改openwire端口为61617，其他的transportConnector删除；  
3.修改netty端口为8162；  
4.增加下面的配置

<networkConnectors>
        <networkConnector name="bridge" uri="static:(tcp://localhost:61616)" duplex="true" conduitSubscriptions="false"/>
    </networkConnectors>

duplex默认为false，单向连接。如果配置为false，那么发送到amq2的消息可以从amq1消费，反之则不行。  
conduitSubscriptions默认true，是否把同一个broker的多个consumer当做一个来处理。如果配置为true，假定有1个消费者连接amq1，3个消费者连接amq2，那么amq1的那个消费者将接收到50%的消息，amq2的3个消费者一共接收到50%的消息。所以这里设置为false，这样假定发送100条消息，那么每个消费者消费25条消息。

5.在destinationPolicy增加下面的配置

<policyEntry queue=">" enableAudit="false">
        <networkBridgeFilterFactory>
            <conditionalNetworkBridgeFilterFactory replayWhenNoConsumers="true"/>
        </networkBridgeFilterFactory>
    </policyEntry>

### 代码 ###

客户端使用failover协议来连接mq。

failover:(tcp://127.0.0.1:61616,tcp://127.0.0.1:61626)?randomize=false

指定randomize为false，这样会先连接127.0.0.1:61616，连接不上才会连接后面的地址。

### 测试 ###

配置duplex=false，测试结果。  
a.连接amq1发送消息；  
\[外链图片转存失败(img-BmcdQjtf-1566178640426)(/img/activemq-broker-duplex-false-producer.png)\]  
b.消费者连接amq2接收消息  
\[外链图片转存失败(img-JvyWiEmU-1566178640426)(/img/activemq-broker-duplex-false-consumer.png)\]  
可以发现发送到amq1的消息amq2没法消费。

将duplex改为true，amq2就可以消费amq1的消息了。

其他的就不一一测试了。

## 注意事项 ##

q2没法消费。

将duplex改为true，amq2就可以消费amq1的消息了。

其他的就不一一测试了。

## 注意事项 ##

这里使用2个broker，实际可以根据需要配置多个。多个地址用逗号分隔即可。比如uri=“static:(tcp://localhost:61616,tcp://localhost:61636)”。

发表评论取消回复

表情：

评论列表（有 0 条评论，387人围观）

还没有评论，来说两句吧...

相关阅读

相关 ActiveMQ连接不释放问题

ActiveMQ连接不释放问题实际问题为:大量失效连接处于ESTABLISHED状态. 检查问题的过程线上出现了activemq连接不上的报错The JMS

川长思鸟来/ 2023年06月20日 09:12/ 0 赞/ 1 阅读

相关 ActiveMQ“连接池”使用

1. ActiveMQ的连接池 ActiveMQ提供了PoolConnectionFactory、PoolConnection等实现连接池功能，连接池是供对connecti

深藏阁楼爱情的钟/ 2022年06月13日 14:36/ 0 赞/ 239 阅读

相关 ActiveMQ 连接池

PooledConnectionFactory有两个属性maxConnections，maximumActive。咋一看来，用人类的常识理解，maxConnection应该表示

矫情吗；*/ 2022年06月13日 02:58/ 0 赞/ 202 阅读

相关 ActiveMQ分布式网络(Forward Bridge)

当ActiveMQ面对大量消息存储和大量Client交互时，性能消耗将会达到单个broker极限，此时我们需要对ActiveMQ进行水平扩展。ActiveMQ提供了“netwo

矫情吗；*/ 2022年06月12日 05:09/ 0 赞/ 267 阅读

相关 ActiveMQ集群：网络连接模式(network connector)详解

网络连接模式(network connector) 针对海量消息所要求的横向扩展性和系统的高可用性，ActiveMQ提供了网络连接模式的集群功能。简单的说，就是通过把多个

悠悠/ 2022年06月12日 05:08/ 0 赞/ 498 阅读

相关 Freemarker静态化ActiveMQ实现

Freemarker 实现商品页面静态化 ActiveMQ 使用topic模式，添加商品时监听到消息，根据商品id 从数据库中查询商品信息，生成静态页面

素颜马尾好姑娘i/ 2022年05月16日 09:24/ 0 赞/ 192 阅读

相关 java连接ActiveMQ测试

\\\代码测试前，先在项目中引入ActiveMQ的jar包，在pom.xml中添加如下配置：因为activemq5.11.2不会和spring产生冲突，所以用这个版本较好！

雨点打透心脏的1/2处/ 2022年05月09日 22:54/ 0 赞/ 354 阅读

相关 centos无法连接网络及静态IP配置

centos6/7用默认选项安装完成之后，默认是上不了网的原因在于默认的网卡没有启动，网上的配置都是改配置文件。最近发现ilanyu推荐的nmtui挺好用的，介绍如下

梦里梦外;/ 2022年04月17日 03:08/ 0 赞/ 308 阅读

相关 java连接activemq

原文：[https://blog.csdn.net/jiuqiyuliang/article/details/48608237][https_blog.csdn.net_jiu

短命女/ 2022年02月28日 21:20/ 0 赞/ 196 阅读

相关 ActiveMQ静态网络连接

前言使用静态网络连接（static networkConnector）可以将多个broker连接起来，作为一个集群对外提供服务。我们假定有amq1和amq2配置了

淩亂°似流年/ 2021年10月14日 05:28/ 0 赞/ 388 阅读