登录  /  注册
首页 > 后端开发 > php教程 > 正文

PHP Socket实现的POP3类

php中文网
发布： 2016-07-25 08:57:48
原创
956人浏览过

  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. ?>
复制代码


智能AI问答
PHP中文网智能助手能迅速回答你的编程问题，提供实时的代码和解决方案，帮助你解决各种难题。不仅如此，它还能提供编程资源和学习指导，帮助你快速提升编程技能。无论你是初学者还是专业人士，AI智能助手都能成为你的可靠助手，助力你在编程领域取得更大的成就。
我要提问
来源：php中文网
收藏 点赞
上一篇：PHP查询网站PR值的实现代码 下一篇：Google PR值的PHP实现代码
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系admin@php.cn
作者最新文章
最新问题
使用计算属性的mailto链接未加载完整的消息正文 mailto链接已正确加载收件人和主题，但似乎将电子邮件正文截断为非常短的长度。我的电子邮件总共有1500个字符，因此低于mailto限制。该电子邮件的正文似乎被截断了大约200个...
P粉811349112来自于2023-12-07 19:05:55
0 1 253
未找到通过 Twitter 分享的结果（仅在移动设备上分享）：错误 我有一个简单的Faceb ook、Twitter和Pinterest分享按钮<ahref="<?phpecho"$base_url/share.ph...
P粉486743671来自于2023-12-07 10:54:26
0 1 186
如何在 JavaScript 中将 COCO RLE 二进制掩码解码为图像？ 这是COCORLE掩码的示例-https://pastebin.com/ZhE2en4C这是YOLOv8验证运行的输出，取自生成的Predictions.json文件。我正在尝试在...
P粉709307865来自于2023-12-07 10:08:08
0 1 197
Nuxt-link使用Bootstrap-vue刷新页面的问题 我正在使用nuxt和bootstrap构建自定义悬停下拉菜单以进行导航。我遇到的问题是我的导航子菜单NuxtLinks正在刷新整个页面，而不是平滑地更改Nuxt块中的应用程序内容。...
P粉512729862来自于2023-12-07 08:58:02
0 1 310
为什么 Inertia JS Form 不能与 vue.js 一起使用？当我使用错误时 我目前遇到一个问题。我曾经有一个IndexUserSettings.vue，它显示了IndexUserBillingDetail.vue。在此vue中，检查create:boole...
P粉302160436来自于2023-12-06 21:56:35
0 1 187
如何修复 Vue 应用程序的窗口对象上的这些 Typescript 错误？ 在我的Vue3应用程序的组件中，我需要使用窗口上的一些自定义属性，如下所示：window.ZohoHCAsapSettings={//<--ERRORHEREticketsS...
P粉344355715来自于2023-12-06 20:46:24
0 2 190
React hook 表单字段数组验证不起作用 我有一个字段数组，其中有一个输入字段，我为其设置了一些验证规则，例如required和minLength。我希望在附加新字段时立即验证该字段。但是，这种情况并没有发生，即使我附加空...
P粉665679053来自于2023-12-06 19:41:46
0 1 211
Vue中v-html无法渲染\r\n\t 我有这样的数据：data:{content:"<p><spanstyle=\"font-size:16px\">Berikut...
P粉852114752来自于2023-12-06 17:55:55
0 1 243
Vue 3 composition api中的双向表单数据绑定 我开始在vue中从选项api过渡到组合api。我有以下代码块，我正在尝试实现2路绑定。我正在使用ant-design-vue库进行滑块输入。并尝试将滑块值绑定到输入字段。<t...
P粉982881583来自于2023-12-06 10:55:35
0 1 266
单页应用程序在 AWS Cognito 中遇到自定义登录重定向问题 如果我在Cognito上的应用程序客户端中使用托管UI，则重定向可以正常工作。但是，如果我创建自己的登录页面，它不会重定向到我想要的网站。这是在使用VueJS的单页应用程序中，我也...
P粉323374878来自于2023-12-05 23:47:09
0 1 278
相关专题
更多>
热门推荐
热门教程
更多>
相关推荐
热门推荐
最新课程
最新下载
更多>
网站特效
网站源码
网站素材
前端模板
关于我们 免责申明 意见反馈 讲师合作 广告合作 技术文章
php中文网：公益在线php培训，帮助PHP学习者快速成长！
关注服务号 技术交流群
app下载
PHP中文网订阅号
每天精选资源文章推送
PHP中文网APP
随时随地碎片化学习
PHP中文网抖音号
发现有趣的

Copyright 2014-2023 //m.sbmmt.com/ All Rights Reserved | 苏州跃动光标网络科技有限公司 | 苏ICP备2020058653号-1

 | 本站CDN由 数掘科技 提供

登录PHP中文网，和优秀的人一起学习！
全站2000+教程免费学
微信扫码登录

  • 精品班

  • 技术支持

  • 技术咨询

  • 学习群

  • 会员优惠

  • 返回顶部