服务工厂实例化的bean如何访问httpServletRequest对象?



好吧,我有一个关于这个主题的赏钱,只有部分答案,所以我打算打开这个,简化这个主题,因为我猜原来的那个太臃肿了。

我面临的情况是,我基本上有一个过滤器,从servlet上下文中获得一个Spring服务工厂对象,当过滤器调用它的getService方法时,这个工厂分配一个bean的实例,但是我需要访问请求的会话或实际的httpServletRequest对象,因为我需要请求的userID。我认为,从我所读到的内容来看,我不应该将它传递给bean,不仅因为它不是线程安全的,而且因为它会破坏拥有过滤器的远程服务桥接器(CP2JavaWS)的抽象。

我怎么能让这个bean访问会话或httpServletRequest?

我尝试使用FacesContext,但它没有工作,因为我认为bean不是由jsp调用实例化,而是从一个过滤器。

Now Some code.

this is my web.xml

<display-name>CP2JavaWSTest</display-name>
<welcome-file-list>
    <welcome-file>index.html</welcome-file>
</welcome-file-list>
<error-page>
  <error-code>404</error-code>
  <location>/err.jsp</location>
</error-page>
<context-param>
    <param-name>contextConfigLocation</param-name>
    <param-value>/WEB-INF/applicationContext*.xml</param-value>
</context-param>
<listener>
<listener-class>
    org.springframework.web.context.request.RequestContextListener
</listener-class>

<listener> 
    <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
</listener>
<listener>
    <listener-class>com.cp2javaws.listeners.SpringContextWrapperListener</listener-class>
</listener>
<listener>
    <listener-class>com.bucle.listeners.BCLUserDatabaseContextListener</listener-class>
</listener>
<filter>
    <filter-name>BCLAuthenticationFilter</filter-name>
    <filter-class>com.bucle.filters.BCLAuthenticationFilter</filter-class>
</filter>
<filter>
    <filter-name>BCLAuthorizationFilter</filter-name>
    <filter-class>com.bucle.filters.BCLAuthorizationFilter</filter-class>
</filter>
<filter>
    <filter-name>CPJSonFilter</filter-name>
    <filter-class>com.cp2javaws.filters.CPJSonFilter</filter-class>
</filter>

应用程序上下文:

  <bean id="service1" class="com.bucle.database.BCLDb4oManager" scope="request"/>
  <bean id="service2" class="com.bucle.services.appe.BCLUserCFVC"/>
  <bean id="service3" class="com.bucle.services.appe.BCLUserCustomizedFutureValueCalculator"/>

CPWJavaWS过滤器

public class CPJSonFilter implements Filter {
    //.. properties
    public void init(FilterConfig filterConfig) 
    throws ServletException {
    //.. init code
    }
    public void destroy() {
        //..
    }
    public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) 
        throws IOException, ServletException {

        HttpSession session = ((HttpServletRequest)request).getSession(true); 
        //..Class and method decoding and mapping from JSON
                Class type = null;
                String value = request.getParameter(CP2JavaWSRequestParameterType+paramOrderString);
                if(paramName.indexOf(CP2JavaWSRequestGenericParamSuffix)>0 || request.getParameter(CP2JavaWSRequestParameterType+paramOrderString).equals("id")) {//SAMIR
                    type = Object.class;
                } else {
                    if(paramName.indexOf(CP2JavaWSRequestNullParamSuffix)>0) {
                        String CPClassName = paramName.substring(paramName.indexOf(CP2JavaWSRequestNullParamSuffix)+CP2JavaWSRequestNullParamSuffix.length());
                        try {
                            type = getJavaClassForCPClass(CPClassName);
                        } catch (CP2JavaWSException e) {
                            throw new ServletException("Cannot find corresponding Java class for null argument at index "+paramOrderString+" (passed CP class name is"+CPClassName+")");
                        }
                    } else if(List.class.isAssignableFrom(convertedObject.getClass())) {
                        type = List.class;
                    } else if(Map.class.isAssignableFrom(convertedObject.getClass())) { 
                        type = Map.class;
                    } else {
                        type = convertedObject.getClass();
                    }
                }
                typesOrderedMap.put(new Integer(paramOrderString), type);
            }
        }
        // invoke the service method using the provided service factory class
        Object result = null;
        try {
                Class serviceInterfaceClass = Class.forName(serviceInterfaceName);
                ServiceFactory serviceFactory = (ServiceFactory) filterConfig.getServletContext().getAttribute(ServiceFactory.CP2JAVAWS_SERVICES_FACTORY);
                Object service = serviceFactory.getService(serviceInterfaceClass);

                Method method = service.getClass().getDeclaredMethod(serviceMethodName, (Class[]) typesOrderedMap.values().toArray(new Class[typesOrderedMap.size()]));
                result = method.invoke(service, argumentsOrderedMap.values().toArray());
        } catch(Exception e) {
            throw new ServletException("Error invoking the service method :"+serviceMethodName+" on service "+serviceInterfaceName,e);
        }
        //...Convert result to JSON
            response.setContentType("application/json");
            PrintWriter writer = response.getWriter();
    StringBuffer stb = new StringBuffer();
            //... append result and some other stuff to the string buffer stb
        response.setContentLength(stb.length());
        ((HttpServletResponse)response).setStatus(HttpServletResponse.SC_OK);
        writer.write(stb.toString());
        writer.flush();
    }
    public static Class getJavaClassForCPClass(String CPClassName) throws CP2JavaWSException {
    //... returns the matching Class.class according to a default map like: CPArray -> List.class
    }
}

