出于此 question 中提到的原因，我正在生成随机标记它们被放置在 java.util.List 中，而这个 List 保存在 session 范围内。

经过一些 Google 搜索后，我决定每小时删除 session 中此 List 包含的所有元素( token )。

我可以考虑使用 Quartz API 但这样做似乎无法操纵用户的 session 。我在 Spring 中使用 Quartz API(1.8.6、2.x 与我正在使用的 Spring 3.2 不兼容)进行的尝试如下所示。

package quartz;

import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.springframework.scheduling.quartz.QuartzJobBean;

public final class RemoveTokens extends QuartzJobBean
{    
    @Override
    protected void executeInternal(JobExecutionContext context) throws JobExecutionException
    {
        System.out.println("QuartzJobBean executed.");
    }
}

并且在 application-context.xml 文件中配置如下。

<bean name="removeTokens" class="org.springframework.scheduling.quartz.JobDetailBean">
    <property name="jobClass" value="quartz.RemoveTokens" />
    <property name="jobDataAsMap">
        <map>
            <entry key="timeout" value="5" />
        </map>
    </property>
</bean>

<bean id="simpleTrigger" class="org.springframework.scheduling.quartz.SimpleTriggerFactoryBean">
      <property name="jobDetail" ref="removeTokens"/>
      <property name="startDelay" value="10000"/>
      <property name="repeatInterval" value="3600000"/>
</bean>

<bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
  <property name="triggers">
      <list>
          <ref bean="simpleTrigger" />
      </list>
  </property>
</bean>

RemoveTokens 类中的覆盖方法每小时执行一次，初始间隔为 10 秒，如 XML 中配置的那样，但无法执行某些类的某些方法来删除可用的 token 存储在用户 session 中的 List。可能吗？

以定义的时间间隔(每小时)删除存储在 session 范围内的此 List 的公平方法是什么？如果使用这个 Quartz API 可以实现，那就更好了。

编辑:

根据下面的回答，我尝试了以下方法，但不幸的是，它没有什么不同。

在application-context.xml文件中，

<task:annotation-driven executor="taskExecutor" scheduler="taskScheduler"/>
<task:executor id="taskExecutor" pool-size="5"/>
<task:scheduler id="taskScheduler" pool-size="10"/>

这需要以下额外的命名空间，

xmlns:task="http://www.springframework.org/schema/task"
xsi:schemaLocation="http://www.springframework.org/schema/task
                    http://www.springframework.org/schema/task/spring-task-3.2.xsd"

以下 bean 已注册为 session 范围的 bean。

package token;

import java.util.ArrayList;
import java.util.List;
import java.util.Random;
import org.apache.commons.lang.StringUtils;
import org.springframework.context.annotation.Scope;
import org.springframework.stereotype.Service;

@Service
//@Scope("session")
public final class SessionToken implements SessionTokenService
{
    private List<String> tokens;

    private static String nextToken()
    {
        long seed = System.currentTimeMillis(); 
        Random r = new Random();
        r.setSeed(seed);
        return Long.toString(seed) + Long.toString(Math.abs(r.nextLong()));
    }

    @Override
    public boolean isTokenValid(String token)
    {        
        return tokens==null||tokens.isEmpty()?false:tokens.contains(token);
    }

    @Override
    public String getLatestToken()
    {
        if(tokens==null)
        {
            tokens=new ArrayList<String>(0);
            tokens.add(nextToken());            
        }
        else
        {
            tokens.add(nextToken());
        }

        return tokens==null||tokens.isEmpty()?"":tokens.get(tokens.size()-1);
    }

    @Override
    public boolean unsetToken(String token)
    {                
        return !StringUtils.isNotBlank(token)||tokens==null||tokens.isEmpty()?false:tokens.remove(token);
    }

    @Override
    public void unsetAllTokens()
    {
        if(tokens!=null&&!tokens.isEmpty())
        {
            tokens.clear();
        }
    }
}

及其实现的接口(interface)，

package token;

import java.io.Serializable;

public interface SessionTokenService extends Serializable
{
    public boolean isTokenValid(String token);
    public String getLatestToken();
    public boolean unsetToken(String token);
    public void unsetAllTokens();
}

并且这个 bean 在 application-context.xml 文件中配置如下。

<bean id="sessionTokenCleanerService" class="token.SessionToken" scope="session">
    <aop:scoped-proxy proxy-target-class="false"/>
</bean>

现在，我在下面的类中注入(inject)这项服务。

package token;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service;

@Service
public final class PreventDuplicateSubmission
{    
    @Autowired
    private final SessionTokenService sessionTokenService=null;

    @Scheduled(fixedDelay=3600000)
    public void clearTokens()
    {
        System.out.println("Scheduled method called.");
        sessionTokenService.unsetAllTokens();            
    }
}

并且在application-context.xml文件中，

<bean id="preventDuplicateSubmissionService" class="token.PreventDuplicateSubmission"/>

以上两个 bean 都用 @Service 注释，它们应该是 dispatacher-servelt.xml< 中的="">context:component-scan 的一部分 文件(或任何名称)。

在前面的代码片段中使用 @Scheduled 注释的方法以给定的速率定期调用，但它会导致抛出以下明显的异常。

