Tomcat添加JMS远程监控的代码示例

<broker xmlns="http://activemq.apache.org/schema/core" brokerName="localhost" dataDirectory="${activemq.data}">
    <destinations>
        <topic physicalName="TomcatMetricsTopic"/>
    </destinations>
</broker>

export CATALINA_OPTS="$CATALINA_OPTS -Dcom.sun.management.jmxremote"
export CATALINA_OPTS="$CATALINA_OPTS -Dcom.sun.management.jmxremote.port=1099"
export CATALINA_OPTS="$CATALINA_OPTS -Dcom.sun.management.jmxremote.authenticate=false"
export CATALINA_OPTS="$CATALINA_OPTS -Dcom.sun.management.jmxremote.ssl=false"

<dependency>
    <groupId>org.codehaus.groovy.modules.jms</groupId>
    <artifactId>jmx-messaging</artifactId>
    <version>1.0</version>
</dependency>

import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.jms.core.JmsTemplate;

public class JmxToJmsBridge {
    
    public static void main(String[] args) throws Exception {
        ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");
        JmsTemplate jmsTemplate = (JmsTemplate) context.getBean("jmsTemplate");

        // 假设我们有一个方法将JMX数据转换为JMS消息
        String jmxDataAsMessage = convertJmxDataToMessage();
        
        // 将JMX数据发送到JMS主题
        jmsTemplate.convertAndSend("TomcatMetricsTopic", jmxDataAsMessage);
    }

    private static String convertJmxDataToMessage() {
        // 这里应该是从JMX获取数据并转换成字符串形式的逻辑
        return "Sample JMX Data";
    }
}

<bean id="connectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
    <property name="brokerURL" value="tcp://localhost:61616"/>
</bean>

<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
    <property name="connectionFactory" ref="connectionFactory"/>
</bean>