php使用smtp，pop3协议收发邮件代码

<?php 
if ($EMAIL_INC) return; 
$EMAIL_INC=  "defined"; 
define( "SmtpPort",25); 

class Pop3 { 
    var $subject;                          // 邮件主题  
    var $from_email;                       // 发件人地址
    var $from_name;                        // 发件人姓名
    var $to_email;                         // 收件人地址
    var $to_name;                          // 收件人姓名
    var $body;                             // 邮件内容
    var $filename;                         // 文件名
    var $socket;                 // 当前的 socket 
    var $Line; 
    var $Status; 

    function pop3_open($server, $port)   
    { 

        $this->Socket = fsockopen($server, $port); 
        if ($this->Socket <= 0){ 
            return false; 
        } 
    $this->Line = fgets($this->Socket, 1024); 
    $this->Status[ "LASTRESULT"] = substr($this->Line, 0, 1); 
    $this->Status[ "LASTRESULTTXT"] = substr($this->Line, 0, 1024); 

    if ($this->Status[ "LASTRESULT"] <>  "+") return false; 
    return true; 
    } 

    function pop3_user($user) 
    { 

        if ($this->Socket < 0){ 
          return false; 
        } 
        fputs($this->Socket,  "USER $this->user\r\n"); 
        $this->Line = fgets($this->Socket, 1024); 
        $this->Status[ "LASTRESULT"] = substr($this->Line, 0, 1); 
        $this->Status[ "LASTRESULTTXT"] = substr($this->Line, 0, 1024); 

        if ($this->Status[ "LASTRESULT"] <>  "+") return false; 

        return true; 
    } 

    function pop3_pass( $pass) 
    { 

        fputs($this->Socket,  "PASS $pass\r\n"); 
        $this->Line = fgets($this->Socket, 1024); 
        $this->Status[ "LASTRESULT"] = substr($this->Line, 0, 1); 
        $this->Status[ "LASTRESULTTXT"] = substr($this->Line, 0, 1024); 

        if ($this->Status[ "LASTRESULT"] <>  "+") return 0; 

        return 1; 
    } 

    function pop3_stat() 
    { 

        fputs($this->Socket,  "STAT\r\n"); 
        $this->Line = fgets($this->Socket, 1024); 
        $this->Status[ "LASTRESULT"] = substr($this->Line, 0, 1); 
        $this->Status[ "LASTRESULTTXT"] = substr($this->Line, 0, 1024); 

        if ($this->Status[ "LASTRESULT"] <>  "+") return 0; 

        if (!eregi( "+OK (.*) (.*)", $this->Line, $regs))  
            return 0; 

        return $regs[1]; 
    } 

    function pop3_list() 
    { 
        fputs($this->Socket,  "LIST\r\n"); 
        $this->Line = fgets($this->Socket, 1024); 
        $this->Status[ "LASTRESULT"] = substr($this->Line, 0, 1); 
        $this->Status[ "LASTRESULTTXT"] = substr($this->Line, 0, 1024); 

        if ($this->Status[ "LASTRESULT"] <>  "+") return 0; 

        $i = 0; 
        while  (substr($this->Line  =  fgets($this->Socket, 1024),  0,  1)  <>   ".") 
        { 
            $articles[$i] = $this->Line; 
            $i++; 
        } 
        $articles[ "count"] = $i; 

        return $articles; 
    } 

    function pop3_retr($nr) 
    { 

        fputs($this->Socket,  "RETR $nr\r\n"); 
        $this->Line = fgets($this->Socket, 1024); 
        $this->Status[ "LASTRESULT"] = substr($this->Line, 0, 1); 
        $this->Status[ "LASTRESULTTXT"] = substr($this->Line, 0, 1024); 

        if ($this->Status[ "LASTRESULT"] <>  "+") return 0; 

        while  (substr($this->Line  =  fgets($this->Socket, 1024),  0,  1)  <>   ".") 
        { 
            $data[$i] = $this->Line; 
            $i++; 
        } 
        $data[ "count"] = $i; 

        return $data; 
    } 

    function pop3_dele( $nr) 
    { 

        fputs($this->Socket,  "DELE $nr\r\n"); 
        $this->Line = fgets($this->Socket, 1024); 
        $this->Status[ "LASTRESULT"] = substr($this->Line, 0, 1); 
        $this->Status[ "LASTRESULTTXT"] = substr($this->Line, 0, 1024); 

        if ($this->Status[ "LASTRESULT"] <>  "+") return 0; 
        return 1; 
    } 

    function pop3_quit() 
    { 

        fputs($this->Socket,  "QUIT\r\n"); 
        $this->Line = fgets($this->Socket, 1024); 
        $this->Status[ "LASTRESULT"] = substr($this->Line, 0, 1); 
        $this->Status[ "LASTRESULTTXT"] = substr($this->Line, 0, 1024); 

        if ($this->Status[ "LASTRESULT"] <>  "+") return 0; 

        return 1; 
    } 
} 

