首页 > 其他分享 >ActiveMQ 的网络连接及消息回流机制

ActiveMQ 的网络连接及消息回流机制

时间:2024-09-14 14:22:16浏览次数:13  
标签:broker 192.168 MQ 消息 服务器 网络连接 回流 ActiveMQ 连接


1、ActiveMQ 的网络连接

activeMQ 如果要实现扩展性和高可用性的要求的话,就需要用用到网络连接模式。

NetworkConnector:主要用来配置 broker 与 broker 之间的通信连接

ActiveMQ 的网络连接及消息回流机制_发送消息

如上图所示,MQ 服务器1 和MQ 服务器2 通过 NewworkConnector 相连,则生产者1和生产者2发送消息,消费者3和消费者4都可以接收到,而生产者3和生产者4发送的消息,消费者1和消费者2同样也可以接收到 ,这样就增强了消息服务器的可用性。

静态网络连接

假设 MQ 服务器1 的 ip 地址是192.168.110.60, MQ 服务器2 的 ip 地址是192.168.110.61

配置说明

修改 MQ 服务器1 的 activeMQ.xml,在 broker 节点里增加如下配置:

<networkConnectors> 
  <networkConnector uri="static://(tcp://192.168.110.60:61616,tcp://192.168.110.61:61616)"/> 
</networkConnectors>

修改 MQ 服务器2 的 activeMQ.xml,在 broker 节点里增加如下配置:

<networkConnectors> 
  <networkConnector uri="static://(tcp://192.168.110.61:61616,tcp://192.168.110.60:61616)"/> 
</networkConnectors>

重启两台服务器。

