社区 学习 工具库 休闲
搜索
简体中文
首页 > 后端开发 > php教程 > PHP Socket实现的POP3类

PHP Socket实现的POP3类

WBOY
发布： 2016-07-25 08:57:48
原创
1360 人浏览过

  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." ...\r\n";
  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."\r\n";
  100. }
  101. else
  102. {
  103. echo "Send Command: PASS ******\r\n";
  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."\r\n";
  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. //提取若干响应信息,$intReturnType是返回值类型, 1为字符串, 2为数组
  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->getLineResponse();
  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. //提取请求是否成功
  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. //获取是否已连接
  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. //设置消息

  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. //获取消息
  220. function getMessage()
  221. {
  222. return $this->strMessage;
  223. }
  224. //获取错误号
  225. function getErrorNum()
  226. {
  227. return $this->intErrorNum;
  228. }
  229. //获取请求信息
  230. function getRequest()
  231. {
  232. return $this->strRequest;
  233. }
  234. //获取响应信息
  235. function getResponse()
  236. {
  237. return $this->strResponse;
  238. }

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

  240. // 邮件原子操作
  241. //---------------
  242. //登录邮箱
  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. //退出登录
  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. //获取是否在线
  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. //获取邮件数量和字节数(返回数组)
  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) {
  314. $this->setMessage('STAT command response message is error', 2006);
  315. return false;
  316. }
  317. return array($arrResponse[1], $arrResponse[2]);
  318. }
  319. }
  320. //获取指定邮件得session Id
  321. function getMailSessId($intMailId, $intReturnType=2)
  322. {
  323. if (!$this->getIsConnect() && $this->bolIsLogin)
  324. {
  325. return false;
  326. }
  327. if (!$intMailId = intval($intMailId))
  328. {
  329. $this->setMessage('Mail message id invalid', 1005);
  330. return false;
  331. }
  332. $this->sendCommand("UIDL ". $intMailId);
  333. $this->getLineResponse();
  334. if (!$this->getRestIsSucceed())
  335. {
  336. return false;
  337. }
  338. if ($intReturnType == 1)
  339. {
  340. return $this->strResponse;
  341. }
  342. else
  343. {
  344. $arrResponse = explode(" ", $this->strResponse);
  345. if (!is_array($arrResponse) || count($arrResponse) {
  346. $this->setMessage('UIDL command response message is error', 2006);
  347. return false;
  348. }
  349. return array($arrResponse[1], $arrResponse[2]);
  350. }
  351. }
  352. //取得某个邮件的大小
  353. function getMailSize($intMailId, $intReturnType=2)
  354. {
  355. if (!$this->getIsConnect() && $this->bolIsLogin)
  356. {
  357. return false;
  358. }
  359. $this->sendCommand("LIST ".$intMailId);
  360. $this->getLineResponse();
  361. if (!$this->getRestIsSucceed())
  362. {
  363. return false;
  364. }
  365. if ($intReturnType == 1)
  366. {
  367. return $this->strResponse;
  368. }
  369. else
  370. {
  371. $arrMessage = explode(' ', $this->strResponse);
  372. return array($arrMessage[1], $arrMessage[2]);
  373. }
  374. }
  375. //获取邮件基本列表数组
  376. function getMailBaseList($intReturnType=2)
  377. {
  378. if (!$this->getIsConnect() && $this->bolIsLogin)
  379. {
  380. return false;
  381. }
  382. $this->sendCommand("LIST");
  383. $this->getLineResponse();
  384. if (!$this->getRestIsSucceed())
  385. {
  386. return false;
  387. }
  388. return $this->getRespMessage($intReturnType);
  389. }
  390. //获取指定邮件所有信息，intReturnType是返回值类型，1是字符串,2是数组
  391. function getMailMessage($intMailId, $intReturnType=1)
  392. {
  393. if (!$this->getIsConnect() && $this->bolIsLogin)
  394. {
  395. return false;
  396. }
  397. if (!$intMailId = intval($intMailId))
  398. {
  399. $this->setMessage('Mail message id invalid', 1005);
  400. return false;
  401. }
  402. $this->sendCommand("RETR ". $intMailId);
  403. $this->getLineResponse();
  404. if (!$this->getRestIsSucceed())
  405. {
  406. return false;
  407. }
  408. return $this->getRespMessage($intReturnType);
  409. }
  410. //获取某邮件前指定行, $intReturnType 返回值类型，1是字符串，2是数组
  411. function getMailTopMessage($intMailId, $intTopLines=10, $intReturnType=1)
  412. {
  413. if (!$this->getIsConnect() && $this->bolIsLogin)
  414. {
  415. return false;
  416. }
  417. if (!$intMailId=intval($intMailId) || !$intTopLines=int($intTopLines))
  418. {
  419. $this->setMessage('Mail message id or Top lines number invalid', 1005);
  420. return false;
  421. }
  422. $this->sendCommand("TOP ". $intMailId ." ". $intTopLines);
  423. $this->getLineResponse();
  424. if (!$this->getRestIsSucceed())
  425. {
  426. return false;
  427. }
  428. return $this->getRespMessage($intReturnType);
  429. }
  430. //删除邮件
  431. function delMail($intMailId)
  432. {
  433. if (!$this->getIsConnect() && $this->bolIsLogin)
  434. {
  435. return false;
  436. }
  437. if (!$intMailId=intval($intMailId))
  438. {
  439. $this->setMessage('Mail message id invalid', 1005);
  440. return false;
  441. }
  442. $this->sendCommand("DELE ".$intMailId);
  443. $this->getLineResponse();
  444. if (!$this->getRestIsSucceed())
  445. {
  446. return false;
  447. }
  448. return true;
  449. }
  450. //重置被删除得邮件标记为未删除
  451. function resetDeleMail()
  452. {
  453. if (!$this->getIsConnect() && $this->bolIsLogin)
  454. {
  455. return false;
  456. }
  457. $this->sendCommand("RSET");
  458. $this->getLineResponse();
  459. if (!$this->getRestIsSucceed())
  460. {
  461. return false;
  462. }
  463. return true;
  464. }
  465. //---------------
  466. // 调试操作
  467. //---------------
  468. //输出对象信息
  469. function printObject()
  470. {
  471. print_r($this);
  472. exit;
  473. }
  474. //输出错误信息
  475. function printError()
  476. {
  477. echo "[Error Msg] : $strMessage
    \n";
  478. echo "[Error Num] : $intErrorNum
    \n";
  479. exit;
  480. }
  481. //输出主机信息
  482. function printHost()
  483. {
  484. echo "[Host] : $this->strHost
    \n";
  485. echo "[Port] : $this->intPort
    \n";
  486. echo "[Email] : $this->strEmail
    \n";
  487. echo "[Passwd] : ********
    \n";
  488. exit;
  489. }
  490. //输出连接信息
  491. function printConnect()
  492. {
  493. echo "[Connect] : $this->resHandler
    \n";
  494. echo "[Request] : $this->strRequest
    \n";
  495. echo "[Response] : $this->strResponse
    \n";
  496. exit;
  497. }
  498. }
  499. ?>
