Some companies do not like such access and will report it is a cracking attempt. Maybe it's not as big an issue as it was several years ago, but there are ignorant companies out there. I didn't understand it either, but obviously it happens.
I wrote a class that you can use for the validation with SMTP. It will only work on Linux as Windows doesn't have the getmxrr() function or other DNS functions.
If needed on windows, one can replace the DNS functions with the Pear Net_DNS library.
http://pear.php.net/package/Net_DNS
<? /** * Validate an Email Address Via SMTP * This queries the SMTP server to see if the email address is accepted. * @copyright http://creativecommons.org/licenses/by/2.0/ - Please keep this comment intact * @author gabe@fijiwebdesign.com * @contributors adnan@barakatdesigns.net * @version 0.1a */ class SMTP_validateEmail { var $sock; var $user; var $domain; var $port = 25; var $max_conn_time = 30; var $max_read_time = 5; var $from_user = 'user'; var $from_domain = 'localhost'; var $debug = false; function SMTP_validateEmail($email = false, $sender = false) { if ($email) { $this->setEmail($email); } if ($sender) { $this->setSenderEmail($sender); } } function setEmail($email) { list($user, $domain) = explode('@', $email); $this->user = $user; $this->domain = $domain; } function setSenderEmail($email) { list($user, $domain) = explode('@', $email); $this->from_user = $user; $this->from_domain = $domain; } /** * Validate an Email Address * @param String $email Email to validate (recipient email) * @param String $sender Senders Email */ function validate($email = false, $sender = false) { if ($email) { $this->setEmail($email); } if ($sender) { $this->setSenderEmail($sender); } // retrieve SMTP Server via MX query on domain $result = getmxrr($this->domain, $hosts, $mxweights); // retrieve MX priorities for($n=0; $n < count($hosts); $n++){ $mxs[$hosts[$n]] = $mxweights[$n]; } asort($mxs); // last fallback is the original domain array_push($mxs, $this->domain); $this->debug(print_r($mxs, 1)); $timeout = $this->max_conn_time/count($hosts); // try each host while(list($host) = each($mxs)) { // connect to SMTP server $this->debug("try $host:$this->port\n"); if ($this->sock = fsockopen($host, $this->port, $errno, $errstr, (float) $timeout)) { socket_set_blocking($this->sock, false); break; } } $code = substr($reply, 0, 3); if($code != '220') { // MTA gave an error... return false; } // did we get a TCP socket if ($this->sock) { $resp = ''; $start = $this->microtime_float(); while(1) { $reply = fread($this->sock, 2082); $resp .= $reply; if (($resp != '' && trim($reply) == '') || ($this->microtime_float() - $start > $this->max_read_time )) { break; } } // say helo $this->send("HELO ".$this->from_domain); // tell of sender $this->send("MAIL FROM: <".$this->from_user.'@'.$this->from_domain.">"); // ask of recepient $reply = $this->send("RCPT TO: <".$this->user.'@'.$this->domain.">"); // quit $this->send("quit"); // close socket fclose($this->sock); // get code and msg from response $code = substr($reply, 0, 3); if ($code == '250') { // you received 250 so the email address was accepted return true; } elseif ($code == '451' || $code == '452') { // you received 45[12] so the email address was greylisted (or some temporary error occured on the MTA) - so assume mailbox exists return true; } } return false; } function send($msg) { fwrite($this->sock, $msg."\r\n"); $resp = ''; $start = $this->microtime_float(); while(1) { $reply = fread($this->sock, 2082); $resp .= $reply; if (($resp != '' && trim($reply) == '') || ($this->microtime_float() - $start > $this->max_read_time )) { break; } } $this->debug(">>>\n$msg\n"); $this->debug("<<<\n$resp"); return $resp; } /** * Simple function to replicate PHP 5 behaviour. http://php.net/microtime */ function microtime_float() { list($usec, $sec) = explode(" ", microtime()); return ((float)$usec + (float)$sec); } function debug($str) { if ($this->debug) { echo $str; } } } ?>
socket_set_blocking($this->sock, false);
function send($msg) { fwrite($this->sock, $msg."\r\n"); $resp = ''; $start = $this->microtime_float(); while(1) { $reply = fread($this->sock, 2082); $resp .= $reply; if (($resp != '' && trim($reply) == '') || ($this->microtime_float() - $start > $this->max_read_time )) { break; } } $this->debug(">>>\n$msg\n"); $this->debug("<<<\n$resp"); return $resp; }
$this->microtime_float() - $start > $this->max_read_time )
Theres a bit of guessing in that class, in the reading from the socket.
The class currently reads from the socket between client and MTA in non-blocking mode.
PHP Syntax (Toggle Plain Text)
socket_set_blocking($this->sock, false);
It tries to read from the socket until it receives a few bytes, and will finish reading until that stream is done.
PHP Syntax (Toggle Plain Text)
function send($msg) { fwrite($this->sock, $msg."\r\n"); $resp = ''; $start = $this->microtime_float(); while(1) { $reply = fread($this->sock, 2082); $resp .= $reply; if (($resp != '' && trim($reply) == '') || ($this->microtime_float() - $start > $this->max_read_time )) { break; } } $this->debug(">>>\n$msg\n"); $this->debug("<<<\n$resp"); return $resp; }
The timer:
PHP Syntax (Toggle Plain Text)
$this->microtime_float() - $start > $this->max_read_time )
makes sure it doesn't keep reading for ever.
I'd think there is a better way to do this, a more standard way? maybe one defined in the SMTP specs?
Is there a delimiter to wait for when making a read, to know the MTA has finished the response?
At the moment, if the MTA doesn't respond before SMTP_validateEmail::max_read_time then the read will stop, and nothing will be received.
I started with having reads in blocking mode, but with hotmail it hanged on the first read? Maybe it was due to not reading the HELO first, and now that you're updated that reading in blocking mode should work with all MTAs?
edit: Do you think using the "verify" command before trying 'RCPT TO' would be more polite and should give less chance of blacklisting?
<? /** * Validate an Email Address Via SMTP * This queries the SMTP server to see if the email address is accepted. * @copyright http://creativecommons.org/licenses/by/2.0/ - Please keep this comment intact * @author gabe@fijiwebdesign.com * @contributers adnan@barakatdesigns.net * @version 0.1a */ class SMTP_validateEmail { var $sock; var $user; var $domain; var $port = 25; var $max_conn_time = 30; var $max_read_time = 5; var $from_user = 'user'; var $from_domain = 'localhost'; var $debug = false; function SMTP_validateEmail($email = false, $sender = false) { if ($email) { $this->setEmail($email); } if ($sender) { $this->setSenderEmail($sender); } } function setEmail($email) { list($user, $domain) = explode('@', $email); $this->user = $user; $this->domain = $domain; } function setSenderEmail($email) { list($user, $domain) = explode('@', $email); $this->from_user = $user; $this->from_domain = $domain; } /** * Validate an Email Address * @param String $email Email to validate (recipient email) * @param String $sender Senders Email */ function validate($email = false, $sender = false) { if ($email) { $this->setEmail($email); } if ($sender) { $this->setSenderEmail($sender); } // retrieve SMTP Server via MX query on domain $result = getmxrr($this->domain, $hosts, $mxweights); // retrieve MX priorities for($n=0; $n < count($hosts); $n++){ $mxs[$hosts[$n]] = $mxweights[$n]; } asort($mxs); // last fallback is the original domain array_push($mxs, $this->domain); $this->debug(print_r($mxs, 1)); $timeout = $this->max_conn_time/count($hosts); // try each host while(list($host) = each($mxs)) { // connect to SMTP server $this->debug("try $host:$this->port\n"); if ($this->sock = fsockopen($host, $this->port, $errno, $errstr, (float) $timeout)) { stream_set_timeout($this->sock, $this->max_read_time); break; } } // did we get a TCP socket if ($this->sock) { $reply = fread($this->sock, 2082); preg_match('/^([0-9]{3}) /ims', $reply, $matches); $code = isset($matches[1]) ? $matches[1] : ''; if($code != '220') { // MTA gave an error... return false; } // say helo $this->send("HELO ".$this->from_domain); // tell of sender $this->send("MAIL FROM: <".$this->from_user.'@'.$this->from_domain.">"); // ask of recepient $reply = $this->send("RCPT TO: <".$this->user.'@'.$this->domain.">"); // quit $this->send("quit"); // close socket fclose($this->sock); // get code and msg from response preg_match('/^([0-9]{3}) /ims', $reply, $matches); $code = isset($matches[1]) ? $matches[1] : ''; if ($code == '250') { // you received 250 so the email address was accepted return true; } elseif ($code == '451' || $code == '452') { // you received 451 so the email address was greylisted (or some temporary error occured on the MTA) - so assume is ok return true; } } return false; } function send($msg) { fwrite($this->sock, $msg."\r\n"); $reply = fread($this->sock, 2082); $this->debug(">>>\n$msg\n"); $this->debug("<<<\n$reply"); return $reply; } /** * Simple function to replicate PHP 5 behaviour. http://php.net/microtime */ function microtime_float() { list($usec, $sec) = explode(" ", microtime()); return ((float)$usec + (float)$sec); } function debug($str) { if ($this->debug) { echo $str; } } } ?>
function setEmail($email) { $parts = explode('@', $email); $this->domain = array_pop($parts); $this->user= implode('@', $parts); }
<?php /** * Validate Email Addresses Via SMTP * This queries the SMTP server to see if the email address is accepted. * @copyright http://creativecommons.org/licenses/by/2.0/ - Please keep this comment intact * @author gabe@fijiwebdesign.com * @contributers adnan@barakatdesigns.net * @version 0.1a */ class SMTP_validateEmail { /** * PHP Socket resource to remote MTA * @var resource $sock */ var $sock; /** * Current User being validated */ var $user; /** * Current domain where user is being validated */ var $domain; /** * List of domains to validate users on */ var $domains; /** * SMTP Port */ var $port = 25; /** * Maximum Connection Time to an MTA */ var $max_conn_time = 30; /** * Maximum time to read from socket */ var $max_read_time = 5; /** * username of sender */ var $from_user = 'user'; /** * Host Name of sender */ var $from_domain = 'localhost'; /** * Nameservers to use when make DNS query for MX entries * @var Array $nameservers */ var $nameservers = array( '192.168.0.1' ); var $debug = false; /** * Initializes the Class * @return SMTP_validateEmail Instance * @param $email Array[optional] List of Emails to Validate * @param $sender String[optional] Email of validator */ function SMTP_validateEmail($emails = false, $sender = false) { if ($emails) { $this->setEmails($emails); } if ($sender) { $this->setSenderEmail($sender); } } function _parseEmail($email) { $parts = explode('@', $email); $domain = array_pop($parts); $user= implode('@', $parts); return array($user, $domain); } /** * Set the Emails to validate * @param $emails Array List of Emails */ function setEmails($emails) { foreach($emails as $email) { list($user, $domain) = $this->_parseEmail($email); if (!isset($this->domains[$domain])) { $this->domains[$domain] = array(); } $this->domains[$domain][] = $user; } } /** * Set the Email of the sender/validator * @param $email String */ function setSenderEmail($email) { $parts = $this->_parseEmail($email); $this->from_user = $parts[0]; $this->from_domain = $parts[1]; } /** * Validate Email Addresses * @param String $emails Emails to validate (recipient emails) * @param String $sender Sender's Email * @return Array Associative List of Emails and their validation results */ function validate($emails = false, $sender = false) { $results = array(); if ($emails) { $this->setEmails($emails); } if ($sender) { $this->setSenderEmail($sender); } // query the MTAs on each Domain foreach($this->domains as $domain=>$users) { $mxs = array(); // retrieve SMTP Server via MX query on domain list($hosts, $mxweights) = $this->queryMX($domain); // retrieve MX priorities for($n=0; $n < count($hosts); $n++){ $mxs[$hosts[$n]] = $mxweights[$n]; } asort($mxs); // last fallback is the original domain array_push($mxs, $this->domain); $this->debug(print_r($mxs, 1)); $timeout = $this->max_conn_time/count($hosts); // try each host while(list($host) = each($mxs)) { // connect to SMTP server $this->debug("try $host:$this->port\n"); if ($this->sock = fsockopen($host, $this->port, $errno, $errstr, (float) $timeout)) { stream_set_timeout($this->sock, $this->max_read_time); break; } } // did we get a TCP socket if ($this->sock) { $reply = fread($this->sock, 2082); $this->debug("<<<\n$reply"); preg_match('/^([0-9]{3}) /ims', $reply, $matches); $code = isset($matches[1]) ? $matches[1] : ''; if($code != '220') { // MTA gave an error... foreach($users as $user) { $results[$user.'@'.$domain] = false; } continue; } // say helo $this->send("HELO ".$this->from_domain); // tell of sender $this->send("MAIL FROM: <".$this->from_user.'@'.$this->from_domain.">"); // ask for each recepient on this domain foreach($users as $user) { // ask of recepient $reply = $this->send("RCPT TO: <".$user.'@'.$domain.">"); // get code and msg from response preg_match('/^([0-9]{3}) /ims', $reply, $matches); $code = isset($matches[1]) ? $matches[1] : ''; if ($code == '250') { // you received 250 so the email address was accepted $results[$user.'@'.$domain] = true; } elseif ($code == '451' || $code == '452') { // you received 451 so the email address was greylisted (or some temporary error occured on the MTA) - so assume is ok $results[$user.'@'.$domain] = true; } else { $results[$user.'@'.$domain] = false; } } // quit $this->send("quit"); // close socket fclose($this->sock); } } return $results; } function send($msg) { fwrite($this->sock, $msg."\r\n"); $reply = fread($this->sock, 2082); $this->debug(">>>\n$msg\n"); $this->debug("<<<\n$reply"); return $reply; } /** * Query DNS server for MX entries * @return */ function queryMX($domain) { $hosts = array(); $mxweights = array(); if (function_exists('getmxrr')) { getmxrr($domain, $hosts, $mxweights); } else { // windows, we need Net_DNS require_once 'Net/DNS.php'; $resolver = new Net_DNS_Resolver(); $resolver->debug = $this->debug; // nameservers to query $resolver->nameservers = $this->nameservers; $resp = $resolver->query($domain, 'MX'); if ($resp) { foreach($resp->answer as $answer) { $hosts[] = $answer->exchange; $mxweights[] = $answer->preference; } } } return array($hosts, $mxweights); } /** * Simple function to replicate PHP 5 behaviour. http://php.net/microtime */ function microtime_float() { list($usec, $sec) = explode(" ", microtime()); return ((float)$usec + (float)$sec); } function debug($str) { if ($this->debug) { echo htmlentities($str); } } } ?>
$mxs[$this->domain] = '0';
Hey Guys,
I've updated the SMTP_validateEmail class with better email address parsing, and it can now validate multiple emails on the same domain via a single socket connection for efficiency.
Also added is support for Windows clients, which requires Net_DNS.
http://pear.php.net/package/Net_DNS
<?php /** * Validate Email Addresses Via SMTP * This queries the SMTP server to see if the email address is accepted. * @copyright http://creativecommons.org/licenses/by/2.0/ - Please keep this comment intact * @author gabe@fijiwebdesign.com * @contributers adnan@barakatdesigns.net * @version 0.1a */ class SMTP_validateEmail { /** * PHP Socket resource to remote MTA * @var resource $sock */ var $sock; /** * Current User being validated */ var $user; /** * Current domain where user is being validated */ var $domain; /** * List of domains to validate users on */ var $domains; /** * SMTP Port */ var $port = 25; /** * Maximum Connection Time to an MTA */ var $max_conn_time = 30; /** * Maximum time to read from socket */ var $max_read_time = 5; /** * username of sender */ var $from_user = 'user'; /** * Host Name of sender */ var $from_domain = 'localhost'; /** * Nameservers to use when make DNS query for MX entries * @var Array $nameservers */ var $nameservers = array( '192.168.0.1' ); var $debug = false; /** * Initializes the Class * @return SMTP_validateEmail Instance * @param $email Array[optional] List of Emails to Validate * @param $sender String[optional] Email of validator */ function SMTP_validateEmail($emails = false, $sender = false) { if ($emails) { $this->setEmails($emails); } if ($sender) { $this->setSenderEmail($sender); } } function _parseEmail($email) { $parts = explode('@', $email); $domain = array_pop($parts); $user= implode('@', $parts); return array($user, $domain); } /** * Set the Emails to validate * @param $emails Array List of Emails */ function setEmails($emails) { foreach($emails as $email) { list($user, $domain) = $this->_parseEmail($email); if (!isset($this->domains[$domain])) { $this->domains[$domain] = array(); } $this->domains[$domain][] = $user; } } /** * Set the Email of the sender/validator * @param $email String */ function setSenderEmail($email) { $parts = $this->_parseEmail($email); $this->from_user = $parts[0]; $this->from_domain = $parts[1]; } /** * Validate Email Addresses * @param String $emails Emails to validate (recipient emails) * @param String $sender Sender's Email * @return Array Associative List of Emails and their validation results */ function validate($emails = false, $sender = false) { $results = array(); if ($emails) { $this->setEmails($emails); } if ($sender) { $this->setSenderEmail($sender); } // query the MTAs on each Domain foreach($this->domains as $domain=>$users) { $mxs = array(); // retrieve SMTP Server via MX query on domain list($hosts, $mxweights) = $this->queryMX($domain); // retrieve MX priorities for($n=0; $n < count($hosts); $n++){ $mxs[$hosts[$n]] = $mxweights[$n]; } asort($mxs); // last fallback is the original domain $mxs[$this->domain] = '0'; $this->debug(print_r($mxs, 1)); $timeout = $this->max_conn_time/count($hosts); // try each host while(list($host) = each($mxs)) { // connect to SMTP server $this->debug("try $host:$this->port\n"); if ($this->sock = fsockopen($host, $this->port, $errno, $errstr, (float) $timeout)) { stream_set_timeout($this->sock, $this->max_read_time); break; } } // did we get a TCP socket if ($this->sock) { $reply = fread($this->sock, 2082); $this->debug("<<<\n$reply"); preg_match('/^([0-9]{3}) /ims', $reply, $matches); $code = isset($matches[1]) ? $matches[1] : ''; if($code != '220') { // MTA gave an error... foreach($users as $user) { $results[$user.'@'.$domain] = false; } continue; } // say helo $this->send("HELO ".$this->from_domain); // tell of sender $this->send("MAIL FROM: <".$this->from_user.'@'.$this->from_domain.">"); // ask for each recepient on this domain foreach($users as $user) { // ask of recepient $reply = $this->send("RCPT TO: <".$user.'@'.$domain.">"); // get code and msg from response preg_match('/^([0-9]{3}) /ims', $reply, $matches); $code = isset($matches[1]) ? $matches[1] : ''; if ($code == '250') { // you received 250 so the email address was accepted $results[$user.'@'.$domain] = true; } elseif ($code == '451' || $code == '452') { // you received 451 so the email address was greylisted (or some temporary error occured on the MTA) - so assume is ok $results[$user.'@'.$domain] = true; } else { $results[$user.'@'.$domain] = false; } } // quit $this->send("quit"); // close socket fclose($this->sock); } } return $results; } function send($msg) { fwrite($this->sock, $msg."\r\n"); $reply = fread($this->sock, 2082); $this->debug(">>>\n$msg\n"); $this->debug("<<<\n$reply"); return $reply; } /** * Query DNS server for MX entries * @return */ function queryMX($domain) { $hosts = array(); $mxweights = array(); if (function_exists('getmxrr')) { getmxrr($domain, $hosts, $mxweights); } else { // windows, we need Net_DNS require_once 'Net/DNS.php'; $resolver = new Net_DNS_Resolver(); $resolver->debug = $this->debug; // nameservers to query $resolver->nameservers = $this->nameservers; $resp = $resolver->query($domain, 'MX'); if ($resp) { foreach($resp->answer as $answer) { $hosts[] = $answer->exchange; $mxweights[] = $answer->preference; } } } return array($hosts, $mxweights); } /** * Simple function to replicate PHP 5 behaviour. http://php.net/microtime */ function microtime_float() { list($usec, $sec) = explode(" ", microtime()); return ((float)$usec + (float)$sec); } function debug($str) { if ($this->debug) { echo htmlentities($str); } } } ?>
| DaniWeb Message | |
| Cancel Changes | |