activemq监控工具(如何心跳感知与ActiveMQ服务器的连接状态)

本文目录
如何心跳感知与ActiveMQ服务器的连接状态
当我们需要部署一套安全稳定的ActiveMQ时,可以使用集群方式,这需要部署至少两套的ActiveMQ服务,但是如果ActiveMQ整个集群也宕机,这时消息都无法发送,这可怎么办,还好ActiveMQ提供了消息传输监听(transportListener),可以对ActiveMQConnectionFactory添加一个Activemq的消息传输监听,该监听实现 Activemq的TransportListener接口。该接口实现的监听方法有onCommand(),onException(), transportResumed () ,transportInterupted()等监听方法。拥有这些方法就足以实时感知ActiveMQ服务器的状态了,当发现服务器无法连接时,就采取相应措施,如把消息存储在本地,当服务器恢复时再进行发送。
package com.jms.failover;
import java.io.IOException;
import org.apache.activemq.transport.TransportListener;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class ActiveMQTransportListener implements TransportListener{
protected final Logger logger = LoggerFactory.getLogger(ActiveMQTransportListener.class);
/**
* 对消息传输命令进行监控
* @param command
*/
@Override
public void onCommand(Object o) {
}
/**
* 对监控到的异常进行触发
* @param error
*/
@Override
public void onException(IOException error) {
logger.error("onException -》 消息服务器连接错误......");
}
/**
* 当failover时触发
*/
@Override
public void transportInterupted() {
logger.error("transportInterupted -》 消息服务器连接发生中断......");
//这里就可以状态进行标识了
}
/**
* 监控到failover恢复后进行触发
*/
@Override
public void transportResumed() {
logger.info("transportResumed -》 消息服务器连接已恢复......");
//这里就可以进行状态标识了
}
}
《!-- ActiveMQ 连接工厂,用于连接远程broker --》
《bean id="connectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory" destroy-method="stop"》
《property name="brokerURL" value="${activemq.broker.failover.uri}" /》
《property name="userName" value="${activemq.username}" /》
《property name="password" value="${activemq.password}" /》
《property name="useAsyncSend" value="true" /》
《property name="alwaysSessionAsync" value="true" /》
《property name="redeliveryPolicy" ref="redeliveryPolicy" /》
《property name="prefetchPolicy" ref="prefetchPolicy" /》
《!-- 消息传输监听器 --》
《property name="transportListener"》
《bean class="com.jms.failover.ActiveMQTransportListener" /》
《/property》
《property name="dispatchAsync" value="true" /》
《/bean》
activemq杀死后自行启动
activemq杀死后自行启动的原因是activemq拥有自启动。根据查询相关公开信息显示activemq程序拥有自启动动功能,在后台进行杀死后,任然会按照程序设定进行自动启动。计算机程序,港、台译做电脑程式。计算机程序是一组计算机能识别和执行的指令,运行于电子计算机上,满足人们某种需求的信息化工具。
怎么找到 activemq 安装目录
1. IBM WebSphere MQ消息中间件有很多的特性和优点,使用IBM WebSphere MQ可以简化和优化消息通讯的应用设计。为了满足用户各种不同的应用的通讯需求,IBM WebSphere MQ采用了大量业界领先的技术,并拥有许多先进的功能,其中很多是其他厂商所无能为力的。将这些技术和功能应用到客户的通讯系统之中,可以简化应用逻辑,优化系统架构,从而提高整个系统的可靠性、可用性和可扩展性。下面将介绍怎样使用IBM WebSphereMQ的一些特性来简化程序。2. ActiveMQ速度非常快;一般要比jbossMQ快10倍。 优点:是一个快速的开源消息组件(框架),支持集群,同等网络,自动检测,TCP,SSL,广播,持久化,XA,和J2EE1.4容器无缝结合,并且支持轻量级容器和大多数跨语言客户端上的Java虚拟机。消息异步接受,减少软件多系统集成的耦合度。消息可靠接收,确保消息在中间件可靠保存,多个消息也可以组成原子事务。 缺点:ActiveMQ默认的配置性能偏低,需要优化配置,但是配置文件复杂,ActiveMQ本身不提供管理工具;示例代码少;主页上的文档看上去比较全面,但是缺乏一种有效的组织方式,文档只有片段,用户很难由浅入深进行了解,二、文档整体的专业性太强。在研究阶段可以通过查maillist、看Javadoc、分析源代码来了解。
android studio安装后哪里有官方文档
android studio安装后哪里有官方文档
:developer.android./intl/zh-/index.
需要帆樯
activemq没有官方文档吗
ActiveMQ另问题要软件能挂掉挂掉怕怕挂掉信息给丢所本节析几种持久化式:、持久化文件ActiveMQ默认支持种搜索式要发消息设置消息持久化打安装目录配置文件:D:\ActiveMQ\apache-activemq\conf\activemq.xml越80行发现默认配置项: 注意使用kahaDB基于文件支持事务消息存储器靠高性能扩展消息存储器 设计初衷使用简单并尽能快KahaDB索引使用transaction log并且所destination使用index测试表明:用于产环境支持1万active connection每connection独立queue该表现已经足矣应付部需求再发送消息候改变第二参数:MsgDeliveryMode.PersistentMessage保存式2种PERSISTENT:保存磁盘consumer消费message删除NON_PERSISTENT:保存内存消费message清除注意:堆积消息太能导致内存溢打产者端发送消息:wps30F4.tmp启消费者端同管理界面查看:wps3105.tmp发现消息等待没持久化ActiveMQ宕机重启消息丢失我现修改文件持久化重启ActiveMQ消费者仍能够收消息
oracle rac 安装官方文档 地址在哪
例如:
一个双节点的RAC,每个节点两个网卡,eth0,eth1
节点一:
eth0 配置私有IP(priv ip)
私有IP包括neork heartbeat和cache fusion,用于心跳同步,这个对于用户层面,可以直接忽略,简单理解,这个Ip用来保证两台服务器同步数据用的私网IP。
eth1 配置公有IP(public ip)(提供对外数据服务)
公有IP一般用于管理员,用来确保可以操作到正确的机器,我更愿意叫他真实IP。
eth0:1 虚拟IP(VIP)
当启动集群服务时,会在网卡eth0上自动生成一个临时网卡eth0:1。
虚拟IP用于客户端应用,以支持失效转移,通俗说就是一台挂了,另一台自动接管,客户端没有任何感觉。
同理
节点二 也有三个 IP:priv ip,public ip,vip
节点一+节点二=6个ip
还有一个IP是SCAN IP
SCAN:
Single Client Aess Name,单一客户访问名称,意思是客户端(如jdbc,pl/sql等)访问数据库时的公共域名,由于rac是多节点的,客户端要访问数据库,通过scan机制,只需要提供一个访问名称,oracle rac会自动为客户端分配一个节点,这对客户端来说是透明的。
其中:私有IP,VIP,SCANip在一个网段
:docs.oracle./cd/E11882_01/nav/portal_11.htm
11g的在线安装文档
:docs.oracle./database/122/nav/install-and-upgrade.htm
12c的在线安装文档
spring官方文档中哪里有spring的头信息
java spring配置文件的约束文件dtd可以通过手动下载spring开源包,在spring开源包中可以直接找到约束的dtd文件。 java spring配置文件的约束文件dtd如果是在联网的情况下,
哪里有 Chrome 开发者工具的官方文档
Chrome的开发者工具。。你是说F12那个吗?没听说过有文档。
CSS文档,见过CSS3的翻译,好像是淘宝还是腾讯的人自己做的。
JavaScript文档不就是ECMA标准?
F12打开开发人员工具,在设置菜单里可以直接跳转到官方文档页面。
chrome开发者中心有详细介绍
:developer.chrome./devtools/docs/shortcuts
到Google上搜索Chrome Developer Tools即可查看官方文档。
或者直接搜索Google Chrome API,即可查看各种API接口的详细介绍

更多文章:
在from子句中可以出现(如何在from 子句中嵌套查询下面的语句在access中出错!)
2026年10月11日 05:20
countif函数统计个数怎么用(countif函数怎么用 详解Excel中countif函数的使用方法)
2026年10月11日 03:30
正则匹配数字之前的字符(正则表达式如何匹配前面是数字、中间是“/”、后面也是数字,就像2/3专业的模式)
2026年10月11日 03:00
orlnsertbootmediinselected(我电脑开机显示这个是什么意思or insert boot media in select)
2026年10月10日 23:00
display的用法(display是什么意思 详解display的含义和用法)
2026年10月10日 22:00
html全部居中代码(怎么让网页居中显示,html如何让网页居中)
2026年10月10日 21:10





