PHP Socket实现的POP3类

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('[e-mail]', '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. ?>

复制代码