Java Spring集成ActiveMQ调度器时如何获取定时任务Scheduled Job Id

问题本质 #

你之前通过JmsTemplate浏览业务队列无法获取到jobId，是因为未到触发时间的调度任务不会投递到业务队列，而是存储在ActiveMQ内置的调度器存储中，只有任务触发时消息才会进入业务队列，因此队列为空时无法通过浏览队列拿到ID。

可选实现方案 #

方案1：通过JMX调用ScheduledBrokerViewMBean获取全量调度任务ID #

ActiveMQ默认开启JMX后，会暴露org.apache.activemq.broker.jmx.ScheduledBrokerViewMBean接口，可直接查询所有待执行的调度任务信息，包含jobId、触发时间、目标队列等属性。
代码示例：

import org.apache.activemq.broker.jmx.ScheduledBrokerViewMBean;
import javax.management.MBeanServerConnection;
import javax.management.MBeanServerInvocationHandler;
import javax.management.ObjectName;
import javax.management.remote.JMXConnector;
import javax.management.remote.JMXConnectorFactory;
import javax.management.remote.JMXServiceURL;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;

public List<String> getAllScheduledJobIds() throws Exception {
    // 替换为你的ActiveMQ JMX服务地址
    JMXServiceURL jmxUrl = new JMXServiceURL("service:jmx:rmi:///jndi/rmi://127.0.0.1:1099/jmxrmi");
    JMXConnector connector = JMXConnectorFactory.connect(jmxUrl);
    MBeanServerConnection connection = connector.getMBeanServerConnection();
    
    // 替换为你的ActiveMQ broker名称，默认值为localhost
    ObjectName schedulerMBeanName = new ObjectName("org.apache.activemq:type=Broker,brokerName=localhost,service=Scheduler");
    ScheduledBrokerViewMBean schedulerMBean = MBeanServerInvocationHandler.newProxyInstance(
            connection,
            schedulerMBeanName,
            ScheduledBrokerViewMBean.class,
            false
    );
    
    // 获取所有调度任务
    Map<String, Object>[] allJobs = schedulerMBean.getScheduledJobs();
    List<String> jobIdList = new ArrayList<>();
    for (Map<String, Object> job : allJobs) {
        jobIdList.add((String) job.get("jobId"));
    }
    
    connector.close();
    return jobIdList;
}

方案注意事项：

• 需确认ActiveMQ服务端useJmx配置为true（默认开启）
• 若配置了JMX权限验证，需在JMXConnectorFactory.connect方法中传入用户名密码参数
• 生产环境建议限制JMX端口的访问权限

方案2：创建调度任务时本地存储Job ID #

如果可以调整任务创建的逻辑，最简便的方式是在创建调度任务时直接获取返回的jobId，存入本地的数据库或Redis中，后续查询直接从本地存储读取即可，性能最高也无需额外对接ActiveMQ的其他接口。
代码示例：

import org.apache.activemq.ScheduledMessage;
import org.springframework.jms.core.JmsTemplate;
import javax.jms.Message;
import javax.jms.Session;

public String createScheduledJob(String targetQueue, String cron, String messageContent) {
    // 发送调度消息并获取返回的消息对象
    Message resultMsg = jmsTemplate.sendAndReceive(targetQueue, session -> {
        Message msg = session.createTextMessage(messageContent);
        // 设置cron调度规则，也可根据需求替换为延迟/周期调度参数
        msg.setStringProperty(ScheduledMessage.AMQ_SCHEDULED_CRON, cron);
        return msg;
    });
    
    // 从返回消息中获取调度任务ID
    String jobId = resultMsg.getStringProperty(ScheduledMessage.AMQ_SCHEDULED_JOB_ID);
    // 此处可将jobId关联业务信息存入本地存储，方便后续查询、删除操作
    // yourLocalStorageService.saveJobId(jobId, businessId, cron);
    return jobId;
}

方案注意事项：

• 该方式仅适用于可以修改任务创建逻辑的场景
• 本地存储jobId时建议关联业务标识，避免后续无法对应任务所属的业务场景

补充：如果只是需要验证调度任务是否创建成功，也可以通过ActiveMQ自带的控制台，进入调度器页面直接查看所有已创建的调度任务ID。

内容的提问来源于stack exchange，提问作者RandomCode