org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'scopedTarget.sessionTokenCleanerService': Scope 'session' is not active for the current thread; consider defining a scoped proxy for this bean if you intend to refer to it from a singleton; nested exception is java.lang.IllegalStateException: No thread-bound request found: Are you referring to request attributes outside of an actual web request, or processing a request outside of the originally receiving thread? If you are actually operating within a web request and still receive this message, your code is probably running outside of DispatcherServlet/DispatcherPortlet: In this case, use RequestContextListener or RequestContextFilter to expose the current request.
    at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:343)
    at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:194)
    at org.springframework.aop.target.SimpleBeanTargetSource.getTarget(SimpleBeanTargetSource.java:33)
    at org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java:184)
    at $Proxy79.unsetAllTokens(Unknown Source)
    at token.PreventDuplicateSubmission.clearTokens(PreventDuplicateSubmission.java:102)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:601)
    at org.springframework.scheduling.support.ScheduledMethodRunnable.run(ScheduledMethodRunnable.java:64)
    at org.springframework.scheduling.support.DelegatingErrorHandlingRunnable.run(DelegatingErrorHandlingRunnable.java:53)
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
    at java.util.concurrent.FutureTask$Sync.innerRunAndReset(FutureTask.java:351)
    at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:178)
    at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:178)
    at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603)
    at java.lang.Thread.run(Thread.java:722)
Caused by: java.lang.IllegalStateException: No thread-bound request found: Are you referring to request attributes outside of an actual web request, or processing a request outside of the originally receiving thread? If you are actually operating within a web request and still receive this message, your code is probably running outside of DispatcherServlet/DispatcherPortlet: In this case, use RequestContextListener or RequestContextFilter to expose the current request.
    at org.springframework.web.context.request.RequestContextHolder.currentRequestAttributes(RequestContextHolder.java:131)
    at org.springframework.web.context.request.SessionScope.get(SessionScope.java:90)
    at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:329)
    ... 19 more

要清除存储在用户 session 中的数据，应该在定义的时间间隔内定期调用执行此任务的方法从每个用户的 session ，但这次尝试并非如此。方法是什么？问题可能只是:如何从每个用户的 session 中触发一个固定的时间间隔？ Spring 或 Servlet API 是否支持实现此目的？

最佳答案

评论

祝贺使用 token 来防止重新提交(核心 J2EE 模式一书中的“Introduce Synchronizing Token”重构)。 :^)

Quartz 对于复杂或精确的调度很有值(value)。但是您的要求不需要 Quartz。可能对学习 CDI、java.util.Timer、ScheduledExecutor 和/或 EJB 计时器更有用。

如您所述，如果使用调度程序，最好让所有用户共享一个单独的调度程序，而不是让每个用户 session 都有一个调度程序和线程实例。

如果您存储对 HttpSession 的引用或将其作为参数传递，请小心。存储引用可防止在 session 完成时进行垃圾收集 - 导致(大？)内存泄漏。尝试使用 HttpSessionListener 和其他技巧来清理引用，可能行不通并且很困惑。将 HttpSession 作为参数传递给方法会使它们人为地依赖于 Servlet 容器并且难以进行单元测试，因为您必须模拟复杂的 HttpSession 对象。将所有 session 数据包装在单个对象 UserSessionState 中会更清晰 - 在您的 session 和对象实例变量中存储对 this 的引用。这也称为上下文对象模式——即将所有作用域数据存储在一个/几个 POJO 上下文对象中，独立于 HTTP 协议(protocol)类。

回答

针对您的问题，我建议两种替代解决方案:

1. 使用java.util.Timer 单例实例

   您可以将 java.util.Timer(在 Java SE 1.3 中引入)替换为 ScheduledExecutor(在 Java SE 5 中引入)以获得几乎相同的解决方案。

   这在 JVM 中可用。它不需要 jar 设置和配置。 您调用 timerTask.schedule，传入一个 TimerTask 实例。当计划到期时，调用 timerTask.run。您可以通过 timerTask.cancel 和 timerTask.purge 删除计划任务，从而释放已用内存。

   您编写 TimerTask 代码，包括它的构造函数，然后创建一个新实例并将其传递给 schedule 方法，这意味着您可以在 TimerTask<>;您可以保留对它的引用并在以后随时调用 setter 方法。

   我建议您创建两个全局单例:一个Timer 实例和一个TimerTask 实例。在您的自定义 TimerTask 实例中，保留所有用户 session 的列表(以 POJO 形式如 UserSessionState 或 Spring/CDI bean，而不是 HttpSession).向此类添加两个方法:addSessionObject 和removeSessionObject，参数为UserSessionState 或类似的。在TimerTask.run方法中，遍历UserSessionState的集合，清除数据。

   创建一个自定义的 HttpSessionListener - 从 sessionCreated 中，将一个新的 UserSessionState 实例放入 session 中并调用 TimerTask.addUserSession；从 sessionDestroyed 调用 TimerTask.removeUserSession。

   调用全局范围的单例 timer.schedule 来安排 TimerTask 实例以清除 session 范围引用的内容。

2. 使用大小上限的 token 列表(无清理)

   不要根据耗时清理 token 。而是限制列表大小(例如 25 个 token )并存储最近生成的 token 。

   这可能是最简单的解决方案。当你向列表中添加一个元素时，检查你是否超过了最大大小，如果是则环绕并从列表中最早的索引插入:

   if (++putIndex > maxSize) {
       putIndex = 0;
   }
   list.put(putIndex, newElement);
   

   这里不需要调度器，也不需要形成和维护一组所有用户 session 。

关于java - 如何每隔一小时定期删除 session 数据？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/16124813/