Community Learn Tools Library Leisure
search
English
Home > Backend Development > PHP Tutorial > POP3 class implemented by PHP Socket

POP3 class implemented by PHP Socket

WBOY
Release： 2016-07-25 08:57:48
Original
1361 people have browsed it

  3. /**

  4. * PHP Socket POP3类
  5. * by bbs.it-home.org
  6. */
  7. class SocketPOPClient
  8. {
  9. var $strMessage = '';
  10. var $intErrorNum = 0;
  11. var $bolDebug = false;

  12. var $strEmail = '';

  13. var $strPasswd = '';
  14. var $strHost = '';
  15. var $intPort = 110;
  16. var $intConnSecond = 30;
  17. var $intBuffSize = 8192;
  18. var $resHandler = NULL;
  19. var $bolIsLogin = false;
  20. var $strRequest = '';
  21. var $strResponse = '';
  22. var $arrRequest = array();
  23. var $arrResponse = array();

  24. //---------------

  25. // 基础操作
  26. //---------------
  27. //构造函数
  28. function SocketPOP3Client($strLoginEmail, $strLoginPasswd, $strPopHost='', $intPort='')
  29. {
  30. $this->strEmail = trim(strtolower($strLoginEmail));
  31. $this->strPasswd = trim($strLoginPasswd);
  32. $this->strHost = trim(strtolower($strPopHost));
  33. if ($this->strEmail=='' || $this->strPasswd=='')
  34. {
  35. $this->setMessage('Email address or Passwd is empty', 1001);
  36. return false;
  37. }
  38. if (!PReg_match("/^[w-]+(.[w-]+)*@[w-]+(.[w-]+)+$/i", $this->strEmail))
  39. {
  40. $this->setMessage('Email address invalid', 1002);
  41. return false;
  42. }
  43. if ($this->strHost=='')
  44. {
  45. $this->strHost = substr(strrchr($this->strEmail, "@"), 1);
  46. }
  47. if ($intPort!='')
  48. {
  49. $this->intPort = $intPort;
  50. }
  51. $this->connectHost();
  52. }

  53. //连接服务器

  54. function connectHost()
  55. {
  56. if ($this->bolDebug)
  57. {
  58. echo "Connection ".$this->strHost." ...rn";
  59. }
  60. if (!$this->getIsConnect())
  61. {
  62. if ($this->strHost=='' || $this->intPort=='')
  63. {
  64. $this->setMessage('POP3 host or Port is empty', 1003);
  65. return false;
  66. }
  67. $this->resHandler = @fsockopen($this->strHost, $this->intPort, &$this->intErrorNum, &$this->strMessage, $this->intConnSecond);
  68. if (!$this->resHandler)
  69. {
  70. $strErrMsg = 'Connection POP3 host: '.$this->strHost.' failed';
  71. $intErrNum = 2001;
  72. $this->setMessage($strErrMsg, $intErrNum);
  73. return false;
  74. }
  75. $this->getLineResponse();
  76. if (!$this->getRestIsSucceed())
  77. {
  78. return false;
  79. }
  80. }
  81. return true;
  82. }
  83. //关闭连接
  84. function closeHost()
  85. {
  86. if ($this->resHandler)
  87. {
  88. fclose($this->resHandler);
  89. }
  90. return true;
  91. }
  92. //发送指令
  93. function sendCommand($strCommand)
  94. {
  95. if ($this->bolDebug)
  96. {
  97. if (!preg_match("/PASS/", $strCommand))
  98. {
  99. echo "Send Command: ".$strCommand."rn";
  100. }
  101. else
  102. {
  103. echo "Send Command: PASS ******rn";
  104. }
  105. }
  106. if (!$this->getIsConnect())
  107. {
  108. return false;
  109. }
  110. if (trim($strCommand)=='')
  111. {
  112. $this->setMessage('Request command is empty', 1004);
  113. return false;
  114. }
  115. $this->strRequest = $strCommand."rn";
  116. $this->arrRequest[] = $strCommand;
  117. fputs($this->resHandler, $this->strRequest);
  118. return true;
  119. }
  120. //提取响应信息第一行
  121. function getLineResponse()
  122. {
  123. if (!$this->getIsConnect())
  124. {
  125. return false;
  126. }
  127. $this->strResponse = fgets($this->resHandler, $this->intBuffSize);
  128. $this->arrResponse[] = $this->strResponse;
  129. return $this->strResponse;
  130. }
  131. //Extract some response information, $intReturnType is the return value type, 1 is a string, 2 is an array
  132. function getRespMessage($intReturnType)
  133. {
  134. if (!$this->getIsConnect())
  135. {
  136. return false ;
  137. }
  138. if ($intReturnType == 1)
  139. {
  140. $strAllResponse = '';
  141. while(!feof($this->resHandler))
  142. {
  143. $strLineResponse = $this->getLineResponse();
  144. if (preg_match("/^+OK/", $strLineResponse))
  145. {
  146. continue;
  147. }
  148. if (trim($strLineResponse)=='.')
  149. {
  150. break;
  151. }
  152. $strAllResponse .= $strLineResponse;
  153. }
  154. return $strAllResponse;
  155. }
  156. else
  157. {
  158. $arrAllResponse = array();
  159. while(!feof($this->resHandler))
  160. {
  161. $strLineResponse = $this->getLineRes ponder ();
  162. if (preg_match("/^+OK/", $strLineResponse))
  163. {
  164. continue;
  165. }
  166. if (trim($strLineResponse)=='.')
  167. {
  168. break;
  169. }
  170. $ arrAllResponse[] = $strLineResponse;
  171. }
  172. return $arrAllResponse;
  173. }
  174. }
  175. //Whether the extraction request was successful
  176. function getRestIsSucceed($strRespMessage='')
  177. {
  178. if (trim($responseMessage)=='')
  179. {
  180. if ($this->strResponse=='')
  181. {
  182. $this->getLineResponse();
  183. }
  184. $strRespMessage = $this->strResponse;
  185. }
  186. if (trim($strRespMessage )=='')
  187. {
  188. $this->setMessage('Response message is empty', 2003);
  189. return false;
  190. }
  191. if (!preg_match("/^+OK/", $strRespMessage))
  192. {
  193. $this->setMessage($strRespMessage, 2000);
  194. return false;
  195. }
  196. return true;
  197. }
  198. //Get whether it is connected
  199. function getIsConnect()
  200. {
  201. if (!$this-> ;resHandler)
  202. {
  203. $this->setMessage("Nonexistent availability connection handler", 2002);
  204. return false;
  205. }
  206. return true;
  207. }

  208. //Set message

  209. function setMessage($strMessage, $intErrorNum)
  210. {
  211. if (trim($strMessage)=='' || $intErrorNum=='')
  212. {
  213. return false;
  214. }
  215. $this->strMessage = $strMessage ;
  216. $this->intErrorNum = $intErrorNum;
  217. return true;
  218. }
  219. //Get the message
  220. function getMessage()
  221. {
  222. return $this->strMessage;
  223. }
  224. //Get the error number
  225. function getErrorNum ()
  226. {
  227. return $this->intErrorNum;
  228. }
  229. //Get request information
  230. function getRequest()
  231. {
  232. return $this->strRequest;
  233. }
  234. //Get response information
  235. function getResponse()
  236. {
  237. return $this->strResponse;
  238. }

  239. //---------------

  240. // Email atomic operation
  241. //- --------------
  242. //Log in to email
  243. function popLogin()
  244. {
  245. if (!$this->getIsConnect())
  246. {
  247. return false;
  248. }
  249. $this ->sendCommand("USER ".$this->strEmail);
  250. $this->getLineResponse();
  251. $bolUserRight = $this->getRestIsSucceed();
  252. $this->sendCommand("PASS ".$this->strPasswd);
  253. $this->getLineResponse();
  254. $bolPassRight = $this->getRestIsSucceed();
  255. if (!$bolUserRight || !$bolPassRight)
  256. {
  257. $this ->setMessage($this->strResponse, 2004);
  258. return false;
  259. }
  260. $this->bolIsLogin = true;
  261. return true;
  262. }
  263. //Log out
  264. function popLogout()
  265. {
  266. if (!$this->getIsConnect() && $this->bolIsLogin)
  267. {
  268. return false;
  269. }
  270. $this->sendCommand("QUIT");
  271. $this->getLineResponse();
  272. if (!$this->getRestIsSucceed())
  273. {
  274. return false;
  275. }
  276. return true;
  277. }
  278. //Get whether online
  279. function getIsOnline()
  280. {
  281. if (!$this->getIsConnect() && $this->bolIsLogin)
  282. {
  283. return false;
  284. }
  285. $this->sendCommand(" NOOP");
  286. $this->getLineResponse();
  287. if (!$this->getRestIsSucceed())
  288. {
  289. return false;
  290. }
  291. return true;
  292. }
  293. //Get the number and bytes of emails Number (return array)
  294. function getMailSum($intReturnType=2)
  295. {
  296. if (!$this->getIsConnect() && $this->bolIsLogin)
  297. {
  298. return false;
  299. }
  300. $this-> sendCommand("STAT");
  301. $strLineResponse = $this->getLineResponse();
  302. if (!$this->getRestIsSucceed())
  303. {
  304. return false;
  305. }
  306. if ($intReturnType==1)
  307. {
  308. return $this->strResponse;
  309. }
  310. else
  311. {
  312. $arrResponse = explode(" ", $this->strResponse);
  313. if (!is_array($arrResponse) || count($arrResponse) <=0)
  314. {
  315. $this->setMessage('STAT command response message is error', 2006);
  316. return false;
  317. }
  318. return array($arrResponse[1], $arrResponse[2]);
  319. }
  320. }
  321. //Get the session Id of the specified email
  322. function getMailSessId($intMailId, $intReturnType=2)
  323. {
  324. if (!$this->getIsConnect() && $this->bolIsLogin)
  325. {
  326. return false;
  327. }
  328. if (!$intMailId = intval($intMailId))
  329. {
  330. $this->setMessage('Mail message id invalid', 1005);
  331. return false;
  332. }
  333. $this-> sendCommand("UIDL ". $intMailId);
  334. $this->getLineResponse();
  335. if (!$this->getRestIsSucceed())
  336. {
  337. return false;
  338. }
  339. if ($intReturnType == 1)
  340. {
  341. return $this->strResponse;
  342. }
  343. else
  344. {
  345. $arrResponse = explode(" ", $this->strResponse);
  346. if (!is_array($arrResponse) || count($arrResponse) <=0)
  347. {
  348. $this->setMessage('UIDL command response message is error', 2006);
  349. return false;
  350. }
  351. return array($arrResponse[1], $arrResponse[2]);
  352. }
  353. }
  354. //Get the size of a certain email
  355. function getMailSize($intMailId, $intReturnType=2)
  356. {
  357. if (!$this->getIsConnect() && $this->bolIsLogin)
  358. {
  359. return false;
  360. }
  361. $this->sendCommand("LIST ".$intMailId);
  362. $this->getLineResponse();
  363. if (!$this->getRestIsSucceed())
  364. {
  365. return false;
  366. }
  367. if ($intReturnType == 1)
  368. {
  369. return $this->strResponse;
  370. }
  371. else
  372. {
  373. $arrMessage = explode(' ', $this->strResponse);
  374. return array($ arrMessage[1], $arrMessage[2]);
  375. }
  376. }
  377. //Get the basic mail list array
  378. function getMailBaseList($intReturnType=2)
  379. {
  380. if (!$this->getIsConnect() && $this ->bolIsLogin)
  381. {
  382. return false;
  383. }
  384. $this->sendCommand("LIST");
  385. $this->getLineResponse();
  386. if (!$this->getRestIsSucceed())
  387. {
  388. return false;
  389. }
  390. return $this->getRespMessage($intReturnType);
  391. }
  392. //Get all information of the specified email, intReturnType is the return value type, 1 is a string, 2 is an array
  393. function getMailMessage($ intMailId, $intReturnType=1)
  394. {
  395. if (!$this->getIsConnect() && $this->bolIsLogin)
  396. {
  397. return false;
  398. }
  399. if (!$intMailId = intval($intMailId))
  400. {
  401. $this->setMessage('Mail message id invalid', 1005);
  402. return false;
  403. }
  404. $this->sendCommand("RETR ". $intMailId);
  405. $this->getLineResponse( );
  406. if (!$this->getRestIsSucceed())
  407. {
  408. return false;
  409. }
  410. return $this->getRespMessage($intReturnType);
  411. }
  412. //Get the specified line before a certain email, $intReturnType return value type, 1 is a string, 2 is an array
  413. function getMailTopMessage($intMailId, $intTopLines=10, $intReturnType=1)
  414. {
  415. if (!$this- >getIsConnect() && $this->bolIsLogin)
  416. {
  417. return false;
  418. }
  419. if (!$intMailId=intval($intMailId) || !$intTopLines=int($intTopLines))
  420. {
  421. $this ->setMessage('Mail message id or Top lines number invalid', 1005);
  422. return false;
  423. }
  424. $this->sendCommand("TOP ". $intMailId ." ". $intTopLines);
  425. $this ->getLineResponse();
  426. if (!$this->getRestIsSucceed())
  427. {
  428. return false;
  429. }
  430. return $this->getRespMessage($intReturnType);
  431. }
  432. //Delete message
  433. function delMail($intMailId)
  434. {
  435. if (!$this->getIsConnect() && $this->bolIsLogin)
  436. {
  437. return false;
  438. }
  439. if (!$intMailId=intval($intMailId))
  440. {
  441. $this->setMessage('Mail message id invalid', 1005);
  442. return false;
  443. }
  444. $this->sendCommand("DELE ".$intMailId);
  445. $this->getLineResponse();
  446. if (!$this->getRestIsSucceed())
  447. {
  448. return false;
  449. }
  450. return true;
  451. }
  452. //Reset deleted emails marked as not deleted
  453. function resetDeleMail()
  454. {
  455. if ( !$this->getIsConnect() && $this->bolIsLogin)
  456. {
  457. return false;
  458. }
  459. $this->sendCommand("RSET");
  460. $this->getLineResponse();
  461. if (!$this->getRestIsSucceed())
  462. {
  463. return false;
  464. }
  465. return true;
  466. }
  467. //---------------
  468. // Debug operation
  469. / /---------------
  470. //Output object information
  471. function printObject()
  472. {
  473. print_r($this);
  474. exit;
  475. }
  476. //Output error information
  477. function printError ()
  478. {
  479. echo "[Error Msg] : $strMessage
    n";
  480. echo "[Error Num] : $intErrorNum
    n";
  481. exit;
  482. }
  483. //Output host information
  484. function printHost()
  485. {
  486. echo "[Host] : $this->strHost
    n";
  487. echo "[Port] : $this->intPort
    n";
  488. echo "[ Email] : $this->strEmail
    n";
  489. echo "[Passwd] : ********
    n";
  490. exit;
  491. }
  492. //Output connection information
  493. function printConnect()
  494. {
  495. echo "[Connect] : $this->resHandler
    n";
  496. echo "[Request] : $this->strRequest
    n";
  497. echo "[ Response] : $this->strResponse
    n";
  498. exit;
  499. }
  500. }
  501. ?>

