使用JobOperator获取运行中Job执行记录时遇XStream转换异常求助

哎，这个坑我之前踩过！你碰到的是XStream在序列化/反序列化java.util.Map$Entry时的经典问题——因为Map.Entry是个接口，而HashMap里的具体Entry实现是内部私有的，XStream默认的反射转换器没法直接实例化它，所以抛出了InstantiationException。

问题根源 #

Spring Batch的JobOperator在处理Job执行记录时，会用XStream序列化一些包含Map的数据（比如JobParameters里的参数），当这些Map被XStream解析时，它尝试直接构造Map$Entry类型，但这个类型没有公共的无参构造方法，也不是可实例化的类，所以报错。

解决方案 #

这里给你两种靠谱的解决思路：

1. 给XStream添加自定义Map.Entry转换器

我们可以写一个自定义转换器，告诉XStream怎么正确处理Map.Entry的序列化和反序列化：

import com.thoughtworks.xstream.converters.Converter;
import com.thoughtworks.xstream.converters.MarshallingContext;
import com.thoughtworks.xstream.converters.UnmarshallingContext;
import com.thoughtworks.xstream.io.HierarchicalStreamReader;
import com.thoughtworks.xstream.io.HierarchicalStreamWriter;
import java.util.AbstractMap;
import java.util.Map;

public class MapEntryConverter implements Converter {

    @Override
    public boolean canConvert(Class type) {
        return Map.Entry.class.isAssignableFrom(type);
    }

    @Override
    public void marshal(Object source, HierarchicalStreamWriter writer, MarshallingContext context) {
        Map.Entry entry = (Map.Entry) source;
        writer.startNode("key");
        context.convertAnother(entry.getKey());
        writer.endNode();
        writer.startNode("value");
        context.convertAnother(entry.getValue());
        writer.endNode();
    }

    @Override
    public Object unmarshal(HierarchicalStreamReader reader, UnmarshallingContext context) {
        reader.moveDown();
        Object key = context.convertAnother(null, Object.class);
        reader.moveUp();
        reader.moveDown();
        Object value = context.convertAnother(null, Object.class);
        reader.moveUp();
        return new AbstractMap.SimpleEntry(key, value);
    }
}

然后在配置JobOperator的时候，把这个转换器注册到XStream里：

import org.springframework.batch.core.configuration.annotation.JobOperatorFactoryBean;
import org.springframework.batch.core.repository.JobRepository;
import org.springframework.batch.core.launch.JobOperator;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import com.thoughtworks.xstream.XStream;

@Configuration
public class BatchConfig {

    @Bean
    public JobOperator jobOperator(JobRepository jobRepository) throws Exception {
        JobOperatorFactoryBean factory = new JobOperatorFactoryBean();
        factory.setJobRepository(jobRepository);
        // 其他必要配置，比如JobLauncher、JobExplorer等

        // 自定义XStream并添加转换器
        XStream xStream = new XStream();
        xStream.registerConverter(new MapEntryConverter());
        // 注册其他默认需要的转换器（比如针对JobParameters的）
        xStream.autodetectAnnotations(true);
        factory.setXStream(xStream);

        factory.afterPropertiesSet();
        return factory.getObject();
    }
}

2. 绕开XStream，直接用JobRepository查询执行记录

如果不想折腾XStream的配置，也可以直接通过JobRepository或者JobExplorer来获取Job执行记录，这样就不会触发XStream的序列化：

import org.springframework.batch.core.JobExecution;
import org.springframework.batch.core.explore.JobExplorer;
import org.springframework.beans.factory.annotation.Autowired;
import java.util.List;

// 在你的服务类里
@Autowired
private JobExplorer jobExplorer;

public List<JobExecution> getRunningJobExecutions() {
    // 获取所有运行中的Job执行记录
    return jobExplorer.findRunningJobExecutions("your-job-name");
}

这种方式更直接，而且避免了XStream的序列化问题，适合只需要获取基本执行信息的场景。

最后提醒 #

如果是用Spring Boot，注意默认的JobOperator已经有一些XStream配置，替换的时候要确保保留必要的转换器，避免其他序列化问题。

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