Java Listener中Spring接口注入的使用

在项目中使用Spring通常使用他的依赖注入可以很好的处理,接口与实现类之间的耦合 性,但是通常的应用场景中都是Service层和DAO层,或者web层的话, 也是与Strust2来整合,那么如何在Listener中使用Spring自动注入的接口呢。 接下来开始记录下今天做的一个小工具。

这个小工具是通过这个Listener来开启一个线程, 然后定时访问数据库中的数据,将数据获取出来后,然后逐条分析数据里边的手机号码,来通过淘宝提供的一个接口来分析手机号的归属地。那么在Listener中如何来访问数据库呢。下面直接贴代码:

...

import java.util.ArrayList;
import java.util.List;

import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;

import org.apache.commons.lang3.StringUtils;
import org.apache.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.util.CollectionUtils;
import org.springframework.web.context.WebApplicationContext;
import org.springframework.web.context.support.WebApplicationContextUtils;

import cn.org.rapid_framework.page.Page;

/**
 * Listener的方式在后台执行一线程
 *
 * @author
 *
 */
public class MyListener implements ServletContextListener {
    private MyThread myThread;
    private Logger logger = Logger.getLogger(MyListener.class);

    public void contextDestroyed(ServletContextEvent e) {
        if (myThread != null && myThread.isInterrupted()) {
            myThread.interrupt();
        }
    }

    public void contextInitialized(ServletContextEvent e) {
        String str = null;
        if (str == null && myThread == null) {
            myThread = new MyThread(e);
            myThread.start(); // servlet 上下文初始化时启动 socket
        }
    }
}

/**
 * 自定义一个 Class 线程类继承自线程类,重写 run() 方法,用于从后台获取并处理数据
 *
 * @author Champion.Wong
 *
 */
class MyThread extends Thread {
    private Logger logger = Logger.getLogger(MyThread.class);
    ServletContextEvent _e;
    public MyThread(ServletContextEvent e) {
        _e = e;
    }

    public void run() {
        while (!this.isInterrupted()) {// 线程未中断执行循环
            IGoldenPhoneManager phoneManager;
            List<GoldenPhone> phoneList = new ArrayList<GoldenPhone>();
            WebApplicationContext context = WebApplicationContextUtils.getRequiredWebApplicationContext(_e.getServletContext());
            phoneManager = (IGoldenPhoneManager) context.getBean("igoldenPhoneManager");
            System.out.println("开始获取所有电话记录...");
            int pageSize = 100;
            for (int i = 0; i < 46800; i++) {
                GoldenPhoneQuery query = new GoldenPhoneQuery();
                query.setPageNumber(i);
                query.setPageSize(pageSize);
                Page result = phoneManager.findPage(query);
                if (result != null) {
                    phoneList = result.getResult();
                    System.out.println("获取所有电话记录数目:" + result.getResult().size());
                    if (!CollectionUtils.isEmpty(phoneList)) {
                        for (GoldenPhone phoneModel : phoneList) {
                            if (StringUtils.isBlank(phoneModel.getProvinces())) {
                                String provinces = new PhoneService().getPhoneArea(phoneModel.getTel());
                                phoneModel.setProvinces(provinces);
                                phoneManager.update(phoneModel);
                                try {
                                    Thread.sleep(3000);
                                    System.out.println("休息3m钟...");
                                } catch (InterruptedException e1) {
                                    e1.printStackTrace();
                                }
                            }
                        }
                    }
                }
            }
        }
    }
}

可以看到,方法中通过

WebApplicationContext context = WebApplicationContextUtils.getRequiredWebApplicationContext(_e.getServletContext()); phoneManager = (IGoldenPhoneManager) context.getBean("igoldenPhoneManager"); 

来获取一个bean,这样就能获取到一个已经注入好的bean了。这里需要注意 的是:在web.xml中添加这个侦听的时候, 需要先引入Spring的Listener然后引入这个自定义的Listener,需要注意前后顺序。接下来就是通过开启一个线程,来处理当前的一些数据 逻辑。这段代码中另外一个注意的地方就是有时,我们在想如何将一个参数传递到一个线程中, 上文我的做法是通过构造函数传入。

时间: 2024-11-05 15:51:33

Java Listener中Spring接口注入的使用的相关文章

java学习中,接口的使用(重要,常用知识点)(java 学习中的小记录)