生产者连接到 MQ 服务器1(tcp://192.168.110.60:61616)发送消息,消费者连接到 MQ 服务器2(tcp://192.168.110.61:61616)可以获取消息,同时,生产者连接到 MQ 服务器2(tcp://192.168.110.61:61616)发送消息,消费者连接到 MQ 服务器1(tcp://192.168.110.60:61616)也可以获取消息。

两个 broker 通过一个 static 的协议来进行网络连接,一个 Consumer 连接到 broker2 的一个地址上,当 Producer 在 broker1 上以相同的地址发送消息时,此时消息会被转移到Broker2上,也就是说 broker1 会转发消息到 broker2 上。

2、消息回流机制

上面的配置,存在一个问题,如果生产者1向 MQ 服务器1发送10条消息,消费者3从 MQ 服务器2获取了10条消息,此时,万一 MQ 服务器2宕机了,此时这10条消息就会丢失,MQ 服务器1上的消息被 MQ 服务器2拿走了,MQ 服务器1上的消费者读取不到这些消息了。

activemq 从5.6版本开始,在 destinationPolicy 上新增了一个选项 replayWhenNoConsumers 属性设置为 true,这个属性可以用来解决当一个 broker上有需要转发的消息但是没有消费者时,把消息回流到它原始的 broker。同时把enableAudit 设置为false,为了防止消息回流后被当作重复消息而不被分发。

在两台服务器的 activeMQ.xml中,通过如下配置,即可完成消息回流处理。

<policyEntry queue=">" enableAudit="false"> 
  <networkBridgeFilterFactory> 
    <conditionalNetworkBridgeFilterFactory replayWhenNoConsumers="true"/>           </networkBridgeFilterFactory>   
</policyEntry>
3、容错的链接

前面讲述的都是 Client 配置连接到指定的 broker 上,但是如果 broker 的连接失败怎么办呢?默认的情况下,这种协议用于随机的去选择一个链接去连接,如果连接失败了,那么会连接到其他的broker上。默认配置定义了延迟重新连接,意味着传输将会在10s后自动去重新连接可用的broker.当然所以有的重新连接参数都可以根据应用的需要而配置的。

在客户端程序中创建 ConnectionFactory 时使用如下代码即可做到容错的连接配置:

//随机连接不同的broker
ConnectionFactory factory = new ActiveMQConnectionFacory("failover:(tcp://192.168.110.60:61616,tcp://192.168.110.61:61616)?randomize=true")

Failover 协议可用的配置参数

ActiveMQ 的网络连接及消息回流机制_网络连接_02

4、动态网络连接

ActiveMQ 使用 Multicast (组播)协议建立服务与远程的 broker 服务的网络链接,实现 broker 的发现机制。

配置一个组播的ip地址,当前网络内所有的 broker 回向组播的服务端发送消息,证明自己是存活的,并且建立连接,这种动态连接的方式会一直不断地进行连接,会消耗网络资源,因此,不建议使用动态网络连接。

标签:broker,192.168,MQ,消息,服务器,网络连接,回流,ActiveMQ,连接
From: https://blog.51cto.com/javazyx/12016550

相关文章

  • CVE-2015-5254(ActiveMQ-反序列化漏洞)
    漏洞描述编号:CVE-2015-5254影响版本:ApacheActiveMQ5.13.0之前5.x版本CVE地址:CVE-2015-5254漏洞原理:该漏洞源于程序没有限制可在代理中序列化的对象。远程攻击者可借助特制的序列化的JavaMessageService(JMS)ObjectMessage对象利用该漏洞执行任意代码复现环境windows,doc......
  • 实现一个通过调用openai4.0的智能聊天系统,支持上传图片(这里是通过websocket返回流式效
    <template><divclass="chatInfor"><divclass="chatInfor-content"><el-scrollbarheight="97%"id="chatBox"ref="scrollbarRef"v-loading="loading"wi......
  • 主机windows系统,虚拟机安装ubuntu无线网络连接配置
    主机系统:windows系统虚拟机版本:VMware10.0.1build-1379776ubuntu系统版本:ubuntu16.04LTSlinux系统配置:按照顺序点击下图中的1位置,会出现一个下拉列表然后点击下拉列表中2的位置,编辑连接然后出现下图中所示界面选中3所示位置,然后点击4“编辑”依次配置如下箭头所......
  • Jetson设备通过网线连接主机,通过主机共享网络连接
    jetson设备可以通过网线连接电脑,通过设置ip在一个网段下即可实现通信。通信后如果相互ping通,可以通过Nomachine在主机上登录Jetson的远程图像界面。通过主机连接Wifi并设置共享模式,则Jetson也可以通过主机联网。Jetson成功联网后,如果主机使用某常用软件科学上网,可以设置Al......
  • 无网卡Ubuntu通过网线有线接入Windows主机子网,以太网子网显示“未识别的网络”,且无Int
    因为工作需要,开始在Ubuntu主机上部署CAPEv2沙箱草单的是,我的Ubuntu主机没有网卡。于是选择通过一根网线将Ubuntu与另一台Windows主机相连,使Ubuntu成为Windows的子网从而可以上网首先常规操作:控制面板→网络和Internet→网络和共享中心→更改适配器设置,进入如下界面右键WLAN→......
  • 根据网络连接(文件链接)下载文件到本地
    1publicvoidDownloadFile(stringURL,stringfilename)2{3HttpWebRequestreq=null;4HttpWebResponserep=null;5Streamst=null;6Streamso=null;7try8{9req=(HttpWebRequest)Web......
  • 1、消息队列框架:ActiveMQ - 开源项目研究文章
    ActiveMQ是Apache软件基金会下的一个开源消息队列服务,遵循JMS1.1规范(JavaMessageService),是一种面向消息中间件(MOM)的实现。它提供高可用性、出色的性能、可扩展性、稳定性和安全性的消息传递服务。ActiveMQ的架构ActiveMQ的架构包括生产者(Producer)、消费者......
  • C#连接使用ActiveMQ消息队列
      安装部署好集群环境:192.168.209.133:61616,192.168.209.134:61616,192.168.209.135:61616因为ActiveMQ的集群模式是一种master-slave模式,master节点对外提供服务,slave节点只做数据同步备份,当master节点挂了,slave就会成为master从而继续对外提供服务,以此实现高可用。......
  • 小技巧:通过命令行和网络连接获取电脑所连wifi密码
    方法一:命令行第一步,命令行输入下列命令,获取连接过的wifinetshwlanshowprofile第二步,输入以下命令查看你想看的wifi密码(红色改为你获取的任意一个wifi名称) netshwlanshowprofilehappykey=clear第三步,查看密码 方法二:网络连接第一步,搜索网络连接,点击进去......
  • 前端回流与重绘:概念及触发条件
    在前端开发中,性能优化是一个永恒的话题。回流(Reflow)与重绘(Repaint)是两个重要的概念,它们直接影响着页面的渲染性能和用户体验。本文将详细介绍回流与重绘的概念、触发条件及其优化方法。一、回流(Reflow)(重排)1.1概念回流,又称重排(Reflow),是指当DOM的变化引起元素的几何属性(如尺寸、......