欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

PHP receiveMail实现收邮件功能

程序员文章站 2023-12-09 21:44:28
用php来发邮件,相信大家都不陌生,但读取收件箱的话,接触就少了,这次总结下自己的经验,希望可以帮助大家. 注意: 1.php读取收件箱主要是利用imap扩展,所以在使...

用php来发邮件,相信大家都不陌生,但读取收件箱的话,接触就少了,这次总结下自己的经验,希望可以帮助大家.

注意:

1.php读取收件箱主要是利用imap扩展,所以在使用以下方法前,必须开启imap扩展模块的支持.

2.此方法支持中文,不会乱码,需要保持所有文件的编码的一致性

1.文件结构

PHP receiveMail实现收邮件功能

2.邮件类 ./mailreceived/receivemail.class.php

./mailreceived/receivemail.class.php 文件内容如下:

<?php 
// main recivemail class file - version 1.0 (03-06-2015) 
/* 
 * file: recivemail.class.php 
 * description: reciving mail with attechment 
 * version: 1.1 
 * created: 03-06-2015 
 * author: sara zhou 
 */ 
class receivemail 
{ 
  var $server=''; 
  var $username=''; 
  var $password=''; 
   
  var $marubox='';           
   
  var $email='';    
   
  function receivemail($username,$password,$emailaddress,$mailserver='localhost',$servertype='pop',$port='110',$ssl = false) //constructure 
  { 
    if($servertype=='imap') 
    { 
      if($port=='') $port='143';  
      $strconnect='{'.$mailserver.':'.$port. '}inbox';  
    } 
    else 
    { 
      $strconnect='{'.$mailserver.':'.$port. '/pop3'.($ssl ? "/ssl" : "").'}inbox';  
    } 
    $this->server      =  $strconnect; 
    $this->username     =  $username; 
    $this->password     =  $password; 
    $this->email     =  $emailaddress; 
  } 
  function connect() //connect to the mail box 
  { 
    $this->marubox=@imap_open($this->server,$this->username,$this->password); 
     
    if(!$this->marubox) 
    { 
      return false; 
//     echo "error: connecting to mail server"; 
//     exit; 
    } 
    return true; 
  } 
   
   
  function getheaders($mid) // get header info 
  { 
    if(!$this->marubox) 
      return false; 
 
    $mail_header=imap_header($this->marubox,$mid); 
    $sender=$mail_header->from[0]; 
    $sender_replyto=$mail_header->reply_to[0]; 
    if(strtolower($sender->mailbox)!='mailer-daemon' && strtolower($sender->mailbox)!='postmaster') 
    { 
      $subject=$this->decode_mime($mail_header->subject); 
 
      $cclist=array(); 
      foreach ($mail_header->cc as $k => $v) 
      { 
        $cclist[]=$v->mailbox.'@'.$v->host; 
      } 
      $tolist=array(); 
      foreach ($mail_header->to as $k => $v) 
      { 
        $tolist[]=$v->mailbox.'@'.$v->host; 
      } 
      $cclist=implode(",", $cclist); 
      $tolist=implode(",", $tolist); 
      $mail_details=array( 
          'fromby'=>strtolower($sender->mailbox).'@'.$sender->host, 
          'fromname'=>$this->decode_mime($sender->personal), 
          'cclist'=>$cclist,//strtolower($sender_replyto->mailbox).'@'.$sender_replyto->host, 
          'tonameoth'=>$this->decode_mime($sender_replyto->personal), 
          'subject'=>$subject, 
          'maildate'=>date("y-m-d h:i:s",$mail_header->udate), 
          'udate'=>$mail_header->udate, 
          'tolist'=>$tolist//strtolower($mail_header->to[0]->mailbox).'@'.$mail_header->to[0]->host 
//         'to'=>strtolower($mail_header->toaddress) 
        ); 
    } 
    return $mail_details; 
  } 
  function get_mime_type(&$structure) //get mime type internal private use 
  {  
    $primary_mime_type = array("text", "multipart", "message", "application", "audio", "image", "video", "other");  
     
    if($structure->subtype && $structure->subtype!="png") {  
      return $primary_mime_type[(int) $structure->type] . '/' . $structure->subtype;  
    }  
    return "text/plain";  
  }  
  function get_part($stream, $msg_number, $mime_type, $structure = false, $part_number = false) //get part of message internal private use 
  {  
     
    if(!$structure) {  
      $structure = imap_fetchstructure($stream, $msg_number);  
    }  
    if($structure) {  
      if($mime_type == $this->get_mime_type($structure)) 
      {  
        if(!$part_number)  
        {  
          $part_number = "1";  
        }  
        $text = imap_fetchbody($stream, $msg_number, $part_number); 
         
        if($structure->encoding == 3) 
        { 
          return imap_base64($text); 
//         if ($structure->parameters[0]->value!="utf-8") 
//         { 
//           return imap_base64($text); 
//         } 
//         else 
//         { 
//           return imap_base64($text); 
//         } 
        } 
        else if($structure->encoding == 4) 
        { 
          return iconv('gb2312','utf8',imap_qprint($text)); 
        } 
        else 
        { 
          return iconv('gb2312','utf8',$text); 
        } 
      }  
      if($structure->type == 1) /* multipart */  
      {  
        while(list($index, $sub_structure) = each($structure->parts)) 
        {  
          if($part_number) 
          {  
            $prefix = $part_number . '.';  
          }  
          $data = $this->get_part($stream, $msg_number, $mime_type, $sub_structure, $prefix . ($index + 1));  
          if($data) 
          {  
            return $data;  
          }  
        }  
      }  
    } 
    return false;  
  }  
  function gettotalmails() //get total number off unread email in mailbox 
  { 
    if(!$this->marubox) 
      return false; 
 
//   return imap_headers($this->marubox); 
    return imap_num_recent($this->marubox); 
  } 
   
