• 技术文章 >后端开发 >php教程

    PHP Socket实现的POP3类

    2016-07-25 08:57:48原创403

    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)<=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. //获取指定邮件得session Id
    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. //取得某个邮件的大小
    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. //获取邮件基本列表数组
    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. //获取指定邮件所有信息，intReturnType是返回值类型，1是字符串,2是数组
    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. //获取某邮件前指定行, $intReturnType 返回值类型，1是字符串，2是数组
    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. //删除邮件
    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. //重置被删除得邮件标记为未删除
    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. // 调试操作
    469. //---------------
    470. //输出对象信息
    471. function printObject()
    472. {
    473. print_r($this);
    474. exit;
    475. }
    476. //输出错误信息
    477. function printError()
    478. {
    479. echo "[Error Msg] : $strMessage
      \n";
    480. echo "[Error Num] : $intErrorNum
      \n";
    481. exit;
    482. }
    483. //输出主机信息
    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. //输出连接信息
    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. ?>

    复制代码

    调用示例：

    2. //测试代码
    3. //例如：$o = SocketPOP3Client('邮箱地址', '密码', 'POP3服务器', 'POP3端口')
    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. ?>
    复制代码
    声明：本文原创发布php中文网，转载请注明出处，感谢您的尊重！如有疑问，请联系admin@php.cn处理
    专题推荐：PHP Socket实现的POP3类
    上一篇：PHP查询网站PR值的实现代码 下一篇：Google PR值的PHP实现代码
    大前端线上培训班

    相关文章推荐

    • PHP中的命名空间定义与使用（实例详解）• 带你分清类中的构造函数与析构函数• PHP中clone关键字和__clone()方法的使用（实例详解）• 五分钟带你了解PHP中的魔术方法（实例详解）• 怎样去搞定PHP类的继承？（总结分享）

    全部评论我要评论

  • 取消发布评论发送
    • 1/1

    PHP中文网

    首页 首页课程 课程文章文章问答 问答博客博客词典 词典手册 手册资源 资源搜索 搜索APP下载 APP下载