PHP Socket で実装された POP3 クラス

/**
* PHP ソケット POP3类
* by bbs.it-home.org
*/
class SocketPOPClient
{
 var $strMessage = '';
 var $intErrorNum = 0;
 var $bolDebug = false;
    var $strEmail = '';
 var $strPasswd = '';
 var $strHost = '';
 var $intPort = 110;
 var $intConnSecond = 30;
 var $intBuffSize = 8192;
 var $resHandler = NULL;
 var $bolIsLogin = false;
 var $strRequest = '';
 var $strResponse = '';
 var $arrRequest = array();
 var $arrResponse = array();
    //---------------
 // 基础操作
 //--------------
 //构造関数数
 function SocketPOP3Client($ strLoginEmail, $strLoginPasswd, $strPopHost='', $intPort='')
 {
 $this->strEmail = トリム(strto lower($strLoginEmail));
 $this->strPasswd = トリム($strLoginPasswd);
 $this->strHost = トリム(strto lower($strPopHost));
 if ($this->strEmail=='' || $this->strPasswd=='')
 {
 $this-> ;setMessage('メールアドレスまたはパスワードが空です', 1001);
 false を返します。
 }
 if (!PReg_match("/^[w-]+(.[w-]+)*@[w-]+(.[w-]+)+$/i", $this-> strEmail))
 {
 $this->setMessage('メール アドレスが無効です', 1002);
 false を返します。
 }
 if ($this->strHost=='')
 {
 $this->strHost = substr(strrchr($this->strEmail, "@"), 1);
 }
 if ($intPort!='')
 {
 $this->intPort = $intPort;
 }
 $this->connectHost();
 }
    //接続サービス务器
 function connectHost()
 {
 if ($this->bolDebug)
 {
 echo "Connection ".$this->strHost." ...rn";
 }
 if (!$this->getIsConnect())
 {
 if ($this->strHost=='' || $this->intPort=='')
 {
 $this-> ;setMessage('POP3 ホストまたはポートが空です', 1003);
 false を返します。
 }
 $this->resHandler = @fsockopen($this->strHost, $this->intPort, &$this->intErrorNum, &$this->strMessage, $this->intConnSecond) ;
 if (!$this->resHandler)
 {
 $strErrMsg = '接続 POP3 ホスト: '.$this->strHost.'失敗した';
 $intErrNum = 2001;
 $this->setMessage($strErrMsg, $intErrNum);
 false を返します。
 }
 $this->getLineResponse();
 if (!$this->getRestIsSucceed())
 {
 return false;
 }
 }
 true を返します。
 }
 //关闭接続
 function closeHost()
 {
 if ($this->resHandler)
 {
 fclose($this->resHandler);
 }
 true を返します。
 }
 //送信命令
 function sendCommand($strCommand)
 {
 if ($this->bolDebug)
 {
 if (!preg_match("/PASS/", $strCommand))
 {
 echo "送信コマンド: ".$strCommand."rn";
 }
 else
 {
 echo "送信コマンド: PASS ******rn";
 }
 }
 if (!$this->getIsConnect())
 {
 return false;
 }
 if (trim($strCommand)=='')
 {
 $this->setMessage('リクエストコマンドは空です', 1004);
 false を返します。
 }
 $this->strRequest = $strCommand."rn";
 $this->arrRequest[] = $strCommand;
 fputs($this->resHandler, $this->strRequest);
 true を返します。
 }
 //提取响应情報第一行
 function getLineResponse()
 {
 if (!$this->getIsConnect())
 {
 return false;
 }
 $this->strResponse = fgets($this->resHandler, $this->intBuffSize);
 $this->arrResponse[] = $this->strResponse;
 return $this->strResponse;
 }
 //応答情報を抽出します。$intReturnType は戻り値の型、1 は文字列、2 は配列です
 function getRespMessage($intReturnType)
 {
 if (!$this->getIsConnect())
 {
 false を返す ;
 }
 if ($intReturnType == 1)
 {
 $strAllResponse = '';
 while(!feof($this->resHandler))
 {
 $strLineResponse = $this->getLineResponse( );
 if (preg_match("/^+OK/", $strLineResponse))
 {
 続行;
 if (trim($strLineResponse)=='.')
 {
 }
 $strAllResponse .= $strLineResponse; }
 return $strAllResponse; }
 else
 {
 $arrAllResponse = array();
 {
 $strLineResponse = $this-> ;getLineRes 熟考 ();
 if (preg_match("/^+OK/", $strLineResponse))
 {
 続行;
 }
 if (trim($strLineResponse)=='.')
 {
 ブレーク; }
 $ arrAllResponse[] = $strLineResponse; }
 return $arrAllResponse; }
 }
 //抽出リクエストが成功したかどうか
 function getRestIsSucceed($strRespMessage='')
 {
 if (trim($responseMessage) =='')
 {
 if ($this->strResponse=='')
 {
 $this->getLineResponse(); }
 $strRespMessage = $this->strResponse;
 if (trim($strRespMessage )=='')
 {
 $this->setMessage('応答メッセージは空です', 2003);
 return false;
 }
 if (!preg_match("/^+OK/") , $strRespMessage))
 {
 $this->setMessage($strRespMessage, 2000);
 return false; }
 return true
 function getIsConnect()
 {
 if (!$this->resHandler)
 {
 $this->setMessage("存在しない可用性接続ハンドラー", 2002);
 return false;
 }
 return true; ; // メッセージを設定します
 function setMessage($strMessage, $intErrorNum)
 {
 if (trim($strMessage)=='' || $intErrorNum=='')
 {
 return false;
 $this- >strMessage = $strMessage ;
 $this->intErrorNum = $intErrorNum;
 return true;
 function getMessage()
 {
 return $this->strMessage; /エラー番号を取得
 function getErrorNum ()
 {
 return $this->intErrorNum;
 }
 // リクエスト情報を取得
 function getRequest()
 {
 return $this->strRequest
 }
 //レスポンス情報の取得
 function getResponse()
 {
 return $this->strResponse
 }
 //---------------
 / / メールのアトミック操作
 //- --------------
 //メールにログイン
 function PopLogin()
 {
 if (!$this->getIsConnect())
 {
 return false
 }
 $this ->sendCommand("USER ".$this->getLineResponse();
 $bolUserRight = $this->getRestIsSucceed();
 $this->sendCommand("PASS ".$this->getLineResponse();
 $bolPassRight = $this->getRestIsSucceed();
 if (!$bolUserRight | | !$bolPassRight)
 {
 $this ->setMessage($this->strResponse, 2004);
 $this->bolIsLogin = true;
 }
 //ログアウト
 function PopLogout()
 {
 if (!$this->getIsConnect() && $this->bolIsLogin)
 {
 return false; }
 $this->sendCommand("QUIT");
 $this->getLineResponse();
 if (!$this->getRestIsSucceed())
 {
 戻り値
 }
 戻り値
 }
 //オンラインかどうかを取得
 function getIsOnline()
 {
 if (!$this->getIsConnect() && $this->bolIsLogin)
 {
 return false
 }
 $this->sendCommand(" NOOP");
 $this->getLineResponse();
 if (!$this->getRestIsSucceed())
 {
 return false;
 }
 return true;
 }
 // の数とバイトを取得しますメール番号 (配列を返す)
 function getMailSum($intReturnType=2)
 {
 if (!$this->getIsConnect() && $this->bolIsLogin)
 {
 return false;
 $this-> ; sendCommand("STAT");
 $strLineResponse = $this->getLineResponse();
 {
 return false }
 if ($intReturnType==1) )
 {
 return $this->strResponse; }
 else
 {
 $arrResponse =explode(" ", $this->strResponse)
 if (!is_array($arrResponse) || count($arrResponse) )  {
 $this->setMessage('STAT コマンド応答メッセージがエラーです', 2006);
 return false;
 }
 return array($arrResponse[1], $arrResponse[2]) ;
 }
 }
 //指定されたメールのセッションIDを取得する
 function getMailSessId($intMailId, $intReturnType=2)
 {
 if (!$this->getIsConnect() && $this->bolIsLogin)
 {
 return false;
 if (!$intMailId = intval($intMailId))
 {
 $this->setMessage('メール メッセージ ID が無効です', 1005);
 return false; -> sendCommand("UIDL ".$intMailId);
 $this->getLineResponse();
 {
 return false }
 if ($intReturnType = = 1)
 {
 return $this->strResponse; }
 else
 {
 $arrResponse =explode(" ", $this->strResponse)
 if (!is_array($arrResponse) || count( $arrResponse) <=0)
 {
 $this->setMessage('UIDL コマンド応答メッセージがエラーです', 2006);
 return false;
 }
 return array($arrResponse[1], $arrResponse[2] ]);
 }
 }
 //特定のメールのサイズを取得する
 function getMailSize($intMailId, $intReturnType=2)
 {
 if (!$this->getIsConnect() && $this->bolIsLogin )
 {
 return false;
 }
 $this->sendCommand("LIST ".$intMailId);
 if (!$this->getRestIsSucceed());
 return false;
 }
 if ($intReturnType == 1)
 {
 return $this->strResponse; }
 else
 {
 $arrMessage =explode(' ', $this->strResponse); return array($ arrMessage[1], $arrMessage[2]);
 }
 }
 //基本的なメールリスト配列を取得します
 function getMailBaseList($intReturnType=2)
 {
 if (!$this->getIsConnect () && $this ->bolIsLogin)
 {
 return false; }
 $this->getLineResponse();
 if (!$this-> getRestIsSucceed())
 {
 return false;
 }
 return $this->getRespMessage($intReturnType);
 }
 // 指定されたメールのすべての情報を取得します。 intReturnType は戻り値の型で、1 は文字列です。 2 は配列
関数 getMailMessage($ intMailId, $intReturnType=1)
 {
 if (!$this->getIsConnect() && $this->bolIsLogin)
 {
 return false }
 if (! $intMailId = intval($intMailId))
 {
 $this->setMessage('メール メッセージ ID が無効です', 1005);
 return false; }
 $this->sendCommand("RETR ". $intMailId) ;
 $this->getLineResponse();
 if (!$this->getRestIsSucceed())
 return $this->getRespMessage($intReturnType);
 //特定のメールの前の指定された行を取得します。$intReturnType 戻り値の型、1 は文字列、2 は配列
 function getMailTopMessage($intMailId, $intTopLines=10, $intReturnType=1)
 {
 if (! $this->getIsConnect() && $this->bolIsLogin)
 {
 return false; }
 if (!$intMailId=intval($intMailId) || !$intTopLines=int($intTopLines))
 {
 $this ->setMessage('メール メッセージ ID または先頭行番号が無効です', 1005);
 return false; }
 $this->sendCommand("TOP ". $intMailId ." ". $intTopLines);
 $this ->getLineResponse();
 if (!$this->getRestIsSucceed())
 {
 return false; }
 return $this->getRespMessage($intReturnType);メッセージ
 関数 delMail($intMailId)
 {
 if (!$this->getIsConnect() && $this->bolIsLogin)
 {
 return false
 }
 if (!$intMailId=intval($intMailId) )
 {
 $this->setMessage('メール メッセージ ID が無効です', 1005);
 $this->sendCommand("DELE ".$intMailId); ();
 if (!$this->getRestIsSucceed())
 {
 return false; }
 return true;
 function replaceDeleMail()
 if ( !$this->getIsConnect() && $this->bolIsLogin)
 {
 return false; }
 $this->sendCommand("RSET")
 if (!$this->getRestIsSucceed())
 {
 return false; }
 return true;
 //---------------
 // デバッグ操作
 / /--------------
 //オブジェクト情報を出力
 function printObject()
 {
 print_r($this)
 exit
 }
 // エラー情報を出力
 function printError; ()
 {
 echo "[Error Msg] : $strMessage n";
 echo "[Error Num] : $intErrorNum n";
 }
 // ホスト情報を出力します。 function printHost()
 {
 echo "[ホスト] : $this->strHost n";
 echo "[ポート] : $this->intPort n";
 echo "[ Email] : $this->strEmail n";
 echo "[Passwd] : ******** n";
 exit;
 }
 //接続情報を出力します
 function printConnect()
 {
 echo "[接続] : $this->resHandler n";
 echo "[リクエスト] : $this->strRequest n";
 echo "[ Response] : $this->strResponse n";
 exit;
 }
}
?



コードをコピー


呼び出し例:





//テストコード
//例: $o = SocketPOP3Client('メールアドレス', 'パスワード', 'POP3サーバー', 'POP3ポート')
/*
set_time_limit( 0 );
$o = 新しい SocketPOPClient('abc@126.com', 'pop.126.com', '110'); - >getMailBaseList());
print_r($o->getMailSum(1));

コードをコピーします