  function getattach($mid,$path) // get atteced file from mail 
  { 
    if(!$this->marubox) 
      return false; 
 
    $struckture = imap_fetchstructure($this->marubox,$mid); 
     
    $files=array(); 
    if($struckture->parts) 
    { 
      foreach($struckture->parts as $key => $value) 
      { 
        $enc=$struckture->parts[$key]->encoding; 
         
        //取邮件附件 
        if($struckture->parts[$key]->ifdparameters) 
        { 
          //命名附件,转码 
          $name=$this->decode_mime($struckture->parts[$key]->dparameters[0]->value);          
          $extend =explode("." , $name); 
          $file['extension'] = $extend[count($extend)-1]; 
          $file['pathname'] = $this->setpathname($key, $file['extension']); 
          $file['title']   = !empty($name) ? htmlspecialchars($name) : str_replace('.' . $file['extension'], '', $name); 
          $file['size']   = $struckture->parts[$key]->dparameters[1]->value; 
//         $file['tmpname']  = $struckture->parts[$key]->dparameters[0]->value; 
          if(@$struckture->parts[$key]->disposition=="attachment") 
          { 
            $file['type']   = 1;    
          } 
          else 
          { 
            $file['type']   = 0; 
          }       
          $files[] = $file;           
           
          $message = imap_fetchbody($this->marubox,$mid,$key+1); 
          if ($enc == 0) 
            $message = imap_8bit($message); 
          if ($enc == 1) 
            $message = imap_8bit ($message); 
          if ($enc == 2) 
            $message = imap_binary ($message); 
          if ($enc == 3)//图片 
            $message = imap_base64 ($message);  
          if ($enc == 4) 
            $message = quoted_printable_decode($message); 
          if ($enc == 5) 
            $message = $message; 
          $fp=fopen($path.$file['pathname'],"w"); 
          fwrite($fp,$message); 
          fclose($fp); 
           
        } 
        // 处理内容中包含图片的部分 
        if($struckture->parts[$key]->parts) 
        { 
          foreach($struckture->parts[$key]->parts as $keyb => $valueb) 
          { 
            $enc=$struckture->parts[$key]->parts[$keyb]->encoding; 
            if($struckture->parts[$key]->parts[$keyb]->ifdparameters) 
            { 
              //命名图片 
              $name=$this->decode_mime($struckture->parts[$key]->parts[$keyb]->dparameters[0]->value); 
              $extend =explode("." , $name); 
              $file['extension'] = $extend[count($extend)-1]; 
              $file['pathname'] = $this->setpathname($key, $file['extension']); 
              $file['title']   = !empty($name) ? htmlspecialchars($name) : str_replace('.' . $file['extension'], '', $name); 
              $file['size']   = $struckture->parts[$key]->parts[$keyb]->dparameters[1]->value; 
//             $file['tmpname']  = $struckture->parts[$key]->dparameters[0]->value; 
              $file['type']   = 0; 
              $files[] = $file; 
               
              $partnro = ($key+1).".".($keyb+1); 
               
              $message = imap_fetchbody($this->marubox,$mid,$partnro); 
              if ($enc == 0) 
                  $message = imap_8bit($message); 
              if ($enc == 1) 
                  $message = imap_8bit ($message); 
              if ($enc == 2) 
                  $message = imap_binary ($message); 
              if ($enc == 3) 
                  $message = imap_base64 ($message); 
              if ($enc == 4) 
                  $message = quoted_printable_decode($message); 
              if ($enc == 5) 
                  $message = $message; 
              $fp=fopen($path.$file['pathname'],"w"); 
              fwrite($fp,$message); 
              fclose($fp); 
            } 
          } 
        }         
      } 
    } 
    //move mail to taskmailbox 
    $this->move_mails($mid, $this->marubox);    
 
    return $files; 
  } 
   
