开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > Internet/网络编程 > WEB邮件程序 > 查看源码
TestRe.java
资源名称：Softeem-WebMail.rar　[点击查看]
上传用户：liangcc
上传日期：2019-05-24
资源大小：4412k
文件大小：11k
源码类别：

WEB邮件程序

开发平台：

Java

TestRe.java：源码内容
  1. package com.softeem.webmail.action.receivemail;
  3. import java.io.*;
  4. import java.text.*;
  5. import java.util.*;
  6. import javax.mail.*;
  7. import javax.mail.internet.*;
  9. /**
  10.  * @author Administrator
  11.  * 
  12.  */
  13. public class TestRe {
  14. private MimeMessage mimeMessage = null;
  15. private String saveAttachPath = "";// 附件下载后的存放目录
  17. private StringBuffer bodytext = new StringBuffer();
  18. // 存放邮件内容的StringBuffer对象
  19. private String dateformat = "yy-MM-dd　HH:mm";// 默认的日前显示格式
  21. /**
  22.  * 构造函数,初始化一个MimeMessage对象
  23.  */
  24. public TestRe() {
  25. }
  27. public TestRe(MimeMessage mimeMessage) {
  28. this.mimeMessage = mimeMessage;
  29. System.out.println("create　a　PraseMimeMessage　object........");
  30. }
  32. public void setMimeMessage(MimeMessage mimeMessage) {
  33. this.mimeMessage = mimeMessage;
  34. }
  36. /**
  37.  * 
  38.  * 获取发件人的姓名和密码
  39.  * 
  40.  * @return
  41.  */
  42. public String getFrom() throws Exception {
  43. InternetAddress address[] = (InternetAddress[]) mimeMessage.getFrom();
  44. String from = address[0].getAddress();
  45. if (from == null)
  46. from = "";
  47. String personal = address[0].getPersonal();
  48. if (personal == null)
  49. personal = "";
  50. String fromaddr = personal + "<" + from + ">";
  51. return fromaddr;
  52. }
  54. /**
  55.  * 获得邮件的收件人，抄送，和密送的地址和姓名，根据所传递的参数的不同 "to"----收件人 "cc"---抄送人地址 "bcc"---密送人地址
  56.  */
  58. public String getMailAddress(String type) throws Exception {
  59. String mailaddr = "";
  60. String addtype = type.toUpperCase();
  61. InternetAddress[] address = null;
  62. if (addtype.equals("TO") || addtype.equals("CC")
  63. || addtype.equals("BCC"))
  65. {
  66. if (addtype.equals("TO")) {
  67. address = (InternetAddress[]) mimeMessage
  68. .getRecipients(Message.RecipientType.TO);
  69. } else if (addtype.equals("CC")) {
  70. address = (InternetAddress[]) mimeMessage
  71. .getRecipients(Message.RecipientType.CC);
  72. } else {
  73. address = (InternetAddress[]) mimeMessage
  74. .getRecipients(Message.RecipientType.BCC);
  75. }
  76. if (address != null) {
  77. for (int i = 0; i < address.length; i++) {
  78. String email = address[i].getAddress();
  79. if (email == null)
  80. email = "";
  81. else {
  82. email = MimeUtility.decodeText(email);
  83. }
  84. String personal = address[i].getPersonal();
  85. if (personal == null)
  86. personal = "";
  87. else {
  88. personal = MimeUtility.decodeText(personal);
  89. }
  90. String compositeto = personal + "<" + email + ">";
  91. mailaddr += "," + compositeto;
  92. }
  93. mailaddr = mailaddr.substring(1);
  94. }
  95. } else {
  96. throw new Exception("Error　emailaddr　type!");
  97. }
  98. return mailaddr;
  99. }
  101. /**
  102.  * 
  103.  * 获取邮件主题
  104.  */
  105. public String getSubject() throws MessagingException {
  106. String subject = "";
  107. try {
  108. subject = MimeUtility.decodeText(mimeMessage.getSubject());
  109. if (subject == null)
  110. subject = "";
  111. } catch (Exception exce) {
  112. }
  113. return subject;
  114. }
  116. /*
  117.  * 获取邮件发送日期
  118.  * 
  119.  */
  121. public String getSentDate() throws Exception {
  122. Date sentdate = mimeMessage.getSentDate();
  123. SimpleDateFormat format = new SimpleDateFormat(dateformat);
  124. return format.format(sentdate);
  125. }
  127. /**
  128.  * 获取邮件正文
  129.  * 
  130.  * @return
  131.  * 
  132.  */
  134. public String getBodyText() {
  135. return bodytext.toString();
  136. }
  138. /**
  139.  * 解析邮件，把得到的邮件内容保存到一个StringBuffer对象中，解析邮件 主要是根据MimeType类型的不同执行不同的操作，一步一步的解析
  140.  * 
  141.  * 
  142.  */
  144. public void getMailContent(Part part) throws Exception {
  145. String contenttype = part.getContentType();
  146. int nameindex = contenttype.indexOf("name");
  147. boolean conname = false;
  148. if (nameindex != -1)
  149. conname = true;
  150. System.out.println("CONTENTTYPE:　" + contenttype);
  151. if (part.isMimeType("text/plain") && !conname) {
  152. bodytext.append((String) part.getContent());
  153. } 
  154. // else if (part.isMimeType("text/html") && !conname) {
  155. // bodytext.append((String) part.getContent());
  156. // } 
  157. // else if (part.isMimeType("multipart/*")) {
  158. // Multipart multipart = (Multipart) part.getContent();
  159. // int counts = multipart.getCount();
  160. // for (int i = 0; i < counts; i++) {
  161. // getMailContent(multipart.getBodyPart(i));
  162. // }
  163. // } 
  164. // else if (part.isMimeType("message/rfc822")) {
  165. // getMailContent((Part) part.getContent());
  166. // } 
  167. else {
  168. }
  169. }
  171. /**
  172.  * 
  173.  * 判断此邮件是否需要回执，如果需要回执返回"true",否则返回"false"
  174.  * 
  175.  */
  177. public boolean getReplySign() throws MessagingException {
  178. boolean replysign = false;
  179. String needreply[] = mimeMessage
  180. .getHeader("Disposition-Notification-To");
  181. if (needreply != null) {
  182. replysign = true;
  183. }
  184. return replysign;
  185. }
  187. /*
  188.  * 获得此邮件的Message-ID
  189.  * 
  190.  */
  192. public String getMessageId() throws MessagingException {
  193. return mimeMessage.getMessageID();
  194. }
  196. /*
  197.  * 【判断此邮件是否已读，如果未读返回返回false,反之返回true】
  198.  * 
  199.  */
  201. public boolean isNew() throws MessagingException {
  202. boolean isnew = false;
  203. Flags flags = ((Message) mimeMessage).getFlags();
  204. Flags.Flag[] flag = flags.getSystemFlags();
  205. System.out.println("flags's　length:　" + flag.length);
  206. for (int i = 0; i < flag.length; i++) {
  207. if (flag[i] == Flags.Flag.SEEN) {
  208. isnew = true;
  209. System.out.println("seen　Message.......");
  210. break;
  211. }
  212. }
  213. return isnew;
  214. }
  216. /**
  217.  * 
  218.  * 判断此邮件是否包含附件
  219.  * 
  220.  */
  222. public boolean isContainAttach(Part part) throws Exception {
  223. boolean attachflag = false;
  224. String contentType = part.getContentType();
  225. if (part.isMimeType("multipart/*")) {
  226. Multipart mp = (Multipart) part.getContent();
  227. for (int i = 0; i < mp.getCount(); i++) {
  228. BodyPart mpart = mp.getBodyPart(i);
  229. String disposition = mpart.getDisposition();
  230. if ((disposition != null)
  231. && ((disposition.equals(Part.ATTACHMENT)) || (disposition
  232. .equals(Part.INLINE))))
  233. attachflag = true;
  234. else if (mpart.isMimeType("multipart/*")) {
  235. attachflag = isContainAttach((Part) mpart);
  236. } else {
  237. String contype = mpart.getContentType();
  238. if (contype.toLowerCase().indexOf("application") != -1)
  239. attachflag = true;
  240. if (contype.toLowerCase().indexOf("name") != -1)
  241. attachflag = true;
  242. }
  243. }
  244. } else if (part.isMimeType("message/rfc822")) {
  245. attachflag = isContainAttach((Part) part.getContent());
  246. }
  247. return attachflag;
  248. }
  250. /*
  251.  * 保存附件
  252.  * 
  253.  */
  254. public void saveAttachMent(Part part) throws Exception {
  255. String fileName = "";
  256. if (part.isMimeType("multipart/*")) {
  257. Multipart mp = (Multipart) part.getContent();
  258. for (int i = 0; i < mp.getCount(); i++) {
  259. BodyPart mpart = mp.getBodyPart(i);
  260. String disposition = mpart.getDisposition();
  261. if ((disposition != null)
  262. && ((disposition.equals(Part.ATTACHMENT)) || (disposition
  263. .equals(Part.INLINE)))) {
  264. fileName = mpart.getFileName();
  265. if (fileName.toLowerCase().indexOf("gb2312") != -1) {
  266. fileName = MimeUtility.decodeText(fileName);
  267. }
  268. // saveFile(fileName,mpart.getInputStream());
  269. saveFile(fileName, mpart.getInputStream());
  271. } else if (mpart.isMimeType("multipart/*")) {
  272. saveAttachMent(mpart);
  273. } else {
  274. fileName = mpart.getFileName();
  275. if ((fileName != null)
  276. && (fileName.toLowerCase().indexOf("GB2312") != -1)) {
  277. fileName = MimeUtility.decodeText(fileName);
  278. saveFile(fileName, mpart.getInputStream());
  279. }
  280. }
  281. }
  282. } else if (part.isMimeType("message/rfc822")) {
  283. saveAttachMent((Part) part.getContent());
  284. }
  285. }
  287. /**
  288.  * 【设置附件存放路径】
  289.  */
  291. public void setAttachPath(String attachpath) {
  292. this.saveAttachPath = attachpath;
  293. }
  295. /**
  296.  * 
  297.  * 设置日期显示本格式
  298.  */
  299. public void setDateFormat(String format) throws Exception {
  300. this.dateformat = format;
  301. }
  303. /**
  304.  * 【获得附件存放路径】
  305.  */
  307. public String getAttachPath() {
  308. return saveAttachPath;
  309. }
  311. /**
  312.  * 【真正的保存附件到指定目录里】
  313.  */
  315. private void saveFile(String fileName, InputStream in) throws Exception {
  317. String osName = System.getProperty("os.name");
  318. String storedir = getAttachPath();
  319. String separator = "";
  320. if (osName == null)
  321. osName = "";
  322. if (osName.toLowerCase().indexOf("win") != -1) {
  323. separator = "\";
  324. if (storedir == null || storedir.equals(""))
  325. storedir = "c:\tmp";
  326. } else {
  327. separator = "/";
  328. storedir = "/tmp";
  329. }
  330. File storefile = new File(storedir + separator + fileName);
  331. System.out.println("storefile's　path:　" + storefile.toString());
  333. BufferedOutputStream bos = null;
  334. BufferedInputStream bis = null;
  335. try {
  336. bos = new BufferedOutputStream(new FileOutputStream(storefile));
  337. bis = new BufferedInputStream(in);
  338. int c;
  339. while ((c = bis.read()) != -1) {
  340. bos.write(c);
  341. bos.flush();
  342. }
  343. } catch (Exception exception) {
  344. exception.printStackTrace();
  345. throw new Exception("文件保存失败!");
  346. } finally {
  347. bos.close();
  348. bis.close();
  349. }
  350. }
  352. /**
  353.  * PraseMimeMessage类测试
  354.  */
  356. public static void main(String args[]) throws Exception {
  357. String host = "POP3.163.com";// 【POP3.163.com】
  358. String username = "yuxia2217";// 【yuxia2217】
  359. String password = "*************";// 【........】
  360. Properties props = new Properties();
  361. Session session = Session.getDefaultInstance(props, null);
  362. Store store = session.getStore("pop3");
  363. store.connect(host, username, password);
  364. Folder folder = store.getFolder("INBOX");
  365. folder.open(Folder.READ_ONLY);
  366. Message message[] = folder.getMessages();
  367. System.out.println("Messages's　length:　" + message.length);
  368. TestRe pmm = null;
  369. for (int i = 0; i < message.length; i++) {
  370. pmm = new TestRe((MimeMessage) message[i]);
  371. System.out
  372. .println("Message　" + i + "　subject:　" + pmm.getSubject());
  373. System.out.println("Message　" + i + "　sentdate:　"
  374. + pmm.getSentDate());
  375. System.out.println("Message　" + i + "　replysign:　"
  376. + pmm.getReplySign());
  377. System.out.println("Message　" + i + "　hasRead:　" + pmm.isNew());
  378. System.out.println("Message　" + i + "　　containAttachment:　"
  379. + pmm.isContainAttach((Part) message[i]));
  380. System.out.println("Message　" + i + "　form:　" + pmm.getFrom());
  381. System.out.println("Message　" + i + "　to:　"
  382. + pmm.getMailAddress("to"));
  383. System.out.println("Message　" + i + "　cc:　"
  384. + pmm.getMailAddress("cc"));
  385. System.out.println("Message　" + i + "　bcc:　"
  386. + pmm.getMailAddress("bcc"));
  387. pmm.setDateFormat("yy年MM月dd日　HH:mm");
  388. System.out.println("Message　" + i + "　sentdate:　"
  389. + pmm.getSentDate());
  390. System.out.println("Message　" + i + "　Message-ID:　"
  391. + pmm.getMessageId());
  392. pmm.getMailContent((Part) message[i]);
  393. System.out.println("Message　" + i + "　bodycontent:　rn"
  394. + pmm.getBodyText());
  395. pmm.setAttachPath("c:\tmp\coffeecat1124");
  396. pmm.saveAttachMent((Part) message[i]);
  397. }
  398. }
  399. }