<?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;
/* 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;
}
}
}本文地址：
转载随意，但请附上文章地址:-)
What to do if the Chinese socket is garbled?
Summary of common socket errors
What is cryptocurrency kol
The eight most commonly used functions in excel
what is world wide web
Windows 10 running opening location introduction
What is the difference between TCP protocol and UDP protocol?
How to set startup items at startup
![[Web front-end] Node.js quick start](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
