如何在Java Filter 中注入 Service

在项目中遇到一个问题,在 Filter中注入 Serivce失败,注入的service始终为null。如下所示:

public class WeiXinFilter implements Filter{

    @Autowired
    private UsersService usersService;

    public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException {        HttpServletRequest req = (HttpServletRequest)request;        HttpServletResponse resp = (HttpServletResponse)response;     Users users = this.usersService.queryByOpenid(openid);
}

上面的 usersService 会报空指针异常。

解决方法一

public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException {
        HttpServletRequest req = (HttpServletRequest)request;
        HttpServletResponse resp = (HttpServletResponse)response;
        ServletContext sc = req.getSession().getServletContext();        XmlWebApplicationContext cxt = (XmlWebApplicationContext)WebApplicationContextUtils.getWebApplicationContext(sc);                if(cxt != null && cxt.getBean("usersService") != null && usersService == null)            usersService = (UsersService) cxt.getBean("usersService");                Users users = this.usersService.queryByOpenid(openid);

这样就行了。

方法二

public class WeiXinFilter implements Filter{

    private UsersService usersService;

    public void init(FilterConfig fConfig) throws ServletException {
        ServletContext sc = fConfig.getServletContext();
        XmlWebApplicationContext cxt = (XmlWebApplicationContext)WebApplicationContextUtils.getWebApplicationContext(sc);

        if(cxt != null && cxt.getBean("usersService") != null && usersService == null)
            usersService = (UsersService) cxt.getBean("usersService");
    }

相关原理:

1. 如何获取 ServletContext

1)在javax.servlet.Filter中直接获取
ServletContext context = config.getServletContext();

2)在HttpServlet中直接获取

this.getServletContext()

3)在其他方法中,通过HttpServletRequest获得

request.getSession().getServletContext();

2. WebApplicationContext 与 ServletContext (转自:http://blessht.iteye.com/blog/2121845):

Spring的 ContextLoaderListener是一个实现了ServletContextListener接口的监听器,在启动项目时会触发contextInitialized方法(该方法主要完成ApplicationContext对象的创建),在关闭项目时会触发contextDestroyed方法(该方法会执行ApplicationContext清理操作)。

ConextLoaderListener加载Spring上下文的过程

①启动项目时触发contextInitialized方法,该方法就做一件事:通过父类contextLoader的initWebApplicationContext方法创建Spring上下文对象。

②initWebApplicationContext方法做了三件事:创建 WebApplicationContext;加载对应的Spring文件创建里面的Bean实例;将WebApplicationContext放入 ServletContext(就是Java Web的全局变量)中

③createWebApplicationContext创建上下文对象,支持用户自定义的上下文对象,但必须继承自ConfigurableWebApplicationContext,而Spring MVC默认使用ConfigurableWebApplicationContext作为ApplicationContext(它仅仅是一个接口)的实 现。

④configureAndRefreshWebApplicationContext方法用 于封装ApplicationContext数据并且初始化所有相关Bean对象。它会从web.xml中读取名为 contextConfigLocation的配置,这就是spring xml数据源设置,然后放到ApplicationContext中,最后调用传说中的refresh方法执行所有Java对象的创建。

⑤完成ApplicationContext创建之后就是将其放入ServletContext中,注意它存储的key值常量。

方法三

直接使用spring mvc中的HandlerInterceptor或者HandlerInterceptorAdapter 来替换Filter:

public class WeiXinInterceptor implements HandlerInterceptor {
    @Autowired
    private UsersService usersService;   

    @Override
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
        // TODO Auto-generated method stub
        return false;
    }

    @Override
    public void postHandle(HttpServletRequest request, HttpServletResponse response, Object handler, ModelAndView modelAndView)
            throws Exception {
        // TODO Auto-generated method stub

    }

    @Override
    public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) throws Exception {
        // TODO Auto-generated method stub

    }
}

配置拦截路径:

    <mvc:interceptors>
        <mvc:interceptor>
            <mvc:mapping path="/**" />
            <bean class="net.xxxx.interceptor.WeiXinInterceptor" />
        </mvc:interceptor>
    </mvc:interceptors>

Filter 中注入 Service 的示例:

public class WeiXinFilter implements Filter{
    private UsersService usersService;
    public void init(FilterConfig fConfig) throws ServletException {}
    public WeiXinFilter() {}
    public void destroy() {}

