zoukankan      html  css  js  c++  java
  • php发送邮件

    <?php
    //smtp类
    class smtp
    {
        /* Public Variables */
        var $smtp_port;
        var $time_out;
        var $host_name;
        var $log_file;
        var $relay_host;
        var $debug;
        var $auth;
        var $user;
        var $pass;
    
        /* Private Variables */ 
        var $sock;
    
        /* Constractor */
    
    
        function smtp($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;//auth
            $this->user = $user;
            $this->pass = $pass;
            
            #
    
            $this->host_name = "localhost"; //is used in HELO command 
            $this->log_file = "";
    
            $this->sock = FALSE;
    
    
        }
    
    
        /* Main Function */
        function sendmail($to, $from, $subject = "", $body = "", $mailtype, $cc = "", $bcc = "", $additional_headers = "")
        {
            $mail_from = $this->get_address($this->strip_comment($from));
            $body = preg_replace("'(^|(
    ))(.)'si", "1.3", $body);
            $header = "MIME-Version:1.0
    ";
    
            $header .= "To: ".$to."
    ";
    
            if ($cc != "") {
                $header .= "Cc: ".$cc."
    ";
            }
    
            $header .= "From: <".$from.">
    ";
            $header .= "Subject: ".$subject."
    ";
            $header .= $additional_headers;
            $header .= "Date: ".date("r")."
    ";
            $header .= "X-Mailer:By Redhat (PHP/".phpversion().")
    ";
            if($mailtype=="HTML"){
                  //$header .= "Content-Type:text/html
    ";  
                $header .= "Content-Type:text/html;charset="gbk"
    ";
                //charset="gbk" 中文
            }
            
            
    
            list($msec, $sec) = explode(" ", microtime());
    
            $header .= "Message-ID: <".date("YmdHis", $sec).".".($msec*1000000).".".$mail_from.">
    ";
    
            $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."
    ");
                    $sent = FALSE;
                    continue;
                }
    
                if ($this->smtp_send($this->host_name, $mail_from, $rcpt_to, $header, $body)) {
                    $this->log_write("E-mail has been sent to <".$rcpt_to.">
    ");
                } else {
                    $this->log_write("Error: Cannot send email to <".$rcpt_to.">
    ");
                    $sent = FALSE;
                }
    
                fclose($this->sock);
    
                $this->log_write("Disconnected from remote host
    ");
            }
    
            return $sent;
    
        }
    
    /* Private Functions */
        function smtp_send($helo, $from, $to, $header, $body = "")
        {
            if (!$this->smtp_putcmd("HELO", $helo)) {
    
                return $this->smtp_error("sending HELO command");
            }
    
            #auth
    
            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 command");
                }
            }
    
            #
    
            if (!$this->smtp_putcmd("MAIL", "FROM:<".$from.">")) {
                return $this->smtp_error("sending MAIL FROM command");
            }
    
            if (!$this->smtp_putcmd("RCPT", "TO:<".$to.">")) {
                return $this->smtp_error("sending 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><LF>.<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()
        {
            $errno = 0;
            $errstr = "";
            $this->log_write("Trying to ".$this->relay_host.":".$this->smtp_port."
    ");
            $this->sock = @fsockopen($this->relay_host, $this->smtp_port, $errno, $errstr, $this->time_out);
            if (!($this->sock && $this->smtp_ok())) {
                $this->log_write("Error: Cannot connenct to relay host ".$this->relay_host."
    ");
                $this->log_write("Error: ".$errstr." (".$errno.")
    ");
                return FALSE;
            }
    
            $this->log_write("Connected to relay host ".$this->relay_host."
    ");
            return TRUE;
        }
      
    
        function smtp_sockopen_mx($address)
        {
            $errno=0;
            $errstr="";
            $domain = preg_replace("'^.+@([^@]+)$'si", "1", $address);
            $MXHOSTS = array();
            if (!@getmxrr($domain, $MXHOSTS)) {
                $this->log_write("Error: Cannot resolve MX "".$domain.""
    ");
                return FALSE;
            }
    
            foreach ($MXHOSTS as $host) {
                $this->log_write("Trying to ".$host.":".$this->smtp_port."
    ");
                $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 mx host ".$host."
    ");
                    $this->log_write("Error: ".$errstr." (".$errno.")
    ");
    
                    continue;
                }
    
                $this->log_write("Connected to mx host ".$host."
    ");
                return TRUE;
            }
    
            $this->log_write("Error: Cannot connect to any mx hosts (".implode(", ", $MXHOSTS).")
    ");
            return FALSE;
        }
    
        function smtp_message($header, $body)
        {
            fputs($this->sock, $header."
    ".$body);
            $this->smtp_debug("> ".str_replace("
    ", "
    "."> ", $header."
    > ".$body."
    > "));
    
            return TRUE;
        }
       
        function smtp_eom()
        {
            fputs($this->sock, "
    .
    ");
            $this->smtp_debug(". [EOM]
    ");
            return $this->smtp_ok();
        }
    
        function smtp_ok()
        {
            $response = str_replace("
    ", "", fgets($this->sock, 512));
            $this->smtp_debug($response."
    ");
    
            if (!preg_match("'^[23]'si", $response)) {
                fputs($this->sock, "QUIT
    ");
                fgets($this->sock, 512);  
                $this->log_write("Error: Remote host returned "".$response.""
    ");
                return FALSE;
            }
            return TRUE;
        }
    
    
        function smtp_putcmd($cmd, $arg = "")
        {
            if ($arg != "") {
                if($cmd=="") $cmd = $arg;
                else $cmd = $cmd." ".$arg;
            }
            fputs($this->sock, $cmd."
    ");
            $this->smtp_debug("> ".$cmd."
    ");
            return $this->smtp_ok();
        }
    
        function smtp_error($string)
        {
            $this->log_write("Error: Error occurred while ".$string.".
    ");
            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.""
    ");
                return FALSE;;
            }
            flock($fp, LOCK_EX);
            fputs($fp, $message);
            fclose($fp);
    
            return TRUE;
        }
    
        function strip_comment($address)
        {
            $comment = "'([^()]*)'si";
            while (preg_match($comment, $address)) {
                $address = preg_replace($comment, "", $address);
            }
            return $address;
        }
    
        function get_address($address)
        {
            $address = preg_replace("'([ 	
    ])+'si", "", $address);
            $address = preg_replace("'^.*<(.+)>.*$'si", "1", $address);
            return $address;
        }
    
        function smtp_debug($message)
        {
            if ($this->debug) {
            echo $message;
            }
        }
        
        
    }
    
    //调用smtp类发送socket验证邮件
    
    function postmail($to,$subject = "",$body = "", $mailtype){
        $body = preg_replace("'(^|(
    ))(.)'si", "1.3", $body);
    
    
        $smtpserver = "smtp.staff.hexun.com";                    #SMTP服务器地址
        $smtpserverport =25;                                    #SMTP服务器端口,E-mail是25
        $smtpusermail = "edge_noreply@staff.hexun.com";             #SMTP服务器的用户邮箱
        $smtpemailto = $to;                                        #发送给谁,逗号分隔可以多个        
        $smtpuser = "edge_noreply@staff.hexun.com";                                    #SMTP服务器的用户帐号
        $smtppass = "kv17ovxeoea}tNOw";                            #SMTP服务器的用户密码
        $mailsubject = $subject;                            #邮件标题
        $mailbody = $body;                                        #邮件内容
    
        $smtp = new smtp($smtpserver,$smtpserverport,true,$smtpuser,$smtppass);
        #true 表示使用身份验证,否则不使用身份验证.
        
        $smtp->debug = FALSE;
        #是否显示发送的调试信息
        
        $send = $smtp->sendmail($smtpemailto, $smtpusermail, $mailsubject, $mailbody, $mailtype);
        #调用发送函数
        
        return $send;
    }
    
    
    define('LOCAL_IP', '127.0.0.1');
    
    ?>
    require_once(dirname(__FILE__) . "/smtp.php");
    
    $to = "xxx@xxx.com";
    $subject = "[警告]xxx数据列表获取异常";
    $mailtype = "HTML";
    $body = '';
    
    if (!$link) {
        $body = "Unable to connect or select mssql database!
    <br>";
        
        if (strlen($body) > 0) {
            $body .= "<br><br><br><br>[系统邮件,请勿回复此地址]
    ";
                
            $return = postmail($to, $subject, $body , $mailtype);
        }
        die('Unable to connect or select database!
    ');
    }
  • 相关阅读:
    《RocketMQ源码系列》心跳机制
    《RocketMQ源码系列》broker是如何注册到nameserver的
    使用redis客户端工具RedisClient连接windows和linux下的redis并解决无法连接redis的问题
    windows下安装Linux
    redis客户端工具RedisClient的使用
    redis哨兵机制配置
    redis数据的两种持久化方式rdb和aof对比(二)
    redis数据的两种持久化方式rdb和aof对比(一)
    windows下的redis主从复制
    redis持久化配置:rdb和aof
  • 原文地址:https://www.cnblogs.com/grapes/p/3583969.html
Copyright © 2011-2022 走看看