文档章节

ssm框架中 ,服务器启动开启线程,线程中使用添加了spring注解类中的方法

玩转魔方
 玩转魔方
发布于 2017/04/21 16:51
字数 589
阅读 874
收藏 1

——ssm框架中服务器一启动开启一条线程

1.使用监听器,在web.xml中进行配置

<listener>
	   <listener-class>com.hiteamtech.app.common.TimerUtil</listener-class>
	</listener>

2。获取bean的工具类

import java.util.Locale;

import org.springframework.beans.BeansException;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;

/** 
 * 项目名称: 
 * 类名: SpringContextUtil
 * 描述: 获取bean的工具类,可用于在线程里面获取bean
 */
public class SpringContextUtil implements ApplicationContextAware {

    private static ApplicationContext context = null;

    /* (non Javadoc)
     * @Title: setApplicationContext
     * @Description: spring获取bean工具类
     * @param applicationContext
     * @throws BeansException
     * @see org.springframework.context.ApplicationContextAware#setApplicationContext(org.springframework.context.ApplicationContext)
     */
    @Override
    public void setApplicationContext(ApplicationContext applicationContext)
            throws BeansException {
        this.context = applicationContext;
    }

    public static <T> T getBean(String beanName){
        return (T) context.getBean(beanName);
    }

    public static String getMessage(String key){
        return context.getMessage(key, null, Locale.getDefault());
    }

}

3.在applicationContext.xml配置文件中注入这个工具类

<bean id="springContextUtil" class="com.hiteamtech.app.common.SpringContextUtil"></bean>

4.TimerUtils.java文件

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration({ "classpath:sqlMapConfig.xml","classpath:springmvc.xml","classpath:applicationContext.xml","classpath:captcha-context.xml" })
public class TimerUtil implements ServletContextListener {
        @Override  
        public void contextInitialized(ServletContextEvent arg0) {  
            // run in a second  使用工具类获取使用了@service注解的SettingsServiceImpl对象
            ISettingsService settingsService = SpringContextUtil.getBean("settingsServiceImpl");;
            final long timeInterval = 1000*60;  
            Runnable runnable = new Runnable() {  
                public void run() {  
                    while (true) {  
                        long l = System.currentTimeMillis();
                        Date date = new Date(l);
                        SimpleDateFormat dateFormat = new SimpleDateFormat("HH:mm");
                        System.out.println(dateFormat.format(date));
                        settingsService.updateRemindTimeBySid("18b138ded96546179149e6bf502485c4");
                        try {  
                            Thread.sleep(timeInterval);  
                        } catch (InterruptedException e) {  
                            e.printStackTrace();  
                        }  
                    }  
                }  
            };  
            Thread thread = new Thread(runnable);  
            thread.start();  
        }  
          
        @Override  
        public void contextDestroyed(ServletContextEvent arg0) {  
            // TODO Auto-generated method stub  
              
        }        
}

二.接口访问时开启线程

线程类:

public class RobotThread extends Thread {

	/**日志记录器*/
	Logger log = Logger.getLogger(RobotThread.class);
	//要添加的机器人个数
	private String[] robots;
	//线程动作指令  addRobot添加机器人,delRobot删除机器人
	private String cmd = null;
	//直播间id
	private String liveId = null;
	
	private ILiveCacheService liveCache;
	
	private IUserCacheService userCache;
	
	private IRyIMService imService;
	
	public RobotThread(ILiveCacheService liveCache,IUserCacheService userCache,IRyIMService imService, String liveId, String[] robots, String cmd){
		this.liveCache = liveCache;
		this.robots = robots;
		this.cmd = cmd;
		this.liveId = liveId;
		this.userCache = userCache;
		this.imService = imService;
	}
	
	/**
	 * 异步销毁直播缓存数据
	 */
	public void run() {
		log.debug(" cmd:"+this.cmd);
		switch (cmd) {
		case "addRobot":
			this.updateRobot();
			break;
		case "delRobot":
			this.updateRobot();
			break;
		default:
			//错误处理机制
			break;
		}
	}
	
	
	private void updateRobot(){	
	}
	
	
	public static void main(String[] args) {
		Random rd = new Random();
		for (int i = 0; i < 100; i++) {
			System.out.println(rd.nextInt(10)+2);
			/*try {
				//随机休眠1,2秒添加一个
				Thread.sleep(1000*(rd.nextInt(6)+2));
			} catch (InterruptedException e1) {
				e1.printStackTrace();
			}*/
		}
	}
	
}

调用线程的controller:

