storefacade.java

mywork是rcp开发的很好的例子

package net.sf.pim.mail;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import javax.mail.Authenticator;
import javax.mail.Folder;
import javax.mail.Message;
import javax.mail.MessagingException;
import javax.mail.Session;
import javax.mail.Store;
import javax.mail.URLName;

import jp.gr.java_conf.roadster.net.pop.POP3Store;
import net.sf.component.config.ConfigHelper;

/**
 * 
 * @author levin
 * 在POP3Store之上，封装一层，以支持多个POP3Store，各个store用帐号标识
 * 每个store有三个属性，帐号、pop3、smtp
 */
public class StoreFacade {
	private List<StoreInfo> infos;
	private List<Store> stores;
	
	//infos和stores的双向map
	private Map link;
	
	public StoreFacade(String[] addressConfig,String[] pop3Config,String[] smtpConfig){
		if(addressConfig.length != pop3Config.length || addressConfig.length != smtpConfig.length)
			System.out.println("MultiStore初始化失败,邮箱配置不匹配!");
		infos=new ArrayList<StoreInfo>(addressConfig.length);
		stores=new ArrayList<Store>(addressConfig.length);
		link=new HashMap(addressConfig.length*2);
		//设置用户自定义的配置
		Map<String,String> map=ConfigHelper.getMapProperty("mail.popper");
		for(String key:map.keySet()){
			System.setProperty(POP3Store.BASE_PROPERTY+key, map.get(key));
		}
		
		for(int i=0;i<addressConfig.length;i++){
			StoreInfo storeInfo = new StoreInfo(addressConfig[i].trim(),pop3Config[i].trim(),smtpConfig[i].trim());
			infos.add(storeInfo);
			//初始化各pop3store
			try {
				//设置邮箱存储位置
				String conn= storeInfo.pop3.indexOf('?') == -1 ? "/?":"&";
				String dataPath = ConfigHelper.getDataHome()+ "/data/mailbox/"+storeInfo.simpleAccount+"/";
				storeInfo.pop3 += (conn + "localstore=" + dataPath);
				//用一个空的authentication，解决service的classloader问题
				Session session = Session.getInstance(System.getProperties(), new Authenticator() {});
//				session.setDebug(true);
				Store store = session.getStore(new URLName(storeInfo.pop3));
				store.connect();
				store.getFolder("OUTBOX").create(Folder.HOLDS_MESSAGES);
				store.getFolder("TRASHBOX").create(Folder.HOLDS_MESSAGES);
				store.getFolder("ARCHIEBOX").create(Folder.HOLDS_MESSAGES);
				stores.add(store);
				link.put(storeInfo, store);
				link.put(store, storeInfo);
			} catch (Exception e) {
				e.printStackTrace();
			}
		}
	}
	
	public void close() throws MessagingException{
		for(Store store:stores){
			store.close();
		}
	}

	public Folder getFolder(String name) throws MessagingException {
		List<Folder> list=new ArrayList<Folder>(stores.size());
		for(Store store:stores){
			list.add(store.getFolder(name));
		}
		return new MultiFolder(null,name,list);
	}

	//自定义的一些方法
	public List<Store> getStores() {
		return stores;
	}
	//取帐号下指定邮箱
	public Folder getFolder(String name,String account) throws MessagingException {
		int index = -1;
		for(int i=0;i<infos.size();i++){
			if(infos.get(i).account.equals(account)){
				index =i;
				break;
			}
		}
		if(index == -1)
			return null;
		Store store=stores.get(index);
		return store.getFolder(name);
	}
	//从邮件取帐号
	public String getMailAccount(Message message){
		Store store=message.getFolder().getStore();
		StoreInfo info=(StoreInfo) link.get(store);
		if(info != null)
			return info.account;
		else
			return "";
	}	
	//从邮件取帐号
	public String getSimpleMailAccount(Message message){
		Store store=message.getFolder().getStore();
		StoreInfo info=(StoreInfo) link.get(store);
		if(info != null)
			return info.simpleAccount;
		else
			return "";
	}
	//取发件人列表
	public String[] getFromAccount(){
		String[] s=new String[infos.size()];
		int i=0;
		for(StoreInfo info:infos){
			s[i] = info.account ;
			i++;
		}
		return s;
	}
	//取发件服务器
	public String getSMTP(String account){
		for(StoreInfo info:infos){
			if(info.account.equals(account))
				return info.smtp;
		}
		return "";
	}
	//收取邮件
	public synchronized void checkMail(){
		for(Store store:stores){
			((POP3Store)store).checkMail();
		}
	}
}

//每个store有三个属性，帐号、pop3、smtp
class StoreInfo{
	public String account;
	public String simpleAccount;
	public String pop3;
	public String smtp;
	public StoreInfo(String address, String pop3, String smtp) {
		super();
		this.account = address;
		this.pop3 = pop3;
		this.smtp = smtp;
		this.simpleAccount = MailUtil.spliteAddress(address)[0][1];
	}
}