您的位置：首页 → 网页设计 → PHP实例 → smtp邮件发送一例

smtp邮件发送一例

时间：2004/11/7 3:22:00来源：本站整理作者：蓝点我要评论(0)

test_smtp.php




require("smtp.php");



$smtp=new smtp_class;



$smtp->host_name="mail.xiaocui.com";

$smtp->localhost="localhost";

$from="webmaster@xiaocui.com";

$to="root@xiaocui.com";

if($smtp->SendMessage(

  $from,

  array(

   $to

  ),

  array(

   "From: $from",

   "To: $to",

   "Subject: Testing Manuel Lemos' SMTP class"

  ),

  "Hello $to,\n\nIt is just to let you know that your SMTP class is working just fine.\n\nBye.\n"))

  echo "Message sent to $to OK.\n";

else

  echo "Cound not send the message to $to.\nError: ".$smtp->error."\n"

?>



smtp.php






class smtp_class

{

var $host_name="";

var $host_port=25;

var $localhost="";

var $timeout=0;

var $error="";

var $debug=1;

var $esmtp=1;

var $esmtp_host="";

var $esmtp_extensions=array();

var $maximum_piped_recipients=100;



/* private variables - DO NOT ACCESS */



var $state="Disconnected";

var $connection=0;

var $pending_recipients=0;



/* Private methods - DO NOT CALL */



Function OutputDebug($message)

{

  echo $message,"
\n";

}



Function GetLine()

{

  for($line="";;)

  {

   if(feof($this->connection))

   {

    $this->error="reached the end of stream while reading from socket";

    return(0);

   }

   if(($data=fgets($this->connection,100))==false)

   {

    $this->error="it was not possible to read line from socket";

    return(0);

   }

   $line.=$data;

   $length=strlen($line);

   if($length>=2

   && substr($line,$length-2,2)=="\r\n")

   {

    $line=substr($line,0,$length-2);

    if($this->debug)

     $this->OutputDebug("< $line");

    return($line);

   }

  }

}



Function PutLine($line)

{

  if($this->debug)

   $this->OutputDebug("> $line");

  if(!fputs($this->connection,"$line\r\n"))

  {

   $this->error="it was not possible to write line to socket";

   return(0);

  }

  return(1);

}



Function PutData($data)

{

  if(strlen($data))

  {

   if($this->debug)

    $this->OutputDebug("> $data");

   if(!fputs($this->connection,$data))

   {

    $this->error="it was not possible to write data to socket";

    return(0);

   }

  }

  return(1);

}



Function VerifyResultLines($code,$responses="")

{

  if(GetType($responses)!="array")

   $responses=array();

  Unset($match_code);



  while(($line=$this->GetLine($this->connection)))

  {

   if(IsSet($match_code))

   {

    if(strcmp(strtok($line," -"),$match_code))

    {

     $this->error=$line;

     return(0);

    }

   }

   else

   {

    $match_code=strtok($line," -");

    if(GetType($code)=="array")

    {

     for($codes=0;$codes
     if($codes>=count($code))

     {

      $this->error=$line;

      return(0);

     }

    }

    else

    {

     if(strcmp($match_code,$code))

     {

      $this->error=$line;

      return(0);

     }

    }

   }

   $responses[]=strtok("");

   if(!strcmp($match_code,strtok($line," ")))

    return(1);

  }

  return(-1);

}



Function FlushRecipients()

{

  if($this->pending_sender)

  {

   if($this->VerifyResultLines("250")<=0)

    return(0);

   $this->pending_sender=0;

  }

  for(;$this->pending_recipients;$this->pending_recipients--)

  {

   if($this->VerifyResultLines(array("250","251"))<=0)

    return(0);

  }

  return(1);

}



/* Public methods */



Function Connect()

{

  $this->error=$error="";

   $this->esmtp_host="";

   $this->esmtp_extensions=array();

  if(!($this->connection=($this->timeout ? fsockopen($this->host_name,$this->host_port,&$errno,&$error,$this->timeout) : fsockopen($this->host_name,$this->host_port))))

  {

   switch($error)

   {

    case -3:

     $this->error="-3 socket could not be created";

     return(0);

    case -4:

     $this->error="-4 dns lookup on hostname \"".$host_name."\" failed";

     return(0);

    case -5:

     $this->error="-5 connection refused or timed out";

     return(0);

    case -6:

     $this->error="-6 fdopen() call failed";

     return(0);

    case -7:

     $this->error="-7 setvbuf() call failed";

     return(0);

    default:

     $this->error=$error." could not connect to the host \"".$this->host_name."\"";

     return(0);

   }

  }

  else

  {

   if(!strcmp($localhost=$this->localhost,"")

   && !strcmp($localhost=getenv("SERVER_NAME"),"")

   && !strcmp($localhost=getenv("HOST"),""))

     $localhost="localhost";

    $success=0;

    if($this->VerifyResultLines("220")>0)

    {

     if($this->esmtp)

     {

      $responses=array();

      if($this->PutLine("EHLO $localhost")

      && $this->VerifyResultLines("250",&$responses)>0)

      {

       $this->esmtp_host=strtok($responses[0]," ");

       for($response=1;$response
       {

        $extension=strtoupper(strtok($responses[$response]," "));

        $this->esmtp_extensions[$extension]=strtok("");

       }

       $success=1;

      }

     }

     if(!$success

     && $this->PutLine("HELO $localhost")

     && $this->VerifyResultLines("250")>0)

      $success=1;

   }

   if($success)

   {

    $this->state="Connected";

    return(1);

   }

   else

   {

    fclose($this->connection);

    $this->connection=0;

    $this->state="Disconnected";

    return(0);

   }

  }

}



Function MailFrom($sender)

{

  if(strcmp($this->state,"Connected"))

  {

   $this->error="connection is not in the initial state";

   return(0);

  }

  $this->error="";

  if(!$this->PutLine("MAIL FROM: &lt;".$sender."&gt;"))

   return(0);

  if(!IsSet($this->esmtp_extensions["PIPELINING"])

  && $this->VerifyResultLines("250")<=0)

   return(0);

  $this->state="SenderSet";

  if(IsSet($this->esmtp_extensions["PIPELINING"]))

   $this->pending_sender=1;

  $this->pending_recipients=0;

  return(1);

}



Function SetRecipient($recipient)

{

  switch($this->state)

  {

   case "SenderSet":

   case "RecipientSet":

    break;

   default:

    $this->error="connection is not in the recipient setting state";

    return(0);

  }

  $this->error="";

  if(!$this->PutLine("RCPT TO:&lt;".$recipient."&gt;"))

   return(0);

  if(IsSet($this->esmtp_extensions["PIPELINING"]))

  {

   $this->pending_recipients++;

   if($this->pending_recipients>=$this->maximum_piped_recipients)

   {

    if(!$this->FlushRecipients())

     return(0);

   }

  }

  else

  {

   if($this->VerifyResultLines(array("250","251"))<=0)

    return(0);

  }

  $this->state="RecipientSet";

  return(1);

}



Function StartData()

{

  if(strcmp($this->state,"RecipientSet"))

  {

   $this->error="connection is not in the start sending data state";

   return(0);

  }

  $this->error="";

  if(!$this->PutLine("DATA"))

   return(0);

  if($this->pending_recipients)

  {

   if(!$this->FlushRecipients())

    return(0);

  }

  if($this->VerifyResultLines("354")<=0)

   return(0);

  $this->state="SendingData";

  return(1);

}



Function PrepareData($data,&$output)

{

  $length=strlen(&$data);

  for($output="",$position=0;$position<$length;)

  {

   $next_position=$length;

   for($current=$position;$current<$length;$current++)

   {

    switch($data[$current])

    {

     case "\n":

      $next_position=$current+1;

      break 2;

     case "\r":

      $next_position=$current+1;

      if($data[$next_position]=="\n")

       $next_position++;

      break 2;

    }

   }

   if($data[$position]==".")

    $output.=".";

   $output.=substr(&$data,$position,$current-$position)."\r\n";

   $position=$next_position;

  }

}



Function SendData($data)

{

  if(strcmp($this->state,"SendingData"))

  {

   $this->error="connection is not in the sending data state";

   return(0);

  }

  $this->error="";

  return($this->PutData(&$data));

}



Function EndSendingData()

{

  if(strcmp($this->state,"SendingData"))

  {

   $this->error="connection is not in the sending data state";

   return(0);

  }

  $this->error="";

  if(!$this->PutLine("\r\n.")

  || $this->VerifyResultLines("250")<=0)

   return(0);

  $this->state="Connected";

  return(1);

}



Function ResetConnection()

{

  switch($this->state)

  {

   case "Connected":

    return(1);

   case "SendingData":

    $this->error="can not reset the connection while sending data";

    return(0);

   case "Disconnected":

    $this->error="can not reset the connection before it is established";

    return(0);

  }

  $this->error="";

  if(!$this->PutLine("RSET")

  || $this->VerifyResultLines("250")<=0)

   return(0);

  $this->state="Connected";

  return(1);

}



Function Disconnect($quit=1)

{

  if(!strcmp($this->state,"Disconnected"))

  {

   $this->error="it was not previously established a SMTP connection";

   return(0);

  }

  $this->error="";

  if(!strcmp($this->state,"Connected")

  && $quit

  && (!$this->PutLine("QUIT")

  || $this->VerifyResultLines("221")<=0))

   return(0);

  fclose($this->connection);

  $this->connection=0;

  $this->state="Disconnected";

  return(1);

}



Function SendMessage($sender,$recipients,$headers,$body)

{

  if(($success=$this->Connect()))

  {

   if(($success=$this->MailFrom($sender)))

   {

    for($recipient=0;$recipient
    {

     if(!($success=$this->SetRecipient($recipients[$recipient])))

      break;

    }

    if($success

    && ($success=$this->StartData()))

    {

     for($header_data="",$header=0;$header
      $header_data.=$headers[$header]."\r\n";

     if(($success=$this->SendData($header_data."\r\n")))

     {

      $this->PrepareData($body,&$body_data);

      $success=$this->SendData($body_data);

     }

     if($success)

      $success=$this->EndSendingData();

    }

   }

   $disconnect_success=$this->Disconnect($success);

   if($success)

    $success=$disconnect_success;

  }

  return($success);

}



};



?>






相关阅读 Windows错误代码大全 Windows错误代码查询激活windows有什么用Mac QQ和Windows QQ聊天记录怎么合并 Mac QQ和Windows QQ聊天记录Windows 10自动更新怎么关闭 如何关闭Windows 10自动更新windows 10 rs4快速预览版17017下载错误问题Win10秋季创意者更新16291更新了什么 win10 16291更新内容windows10秋季创意者更新时间 windows10秋季创意者更新内容kb3150513补丁更新了什么 Windows 10补丁kb3150513是什么

文章评论
发表评论

热门文章 没有查询到任何记录。

最新文章 我的php文件怎么打开_php运算符怎么写 php 如何生成静态页面的函数PHP生成图片缩略图PHP session常见问题集锦及解决办法PHP实现同步远程Mysql

人气排行 DEDE在文章列表文章没有缩略图的不显示图片php+mysq修改用户密码我的php文件怎么打开_如何打开php文件的办法FCKeditor的配置和使用方法使用dedecms建站教程PHP+Ajax实现分页技术图片存储与浏览一例Linux+Apache+PHP+MySQLPHP生成图片缩略图