php smtp邮件发送类

发布时间：2017-03-24编辑：lianpenglin阅读（1248）

<?php
/*
 * smtp邮件发送类
 */
class smtp {
    public $smtp_port;
    public $time_out;
    public $host_name;
    public $log_file;
    public $relay_host;
    public $debug;
    public $auth;
    public $user;
    public $pass;
    /*私有变量*/
    private $sock;
    //构造方法
    public function __construct($relay_host = "",$smtp_port = 25,$auth = false,$user,$pass)
    {
        $this->debug = false;
        $this->smtp_port = $smtp_port;
        $this->relay_host = $relay_host;
        $this->time_out = 30; //is used in fsockopen
        $this->auth = $auth;
        $this->user = $user;
        $this->pass = $pass;
        $this->host_name = "localhost";//is uses in HELO command
        $this->log_file = '';
        $this->sock = FALSE;
    }
    /*邮件发送*/
    function sendmail($to,$from,$subject = '',$body="",$mailtype='',$cc='',$bcc='',$additional_headers="")
    {
        $mail_from = $this->get_address($this->strip_comment($from));
        $body = preg_replace("(^|(\r\n))(\.)","\1.\3",$body);
        $header = "MIME-Version:1.0\r\n";
        if($mailtype == "HTML") {
            $header .= "Content-Type:text/html\r\n";
        }
        //收件人地址
        $header .= "To :".$to.'\r\n';
        //抄送地址
        if ($cc != "") {
            $header .= "Cc:".$cc.'\r\n';
        }
        //构造邮件头
        $header .= "From :$from<".$from.">\r\n";
        $header .= "Subject:".$subject."\r\n";
        $header .= $additional_headers;
        $header .= "Date:".date("r")."\r\n";
        $header .= "X-Mailer:By PHPMailer (PHP/".phpversion().")\r\n";
        list($msec,$sec) = explode("", microtime());
        $header .= "Message-ID:<".date('YmdHis',$sec).".".($msec*1000000).".".$mail_from.">\r\n";
        $TO = explode(",", $this->strip_comment($to));
        if($cc != "") {
            $TO = array_merge($TO,explode(',', $this->strip_comment($cc)));
        }
        if($bcc != "") {
            $TO = array_merge($TO,explode(',', $this->strip_comment($bcc)));
        }
        $sent = true;
        foreach ($TO as $rcpt_to) {
            $rcpt_to = $this->get_address($rcpt_to);
            if(!$this->smtp_sockopen($rcpt_to)){
                $this->log_write("Error:Cannot send email to".$rcpt_to.'\n');
                $sent = FALSE;
                continue;
            }
            if($this->smtp_send($this->host_name,$mail_from,$rcpt_to,$header,$body)){
                $this->log_write("E-mail has been send to <".$rcpt_to.">\n");
            } else {
                $this->log_write("Error:Cannot send email to <".$rcpt_to.">\n");
                $sent = FALSE;
            }
            fclose($this->sock);
            $this->log_write("Disconnected from remote host\n");
        }
        return $sent;
    }
    //私有方法
    private function smtp_send($helo,$from,$to,$header,$body = '')
    {
        if(!$this->smtp_putcmd('HELO',$helo)){
            return $this->smtp_error("sending HELO command");
        }
        //认证过程
        if($this->auth){
            if(!$this->smtp_putcmd("AUTH LOGIN",base64_encode($this->user))){
                return $this->smtp_error('sending HELO command');
            }
            if(!$this->smtp_putcmd("",base64_encode($this->pass))){
                return $this->smtp_error("sending HELO commang");
            }
        }
        if(!$this->smtp_pucmd("MAIL","FROM:<".$from.">")){
            return $this->smtp_error("sendind RCPT TO command");
        }
        if(!$this->smtp_putcmd("DATA")){
            return $this->smtp_error("sending DATA command");
        }
        if(!$this->smtp_message($header,$body)){
            return $this->smtp_error("sending message");
        }
        if(!$this->smtp_eom()){
            return $this->smtp_error("sending <CR><LE>.<CR><LF>[EOM]");
        }
        if($this->smtp_putcmd("QUIT")){
            return $this->smtp_error("sending QUIT command");
        }
        return TRUE;
    }
    function smtp_sockopen($address)
    {
        if($this->relay_host == "") {
            return $this->smtp_sockopen_mx($address);
        } else {
            return $this->smtp_sockopen_relay();
        }
    }
    function smtp_sockopen_relay()
    {
        $this->log_write("Trying to ".$this->relay_host.":".$this->smtp_port.'\n');
        $this->sock = @fsockopen($this->relay_host,$this->smtp,$errno,$errstr,$this->time_out);
        if(!($this->sock && $this->smtp_ok())){
            $this->log_write("Error:Cannot connect to relay host".$this->relay_host.'\n');
            $this->log_write("Error:".$errstr."(".$errno.")\n");
            return false;
        }
        $this->log_write("Conneted to relay host".$this->relay_host."\n");
        return true;
    }
    //检查域名MX记录是否正确
    function smtp_sockopen_mx($address){
        $domain = preg_replace("^.+@a([^@]+)$", "\1", $address);
        if(!@getmxrr($domain, $MXHOSTS)){
            $this->log_write("Error:Cannot resolve MX\"".$domain."\"\n");
            return FALSE;
        }
        foreach ($MXHOSTS as $host) {
            $this->log_write("Trying to ".$host.":".$this->smtp_port."\n");
            $this->sock = @fsockopen($host,$this->smtp_port,$errno,$errstr,$this->time_out);
            if(!($this->sock && $this->smtp_ok())){
                $this->log_write("Warning:Cannot connect to mxhost".$host."\n");
                $this->log_write("Error:".$errstr."(".$errno.")\n");
                continue;
            }
            $this->log_write("Connected to mx host".$host."\n");
            return TRUE;
        }
        $this->log_write("Error:Cannot connect to any mx hosts (".implode(',', $MXHOSTS).")\n");
        return FALSE;
    }
    function smtp_message($header,$body)
    {
        fputs($this->sock, $header."\r\n".$body);
        $this->smtp_debug(">".str_replace("\r\n", "\n".">", $header."\n>".$body."\n>"));
        return true;
    }
    function smtp_eom()
    {
        fputs($this->sock, "\r\n.\r\n");
        $this->smtp_debug(".[EOM]\n");
        return $this->smtp_ok();
    }
    function smtp_ok()
    {
        $response = str_replace("\r\n", "", fgets($this->sock,512));
        $this->smtp_debug($response."\n");
        if(!preg_match("^[23]", $response)) {
            fputs($this->sock, "QUIT\r\n");
            fgets($this->sock,512);
            $this->log_write("Error:Remote host returned\"".$response."\"\n");
            return false;
        }
        return true;
    }
    function smtp_putcmd($cmd,$arg= '')
    {
        if($arg != "") {
            if($cmd == "") $cmd = $arg;
            else $cmd = $cmd."".$arg;
        }
        fputs($this->sock, $cmd."\r\n");
        $this->smtp_debug(">".$cmd."\n");
        return $this->smtp_ok();
    }
    function smtp_error($string)
    {
        $this->log_write("Error:Error occurred while".$string."\n");
        return false;
    }
    //记录日志
    function log_write($message)
    {
        $this->smtp_debug($message);
        if($this->log_file == "") {
            return true;
        }
        $message = date('M d H:i:s').get_current_user()."[".getmypid()."]:".$message;
        if(!@file_exists($this->log_file) || !($fp = @fopen($this->log_file, "a"))){
            $this->smtp_debug("Warning:Cannot open log file\"".$this->log_file."\"\n");
            return FALSE;
        }
        flock($fp, LOCK_EX);
        fputs($fp, $message);
        fclose($fp);
        return TRUE;
    }
    function strip_comment($address){
        $comment = "\([^()]*\)";
        while(preg_match($comment, $address)){
            $address = preg_replace($comment, "", $address);
        }
        return $address;
    }
    function get_address($address){
        $address = preg_replace("([\t\r\n])+","", $address);
        $address = preg_replace("^.*<(.+)>.*$", "\1", $address);
        return $address;
    }
    function smtp_debug($message)
    {
        if($this->debug){
            echo $message;
        }
    }
}