这是Spring上下文监听器:

public class SpringContextWrapperListener implements ServletContextListener {

    private ServletContext context = null;

    public void contextDestroyed(ServletContextEvent event) {
        this.context = null;
        //log.info("Spring Context Destruido");
    }

    public void contextInitialized(ServletContextEvent event) {
        this.context = event.getServletContext();
        ApplicationContext springContext = (ApplicationContext) WebApplicationContextUtils.getRequiredWebApplicationContext(this.context);
        SpringContextWrapper aSpringContextWrapper = new SpringContextWrapper(springContext);
        this.context.setAttribute(ServiceFactory.CP2JAVAWS_SERVICES_FACTORY, aSpringContextWrapper);
    }
}

和工厂:

public class SpringContextWrapper implements ServiceFactory {
private ApplicationContext springContext;
public SpringContextWrapper(ApplicationContext springContext) {
    this.springContext = springContext;
}
public Object getService(Class serviceInterfaceClass) throws CP2JavaWSException {
    Map services =  this.springContext.getBeansOfType(serviceInterfaceClass);
    Iterator it = services.values().iterator();
    if(it.hasNext()) {
        return it.next();
    }
    throw new CP2JavaWSException("can't find service for interface "+serviceInterfaceClass.getName());
}
public Object getService(String serviceName) throws CP2JavaWSException {
    Object service = this.springContext.getBean(serviceName);
    if(service==null) {
        throw new CP2JavaWSException("can't find service for name "+serviceName);
    }
    return service;
}}

我不是100%确定我理解了这个问题,但我认为你可以使用RequestContextHolder来做你想做的事情。

ServletRequestAttributes attrs = (ServletRequestAttributes)RequestContextHolder.currentRequestAttributes();
HttpServletRequest req = attrs.getRequest();

但是,看到一些代码会有所帮助。我怀疑您可以通过bean的正确scope实现您想要的。

你可以使用threadlocal来存储一个对象,它在你的过滤器的doFilter方法中包装了原始的HttpServletRequest和HttpServletResponse,然后从你的bean中的threadlocal访问这个包装对象。以下是如何实现它的粗略实现:

public class WebRequest {
    private HttpServletRequest request;
    private HttpServletResponse response;
    public WebRequest(HttpServletRequest request, HttpServletResponse response) {
        this.request = request;
        this.response = response;
    }   
}
class WebRequestUtils {
    private static ThreadLocal<WebRequest> webRequest;
    public static void setWebRequest(WebRequest value)   {
        webRequest.set(value);
    }
    public static WebRequest getWebRequest() {
        return webRequest.get();
    }
}
class CustomFilter {
    doFilter(HttpServletRequest request, HttpServletResponse response) {
        WebRequest webRequest = new WebRequest(request, response);
        WebRequestUtils.setWebRequest(webRequest);
    }
}
class Bean {
    void someMethod() {
        WebRequest webRequest = WebRequestUtils.getWebRequest();
    }
}

相关内容

  • 没有找到相关文章

最新更新