SAE数据库定时备份并发送至邮箱

SAE自带的SaeMail限制比较多,不但附件有1M的大小限制,而且无法直接将zip文件发送邮箱,而通过第三方的类来发邮件,可以很好的解决这两个问题。
[PHP] 简易的SMTP邮件发送类
/*
简易的SMTP发送邮件类,代码比较少,有助于学习SMTP协议,
可以带附件,支持需要验证的SMTP服务器(目前的SMTP基本都需要验证)
编写: chenall
时间: 2012-12-04
网址: http://chenall.net/post/cs_smtp/
修订记录:
2012-12-08
添加AddURL函数,可以直接从某个网址上下载文件并作为附件发送。
修正由于发送人和接收人邮件地址没有使用"<>"126邮箱SMTP无法使用的问题。
2012-12-06
添加reset函数,重置连接,这样可以发送多个邮件。
2012-12-05
发送附件的代码整合到send函数中,减少变量的使用,快速输出,节省内存占用;
2012-12-04
第一个版本
使用方法:
1\. 初始化:连接到服务器(默认是QQ邮箱)
$mail = new cs_smtp('smtp.qq.com',25)
if ($mail->errstr) //如果连接出错
die($mail->errstr;
2\. 登录到服务器验证,如果失败返回FALSE;
if (!$mail->login('USERNAME','PASSWORD'))
die($mail->errstr;
3\. 添加附件如果不指定name自动从指定的文件中取文件名
$mail->AddFile($file,$name) //服务器上的文件,可以指定文件名;
4\. 发送邮件
$mail->send($to,$subject,$body)
$to 收件人,多个使用','分隔
$subject 邮件主题,可选。
$body 邮件主体内容,可选
*/
class cs_smtp
{
private $CRLF = "\r\n";
private $from;
private $smtp = null;
private $attach = array();
public $debug = true;//调试开关
public $errstr = '';
function __construct($host='smtp.qq.com',$port = 25) {
if (empty($host))
die('SMTP服务器未指定!');
$this->smtp = fsockopen($host,$port,$errno,$errstr,5);
if (empty($this->smtp))
{
$this->errstr = '错误'.$errno.':'.$errstr;
return;
}
$this->smtp_log(fread($this->smtp, 515));
if (intval($this->smtp_cmd('EHLO '.$host)) != 250 && intval($this->smtp_cmd('HELO '.$host)))
return $this->errstr = '服务器不支持!';
$this->errstr = '';
}
private function AttachURL($url,$name)
{
$info = parse_url($url);
isset($info['port']) || $info['port'] = 80;
isset($info['path']) || $info['path'] = '/';
isset($info['query']) || $info['query'] = '';
$down = fsockopen($info['host'],$info['port'],$errno,$errstr,5);
if (!$down)
return false;
$out = "GET ".$info['path'].'?'.$info['query']." HTTP/1.1\r\n";
$out .="Host: ".$info['host']."\r\n";
$out .= "Connection: Close\r\n\r\n";
fwrite($down, $out);
$filesize = 0;
while (!feof($down)) {
$a = fgets($down,515);
if ($a == "\r\n")
break;
$a = explode(':',$a);
if (strcasecmp($a[0],'Content-Length') == 0)
$filesize = intval($a[1]);
}
$sendsize = 0;
echo "TotalSize: ".$filesize."\r\n";
$i = 0;
while (!feof($down)) {
$data = fread($down,0x2000);
$sendsize += strlen($data);
if ($filesize)
{
echo "$i Send:".$sendsize."\r";
ob_flush();
flush();
}
++$i;
fwrite($this->smtp,chunk_split(base64_encode($data)));
}
echo "\r\n";
fclose($down);
return ($filesize>0)?$filesize==$sendsize:true;
}
function __destruct()
{
if ($this->smtp)
$this->smtp_cmd('QUIT');//发送退出命令
}
private function smtp_log($msg)//即时输出调试使用
{
if ($this->debug == false)
return;
echo $msg."\r\n";
ob_flush();
flush();
}
function reset()
{
$this->attach = null;
$this->smtp_cmd('RSET');
}
function smtp_cmd($msg)//SMTP命令发送和收收
{
fputs($this->smtp,$msg.$this->CRLF);
$this->smtp_log('SEND:'. substr($msg,0,80));
$res = fread($this->smtp, 515);
$this->smtp_log($res);
$this->errstr = $res;
return $res;
}
function AddURL($url,$name)
{
$this->attach[$name] = $url;
}
function AddFile($file,$name = '')//添加文件附件
{
if (file_exists($file))
{
if (!empty($name))
return $this->attach[$name] = $file;
$fn = pathinfo($file);
return $this->attach[$fn['basename']] = $file;
}
return false;
}
function send($to,$subject='',$body = '')
{
$this->smtp_cmd("MAIL FROM: <".$this->from.'>');
$mailto = explode(',',$to);
foreach($mailto as $email_to)
$this->smtp_cmd("RCPT TO: <".$email_to.">");
if (intval($this->smtp_cmd("DATA")) != 354)//正确的返回必须是354
return false;
fwrite($this->smtp,"To:$to\nFrom: ".$this->from."\nSubject: $subject\n");
$boundary = uniqid("--BY_CHENALL_",true);
$headers = "MIME-Version: 1.0".$this->CRLF;
$headers .= "From: <".$this->from.">".$this->CRLF;
$headers .= "Content-type: multipart/mixed; boundary= $boundary\n\n".$this->CRLF;//headers结束要至少两个换行
fwrite($this->smtp,$headers);
$msg = "--$boundary\nContent-Type: text/html;charset=\"ISO-8859-1\"\nContent-Transfer-Encoding: base64\n\n";
$msg .= chunk_split(base64_encode($body));
fwrite($this->smtp,$msg);
$files = '';
$errinfo = '';
foreach($this->attach as $name=>$file)
{
$files .= $name;
$msg = "--$boundary\n--$boundary\n";
$msg .= "Content-Type: application/octet-stream; name=\"".$name."\"\n";
$msg .= "Content-Disposition: attachment; filename=\"".$name."\"\n";
$msg .= "Content-transfer-encoding: base64\n\n";
fwrite($this->smtp,$msg);
if (substr($file,4,1) == ':')//URL like http:///file://
{
if (!$this->AttachURL($file,$name))
$errinfo .= '文件下载错误:'.$name.",文件可能是错误的\r\n$file";
}
else
fwrite($this->smtp,chunk_split(base64_encode(file_get_contents($file))));//使用BASE64编码,再用chunk_split大卸八块(每行76个字符)
}
if (!empty($errinfo))
{
$msg = "--$boundary\n--$boundary\n";
$msg .= "Content-Type: application/octet-stream; name=Error.log\n";
$msg .= "Content-Disposition: attachment; filename=Error.log\n";
$msg .= "Content-transfer-encoding: base64\n\n";
fwrite($this->smtp,$msg);
fwrite($this->smtp,chunk_split(base64_encode($errinfo)));
}
return intval($this->smtp_cmd("--$boundary--\n\r\n.")) == 250;//结束DATA发送,服务器会返回执行结果,如果代码不是250则出错。
}
function login($su,$sp)
{
if (empty($this->smtp))
return false;
$res = $this->smtp_cmd("AUTH LOGIN");
if (intval($res)>400)
return !$this->errstr = $res;
$res = $this->smtp_cmd(base64_encode($su));
if (intval($res)>400)
return !$this->errstr = $res;
$res = $this->smtp_cmd(base64_encode($sp));
if (intval($res)>400)
return !$this->errstr = $res;
$this->from = $su;
return true;
}
}
完善后的代码共有4个文件,比较多,就不贴源文件了,直接下载吧。
将下载后将文件夹放到代码路径下(文件夹名字可以自由修改),然后修改里面db_config.php中的配置,主要是邮箱和一些备份信息的设定;接着在网站代码根目录的config.yaml文件中添加一个cron任务,让备份可以自动定时执行。可以根据自己的需要设计,具体语法可以参考官网的文档。我的设置如下:
handle:
- passwdaccess: if(path ~ "db_backup/db_callback.php") passwd "user:passwd"
cron:
- description: SAE database backup
url: db_backup/db_callback.php
schedule: every day of month 04:00
login: user@passwd
这样,在每天凌晨的4点就会进行自动备份。
OK,完工,去Storage看看吧,所有的备份数据均在那里,是不是心里踏实了许多。
(温馨提示:目前DeferredJob每天只能执行10次)