transport.java

java网络编程

import java.io.*;
import java.net.*;
import java.util.*;

/**
*  Transport class
*
*/

public class Transport
{
	public Transport()
	{}
	public Transport( String smtpHost,int smtpPort )
	{ this.smtpHost = smtpHost;
    this.smtpPort = smtpPort;
	}
	/**
	*返回SMTP主机(ie， smtpServer.coolservlets.com).
	*/
	public String getSmtpHost( )
	{ return smtpHost;
	}
	/**
	*  返回SMTP端口号 (usually 25).
	*/
	public int getSmtpPort( )
	{ return smtpPort;
	}
	/**
	* 设置SMTP主机
	*/
	public void setSmtpHost( String smtpHost )
	{ this.smtpHost = smtpHost;
	}
	/**
	* 设置SMTP 端口号
	*/
	public void setSmtpPort( int smtpPort )
	{ this.smtpPort = smtpPort;
	}
	
	/**
	*  发送信息，信息的发送情况如下：
	*/
	public void send( Message msg ) throws TransportException
	{
		try
		{
			Socket s = new Socket( this.smtpHost,this.smtpPort );
			PrintWriter out = new PrintWriter( s.getOutputStream() );
			// InputStreamReader in = new InputStreamReaders( s.getInputStream() );
			// 更加完整的错误检测
			
			out.println( "HELO " + this.smtpHost );
			
			// 来自：
			Address[] from = msg.getFrom();
			if( from == null || from.length == 0 )
				throw new TransportException( "No \"FROM\" specified." );
			/* 添加新的"else" 情况: 1.1 */
			/* 确保FROM被包括了 */
			else
			{ if( from[0].getAddress() != null && from[0].getAddress().length() > 0 )
			out.println( "MAIL FROM: <" + from[0].getAddress() + ">" );
			else
				throw new TransportException( "No \"FROM\" specified." );
			}
			//获取发送的地址信息
			Address[] to = msg.getRecipients( RecipientType.TO );
			if( to == null || to.length == 0 )
				throw new TransportException( "No \"TO\" specified." );
			else
				for( int i=0; i<to.length; i++ )
					out.println( "RCPT TO: <"+ to[i].getAddress() +">" );
				
				Address[] cc = msg.getRecipients( RecipientType.CC );
				if( cc != null )
					for( int i=0; i<cc.length; i++ )
						out.println( "RCPT TO: <"+ cc[i].getAddress() +">" );
					//记录地址信息
					Address[] bcc = msg.getRecipients( RecipientType.BCC );
					if( bcc != null )
						for( int i=0; i<bcc.length; i++ )
							out.println( "RCPT TO: <"+ bcc[i].getAddress() +">" );
						// 数据段的开始
						out.println( "DATA" );
						
						//来自于
						if( from != null )
							out.println( "From: "+ ( (from[0].getPersonal() != null) ? from[0].getPersonal()+" " : "" )
							+ "<"+ from[0].getAddress() +">" );
						
						// 到达
						if( to != null && to.length > 0 )
						{
							String line = "To: ";
							for( int i=0; i<to.length; i++ )
							{
								line += ( (to[i].getPersonal()!=null)
									? ( to[i].getPersonal() + " <" + to[i].getAddress() + ">" )
									: ( to[i].getAddress() )
									);
								if( i < to.length - 1 )
									line += "， ";
							}
							out.println( line );
						}
						
						//cc段:
						if( cc != null && cc.length > 0 )
						{
							String line = "CC: ";
							for( int i=0; i<cc.length; i++ )
							{
								line += ( (cc[i].getPersonal()!=null)
									? ( cc[i].getPersonal() + " <" + cc[i].getAddress() + ">" )
									: ( cc[i].getAddress() )
									);
								if( i < cc.length - 1 )
									line += "， ";
							}
							out.println( line );//输出信息
						}
						
						// 主体部分
						if( msg.getSubject() != null )
							out.println( "Subject: "+ msg.getSubject() );
						
						// email 的文本部分
						if( msg.getText() != null )
						{ //out.println( new Date() );
							out.println( msg.getText() );//打印出邮件信息
						}
						
						out.println( "." );
						out.println( "QUIT" );
						out.close();//关闭输出流
						
		}
		catch( IOException ioe )
		{ throw new TransportException( "Error connecting to SMTP port." );//打印错误信息
		}
  }
  
  private String smtpHost;
  private int    smtpPort;
}