java学习中,接口的使用(重要,常用知识点)(java 学习中的小记录)作者:王可利(Star·星星) 接口(功能:用来添加拓展功能的) 例子:铅笔.带橡皮檫的铅笔. 两个功能:     1.写字......> 铅笔     2.擦字......> 橡皮擦 想法:定义一个铅笔类,定义一个橡皮擦类,定义一个带橡皮擦的铅笔类继承 铅笔类和橡皮擦类 但是java是单继承的.于是就有了解决的方法:接口(可以添加拓展功能) 如:一个铅笔类,给它添加一个接口给它一个拓展类(橡皮擦类) 接口的定义模式 用

java框架篇---spring 依赖注入

spring依赖注入的方式有4种 构造方法注入 属性注入 工厂注入 注解注入 下面通过一个实例统一讲解: User.java package com.bjsxt.model; public class User { private String username; private String password; public User(){} public User(String username, String password) { super(); this.username = use

漫谈Java程序设计中的接口应用

Java语言提供了一种接口(interface)机制.这种接口机制使Java的面向对象编程变得更加灵活.我们可以用接口来定义一个类的表现形式,但接口不能包含任何实现.在<Thinking in Java>一书中,作者对接口有这样的描述:“接口(interface)比抽象(abstract)的概念更进了一步.你可以把一个接口看成是一个纯的抽象类.”我认为作者对接口的这一解释再准确不过了. 理解并用好接口机制将帮助我们更好的掌握Java这种面向对象的编程语言.下面我们来讨论一下接口的使用规则以及相

Java 8 中函数接口,陈货翻新了炒,只是为了Lambda表达式

Java开发人员应该对java.lang.Runnable,java.util.Comparator,java.util.concurrent.Callable 等等接口不会感到陌生.他们都只有一个单一的抽象方法.这样的接口,我们通常叫单一抽象方法接口(SAM,Single Abstract Method Interface). 以前大家应该经常使用下面的代码片段 public class InnerAnonymousClassSample { public static void main(S

java类中定义接口

今天看到一个java类中定义了接口,写个备忘录,记录一下 1 package com.gxf.test; 2 3 public class Test_interface { 4 public interface show{ 5 public void show(); 6 } 7 static class TestInterface implements show{ 8 9 @Override 10 public void show() { 11 System.out.println("this

JAVA入门[3]—Spring依赖注入

Spring支持属性注入和构造器注入,它支持XML和注解两种方式.本文介绍Spring控制反转容器加载包含beans的XML文件,实现依赖注入. 一.创建bean实例 暂且抛开对象依赖,我们先看下如何通过Spring容器创建bean实例.这里要用到Spring的控制反转容器ApplicationContext,它的getBean方法可以创建bean实例 1.在Maven项目的pom.xml添加spring依赖项. <dependencies> <!-- mybatis核心包 -->

Java集合中Map接口的使用方法

Map接口 Map提供了一种映射关系,其中的元素是以键值对(key-value)的形式存储的,能够实现根据key快速查找value: Map中的键值对以Entry类型的对象实例形式存在: 建(key值)不可重复,value值可以重复,一个value值可以和很多key值形成对应关系,每个建最多只能映射到一个值. Map支持泛型,形式如:Map<K,V> Map中使用put(K key,V value)方法添加 HashMap类 HashMap是Map的一个重要实现类,也是最常用的,基于哈希表实现

Java基础中map接口和实现类

1.Map接口常用的实现类有HashMap和TreeMap. 2.HashMap类实现的Map集合对于添加和删除映射关系效率更高.HashMap是基于哈希表的Map接口的实现,HashMap通过哈希码对其内部的映射关系进行快速查询,由HashMap类实现的Map集合对于添加或删除映射关系效率较高. 3.TreeMap中的映射关系存在一定的顺序,如果希望Map集合中的对象存在一定的顺序,该使用TreeMap类实现Map集合. HashMap类 ①此类不保证映射的顺序,特别是不保证该顺序恒久不变 ②

java语言中的接口概述

接口 接口中的成员修饰符是固定的 1,全局常量:public staticfinal 2,抽象方法:public abstract 接口中的成员都是公共的权限. 类与类之间是继承关系,类与接口之间是实现关系. 接口不可以实例化 只能有实现了接口的子类并覆盖了接口中所有的抽象方法后,该子类才可以实例化.否则,这个子类就是一个抽象类. 调用接口的常量时,接口名,接口的子类名,子类的对象都可以进行调用. 在java中不直接支持多继承,因为会出现调用的不确定性. 所以java将多继承机制进行改良,在ja