ActiveMQ详细配置方案

简介: 本文总结ActiveMQ重要的一些配置,包括高可用failover配置、消息策略等。

一、高可用Failover配置

failover:(uri,...,urlN)?transportOptions负载均衡,默认使用随机的uri进行连接,可以在多个broker中达到负载均衡的效果,有两种方式:

  • failover:(tcp://primary:61616,tcp://secondary:61616)?randomize=false默认优先使用primary,只有当primary机器掉线之后,会自动转移到secondary,但是当primary又重新恢复之后,不会自动切换会primary。
  • failover:(tcp://primary:61616,tcp://secondary:61616)?randomize=false&priorityBackup=true默认优先使用primary,只有当primary机器掉线之后,会自动转移到secondary,但是当primary又重新恢复之后,又会自动切换回primary。


以上两种方式都会存在一个问题,就是当切换到备用机之后,主机器还可能遗留一些未处理的数据,为了解决这个问题,可以在集群之间搭建一个network,这样子数据可以在多个broker之间流转。


二、消息策略配置

  • 禁掉scheduler功能
<broker>节点增加schedulerSupport="false"</broker>
  • 配置按照顺序分发策略
<dispatchPolicy><!--按顺序分发--><strictOrderDispatchPolicy/></dispatchPolicy>
  • 配置恢复策略
<subscriptionRecoveryPolicy><!--只恢复最后一个message--><lastImageSubscriptionRecoveryPolicy/></subscriptionRecoveryPolicy>
  • 配置networkConnector
<networkConnectors><networkConnectoruri="static:(tcp://127.0.0.1:61617,tcp://127.0.0.1:61616)"/></networkConnectors>
  • 配置消息回流到broker
<destinationPolicy><policyMap><policyEntries><policyEntryqueue="test.>"enableAudit="false"><networkBridgeFilterFactory><conditionalNetworkBridgeFilterFactoryreplayWhenNoConsumers="true"/></networkBridgeFilterFactory><pendingMessageLimitStrategy><constantPendingMessageLimitStrategylimit="1000"/></pendingMessageLimitStrategy></policyEntry></policyEntries></policyMap></destinationPolicy>

三、权限配置

  • 配置用户名密码
<beanid="securityConstraint"class="org.eclipse.jetty.http.security.Constraint"><propertyname="name"value="BASIC"/><propertyname="roles"value="admin"/><propertyname="authenticate"value="false"/></bean>

四、发送方式配置

  • 同步发送
failover:(tcp://primary:61616,tcp://secondary:61616)?randomize=false&jms.useAsyncSend=false&priorityBackup=true
  • 异步发送
failover:(tcp://primary:61616,tcp://secondary:61616)?randomize=false&jms.useAsyncSend=true&priorityBackup=true
相关文章
|
消息中间件 Java
ActiveMQ调优方案
讨论ActiveMQ性能调优的方向,提供调优参考。
589 0
|
5月前
|
消息中间件 Kafka API
面试题Kafka问题之RabbitMQ的扩展和二次开发如何解决
面试题Kafka问题之RabbitMQ的扩展和二次开发如何解决
44 1
|
6月前
|
消息中间件 Java Kafka
SpringBoot实用开发篇第六章(整合第三方技术,ActiveMQ,RabbitMQ,RocketMQ,Kafka)
SpringBoot实用开发篇第六章(整合第三方技术,ActiveMQ,RabbitMQ,RocketMQ,Kafka)
|
5月前
|
消息中间件 存储 缓存
微服务数据问题之Kafka的默认复制配置如何解决
微服务数据问题之Kafka的默认复制配置如何解决
|
消息中间件 存储 网络协议
[架构选型 】 全面了解Kafka和RabbitMQ选型(1) -两种不同的消息传递方式
[架构选型 】 全面了解Kafka和RabbitMQ选型(1) -两种不同的消息传递方式
|
消息中间件 存储 缓存
消息中间件ActiveMQ常见问题解析
消息中间件ActiveMQ常见问题解析
391 9
EMQ
|
消息中间件 监控 安全
EMQX 4.x 版本更新:Kafka 与 RocketMQ 集成安全增强
云原生分布式物联网接入平台EMQX此次发布包含多个功能更新:规则引擎RocketMQ支持ACL检查、Kafka支持SASL/SCRAM与SASL/GSSAPI认证以适配更多部署方式,提升MQTT共享订阅性能。
EMQ
298 0
EMQX 4.x 版本更新:Kafka 与 RocketMQ 集成安全增强
|
消息中间件 中间件
ActiveMQ - 基础篇(上)
ActiveMQ - 基础篇(上)
144 0
ActiveMQ - 基础篇(上)
|
消息中间件
ActiveMQ - 基础篇(下)
ActiveMQ - 基础篇(下)
138 0
ActiveMQ - 基础篇(下)
下一篇
DataWorks