smtp邮件发送一例

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(" 　　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") 　　return(0);
　 $this->pending_sender=0;
　}
　for(;$this->pending_recipients;$this->pending_recipients--)
　{
　 if($this->VerifyResultLines(array("250","251")) 　　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: "))
　 return(0);
　if(!IsSet($this->esmtp_extensions["PIPELINING"])
　&& $this->VerifyResultLines("250") 　 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:"))
　 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")) 　　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") 　 return(0);
　$this->state="SendingData";
　return(1);
}

Function PrepareData($data,&$output)
{
　$length=strlen(&$data);
　for($output="",$position=0;$position 　{
　 $next_position=$length;
　 for($current=$position;$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") 　 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") 　 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") 　 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);
}

};

?>