复制代码

调用示例：

  3. //测试代码
  4. //例如：$o = SocketPOP3Client('邮箱地址', '密码', 'POP3服务器', 'POP3端口')
  5. /*
  6. set_time_limit(0);
  7. $o = new SocketPOPClient('abc@126.com', '123456', 'pop.126.com', '110');
  8. $o->popLogin();
  9. print_r($o->getMailBaseList());
  10. print_r($o->getMailSum(1));
  11. print_r($o->getMailTopMessage(2, 2, 2));
  12. $o->popLogout();
  13. $o->closeHost();
  14. $o->printObject();
  15. */
  16. ?>
复制代码


相关标签：
PHP Socket实现的POP3类
来源：php.cn
上一篇：PHP查询网站PR值的实现代码 下一篇：Google PR值的PHP实现代码
本站声明
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系admin@php.cn
作者最新文章
最新问题
PHP数组从URL参数中获取的行为不如预期 我有一个包含类别ID的URL参数，我想将其视为一个数组，如下所示：http://example.com?cat[]=3,9,13在PHP中，我使用它从URL参数获取数组：$catI...
来自于 2024-04-06 22:09:02
0
1
1428
使用网格创建此特定设计：分步指南 我正在尝试创建一个类似于此图像的布局，我尝试过使用此网格但无法实现。<ulclass="container"><liclass="f...
来自于 2024-04-06 20:29:08
0
2
492
如何在 livewire 惰性占位符中使用 laravel 组件 我想在livewire3占位符内添加我的laravel组件的骨架到目前为止我已经尝试过：通过包含Laravel组件来实现Livewire类：publicfunctionplaceh...
来自于 2024-04-06 20:02:10
0
2
543
使用'折叠显示”类自定义 Bootstrap 手风琴标题的外观 我想设置具有类collapseshow的面板的卡标题样式。在此示例中，它是第一个面板。我尝试使用CSS来使用.accordion.card.card-headerbutton.bt...
来自于 2024-04-06 12:53:11
0
1
376
如何连接到表格并显示其内容？ （MySQL 和 PHP） 我有两个mysql表（产品和类别）。我在两个表中都有一些模拟数据。现在我需要以某种方式将类别附加到产品上。例如-ID为1的产品应返回以下内容：|productname|catego...
来自于 2024-04-03 09:55:31
0
1
350
相关专题
更多>
热门推荐
热门教程
更多>
相关教程
热门推荐
最新课程
最新下载
更多>
网站特效
网站源码
网站素材
前端模板