spring+mybatsi FIFO(先进先出)队列，解决并发问题

业务场景：最近负责公司的“邮件系统”的研发工作，公司其他的业务系统都需要调用“邮件服务接口”，导致该邮件服务接口，并发量比较大。

解决思路：

1、web 初始化时，同时需要初始化系统全局的FIFO队列。

2、java FIFO队列的选择，必须是线程安全队列，我这里使用的是BlockingQueue。

3、邮件发送失败，需要重新添到FIFO队列中。

4、spring 定时任务框架，实时处理FIFO队列中的任务。

核心示例代码:

1、web 初始化 FIFO 队列

package com.settlement.initialization; 
 
import java.util.concurrent.BlockingQueue; 
import java.util.concurrent.LinkedBlockingQueue; 
 
import javax.servlet.ServletContext; 
 
import org.springframework.beans.factory.InitializingBean; 
import org.springframework.web.context.ServletContextAware; 
 
public class InitFIFOListener implements InitializingBean, ServletContextAware{ 
	 
	public BlockingQueue<Object> queue = new  LinkedBlockingQueue<Object>(); 
 
	public void setServletContext(ServletContext context) { 
		// TODO Auto-generated method stub 
		 
	} 
 
	public void afterPropertiesSet() throws Exception { 
		// TODO Auto-generated method stub 
		 
	} 
 
	public BlockingQueue<Object> getQueue() { 
		return queue; 
	} 
 
	public void setQueue(BlockingQueue<Object> queue) { 
		this.queue = queue; 
	} 
	 
	 
	 
	 
 
} 

spring-mybatis.xml 配置文件

   <!--初始化全局(FIFO队列)  --> 
    <bean id="initFIFO" class="com.settlement.initialization.InitFIFOListener"> 
    </bean>

2、邮件服务接口。

package com.settlement.controller; 
 
import java.math.BigDecimal; 
import java.util.Queue; 
import java.util.concurrent.BlockingQueue; 
 
import javax.servlet.http.HttpServletRequest; 
 
import org.springframework.stereotype.Controller; 
import org.springframework.web.bind.annotation.RequestMapping; 
import org.springframework.web.bind.annotation.RequestMethod; 
import org.springframework.web.bind.annotation.ResponseBody; 
 
import com.settlement.commons.base.BaseController; 
import com.settlement.commons.email.SendMailUtil; 
import com.settlement.commons.scan.SpringUtils; 
import com.settlement.initialization.InitFIFOListener; 
import com.settlement.model.AccountWallet; 
import com.taobao.api.internal.util.StringUtils; 
 
/** 
 * 邮箱控制器Controller 
 *  
 * @author zzg 
 * @date 2017-02-10 
 */ 
@Controller 
@RequestMapping(value = "/email") 
public class EmailController extends BaseController { 
	private BlockingQueue<Object> queue = null; 
 
	/** 
	 * 针对业务系统高并发-----采用FIFO队列，进行解决 
	 *  
	 * @return 
	 */ 
	@RequestMapping(value = "/receiveemail.action", method = RequestMethod.POST) 
	@ResponseBody 
	public String receiveEmail(HttpServletRequest request) { 
 
		String result = ""; 
		try { 
			//项目全局FIFO 队列 
			if (queue == null) { 
				InitFIFOListener listener = (InitFIFOListener) SpringUtils 
						.getContext().getBean("initFIFO"); 
				queue = listener.queue; 
			} 
			System.out.println("队列大小："+queue.size()); 
			String receiveMailAccount = request.getParameter("email") == null ? null 
					: request.getParameter("email").trim(); 
			queue.offer(receiveMailAccount); 
 
		} catch (Exception e) { 
			result = e.getMessage(); 
			return result; 
		} 
 
		return "success"; 
	} 
 
	/** 
	 * 处理FIFO队列，需要发送的邮件信息 
	 *  
	 * @return 
	 */ 
	@RequestMapping(value = "/sendemail.action", method = RequestMethod.POST) 
	@ResponseBody 
	public String sendEmail() { 
 
		String result = ""; 
		boolean isRunning = true; 
		try { 
			//项目全局FIFO 队列 
			if (queue == null) { 
				InitFIFOListener listener = (InitFIFOListener) SpringUtils 
						.getContext().getBean("initFIFO"); 
				queue = listener.queue; 
			} 
			while (isRunning) { 
				System.out.println("队列大小："+queue.size()); 
				System.out.println("正从队列获取数据..."); 
				String data = (String) queue.poll(); 
				if (null != data) {					 
					System.out.println("正在消费数据：" + data); 
					SendMailUtil.send_163(data); 
				} else { 
					// 超过2s还没数据，认为所有生产线程都已经退出，自动退出消费线程。 
					isRunning = false; 
				} 
			} 
 
		} catch (Exception e) { 
			result = e.getMessage(); 
			return result; 
		} finally { 
			System.out.println("退出消费者线程！"); 
		} 
 
		return "success"; 
	} 
 
} 

3、高并发测试，邮件服务接口。

package com.settlement.concurrent; 
 
import com.settlement.commons.utils.HttpRequest; 
 
public class EmailConcurrentTest { 
 
	/** 
	 * @param args 
	 */ 
	public static void main(String[] args) { 
		// TODO Auto-generated method stub 
		//模拟调用邮件服务接口30次 
//		for(int i=0;i<30;i++){ 
//			HttpRequest.sendPost("http://localhost:8080/Settlement/email/receiveemail.action", "email=2355540290@qq.com"); 
//		} 
		//模拟定时任务，处理FIFO队列 
		HttpRequest.sendPost("http://localhost:8080/Settlement/email/sendemail.action", ""); 
 
	} 
 
} 

温馨提示： Java 邮件发送参考文章

4、效果截图：

待补充。