记录Spring注入Bean改为多例模式

在实际项目中使用注入Bean并且需要对Bean设不同的值(需要实现的效果类似于new Bean)

Spring注入Bean默认创建方式为单例模式,我们现在需要修改为多例模式

在网上找了很久,大多都是几年前使用xml配置。或者是直接加入@Scope("prototype"),并没有生效;希望能帮到大家。以下通过3个步骤即可实现,亲测有效。

1.新增通过Spring上下文获取新对象工具类

@Component
public class SpringContextUtil implements ApplicationContextAware {
    /**
     * Spring应用上下文环境
     */
    private static ApplicationContext applicationContext;

    /**
     *  实现ApplicationContextAware接口的回调方法,设置上下文环境
     * @param applicationContext
     * @throws BeansException
     */
    @Override
    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
        SpringContextUtil.applicationContext = applicationContext;
    }
    /**
     * @return ApplicationContext
     */
    public static ApplicationContext getApplicationContext() {
        return applicationContext;
    }
    /**
     * 获取对象
     *
     * @param name
     * @return Object
     * @throws BeansException
     */
    public static Object getBean(String name) throws BeansException {
        return applicationContext.getBean(name);
    }


}

2.在需要注入的对象,新增注解@Scope("prototype"),以下是我的业务代码,为了做Demo一起复制过来了。

/**
 * 定时任务线程类
 */
@Slf4j
@Data
@Component
@Scope("prototype")
public class ScheduleTask implements Runnable {

//=============================在开启run方法的时候会对传入的参数使用,所以需要每次创建为一个新的对象=====================================
    /**
     * 任务唯一识别码
     */
    private Long id;
    /**
     * 执行类型id
     */
    private Integer typeId;
    /**
     * 巡检提醒To
     */
    private RecordRemindTaskEntity remindTaskEntity;

//=================================================================================
    /**
     * 巡检预警-推送接口
     */
    @Autowired
    private AlarmPushService alarmPushService;

    @Autowired
    private RecordService recordService;

    @Autowired
    private RecordRemindTaskService recordRemindTaskService;

    /**
     * 开始执行-超时50%未巡检-提醒定时任务,时间:
     */
    private static final String HALF_START_MSG="开始执行-超时50%未巡检-提醒定时任务,时间:";
    /**
     * 结束执行-超时50%未巡检-提醒定时任务,时间:
     */
    private static final String HALF_END_MSG="结束执行-超时50%未巡检-提醒定时任务,时间:";

    /**
     * 开始执行-巡检未完成-提醒定时任务,时间:
     */
    private static final String UNDONE_START_MSG="开始执行-巡检未完成-提醒定时任务,时间:";
    /**
     * 结束执行-巡检未完成-提醒定时任务,时间:
     */
    private static final String UNDONE_END_MSG="结束执行-巡检未完成-提醒定时任务,时间:";




    @Override
    public void run() {
        //巡检开始-提醒
        startRemind();
        //巡检过半-提醒
        halfAndUnoneRemind(Constant.HALFTIMEOUT_REMIND_TASK_TYPE, HALF_START_MSG, HALF_END_MSG);
        //巡检未开始-提醒
        halfAndUnoneRemind(Constant.UNDONE_REMIND_TASK_TYPE, UNDONE_START_MSG, UNDONE_END_MSG);
    }

    /**
     * 巡检过半、未开始
     * @param halftimeoutRemindTaskType
     * @param s
     * @param s2
     */
    private void halfAndUnoneRemind(Integer halftimeoutRemindTaskType, String s, String s2) {
        if (typeId.equals(halftimeoutRemindTaskType)) {
            TimeInterval interval = new TimeInterval();
            //查询巡检记录,每日巡检”巡检计划时间已过半,但巡检未开始
            log.info("↓↓↓↓↓↓↓↓定时任务id:"+id + s + LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"))+"↓↓↓↓↓↓↓↓");
            Long recordId = remindTaskEntity.getRecordId();
            RecordEntity byId = recordService.getById(recordId);
            if (BeanUtil.isNotEmpty(byId)) {
                Integer state = byId.getState();
                if (BeanUtil.isNotEmpty(state)) {
                    if (state.equals(Constant.RecordTypeEnum.NOBEGION.getCode())) {
                        //调用消息推送接口
                        alarmPushService.pushPatrolRemind(new PushPatrolRemindReq(typeId,remindTaskEntity.getOrgId()));
                    }
                }
            }
            log.info("↑↑↑↑↑↑↑↑定时任务id:"+id + s2 + LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")) + "接口调用使用时间:" + interval.interval() + "毫秒↑↑↑↑↑↑↑↑");
            //关闭定时任务状态
            closeRemindTask();
        }
    }

    /**
     * 关闭定时任务状态
     */
    private void closeRemindTask() {
        remindTaskEntity.setId(id);
        remindTaskEntity.setStartFlag(Constant.CLOSE);
        remindTaskEntity.setUpdateDate(new Date());
        recordRemindTaskService.updateById(remindTaskEntity);
    }

    /**
     * 巡检开始-提醒
     */
    private void startRemind() {
        if (typeId.equals(Constant.START_REMIND_TASK_TYPE)) {
            TimeInterval interval = new TimeInterval();
            //调用消息推送接口
            log.info("↓↓↓↓↓↓↓↓定时任务id:"+id + "开始执行-巡检开始3分钟-提醒定时任务,时间:" + LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"))+"↓↓↓↓↓↓↓↓");
            alarmPushService.pushPatrolRemind(new PushPatrolRemindReq(typeId, remindTaskEntity.getOrgId()));
            log.info("↑↑↑↑↑↑↑↑定时任务id:"+id + "结束执行-巡检开始3分钟-提醒定时任务,时间:" + LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")) + "接口调用使用时间:" + interval.interval() + "毫秒↑↑↑↑↑↑↑↑");
            //关闭定时任务状态
            closeRemindTask();
        }
    }

}

3.使用(在调用对象的位置使用SpringContextUtil 创建出上下文对象,对获取的对象设值就是一个新创建的对象)

                        ScheduleTask scheduleTask = (ScheduleTask) SpringContextUtil.getBean("scheduleTask");
                        scheduleTask.setTypeId(Constant.START_REMIND_TASK_TYPE);
                        scheduleTask.setRemindTaskEntity(o);
                        scheduleTask.setId(o.getId());
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

相关阅读更多精彩内容

友情链接更多精彩内容