PHP“收发”邮件的一个程序

<?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");
                }
}
*/
?>

原文转自：http://www.ltesting.net