@Controller
@RequestMapping("/liveNotify")
public class LiveNotifyController extends BaseController {

	/**日志记录器*/
	Logger log = Logger.getLogger(LiveNotifyController.class);
	
	@Autowired
	private ILiveService liveService;
	
	@Autowired
	private LiveCacheService liveCache;
	
	@Autowired
	private IUserCacheService userCache;
	
	@Autowired
	private IRyIMService IMService;
	
	@Autowired
	private UserFansMapper userFansDAO;
	
	@Autowired
	private IUserCacheService cacheService;
	
	@Autowired
	private IRyIMService imService;
	
	@Resource
	private UserBlackListMapper userBlackListDao;
	
	@Resource
	private UserFansMapper userFansDao;
	
	@Resource
	private UserInfoMapper userInfoDao;

	@RequestMapping(value = "/liveRobot", method = RequestMethod.POST)
	public void liveJqg(HttpServletRequest req, HttpServletResponse resp){
		//启用异步线程,添加机器人
		new RobotThread(liveCache, userCache, IMService, liveId, robots, cmd).start();
		super.outMsg(200, "success", resp);
	}

方法仅供参考。

© 著作权归作者所有

玩转魔方
粉丝 2
博文 11
码字总数 12490
作品 0
朝阳
程序员
私信 提问
Spring boot异步注解源码解析

一、例子 我们先来看下面这个Demo。 pom.xml中maven依赖: 启动类SpringBootAsyncApplication.java DemoController.java IDemoService接口实现类DemoServiceImpl.java 启动项目后,访问GET h...

Lienson
04/16
55
0
如何在 Spring 异步调用中传递上下文

什么是异步调用? 异步调用是相对于同步调用而言的,同步调用是指程序按预定顺序一步步执行,每一步必须等到上一步执行完后才能执行,异步调用则无需等待上一步程序执行完即可执行。异步调用...

aoho
08/01
0
0
深入理解Spring的ImportSelector接口

  ImportSelector接口是至spring中导入外部配置的核心接口,在SpringBoot的自动化配置和@EnableXXX(功能性注解)都有它的存在,关于SpringBoot的分析可以参考:深入理解SpringBoot的自动装配...

融科聂晨
2018/07/05
0
0
springboot 异步调用

异步调用 启动类:添加@EnableAsync注解 service方法上添加@Async注解 异步线程池 配置 测试 注意事项: 如下方式会使@Async失效 一、异步方法使用static修饰 二、异步类没有使用@Component注...

张欢19933
01/10
16
1
spring boot实现动态增删启停定时任务

在spring boot项目中,可以通过@EnableScheduling注解和@Scheduled注解实现定时任务,也可以通过SchedulingConfigurer接口来实现定时任务。但是这两种方式不能动态添加、删除、启动、停止任务...

jessehua
04/22
0
0

没有更多内容

加载失败,请刷新页面

加载更多

OpenStack 简介和几种安装方式总结

OpenStack :是一个由NASA和Rackspace合作研发并发起的,以Apache许可证授权的自由软件和开放源代码项目。项目目标是提供实施简单、可大规模扩展、丰富、标准统一的云计算管理平台。OpenSta...

小海bug
昨天
6
0
DDD(五)

1、引言 之前学习了解了DDD中实体这一概念,那么接下来需要了解的就是值对象、唯一标识。值对象,值就是数字1、2、3,字符串“1”,“2”,“3”,值时对象的特征,对象是一个事物的具体描述...

MrYuZixian
昨天
6
0
数据库中间件MyCat

什么是MyCat? 查看官网的介绍是这样说的 一个彻底开源的,面向企业应用开发的大数据库集群 支持事务、ACID、可以替代MySQL的加强版数据库 一个可以视为MySQL集群的企业级数据库,用来替代昂贵...

沉浮_
昨天
6
0
解决Mac下VSCode打开zsh乱码

1.乱码问题 iTerm2终端使用Zsh,并且配置Zsh主题,该主题主题需要安装字体来支持箭头效果,在iTerm2中设置这个字体,但是VSCode里这个箭头还是显示乱码。 iTerm2展示如下: VSCode展示如下: 2...

HelloDeveloper
昨天
7
0
常用物流快递单号查询接口种类及对接方法

目前快递查询接口有两种方式可以对接,一是和顺丰、圆通、中通、天天、韵达、德邦这些快递公司一一对接接口,二是和快递鸟这样第三方集成接口一次性对接多家常用快递。第一种耗费时间长,但是...

程序的小猿
昨天
10
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部