我们知道,在前台为了提高用户体验度,在很多情况下都会去用ajax发异步处理一些请求,比如用户登录,注册等等.最近在做的项目中,在后台也老用到异步处理一些数据,比如当注册用户过多,一般我们的数据连接池里面就的数据连接是固定,当用户需要的连接数大于我们数据连接池所支持的数据连接数时,就会出现阻塞这种情况,用户就会感觉很慢,我们可以先返回一个消息给用户说他注册成功,然后我们异步处理,将用户的注册信息插入到数据库中.这样给用户的体验效果会好一点(这只是举个例子,当然在实际操作中我们这样做的情况很少,因为的话当返回给用户提示信息的时候,用户去登录却登录不上.)，注册信息过多。。。
1.我们异步处理后台信息有两个方法 当并发量不是很高的时候 我们可以在后台起一个定时任务（ScheduledTaskExecutorFactory.getScheduledTaskExecutor().scheduleWithFixedDelay）
2.当我们并发量高的时候 我们就要用到队列了
首先 我们先创建一个队列
private static final Logger log = LoggerFactory.getLogger(PushMessageBean.class);
private static final int PUSH_MESSAGE_QUEUE_SIZE = 10;
private BlockingQueue<PushMessage> messagequeue = new ArrayBlockingQueue<PushMessage>(PUSH_MESSAGE_QUEUE_SIZE);
然后 我们把数据加入队列
/**
* 外部放入
*
* @param syncDetail
*/
public void putQueue(PushMessage pushMessage) {
while (!messagequeue.offer(pushMessage)) {
log.debug("PushMessage的queue满了，请求插入");
ScheduledTaskExecutorFactory.getScheduledTaskExecutor().execute(new QueueInsertTask(messagequeue));
}
}
最后我们对队列中的数据进行操作
当然 为了能够达到最好的同步效果 我们最好也起一个定时任务
public void initialize() {
// 定时的去清理queue中的数据，入库
ScheduledTaskExecutorFactory.getScheduledTaskExecutor().scheduleWithFixedDelay(
new QueueInsertTask(messagequeue), 10, 10, TimeUnit.SECONDS);
}
原文：http://my.oschina.net/u/914362/blog/301663