Copy code

Call example:

  2. //Test code
  3. //For example: $o = SocketPOP3Client('Email address', 'Password', 'POP3 server', 'POP3 port')
  4. /*
  5. set_time_limit(0 );
  6. $o = new SocketPOPClient('abc@126.com', '123456', 'pop.126.com', '110');
  7. $o->popLogin();
  8. print_r($o- >getMailBaseList());
  9. print_r($o->getMailSum(1));
  10. print_r($o->getMailTopMessage(2, 2, 2));
  11. $o->popLogout();
  12. $o->closeHost();
  13. $o->printObject();
  14. */
  15. ?>
Copy code


Related labels：
PHP Socket实现的POP3类
source：php.cn
Previous article：PHP implementation code for querying website PR value Next article：PHP implementation code of Google PR value
Statement of this Website
The content of this article is voluntarily contributed by netizens, and the copyright belongs to the original author. This site does not assume corresponding legal responsibility. If you find any content suspected of plagiarism or infringement, please contact admin@php.cn
Latest Articles by Author
Latest Issues
PHP arrays obtained from URL parameters do not behave as expected I have a URL parameter that contains the category ID and I want to treat it as an array li...
From 2024-04-06 22:09:02
0
1
1428
Creating this specific design using a grid: a step-by-step guide I'm trying to create a layout similar to this image, I've tried using this grid but can't ...
From 2024-04-06 20:29:08
0
2
492
How to use laravel components with livewire lazy placeholder I want to add the skeleton of my laravel component inside a livewire3 placeholder What I h...
From 2024-04-06 20:02:10
0
2
543
Customize the appearance of Bootstrap accordion headers using the CollapseDisplay class I want to style the card title of a panel with class collapseshow. In this example, it's t...
From 2024-04-06 12:53:11
0
1
376
How can I connect to a table and display its contents? (MySQL and PHP) I have two mysql tables (product and category). I have some mock data in both tables. Now ...
From 2024-04-03 09:55:31
0
1
350
Related Topics
More>
Popular Recommendations
Popular Tutorials
More>
Related Tutorials
Popular Recommendations
Latest courses
Latest Downloads
More>
Web Effects
Website Source Code
Website Materials
Front End Template