    public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException {
        HttpServletRequest req = (HttpServletRequest)request;
        HttpServletResponse resp = (HttpServletResponse)response;

        String userAgent = req.getHeader("user-agent");        if(userAgent != null && userAgent.toLowerCase().indexOf("micromessenger") != -1){    // 微信浏览器
            String servletPath = req.getServletPath();
            String requestURL = req.getRequestURL().toString();
            String queryString = req.getQueryString();

            if(queryString != null){
                if(requestURL.indexOf("mtzs.html") !=-1 && queryString.indexOf("LLFlag")!=-1){
                    req.getSession().setAttribute("LLFlag", "1");
                    chain.doFilter(request, response);
                    return;
                }
            }

            String openidDES = CookieUtil.getValueByName("openid", req);
            String openid = null;
            if(StringUtils.isNotBlank(openidDES)){
                try {
                    openid = DesUtil.decrypt(openidDES, "rxxxxxxxxxde");    // 解密获得openid
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
            // ... ...
            String[] pathArray = {"/weixin/enterAppFromWeiXin.json", "/weixin/getWeiXinUserInfo.json",
                                    "/weixin/getAccessTokenAndOpenid.json", "/sendRegCode.json", "/register.json",
                                    "/login.json", "/logon.json", "/dump.json", "/queryInfo.json"};
            List<String> pathList = Arrays.asList(pathArray);

            String loginSuccessUrl = req.getParameter("path");
            String fullLoginSuccessUrl = "http://www.axxxxxxx.cn/pc/";
            if(requestURL.indexOf("weixin_gate.html") != -1){
                req.getSession().setAttribute("loginSuccessUrl", loginSuccessUrl);          // ... ...
            }            ServletContext sc = req.getSession().getServletContext();XmlWebApplicationContext cxt = (XmlWebApplicationContext)WebApplicationContextUtils.getWebApplicationContext(sc);                    if(cxt != null && cxt.getBean("usersService") != null && usersService == null)               usersService = (UsersService) cxt.getBean("usersService");                    Users users = this.usersService.queryByOpenid(openid);
            // ... ...
            if(pathList.contains(servletPath)){    // pathList 中的访问路径直接 pass
                chain.doFilter(request, response);
                return;
            }else{
                if(req.getSession().getAttribute(CommonConstants.SESSION_KEY_USER) == null){ // 未登录
                    String llFlag = (String) req.getSession().getAttribute("LLFlag");
                    if(llFlag != null && llFlag.equals("1")){    // 处理游客浏览
                        chain.doFilter(request, response);
                        return;
                    }
                    // ... ...// 3. 从腾讯服务器去获得微信的 openid ,
                    req.getRequestDispatcher("/weixin_gate.html").forward(request, response);
                    return;
                }else{    // 已经登录
                    // 4. 已经登录时的处理
                    chain.doFilter(request, response);
                    return;
                }
            }
        }else{    // 非微信浏览器
            chain.doFilter(request, response);
        }
    }

}

时间: 2024-10-02 12:48:30

如何在Java Filter 中注入 Service的相关文章

在Java filter中调用service层方法

在项目中遇到一个问题,在 Filter中注入 Serivce失败,注入的service始终为null.如下所示: 1 public class WeiXinFilter implements Filter{ 2 3 @Autowired 4 private UsersService usersService; 5 6 public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain)

关于如何在Listener中注入service和ServletContextListener源码分析

今天在做项目时突然发现我该如何向listener中注入service对象,因为监听器无法使用注解注入. 此时有人会想用以下代码通过xml的方式注入: ApplicationContext context=new ClassPathXmlApplication(*.xml); productService =(ProductService)context.getBean("productService"); 这样的话会导致一个问题,那就是Tomcat会两次加载spring的配置文件.所以

Android如何在java代码中设置margin

习惯了直接在xml里设置margin(距离上下左右都是10dip),如: <ImageView android:layout_margin="10dip" android:src="@drawable/image" /> 只是有些情况下,需要在java代码里来写. API中,android.view.ViewGroup.MarginLayoutParams有个方法setMargins(left, top, right, bottom).可是View本身没

如何在Java面试中谈工资

在面试中,工资这块是不得不谈的,即使HR没有主动提起工资的问题,你也得主动顺其自然的跟HR谈起工资.为什么是顺其自然呢?因为在面试中谈工资也是项技术活,比如谈的太早,那么你们接下的的面试沟通环节就会崩塌.在Java面试中也是一样,今天就跟长沙尚学堂小编一起来看看,如何在Java面试中谈工资? 如何在Java面试中谈工资? 1. 有的朋友属于很急的性子,觉得自己在Java面试中,最关注的问题就是工资,总喜欢在Java面试中直接开门见山的问HR:我一个月能够拿到多少工资呢?如果HR也是你一样的性子,

java多线程中注入Spring对象问题

web应用中java多线程并发处理业务时,容易抛出NullPointerException. 原因: 线程中的Spring Bean没有被注入.web容器在启动时,没有提前将线程中的bean注入,在线程启动之前,web容器是无法感知的. 解决方案: 方法一.在声明成员变量的时候,将其定义为static的.(据说不可行) 方法二.将线程设置为主程序的内部类. 在外部类中注入bean,这样在内部类线程中就可以“共享”这个对象. 方法三.定义一个工具类,使用静态工厂方法通过getBean获得bean对

如何在java项目中使用lucene

lucene是一个开源的全文检索引擎工具包,但它不是一个成型的搜索引擎,它的功能就是负责将文本数据按照某种分词算法进行分词,分词后的结果存储在索引库中,然后根据关键字从索引库检检索. 那么应该如何使用呢? 1. 从官网下载http://lucene.apache.org/并解压缩 2.我们可以从官网给的示例中学习如何使用,并且官网还提供了说明文档,可以随时查阅http://lucene.apache.org/core/4_10_2/core/index.html 下面简要展示如何运行示例: 示例

如何在java类中获取javaWeb的根路径

我们有时候需要在java类中(包括util类等)获取web的根路径,可以通过class类路径来获取: public static String getRealPath(Class clazz) { String url = clazz.getResource("").getPath(); int displace = url.indexOf("WEB-INF"); StringBuffer buffer = new StringBuffer(); for (int

如何在java代码中调用一个web项目jsp或者servlet

有时候需要调用一个web项目的jsp或者servlet,但是执行内部的代码,并不是打开jsp,例如需要在一段java代码中清除一个web项目中的缓存,那么可以把清除缓存的代码放在该web项目的一个servlet中,只需要执行如下代码: URL url = new URL("http://192.168.2.123:8080/sace/ClearCache"); url.openStream(); openStream() 执行一次相当于一次URL请求,其中url.openStream(

如何在Java 8中愉快地处理日期和时间

原文:http://www.liaoxuefeng.com/article/00141939241051502ada88137694b62bfe844cd79e12c32000 参考:http://www.cnblogs.com/feika/p/4448924.html(更详细些) Java 8新增了LocalDate和LocalTime接口,为什么要搞一套全新的处理日期和时间的API?因为旧的java.util.Date实在是太难用了. java.util.Date月份从0开始,一月是0,十二