java socket 實現(xiàn)SMTP協(xié)議 發(fā)送郵件

1、java socket 實現(xiàn)SMTP協(xié)議 發(fā)送郵件文章分類:Java編程 package com.socket.test; import java.io.BufferedReader; import java.io.DataOutputStream; import java.io.IOException; import java.io.InputStreamReader; import .Socket; import .UnknownHostException; import ernal.impl.dv.util.Base64; /*

2、* 通過socket向smtp協(xié)議服務(wù)器發(fā)送郵件 * author fuyanqing * */ public class SocketMail String mailServer; String from; String to; String content; String lineFeet = "rn" private int port = 25; Socket client; BufferedReader in; DataOutputStream os; public String getContent() return content; public void se

3、tContent(String content) this.content = content; public String getMailServer() return mailServer; public void setMailServer(String mailServer) this.mailServer = mailServer; public String getFrom() return from; public void setFrom(String from) this.from = from; public String getTo() return to; public

4、 void setTo(String to) this.to = to; /* * 初始化連接 * return */ private boolean init() boolean boo = true; if(mailServer=null | "".equals(mailServer) return false; try client = new Socket(mailServer,port); in = new BufferedReader(new InputStreamReader(client.getInputStream(); os = new DataOutp

5、utStream(client.getOutputStream(); String isConnect = response(); if(isConnect.startsWith("220") else System.out.println("建立連接失?。?quot;+isConnect); boo = false; catch (UnknownHostException e) System.out.println("建立連接失??！"); e.printStackTrace(); boo = false; catch (IOException

6、 e) System.out.println("讀取流失??！"); e.printStackTrace(); boo = false; return boo; /* * 發(fā)送smtp指令 * 并返回服務(wù)器響應(yīng)信息 */ private String sendCommand(String msg) String result = null; try os.writeBytes(msg); os.flush(); result = response(); catch (IOException e) e.printStackTrace(); return result; /* *

7、 讀取服務(wù)器端響應(yīng)信息 * return */ private String response() String result = null; try result = in.readLine(); catch (IOException e) e.printStackTrace(); return result; /* * 關(guān)閉 */ private void close() try os.close(); in.close(); client.close(); catch (IOException e) e.printStackTrace(); /* * 發(fā)送郵件 * return */ p

8、ublic boolean sendMail() /初始化 if(client=null) if(init() else return false; /判斷from,to if(from=null | from.isEmpty() | to = null | to.isEmpty() return false; /進(jìn)行握手 String result = sendCommand("HELO "+mailServer+lineFeet); if(isStartWith(result,"250") else System.out.println("

9、握手失敗："+result); return false; /驗證發(fā)信人信息 String auth = sendCommand("AUTH LOGIN"+lineFeet); if(isStartWith(auth,"334") else return false; String user = sendCommand(new String(Base64.encode("*".getBytes()+lineFeet); if(isStartWith(user,"334") else return fals

10、e; String pass = sendCommand(new String(Base64.encode("*".getBytes()+lineFeet); if(isStartWith(pass,"235") else return false; /發(fā)送指令 String f = sendCommand("Mail From:<"+from+">"+lineFeet); if(isStartWith(f,"250") else return false; String toStr

11、 = sendCommand("RCPT TO:<"+to+">"+lineFeet); if(isStartWith(toStr,"250") else return false; String data = sendCommand("DATA"+lineFeet); if(isStartWith(data,"354") else return false; StringBuilder sb = new StringBuilder(); sb.append("From:&

12、lt;"+from+">"+lineFeet); sb.append("To:<"+to+">"+lineFeet); sb.append("Subject:test"+lineFeet); sb.append("Date:2010/10/27 17:30"+lineFeet); sb.append("Content-Type:text/plain;charset="GB2312""+lineFeet); sb.append(l

13、ineFeet); sb.append(content); sb.append(lineFeet+"."+lineFeet); String conStr = sendCommand(sb.toString(); if(isStartWith(conStr,"250") else return false; /quit String quit = sendCommand("QUIT"+lineFeet); if(isStartWith(quit,"221") else return false; close();

14、return true; private boolean isStartWith(String res,String with) return res.startsWith(with); public static void main(String args) SocketMail mail = new SocketMail(); mail.setMailServer(""); mail.setFrom("*"); mail.setTo("*"); mail.setContent("hello,this is a test

15、mail!"); boolean boo = mail.sendMail(); if(boo) System.out.println("郵件發(fā)送成功！"); else System.out.println("郵件發(fā)送失??！"); ··························

16、3;·················································

17、3;··············SMTP的連接和收發(fā)過程：a.建立TCP連接。b.客戶端發(fā)送HELO命令以標(biāo)識發(fā)件人自己的身份，然后客戶端發(fā)送MAIL命令服務(wù)器端正希望以O(shè)K作為響應(yīng)，表明準(zhǔn)備接收。c.客戶端發(fā)送RCPT命令，以標(biāo)識該電子郵件的計劃接收人，可以有多個RCPT行d.協(xié)商結(jié)束，發(fā)送郵件，用命令DATA發(fā)送e.以.表示結(jié)束輸入內(nèi)容一起發(fā)送出去f.結(jié)束此次發(fā)送，用QUIT命令退出。SMTP的基本命令集：HELO 向服務(wù)器標(biāo)識用戶身份MAIL初始化郵

18、件傳輸mail from: <xxx>RCPT標(biāo)識單個的郵件接收人；常在MAIL命令后面可有多個rcpt to: <xxx>DATA在單個或多個RCPT命令后，表示所有的郵件接收人已標(biāo)識，初始化數(shù)據(jù)傳輸，以.結(jié)束。NOOP 無操作，服務(wù)器應(yīng)響應(yīng)OKRSET重置會話，當(dāng)前傳輸被取消QUIT結(jié)束會話POP3簡介：在POP3協(xié)議中有三種狀態(tài)，認(rèn)可狀態(tài)，處理狀態(tài)，和更新狀態(tài)。當(dāng)客戶機(jī)與服務(wù)器建立聯(lián)系時，一旦客戶機(jī)提供了自己身份并成功確認(rèn)，即由認(rèn)可狀態(tài)轉(zhuǎn)入處理狀態(tài)，在完成相應(yīng)的操作后客戶機(jī)發(fā)出quit命令，則進(jìn)入更新狀態(tài)，更新之后最后重返認(rèn)可狀態(tài)。POP3基本命令集：USERus

19、ernamePASSpasswordSTAT 請求服務(wù)器發(fā)回關(guān)于郵箱的統(tǒng)計資料，如郵件總數(shù)和總字節(jié)數(shù)LIST 返回郵件數(shù)量和每個郵件的大小RETR Msg#返回由參數(shù)標(biāo)識的郵件的全部文本DELEMsg#服務(wù)器將由參數(shù)標(biāo)識的郵件標(biāo)記為刪除，由quit命令執(zhí)行RSET服務(wù)器將重置所有標(biāo)記為刪除的郵件，用于撤消DELE命令NOOP 服務(wù)器返回一個肯定的響應(yīng)QUIT更新class POP3Demo    private static String POP3Server = ""    private static String US

20、ERNAME = "username"/實際應(yīng)用中改成真實的用戶名    private static String PASSWORD = "password"/實際應(yīng)用中改成真實的密碼    public static void main(String args)         int POP3Port = 110;        Socket clie

21、nt = null;        try             / 向POP3服務(wù)程序建立一個套接字連接。            client = new Socket(POP3Demo.POP3Server, POP3Port);      &

22、#160;     / 創(chuàng)建一個BufferedReader對象，以便從套接字讀取輸出。            InputStream is = client.getInputStream();            BufferedReader sockin = new BufferedReader(new InputStreamRea

23、der(is);            / 創(chuàng)建一個PrintWriter對象，以便向套接字寫入內(nèi)容。            OutputStream os = client.getOutputStream();            PrintWriter socko

24、ut = new PrintWriter(os, true);            / 顯示同SMTP服務(wù)程序的握手過程。            System.out.println("S:" + sockin.readLine();          &#

25、160; sockout.println("user " + POP3Demo.USERNAME);            System.out.println("S:" + sockin.readLine();            sockout.println("pass " + POP3Demo.PASSWOR

26、D);            System.out.println("S:" + sockin.readLine();            sockout.println("stat");            String t

27、emp = sockin.readLine().split(" ");            int count = Integer.parseInt(temp1);/得到信箱中共有多少封郵件            for (int i = 1; i < count + 1; i+) /依次打印出郵件的內(nèi)容    

28、;            sockout.println("retr " + i);                System.out.println("以下為第" + i + "封郵件的內(nèi)容");      

29、0;         while (true)                     String reply = sockin.readLine();              

30、0;     System.out.println(reply);                    if (reply.toLowerCase().equals(".")               &#

31、160;         break;                                          

32、;      </xxx></xxx>          catch (IOException e)             System.out.println(e.toString();        finally    

33、0;        try                 if (client != null)                     client.close(); 

34、0;                          catch (IOException e)              class SMTPDemo     /以下三項請在使用時改成真實的信箱地址 

35、60;  /并且注意，SMTPServer和receiver必須是同一個服務(wù)器    private static String sender = "sender"    private static String receiver = "receiver"    private static String SMTPServer = "smtpserver"    public static void ma

36、in(String args)         int SMTPPort = 25;        Socket client = null;        try             / 向SMTP服務(wù)程序建立一個套接字連接。    

37、        client = new Socket(SMTPDemo.SMTPServer, SMTPPort);            / 創(chuàng)建一個BufferedReader對象，以便從套接字讀取輸出。            InputStream is = client.getInputStream

38、();            BufferedReader sockin = new BufferedReader(new InputStreamReader(is);            / 創(chuàng)建一個PrintWriter對象，以便向套接字寫入內(nèi)容。          

39、60; OutputStream os = client.getOutputStream();            PrintWriter sockout = new PrintWriter(os, true);            / 顯示同SMTP服務(wù)程序的握手過程。        

40、0;   System.out.println("S:" + sockin.readLine();            sockout.println("helo");            System.out.println("S:" + sockin.readLine(); 

41、60;          sockout.println("mail from: " + "<" + SMTPDemo.sender + ">");            System.out.println("S:" + sockin.readLine();    

42、        sockout.println("rcpt to: " + "<" + SMTPDemo.receiver + ">");            System.out.println("S:" + sockin.readLine();            sockout.println("data");            /發(fā)送郵件標(biāo)題            sockout.println("subject: 你好");  &