加入收藏 | 设为首页 | 会员中心 | 我要投稿 好传媒网 (https://www.haochuanmei.com/)- 科技、建站、经验、云计算、5G、大数据,站长网!
当前位置: 首页 > 站长学院 > PHP教程 > 正文

php socket 使用smtp服务器发送邮件

发布时间:2022-01-19 18:29:41 所属栏目:PHP教程 来源:互联网
导读:/*邮件发送类 *功能:php socket 使用smtp服务器发送邮件 *作者:longlong *时间:2007-11-26 */ class smtp { /* 全局变量 */ var $smtp_port; var $time_out; var $host_name; var $log_file; var $relay_host; var $debug; var $auth; var $user; var $pass
  /*邮件发送类
  *功能:php socket 使用smtp服务器发送邮件
  *作者:longlong
  *时间:2007-11-26
  */
  class smtp
  {
  /* 全局变量 */
  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;
  /* 构造函数 */
  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;
  }
  /* 主函数,发送邮件 */
  function sendmail($flag, $boundary, $to, $from, $subject = "", $body = "", $mailtype, $cc = "", $bcc = "", $additional_headers = "")
  {
    $mail_from = $this->get_address($this->strip_comment($from));
    $body = ereg_replace("(^|(rn))(.)", "1.3", $body);
    $header = "mime-version:1.0rn";
       
    //*
    if($mailtype=="html"){
    //echo $boundary;exit;
  if($flag==2)
  {
    $header .= "content-type:multipart/mixed; boundary= $boundaryrn";
    //$header .= "content-type:text/htmlrn";
  }
  else
  {   
    $header .= "content-type:text/htmlrn";
  }
    }
    //*/
    $header .= "to: ".$to."rn";
    if ($cc != "") {
    $header .= "cc: ".$cc."rn";
    }
    $header .= "from: $from<".$from.">rn";
    $header .= "subject: ".$subject."rn";
    $header .= $additional_headers;
    $header .= "date: ".date("r")."rn";
    $header .= "x-mailer:by redhat (php/".phpversion().")rn";
    //$header.=$body;//edit by shaolong
      
    list($msec, $sec) = explode(" ", microtime());
    $header .= "message-id: <".date("ymdhis", $sec).".".($msec*1000000).".".$mail_from.">rn";
    $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 sent 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 hostn");
    }
    return $sent;
  }
  /* 私有函数 */
  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()
  {
    $this->log_write("trying to ".$this->relay_host.":".$this->smtp_port."n");
    $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."n");
    $this->log_write("error: ".$errstr." (".$errno.")n");
    return false;
    }
    $this->log_write("connected to relay host ".$this->relay_host."n");
    return true;
  }  
  
  function smtp_sockopen_mx($address)
  {
    $domain = ereg_replace("^.+@([^@]+)$", "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 mx host ".$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."rn".$body);
    $this->smtp_debug("> ".str_replace("rn", "n"."> ", $header."n> ".$body."n> "));
    return true;
  }
  
  function smtp_eom()
  {
    fputs($this->sock, "rn.rn");
    $this->smtp_debug(". [eom]n");
    return $this->smtp_ok();
  }
  
  function smtp_ok()
  {
    $response = str_replace("rn", "", fgets($this->sock, 512));
    $this->smtp_debug($response."n");
    if (!ereg("^[23]", $response)) {
    fputs($this->sock, "quitrn");
    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."rn");
    $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 (ereg($comment, $address)) {
    $address = ereg_replace($comment, "", $address);
    }
    return $address;
  }
  function get_address($address)
  {
    $address = ereg_replace("([ trn])+", "", $address);
    $address = ereg_replace("^.*<(.+)>.*$", "1", $address);
    return $address;
  }
  
  function smtp_debug($message)
  {
    if ($this->debug) {
    echo $message;
    }
  }
  }
 

(编辑:好传媒网)

【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!

    热点阅读