  function getbody($mid,&$path,$imagelist) // get message body 
  { 
    if(!$this->marubox) 
      return false; 
 
    $body = $this->get_part($this->marubox, $mid, "text/html"); 
    if ($body == "") 
      $body = $this->get_part($this->marubox, $mid, "text/plain"); 
    if ($body == "") {  
      return ""; 
    } 
    //处理图片 
    $body=$this->embed_images($body,$path,$imagelist); 
    return $body; 
  } 
   
  function embed_images(&$body,&$path,$imagelist) 
  { 
    // get all img tags 
    preg_match_all('/<img.*?>/', $body, $matches); 
    if (!isset($matches[0])) return; 
     
    foreach ($matches[0] as $img) 
    { 
      // replace image web path with local path 
      preg_match('/src="(.*?)"/', $img, $m); 
      if (!isset($m[1])) continue; 
      $arr = parse_url($m[1]); 
      if (!isset($arr['scheme']) || !isset($arr['path']))continue; 
       
//     if (!isset($arr['host']) || !isset($arr['path']))continue; 
      if ($arr['scheme']!="http") 
      { 
        $filename=explode("@", $arr['path']); 
        $body = str_replace($img, '<img alt="" src="'.$path.$imagelist[$filename[0]].'" style="border: none;" />', $body); 
      } 
    } 
    return $body; 
  } 
   
  function deletemails($mid) // delete that mail 
  { 
    if(!$this->marubox) 
      return false; 
     
    imap_delete($this->marubox,$mid); 
  } 
  function close_mailbox() //close mail box 
  { 
    if(!$this->marubox) 
      return false; 
 
    imap_close($this->marubox,cl_expunge); 
  } 
   
  //移动邮件到指定分组 
  function move_mails($msglist,$mailbox) 
  { 
    if(!$this->marubox) 
      return false; 
   
    imap_mail_move($this->marubox, $msglist, $mailbox); 
  } 
   
  function creat_mailbox($mailbox) 
  { 
    if(!$this->marubox) 
      return false; 
     
    //imap_renamemailbox($imap_stream, $old_mbox, $new_mbox); 
    imap_create($this->marubox, $mailbox); 
  } 
   
  /* 
   * decode_mime()转换邮件标题的字符编码,处理乱码 
   */ 
  function decode_mime($str){ 
    $str=imap_mime_header_decode($str); 
    return $str[0]->text; 
    echo "str";print_r($str); 
    if ($str[0]->charset!="default") 
    {echo "==".$str[0]->text; 
      return iconv($str[0]->charset,'utf8',$str[0]->text); 
    } 
    else 
    { 
      return $str[0]->text; 
    } 
  } 
   
  /** 
   * set path name of the uploaded file to be saved. 
   * 
   * @param int  $fileid 
   * @param string $extension 
   * @access public 
   * @return string 
   */ 
  public function setpathname($fileid, $extension) 
  { 
    return date('ym/dhis', time()) . $fileid . mt_rand(0, 10000) . '.' . $extension; 
  } 
   
} 
?> 

