jdk1.4 Spring 邮件群发，行列机制

jdk1.4 Spring 邮件群发，队列 机制
Spring 邮件群发，队列 机制

<1>

package com.cofortune.zhengjia.common.utils;

import java.io.InputStream;


import javax.mail.internet.MimeMessage;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.mail.MailException;
import org.springframework.mail.MailSender;
import org.springframework.mail.SimpleMailMessage;
import org.springframework.mail.javamail.JavaMailSender;
import org.springframework.mail.javamail.MimeMessagePreparator;

public class MailSenderPooled implements MailSender, JavaMailSender, Runnable {

protected final Log log = LogFactory.getLog(getClass());

// -------------------------------------------------------------------------

/**
  * 实际发送 邮件的 邮件发送器，可以是MailSender，或JavaMailSender
  */
private MailSender mailSender;

// -------------------------------------------------------------------------

/**
  * 邮件排队点号、发送线程，
  */
private Thread thread;

/**
  * 邮件排队队列
  */
private Queue queue = new Queue();

/**
  * 锁，仅此而已
  *
  * @see #run()
  * @see #add(Object)
  */
private Object mutex = new Object();

// -------------------------------------------------------------------------

/**
  * 构造本类对象，同时启动侦听 邮件的到达。
  *
  * 如果要阻止侦听和发送，应该调用close方法，在Spring的Context中"最好"配置destroy-method="close"，不过这不是必须的。
  *
  */
public MailSenderPooled() {
  thread = new Thread(this);
  thread.setDaemon(true);
  thread.start();
}

// -------------------------------------------------------------------------

/**
  * 邮件发送循环，它被作为thread runnable的run实现。
  *
  * @see #add(Object)
  *
  */
public void run() {
  while (!isClose()) {
   if (!isEmpty()) {
    Object object = poll();
    try {
     // 执行实际发送
     doSend(object);
    } catch (Exception ex) {
     log.error(ex);
     ex.printStackTrace();
    }
   }
   // 等~直到add方法的通知!
   synchronized (mutex) {
    try {
     mutex.wait();
    } catch (InterruptedException e) {
    }
   }
  }
}

// -------------------------------------------------------------------------

public MailSender getMailSender() {
  return mailSender;
}

/**
  * 设置实际的 邮件发送器
  *
  * @param mailSender
  */
public void setMailSender(MailSender mailSender) {
  this.mailSender = mailSender;
}

// -------------------------------------------------------------------------

/**
  * 关闭PooledMailSender!
  *
  * 关闭的PooledMailSender不可再接收和发送 邮件
  */
public void close() {
  queue.clear();
  queue = null;
}

/**
  * 已经关闭？
  *
  * 关闭的PooledMailSender不可再接收和发送 邮件
  *
  * @return
  */
public boolean isClose() {
  return queue == null;
}

// -------------------------------------------------------------------------
// 邮件排队机操作方法代理

protected boolean isEmpty() {
  return queue != null && queue.isEmpty();
}

/**
  * 邮件加入排队机
  *
  * @param obj
  * @see #run()
  */
protected void add(Object obj) {
 
  queue.add(obj); 
  synchronized (mutex) {
   mutex.notify();
  }
}

protected Object poll() {
 
  return queue.poll();
}


// -------------------------------------------------------------------------
// MailSender接口实现-将 邮件放入排队机

public void send(SimpleMailMessage simpleMessage) throws MailException {
  add(simpleMessage);
}

public void send(SimpleMailMessage[] simpleMessages) throws MailException {

  SimpleMailMessage[] messages = simpleMessages;
  for (int i = 0; i < messages.length; i++) {
   SimpleMailMessage message = messages[i];
   add(message);
  }
}

// -------------------------------------------------------------------------
// // // JavaMailSender接口实现-将 邮件放入排队机

public void send(MimeMessage mimeMessage) throws MailException {
  add(mimeMessage);
}

public void send(MimeMessage[] mimeMessages) throws MailException {

  MimeMessage[] messages = mimeMessages;
  for (int i = 0; i < messages.length; i++) {
   MimeMessage message = messages[i];
   add(message);
  }

}

public void send(MimeMessagePreparator mimeMessagePreparator)
   throws MailException {
  add(mimeMessagePreparator);
}

public void send(MimeMessagePreparator[] mimeMessagePreparators)
   throws MailException {

  MimeMessagePreparator[] preparators = mimeMessagePreparators;
  for (int i = 0; i < preparators.length; i++) {
   MimeMessagePreparator preparator = preparators[i];
   add(preparator);
  }
}

public MimeMessage createMimeMessage() {
  return ((JavaMailSender) mailSender).createMimeMessage();
}

public MimeMessage createMimeMessage(InputStream contentStream)
   throws MailException {
  return ((JavaMailSender) mailSender).createMimeMessage(contentStream);
}

// -------------------------------------------------------------------------
// 实际发送代理方法

public void doSend(Object object) {
  if (object instanceof SimpleMailMessage) {
   doSend((SimpleMailMessage) object);
  } else if (object instanceof MimeMessage) {
   doSend((MimeMessage) object);
  } else if (object instanceof MimeMessagePreparator) {
   doSend((MimeMessagePreparator) object);
  }
}

public void doSend(SimpleMailMessage simpleMessage) throws MailException {
  mailSender.send(simpleMessage);
}

public void doSend(MimeMessage mimeMessage) throws MailException {
  ((JavaMailSender) mailSender).send(mimeMessage);
}

public void doSend(MimeMessagePreparator mimeMessagePreparator)
   throws MailException {
  ((JavaMailSender) mailSender).send(mimeMessagePreparator);
}

}


<2>

package com.cofortune.zhengjia.common.utils;

import java.util.LinkedList;
import java.util.List;

public class Queue {


private static Queue queue = new Queue();

private List list;

public static final int SIZE = 10;

public Queue() {
  list = new LinkedList();
}

public static Queue getInstance() {
  return queue;

}

public boolean isFull() {
  return list.size() == SIZE;
}

public void add(Object obj) {
  list.add(obj);
}

public Object poll() {
  return (Object) list.remove(0);
}

public boolean isEmpty() {
  return list.isEmpty();
}

public void clear(){
  list.clear();
}

}




本文来自CSDN博客，转载请标明出处：http://blog.csdn.net/xymyeah/archive/2007/08/29/1763382.aspx