class Smtp { 

    var $Subject;              // string the email's subject  
    var $FromName;                 // string sender's name (opt)  
    var $ToName;                   // string recipient's name (opt)  
    var $Body;                     // string body copy  
    var $Attachment;         // attachment (optional) 
    var $AttachmentType; 
    var $Socket; 
    var $Line; 
    var $Status; 

    function Smtp($Server =  "localhost",$Port = SmtpPort) 
    {     
        return $this->Open($Server, $Port); 
    } 

    function SmtpMail($FromEmail, $FromName, $ToEmail, $ToName, $Subject, $Body, $Attachment=null, $AttachmentType= "TEXT") 
    { 
        $this->Subject   = $Subject; 
        $this->ToName    = $ToName; 

        $this->FromName    = $FromName; 
        $this->Body      = $Body; 

        $this->Attachment = $Attachment; 
        $this->AttachmentType = $AttachmentType; 

        if ($this->Helo() == false){ 
            return false; 
        } 
        if ($this->MailFrom($FromEmail) == false){ 
            return false; 
        } 
        if ($this->RcptTo($ToEmail) == false){ 
            return false; 
        } 
        if ($this->Body() == false){ 
            return false; 
        } 
        if ($this->Quit() == false){ 
            return false; 
        } 
    } 

    function Open($Server, $Port) 
    { 

     $this->Socket = fsockopen($Server, $Port); 
     if ($this->Socket < 0) return false; 

     $this->Line = fgets($this->Socket, 1024); 

     $this->Status[ "LASTRESULT"] = substr($this->Line, 0, 1); 
     $this->Status[ "LASTRESULTTXT"] = substr($this->Line, 0, 1024); 

     if ($this->Status[ "LASTRESULT"] <>  "2") return false; 

     return true; 
    } 

    function Helo() 
    { 
        if (fputs($this->Socket,  "helo\r\n") < 0 ){ 
            return false; 
        } 
        $this->Line = fgets($this->Socket, 1024); 

        $this->Status[ "LASTRESULT"] = substr($this->Line, 0, 1); 
        $this->Status[ "LASTRESULTTXT"] = substr($this->Line, 0, 1024); 

        if ($this->Status[ "LASTRESULT"] <>  "2") return false; 

        return true;   
    } 

    function Ehlo() 
    { 

         /* Well, let's use "helo" for now.. Until we need the 
        extra func's   [Unk] 
        */ 
        if(fputs($this->Socket,  "helo localhost\r\n")<0){ 
            return false; 
        } 
        $this->Line = fgets($this->Socket, 1024); 

        $this->Status[ "LASTRESULT"] = substr($this->Line, 0, 1); 
        $this->Status[ "LASTRESULTTXT"] = substr($this->Line, 0, 1024); 

        if ($this->Status[ "LASTRESULT"] <>  "2") return false; 

        return true; 
    } 

    function MailFrom($FromEmail) 
    { 

        if (fputs($this->Socket,  "MAIL FROM: <$FromEmail>\r\n")<0){ 
            return false; 
        } 

        $this->Line = fgets($this->Socket, 1024); 

        $this->Status[ "LASTRESULT"] = substr($this->Line, 0, 1); 
        $this->Status[ "LASTRESULTTXT"] = substr($this->Line, 0, 1024); 

        if ($this->Status[ "LASTRESULT"] <>  "2") return false; 

        return true; 
    } 

    function RcptTo($ToEmail) 
    { 

        if(fputs($this->Socket,  "RCPT TO: <$ToEmail>\r\n")<0){ 
            return false; 
        } 
        $this->Line = fgets($this->Socket, 1024); 

        $this->Status[ "LASTRESULT"] = substr($this->Line, 0, 1); 
        $this->Status[ "LASTRESULTTXT"] = substr($this->Line, 0, 1024); 

        if ($this->Status[ "LASTRESULT"] <>  "2") return false; 
            return true; 
    } 

