java實現POP3郵件客戶端

java實現POP3郵件客戶端

 

完整項目包：http://yunpan.cn/QiVGqacT6uNAj （提取碼：05b4）

第一步：利用socket編程，在客戶端與服務器端之間建立TCP連接，POP3默認端口號為110；

第二步：通過pop3定義的各種命令，用戶可以操作自己的郵箱。

注：

POP3協議中有三種狀態，認正狀態，處理狀態，和更新狀態。 命令的執行可以改變協議的狀態，而對於具體的某命令，它只能在具體的某狀態下使用，這些請參看表1和RFC193。

客戶機與服務器剛與服務器建立連接時，它的狀態為認證狀態；一旦客戶機提供了自己身份並被成功地確認，即由認可狀態轉入處理狀態； 在完成相應的操作后客戶機發出QUIT命令（具體說明見后續內容），則進入更新狀態，更新之后又重返認可狀態；當然在認可狀態下執行QUIT命令，可釋放連接。狀態間的轉移如圖 1所示。

---建立連接---|認可|--認證成功--|處理|--執行QUIT--|更新|        

            |_______ -QUIT結束_________________|

 

常用命令：

命令	參數	使用在何種狀態中	描述
USER	Username	認證	此命令與下面的pass命令若成功，將導致狀態轉換
PASS	Password	認證	此命令若成功，狀態轉化為更新
APOP	Name,Digest	認證	Digest是MD5消息摘要
STAT	None	處理	請求服務器發回關於郵箱的統計資料，如郵件總數和總字節數
UIDL	[Msg#]（郵件號，下同）	處理	返回郵件的唯一標識符，POP3會話的每個標識符都將是唯一的
LIST	[Msg#]	處理	返回郵件的唯一標識符，POP3會話的每個標識符都將是唯一的
RETR	[Msg#]	處理	返回由參數標識的郵件的全部文本
DELE	[Msg#]	處理	服務器將由參數標識的郵件標記為刪除，由QUIT命令執行
TOP	[Msg#]	處理	服務器將返回由參數標識的郵件的郵件頭+前n行內容，n必須是正整數
NOOP	None	處理	服務器返回一個肯定的響應，用於測試連接是否成功
QUIT	None	處理、認證	1)        如果服務器處於“處理”狀態，么將進入“更新”狀態以刪除任何標記為刪除的郵件，並重返“認證”狀態。 2)        如果服務器處於“認證”狀態，則結束會話，退出連接

 

代碼：

 

/**
 * @author hewenwu  3  * 這個程序實現了基於POP3協議的郵件接收功能  4  * */
package mail;  6 
import java.io.BufferedReader;  8 import java.io.BufferedWriter;  9 import java.io.IOException;  10 import java.io.InputStreamReader;  11 import java.io.OutputStreamWriter;  12 import java.io.UnsupportedEncodingException;  13 import java.net.Socket;  14 import java.net.UnknownHostException;  15 import java.util.StringTokenizer;  16 
public class POP3Client {  18 
    private Socket socket = null;  20  
    private boolean debug=true;  22  
    public static void main(String[] args) throws UnknownHostException, IOException {  24   
        String server="pop3.163.com";//POP3服務器地址
  
        String user="**********";//用戶名，填寫自己的郵箱用戶名
  
        String password="*********";//密碼，填寫自己的密碼
 
        POP3Client pop3Client=new POP3Client(server,110);  32  
 pop3Client.recieveMail(user,password);  }  35  
    /*構造函數*/
    public POP3Client(String server,int port) throws UnknownHostException, IOException{  38         try{  39    
            socket=new Socket(server,port);//在新建socket的時候就已經與服務器建立了連接

        }catch(Exception e){  43    
 e.printStackTrace();  45  
        }finally{  47  
            System.out.println("建立連接！");  49  }  50  }  51  
    
    //接收郵件程序
    public boolean recieveMail(String user,String password){  55             
        try {  57                 BufferedReader in=new BufferedReader(new InputStreamReader(socket.getInputStream()));  58        
                BufferedWriter out=new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));  60       
                user(user,in,out);//輸入用戶名
       
                System.out.println("user 命令執行完畢！");  64                 
                pass(password,in,out);//輸入密碼
      
                System.out.println("pass 命令執行完畢！");  68       
 stat(in,out);  70       
                System.out.println("stat 命令執行完畢！");  72                 
 list(in,out);  74                   
                System.out.println("list 命令執行完畢！");  76                 
                retr(2,in,out);  78                 
                System.out.println("retr 命令執行完畢！");  80       
 quit(in,out);  82                 
                System.out.println("quit 命令執行完畢！");  84      
            }catch(Exception e){  86       
 e.printStackTrace();  88       
                return false;  90  }  91             return true;  92  }  93     
    //得到服務器返回的一行命令
    public String getReturn(BufferedReader in){  96     
        String line="";  98   
        try{ 100             line=in.readLine(); 101    
            if(debug){ 103    
                System.out.println("服務器返回狀態:"+line); 105  } 106         }catch(Exception e){ 107  
 e.printStackTrace(); 109  } 110         return line; 111  } 112  
    //從返回的命令中得到第一個字段,也就是服務器的返回狀態碼(+OK或者-ERR)
    public String getResult(String line){ 115 
        StringTokenizer st=new StringTokenizer(line," "); 117 
        return st.nextToken(); 119  } 120  
    //發送命令
    private String sendServer(String str,BufferedReader in,BufferedWriter out) throws IOException{ 123         
        out.write(str);//發送命令
 
        out.newLine();//發送空行
 
        out.flush();//清空緩沖區
  
        if(debug){ 131   
            System.out.println("已發送命令:"+str); 133  } 134          return getReturn(in); 135  } 136  
    //user命令
    
    public void user(String user,BufferedReader in,BufferedWriter out) throws IOException{ 140 
        String result = null; 142  
        result=getResult(getReturn(in));//先檢測連接服務器是否已經成功
 
        if(!"+OK".equals(result)){ 146    
            throw new IOException("連接服務器失敗!"); 148  } 149  
        result=getResult(sendServer("user "+user,in,out));//發送user命令

        if(!"+OK".equals(result)){ 153   
            throw new IOException("用戶名錯誤!"); 155  } 156  } 157  
    //pass命令
    public void pass(String password,BufferedReader in,BufferedWriter out) throws IOException{ 160  
        String result = null; 162  
        result = getResult(sendServer("pass "+password,in,out)); 164  
        if(!"+OK".equals(result)){ 166 
            throw new IOException("密碼錯誤!"); 168  } 169  } 170 
    
    //stat命令

    public int stat(BufferedReader in,BufferedWriter out) throws IOException{ 175  
        String result = null; 177  
        String line = null; 179   
        int mailNum = 0; 181  
        line=sendServer("stat",in,out); 183  
        StringTokenizer st=new StringTokenizer(line," "); 185   
        result=st.nextToken(); 187   
        if(st.hasMoreTokens()) 189  
            mailNum=Integer.parseInt(st.nextToken()); 191  
        else{ 193             
            mailNum=0; 195             
 } 197         
        if(!"+OK".equals(result)){ 199  
            throw new IOException("查看郵箱狀態出錯!"); 201  } 202  
        System.out.println("共有郵件"+mailNum+"封"); 204         return mailNum; 205  } 206     
        //無參數list命令
        public void list(BufferedReader in,BufferedWriter out) throws IOException{ 209      
            String message = ""; 211      
            String line = null; 213      
            line=sendServer("list",in,out); 215      
            while(!".".equalsIgnoreCase(line)){ 217        
                message=message+line+"\n"; 219             
                line=in.readLine().toString(); 221  } 222             
 System.out.println(message); 224  } 225         
          //帶參數list命令
                public void list_one(int mailNumber ,BufferedReader in,BufferedWriter out) throws IOException{ 228 
                    String result = null; 230                      
                    result = getResult(sendServer("list "+mailNumber,in,out)); 232              
                    if(!"+OK".equals(result)){ 234 
                        throw new IOException("list錯誤!"); 236  } 237  } 238  
 //得到郵件詳細信息
 
    public String getMessagedetail(BufferedReader in) throws UnsupportedEncodingException{ 242  
        String message = ""; 244   
        String line = null; 246  
        try{ 248             line=in.readLine().toString(); 249   
            while(!".".equalsIgnoreCase(line)){ 251    
                message=message+line+"\n"; 253    
                line=in.readLine().toString(); 255  } 256         }catch(Exception e){ 257   
 e.printStackTrace(); 259  } 260     
            return message; 262  } 263  
 //retr命令
    public void retr(int mailNum,BufferedReader in,BufferedWriter out) throws IOException, InterruptedException{ 266   
            String result = null; 268    
            result=getResult(sendServer("retr "+mailNum,in,out)); 270   
            if(!"+OK".equals(result)){ 272   
                throw new IOException("接收郵件出錯!"); 274  } 275             
            System.out.println("第"+mailNum+"封"); 277  System.out.println(getMessagedetail(in)); 278             Thread.sleep(3000); 279  } 280  
    //退出
    public void quit(BufferedReader in,BufferedWriter out) throws IOException{ 283  
 String result; 285  
        result=getResult(sendServer("QUIT",in,out)); 287  
        if(!"+OK".equals(result)){ 289   
            throw new IOException("未能正確退出"); 291  } 292  } 293  
}

總結：

    這個項目其實非常簡單，關鍵要理解兩個方面，一是怎么利用socket編程連接到服務器，二是POP3協議命令的格式和返回值的格式。理解了這兩個方面，就好做了。首先建立連接，然后通過socket對象獲取輸入輸出流對象，在輸入輸出流對象上發送命令和接受返回值，接收到返回值之后自己本地處理這些返回值就行啦。

說到輸入輸出流，java的輸入輸出流真的比較多，有點不好記，但是每個輸出流的原理是一樣，而且有封裝的特性。接下來一定要狠狠的把它搞懂了！