3.控制层./mailreceived/mailcontrol.php

 ./mailreceived/mailcontrol.php 内容如下:

<? 
/* 
 * file: mailcontrol.php 
 * description: received mail example 
 * created: 03-06-2015 
 * author: sara zhou 
 */ 
@header('content-type: text/html;charset=utf-8'); 
error_reporting(0); 
ignore_user_abort(); // run script in background 
set_time_limit(0); // run script forever 
date_default_timezone_set('asia/shanghai'); 
include("receivemail.class.php"); 
class mailcontrol 
{ 
  //定义系统常量 
  //用户名 
  public $mailaccount = "123456@qq.com"; 
  public $mailpasswd = "12345"; 
  public $mailaddress = "123456@qq.com"; 
  public $mailserver = "pop.qq.com"; 
  public $servertype = "pop3"; 
  public $port = "110"; 
  public $now    = 0; 
  public $savepath = ''; 
  public $webpath  = "../upload/"; 
   
  public function __construct() 
  { 
    $this->now = date("y-m-d h:i:s",time()); 
     
    $this->setsavepath(); 
  } 
   
  /** 
   * mail received()读取收件箱邮件 
   * 
   * @param 
   * @access public 
   * @return result 
   */ 
  public function mailreceived() 
  { 
    // creating a object of recivemail class 
    $obj= new receivemail($this->mailaccount,$this->mailpasswd,$this->mailaddress,$this->mailserver,$this->servertype,$this->port,false); 
      
    //connect to the mail box 
    $res=$obj->connect();     //if connection fails give error message and exit 
    if (!$res) 
    { 
      return array("msg"=>"error: connecting to mail server"); 
    } 
    // get total number of unread email in mail box 
    $tot=$obj->gettotalmails(); //total mails in inbox return integer value 
    if($tot < 1) { //如果信件数为0,显示信息 
      return array("msg"=>"no message for ".$this->mailaccount); 
    } 
    else 
    { 
      $res=array("msg"=>"total mails:: $tot<br>"); 
   
      for($i=$tot;$i>0;$i--) 
      { 
        $head=$obj->getheaders($i); // get header info return array of headers **array keys are (subject,to,tooth,tonameoth,from,fromname) 
     
        //处理邮件附件 
        $files=$obj->getattach($i,$this->savepath); // 获取邮件附件,返回的邮件附件信息数组 
         
        $imagelist=array(); 
        foreach($files as $k => $file) 
        {       
          //type=1为附件,0为邮件内容图片 
          if($file['type'] == 0) 
          { 
            $imagelist[$file['title']]=$file['pathname']; 
          } 
        } 
        $body = $obj->getbody($i,$this->webpath,$imagelist); 
         
        $res['mail'][]=array('head'=>$head,'body'=>$body,"attachlist"=>$files);        
//       $obj->deletemails($i); // delete mail from mail box 
//       $obj->move_mails($i,"taskmail"); 
      } 
      $obj->close_mailbox();  //close mail box 
      return $res; 
    } 
  } 
    
  /** 
  * creatbox 
  * 
  * @access public 
  * @return void 
  */ 
  public function creatbox($boxname) 
  { 
    // creating a object of recivemail class 
    $obj= new receivemail($this->mailaccount,$this->mailpasswd,$this->mailaddress,$this->mailserver,$this->servertype,$this->port,false); 
    $obj->creat_mailbox($boxname); 
  } 
   
  /** 
   * set save path. 
   * 
   * @access public 
   * @return void 
   */ 
  public function setsavepath() 
  { 
    $savepath = "../upload/" . date('ym/', $this->now); 
    if(!file_exists($savepath)) 
    { 
      @mkdir($savepath, 0777, true); 
      touch($savepath . 'index.html'); 
    } 
    $this->savepath = dirname($savepath) . '/'; 
  } 
    
} 
  $obj=new mailcontrol(); 
  //收取邮件 
  $res=$obj->mailreceived(); 
  echo "<pre>";print_r($res); 
   
  //创建邮箱 
// $obj->creatbox("readybox"); 
?> 

4.访问地址:http://localhost/test.cn/mailreceived/mailcontrol.php 即可

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。