java发送邮件及邮件附件代码实例1

第页packagecom.zlz3907.mail;importjava.io.BufferedReader;importjava.io.File;importjava.io.FileInputStream;importjava.io.FileNotFoundException;importjava.io.IOException;importjava.io.InputStream;importjava.io.InputStreamReader;importjava.io.PrintWriter;importjava.io.UnsupportedEncodingException;importjava.Socket;importjava.nio.charset.Charset;importjava.text.SimpleDateFormat;importjava.util.ArrayList;importjava.util.Date;importjava.util.HashMap;importjava.util.List;importjava.util.Map;importsun.misc.BASE64Encoder;*该类使用Socket连接到邮件服务器，*并实现了向指定邮箱发送邮件及附件的功能。*@authorZhongLizhipublicclassMail{*换行符privatestaticfinalStringLINE_END="\r\n";*值为“true”输出高度信息（包括服务器响应信息），值为“*false”则不输出调试信息。privatebooleanisDebug=true;*值为“true”则在发送邮件{@linkMail#send()}*过程中会读取服务器端返回的消息，*并在邮件发送完毕后将这些消息返回给用户。privatebooleanisAllowReadSocketInfo=true;*邮件服务器地址privateStringhost;*发件人邮箱地址privateStringfrom;*收件人邮箱地址privateList<String>to;*抄送地址privateList<String>cc;*暗送地址privateList<String>bcc;*邮件主题privateStringsubject;*用户名privateStringuser;*密码privateStringpassword;*MIME邮件类型privateStringcontentType;*用来绑定多个邮件单元{@link#partSet}*的分隔标识，我们可以将邮件的正文及每一个附件都看作是一个邮件单元privateStringboundary;*邮件单元分隔标识符，该属性将用来在邮件中作为分割各个邮件单元的标识privateStringboundaryNextPart;*传输邮件所采用的编码privateStringcontentTransferEncoding;*设置邮件正文所用的字符集privateStringcharset;*内容描述privateStringcontentDisposition;*邮件正文privateStringcontent;*发送邮件日期的显示格式privateStringsimpleDatePattern;*附件的默认MIME类型privateStringdefaultAttachmentContentType;*邮件单元的集合，用来存放正文单元和所有的附件单元。privateList<MailPart>partSet;*不同类型文件对应的{@linkMIME}类型映射。在添加附件*{@link#addAttachment(String)}*时，程序会在这个映射中查找对应文件的{@linkMIME}*类型，如果没有，则使用*{@link#defaultAttachmentContentType}*所定义的类型。privatestaticMap<String,String>contentTypeMap;static{//MIMEMediaTypescontentTypeMap=newHashMap<String,String>();contentTypeMap.put("xls","application/vnd.ms-excel");contentTypeMap.put("xlsx","application/vnd.ms-excel");contentTypeMap.put("xlsm","application/vnd.ms-excel");contentTypeMap.put("xlsb","application/vnd.ms-excel");contentTypeMap.put("doc","application/msword");contentTypeMap.put("dot","application/msword");contentTypeMap.put("docx","application/msword");contentTypeMap.put("docm","application/msword");contentTypeMap.put("dotm","application/msword");*该类用来实例化一个正文单元或附件单元对象，他继承了*{@linkMail}*，在这里制作这个子类主要是为了区别邮件单元对象和邮件服务对象*，使程序易读一些。这些邮件单元全部会放到partSet*中，在发送邮件{@link#send()}时,程序会调用*{@link#getAllParts()}*方法将所有的单元合并成一个符合MIME格式的字符串。*@authorZhongLizhiprivateclassMailPartextendsMail{publicMailPart(){*默认构造函数publicMail(){defaultAttachmentContentType="application/octet-stream";simpleDatePattern="yyyy-MM-ddHH:mm:ss";boundary="--=_NextPart_zlz_3907_"+System.currentTimeMillis();boundaryNextPart="--"+boundary;contentTransferEncoding="base64";contentType="multipart/alternative";charset=Charset.defaultCharset().name();partSet=newArrayList<MailPart>();to=newArrayList<String>();cc=newArrayList<String>();bcc=newArrayList<String>();*根据指定的完整文件名在*{@link#contentTypeMap}*中查找其相应的MIME类型，如果没找到，则返回*{@link#defaultAttachmentContentType}*所指定的默认类型。*@paramfileName*文件名*@return返回文件对应的MIME类型。privateStringgetPartContentType(StringfileName){Stringret=null;if(null!=fileName){intflag=fileName.lastIndexOf(".");if(0<=flag&&flag<fileName.length()-1){fileName=fileName.substring(flag+1);ret=contentTypeMap.get(fileName);if(null==ret){ret=defaultAttachmentContentType;returnret;*将给定字符串转换为base64编码的字符串*@paramstr*需要转码的字符串*@paramcharset*原字符串的编码格式*@returnbase64编码格式的字符privateStringtoBase64(Stringstr,Stringcharset){if(null!=str){try{returntoBase64(str.getBytes(charset));}catch(UnsupportedEncodingExceptione){e.printStackTrace();return"";*将指定的字节数组转换为base64格式的字符串*@parambs*需要转码的字节数组*@returnbase64编码格式的字符privateStringtoBase64(byte[]bs){returnnewBASE64Encoder().encode(bs);*将给定字符串转换为base64编码的字符串*@paramstr*需要转码的字符串*@returnbase64编码格式的字符privateStringtoBase64(Stringstr){returntoBase64(str,Charset.defaultCharset().name());*将所有的邮件单元按照标准的MIME格式要求合并。*@return返回一个所有单元合并后的字符串。privateStringgetAllParts(){intpartCount=partSet.size();StringBuildersbd=newStringBuilder(LINE_END);for(inti=partCount-1;i>=0;i--){Mailattachment=partSet.get(i);StringattachmentContent=attachment.getContent();if(null!=attachmentContent&&0<attachmentContent.length()){sbd.append(getBoundaryNextPart()).append(LINE_END);sbd.append("Content-Type:");sbd.append(attachment.getContentType());sbd.append(LINE_END);sbd.append("Content-Transfer-Encoding:");sbd.append(attachment.getContentTransferEncoding());sbd.append(LINE_END);if(i!=partCount-1){sbd.append("Content-Disposition:");sbd.append(attachment.getContentDisposition());sbd.append(LINE_END);sbd.append(LINE_END);sbd.append(attachment.getContent());sbd.append(LINE_END);sbd.append(LINE_END);sbd.append(LINE_END);//sbd.append(boundaryNextPart).//append(LINE_END);partSet.clear();returnsbd.toString();*添加邮件正文单元privatevoidaddContent(){if(null!=content){MailPartpart=newMailPart();part.setContent(toBase64(content));part.setContentType("text/plain;charset=\""+charset+"\"");partSet.add(part);privateStringlistToMailString(List<String>mailAddressList){StringBuildersbd=newStringBuilder();if(null!=mailAddressList){intlistSize=mailAddressList.size();for(inti=0;i<listSize;i++){if(0!=i){sbd.append(";");sbd.append("<").append(mailAddressList.get(i)).append(">");returnsbd.toString();privateList<String>getrecipient(){List<String>list=newArrayList<String>();list.addAll(to);list.addAll(cc);list.addAll(bcc);returnlist;*添加一个附件单元*@paramfilePath*文件路径publicvoidaddAttachment(StringfilePath){addAttachment(filePath,null);publicvoidaddTo(StringmailAddress){this.to.add(mailAddress);publicvoidaddCc(StringmailAddress){this.add(mailAddress);publicvoidaddBcc(StringmailAddress){this.bcc.add(mailAddress);*添加一个附件单元*@paramfilePath*文件路径*@paramcharset*文件编码格式publicvoidaddAttachment(StringfilePath,Stringcharset){if(null!=filePath&&filePath.length()>0){Filefile=newFile(filePath);try{addAttachment(file.getName(),newFileInputStream(file),charset);}catch(FileNotFoundExceptione){System.out.println("错误："+e.getMessage());System.exit(1);*添加一个附件单元*@paramfileName*文件名*@paramattachmentStream*文件流*@paramcharset*文件编码格式publicvoidaddAttachment(StringfileName,InputStreamattachmentStream,Stringcharset){try{byte[]bs=null;if(null!=attachmentStream){intbuffSize=1024;byte[]buff=newbyte[buffSize];byte[]temp;bs=newbyte[0];intreadTotal=0;while(-1!=(readTotal=attachmentStream.read(buff))){temp=newbyte[bs.length];System.arraycopy(bs,0,temp,0,bs.length);bs=newbyte[temp.length+readTotal];System.arraycopy(temp,0,bs,0,temp.length);System.arraycopy(buff,0,bs,temp.length,readTotal);if(null!=bs){MailPartattachmentPart=newMailPart();charset=null!=charset?charset:Charset.defaultCharset().name();StringcontentType=getPartContentType(fileName)+";name=\"=?"+charset+"?B?"+toBase64(fileName)attachmentPart.setCharset(charset);attachmentPart.setContentType(contentType);attachmentPart.setContentDisposition("attachment;filename=\"=?"+charset+"?B?"+toBase64(fileName)+"?=\"");attachmentPart.setContent(toBase64(bs));partSet.add(attachmentPart);}catch(Exceptione){e.printStackTrace();}finally{if(null!=attachmentStream){try{attachmentStream.close();attachmentStream=null;}catch(IOExceptione){e.printStackTrace();Runtime.getRuntime().gc();Runtime.getRuntime().runFinalization();*发送邮件*@return邮件服务器反回的信息publicStringsend(){//对象申明//当邮件发送完毕后，以下三个对象（Socket、//PrintWriter,//BufferedReader）需要关闭。Socketsocket=null;PrintWriterpw=null;BufferedReaderbr=null;try{socket=newSocket(host,25);pw=newPrintWriter(socket.getOutputStream());br=newBufferedReader(newInputStreamReader(socket.getInputStream()));StringBuilderinfoBuilder=newStringBuilder("\nServerinfo:\n\n");//及服务器建立连接pw.write("HELO".concat(host).concat(LINE_END));//连接到邮件服务if(!readResponse(pw,br,infoBuilder,"220"))returninfoBuilder.toString();pw.write("AUTHLOGIN".concat(LINE_END));//登录if(!readResponse(pw,br,infoBuilder,"250"))returninfoBuilder.toString();pw.write(toBase64(user).concat(LINE_END));//输入用户名if(!readResponse(pw,br,infoBuilder,"334"))returninfoBuilder.toString();pw.write(toBase64(password).concat(LINE_END));//输入密码if(!readResponse(pw,br,infoBuilder,"334"))returninfoBuilder.toString();pw.write("MAILFROM:<"+from+">"+LINE_END);//发件人邮箱地址if(!readResponse(pw,br,infoBuilder,"235"))returninfoBuilder.toString();List<String>recipientList=getrecipient();//收件邮箱地址for(inti=0;i<recipientList.size();i++){pw.write("RCPTTO:<"+recipientList.get(i)+">"+LINE_END);if(!readResponse(pw,br,infoBuilder,"250"))returninfoBuilder.toString();//System.out.println(//getAllSendAddress());pw.write("DATA"+LINE_END);//开始输入邮件if(!readResponse(pw,br,infoBuilder,"250"))returninfoBuilder.toString();flush(pw);//设置邮件头信息StringBuffersbf=newStringBuffer("From:<"+from+">"+LINE_END);//发件人sbf.append("To:"+listToMailString(to)+LINE_END);//收件人sbf.append("Cc:"+listToMailString(cc)+LINE_END);//收件人sbf.append("Bcc:"+listToMailString(bcc)+LINE_END);//收件人sbf.append("Subject:"+subject+LINE_END);//邮件主题SimpleDateFormatsdf=newSimpleDateFormat(simpleDatePattern);sbf.append("Date:").append(sdf.format(newDate()));sbf.append(LINE_END);//发送时间sbf.append("Content-Type:");sbf.append(contentType);sbf.append(";");sbf.append("boundary=\"");sbf.append(boundary).append("\"");//邮件类型设置sbf.append(LINE_END);sbf.append("Thisisamulti-partmessageinMIMEformat.");sbf.append(LINE_END);//添加邮件正文单元addContent();//合并所有单元，正文和附件。sbf.append(getAllParts());//发送sbf.append(LINE_END).append(".").append(LINE_END);pw.write(sbf.toString());readResponse(pw,br,infoBuilder,"354");flush(pw);//QUIT退出pw.write("QUIT"+LINE_END);if(!readResponse(pw,br,infoBuilder,"250"))returninfoBuilder.toString();flush(pw);returninfoBuilder.toString();}catch(Exceptione){e.printStackTrace();return"Exception:>"+e.getMessage();}finally{//释放资源try{if(null!=socket)socket.close();if(null!=pw)pw.close();if(null!=br)br.close();}catch(IOExceptione){e.printStackTrace();//this.to.clear();//this.clear();//this.bcc.clear();this.partSet.clear();*将SMTP命令发送到邮件服务器*@parampw*邮件服务器输入流privatevoidflush(PrintWriterpw){if(!isAllowReadSocketInfo){pw.flush();*读取邮件服务器的响应信息*@parampw*邮件服务器输入流*@parambr*邮件服务器输出流*@paraminfoBuilder*用来存放服务器响应信息的字符串缓冲*@parammsgCode*@return*@throwsIOExceptionprivatebooleanreadResponse(PrintWriterpw,BufferedReaderbr,StringBuilderinfoBuilder,StringmsgCode)throwsIOException{if(isAllowReadSocketInfo){pw.flush();Stringmessage=br.readLine();infoBuilder.append("SERVER:/>");infoBuilder.append(message).append(LINE_END);if(null==message||0>message.indexOf(msgCode)){System.out.println("ERROR:"+message);pw.write("QUIT".concat(LINE_END));pw.flush();returnfalse;if(isDebug){System.out.println("DEBUG:/>"+msgCode+"/"+message);returntrue;publicStringgetBoundaryNextPart(){returnboundaryNextPart;publicvoidsetBoundaryNextPart(StringboundaryNextPart){this.boundaryNextPart=boundaryNextPart;publicStringgetDefaultAttachmentContentType(){returndefaultAttachmentContentType;publicvoidsetDefaultAttachmentContentType(StringdefaultAttachmentContentType){this.defaultAttachmentContentType=defaultAttachmentContentType;publicStringgetHost(){returnhost;publicvoidsetHost(Stringhost){this.host=host;publicStringgetFrom(){returnfrom;publicvoidsetFrom(Stringfrom){this.from=from;publicList<String>getTo(){returnto;publicvoidsetTo(List<String>to){this.to=to;publicStringgetSubject(){returnsubject;publicvoidsetSubject(Stringsubject){this.subject=subject;publicStringgetUser(){returnuser;publicvoidsetUser(Stringuser){this.user=user;publicStringgetPassword(){returnpassword;publicvoidsetPassword(Stringpassword){this.password=password;publicStringgetContentType(){returncontentType;publicvoidsetContentType(StringcontentType){this.contentType=contentType;publicStringgetBoundary(){returnboundary;publicvoidsetBoundary(Stringboundary){this.boundary=boundary;publicStringgetContentTransferEncoding(){returncontentTransferEncoding;publicvoidsetContentTransferEncoding(StringcontentTransferEncoding){this.contentTransferEncoding=contentTransferEncoding;publicStringgetCharset(){returncharset;publicvoidsetCharset(Stringcharset){this.charset=charset;publicStringgetContentDisposition(){returncontentDisposition;publicvoidsetContentDisposition(StringcontentDisposition){this.contentDisposition=contentDisposition;publicStringgetSimpleDatePattern(){returnsimpleDatePattern;publicvoidsetSimpleDatePattern(StringsimpleDatePattern){this.simpleDatePattern=simpleDatePattern;publicStringgetContent(){returncontent;publicvoidsetContent(Stringcontent){this.content=content;publicbooleanisAllowReadSocketInfo(){returnisAllowReadSocketInfo;publicvoidsetAllowReadSocketInfo(booleanisAllowReadSocketInfo){this.isAllowReadSocketInfo=isAllowReadSocketInfo;*@paramargspublicstaticvoidmain(String[]args){//应用示例：线程化发送邮件newThread(){@Overridepublicvoidrun(){System.out.println("SENDER-"+this.getId()+":/>"+"开始发送邮件...");//创建邮件对象Mailmail=newMail();mail.setHost("smtp.test");//邮件服务器地址mail.setFrom("sender@m");//发件人邮箱mail.addTo("recipient@m");//收件人邮箱mail.addCc("test@m1");mail.addBcc("test@m2");mail.setSubject("CCTestMail!!");//邮件主题mail.setUser("123");//用户名mail.setPassword("123");//密码mail.setContent("这是一个测试，请不要回复！");//邮件正文mail.addAttachment("utf8中.txt");//添加附件//mail.addAttachment(//"e:/test.htm");////添加附件System.out.println(mail.