    function Body() 
    { 
        $FileSize = 0; 
        $Attachment = null; 
        $fp = null; 

        $buffer = sprintf( "From: %s\r\nTo:%s\r\nSubject:%s\r\n", $this->FromName, $this->ToName, $this->Subject); 

        if(fputs($this->Socket,  "DATA\r\n")<0){ 
            return false; 
        } 
        $this->Line = fgets($this->Socket, 1024); 

        $this->Status[ "LASTRESULT"] = substr($this->Line, 0, 1); 
        $this->Status[ "LASTRESULTTXT"] = substr($this->Line, 0, 1024); 

        if ($this->Status[ "LASTRESULT"] <>  "3") return false; 

        if(fputs($this->Socket, $buffer)<0){ 
            return false; 
        } 

        if ($this->Attachment == null){ 

            if(fputs($this->Socket,  "MIME-Version: 1.0\r\nContent-Type: text/plain; charset=ISO-8859-1\r\nContent-Transfer-Encoding: 7bit\r\n\r\n")<0){ 
                return false; 
            } 
            if(fputs($this->Socket,  "$this->Body\r\n\r\n")<0){ 
                return false; 
            } 

            if(fputs($this->Socket,  ".\r\n")<0){ 
                return false; 
            } 

            $this->Line = fgets($this->Socket, 1024); 
            if (substr($this->Line, 0, 1) <>  "2"){ 
                return false;  
            }else{ 
                return true; 
            } 
        }else{ 
            if(fputs($this->Socket, "MIME-Version: 1.0\r\nContent-Type: multipart/mixed; boundary=\"----=_NextPart_000_01BCFA61.A3697360\"\r\n". 
                 "Content-Transfer-Encoding: 7bit\r\n\r\n". 
                 "This is a multi-part message in MIME format.\r\n". 
                 "\r\n------=_NextPart_000_01BCFA61.A3697360\r\n". 
                 "Content-Type: text/plain; charset=ISO-8859-1\r\n". 
                 "Content-Transfer-Encoding: 7bit\r\n". 
                 "\r\n")<0){ 
                return false; 
            } 

             /* 输出邮件内容 */ 
            if(fputs($this->Socket,  "$this->Body\r\n\r\n")<0){ 
                return false; 
            } 

            if ( fputs($this->Socket, "\r\n------=_NextPart_000_01BCFA61.A3697360\r\n")<0){ 
                return false; 
            } 
            $FileSize = filesize($this->Attachment); 
            if ($FileSize == false){ 
                return false; 
            } 
            if (($fp = fopen($this->Attachment, "r"))== false) { 
                return false; 
            }else{ 
                $Attachment = fread($fp,$FileSize);     
            } 

             // 如果没有附件的目录 
            if (($AttachName = strrchr($this->Attachment, '/')) == false){ 

                $AttachName = $this->Attachment; 
            } 

            if( fputs($this->Socket, 
                 "Content-Type: application/octet-stream; \r\nname=\"$AttachName\"\r\n". 
                 "Content-Transfer-Encoding: quoted-printable\r\n". 
                 "Content-Description: $AttachName\r\n". 
                 "Content-Disposition: attachment; \r\n\tfilename=\"$AttachName\"\r\n". 
                 "\r\n")<0){ 
                return false; 
            } 

             /* 输出附件*/ 
            if( fputs($this->Socket, $Attachment)<0){ 
                return false; 
            } 
            if ( fputs($this->Socket, "\r\n\r\n------=_NextPart_000_01BCFA61.A3697360--\r\n")<0){ 
                return false; 
            } 

            if( fputs($this->Socket, ".\r\n")<0){ 
                return false; 
            } 

            $this->Line = fgets($this->Socket, 1024); 
            if (substr($this->Line, 0, 1) <>  "2") 
                return false;  

            return true; 

        } 
    } 

    function Quit() 
    { 

        if(fputs($this->Socket,  "QUIT\r\n")<0){ 
            return false; 
        } 
        $this->Line = fgets($this->Socket, 1024); 

        $this->Status[ "LASTRESULT"] = substr($this->Line, 0, 1); 
        $this->Status[ "LASTRESULTTXT"] = substr($this->Line, 0, 1024); 

        if ($this->Status[ "LASTRESULT"] <>  "2") return 0; 

        return 1; 
    }  
    function Close() 
    { 
        fclose($this->Socket); 
    } 
} 
/* 

怎样使用这个程序的一个示例 

$MailTo = new Smtp(); 
$MailTo->SmtpMail("Dave@micro-automation.net","Dave Cramer", 
           "Dave@micro-automation.net","David", 
           "Test Mail",$MailMessage,"service.tab",0); 
$MailTo->Close(); 
$MailTo=null; 

*/ 
/* 
 $pop3 = pop3_open("localhost", "110"); 
 if (!$pop3) { 
                printf("[ERROR] Failed to connect to localhost<BR>\n"); 
                return 0; 
 } 

 if (!pop3_user($pop3, "unk")) { 
                printf("[ERROR] Username failed!<BR>\n"); 
                return 0; 
 } 

 if (!pop3_pass($pop3, "secret")) { 
                printf("[ERROR] PASS failed!<BR>\n"); 
                return 0; 
 } 

 $articles = pop3_list($pop3); 
 if (!$articles) { 
                printf("[ERROR] LIST failed!<BR>\n"); 
                return 0; 
 } 

 for ($i = 1; $i < $articles ["count"] + 1; $i++) 
 { 
                printf("i=$i<BR>\n"); 
                $data = pop3_retr($pop3,$i); 
                if (!$data) { 
                                printf("data goes wrong on '$i'<BR>\n"); 
                                return 0; 
                } 

                for ($j = 0; $j < $data["count"]; $j++) 
                { 
                                printf("$data[$j]<BR>\n"); 
                } 
 } 
*/ 
?>