php写的smtp邮件发送类

2. $smtpserver = "*****";
3. $smtpserverport = 25;
4. $smtpuser = "******";
5. $smtppass = "*******";
6. $smtp = new smtp($smtpserver, $smtpserverport, true, $smtpuser, $smtppass); //这里面的一个true是表示使用身份验证,否则不使用身份验证.
7. $smtp->debug = false;
8. //$emailtype ＝ "HTML";
9. for ($i=0; $i<5; $i++) {
10. $smtp->sendmail("*****", "******", "Hello world!","This is only a test!");
11. }
12. echo "共发送了 $i 封邮件！";
13. ?>

下面是具体类的实现。

3. class smtp {

4. /* Public Variables */
5. var $smtp_port;
6. var $time_out;
7. var $host_name;
8. var $log_file;
9. var $relay_host;
10. var $debug;
11. var $auth;
12. var $user;
13. var $pass;
14. /* Private Variables */
15. var $sock;
16. /* Constractor */
17. function smtp($relay_host = "", $smtp_port = 25, $auth = false, $user, $pass)
18. {
19. $this->debug = false;
20. $this->smtp_port = $smtp_port;
21. $this->relay_host = $relay_host;
22. $this->time_out = 30; //is used in fsockopen()
23. $this->auth = $auth; //auth
24. $this->user = $user;
25. $this->pass = $pass;
26. $this->host_name = "localhost"; //is used in HELO command
27. $this->log_file = "";
28. $this->sock = false;
29. }
30. /* Main Function */
31. function sendmail($to, $from, $subject = "", $body = "", $mailtype= "", $cc = "", $bcc = "", $additional_headers = "")
32. {
33. $mail_from = $this->get_address($this->strip_comment($from));
34. $body = ereg_replace("(^|( ))(.)", "1.3", $body);
35. $header .= "MIME-Version:1.0 ";
36. if ($mailtype == "HTML") {
37. $header .= "Content-Type:text/html ";
38. }
39. $header .= "To: " . $to . " ";
40. if ($cc != "") {
41. $header .= "Cc: " . $cc . " ";
42. }
43. $header .= "From: $from<" . $from . ">; ";
44. $header .= "Subject: " . $subject . " ";
45. $header .= $additional_headers;
46. $header .= "Date: " . date("r") . " ";
47. $header .= "X-Mailer:By Redhat (PHP/" . phpversion() . ") ";
48. list($msec, $sec) = explode(" ", microtime());
49. $header .= "Message-ID: <" . date("YmdHis", $sec) . "." . ($msec * 1000000) . "." . $mail_from . ">; ";
50. $TO = explode(",", $this->strip_comment($to));
51. if ($cc != "") {
52. $TO = array_merge($TO, explode(",", $this->strip_comment($cc)));
53. }
54. if ($bcc != "") {
55. $TO = array_merge($TO, explode(",", $this->strip_comment($bcc)));
56. }
57. $sent = true;
58. foreach ($TO as $rcpt_to) {
59. $rcpt_to = $this->get_address($rcpt_to);
60. if (!$this->smtp_sockopen($rcpt_to)) {
61. $this->log_write("Error: Cannot send email to " . $rcpt_to . " ");
62. $sent = false;
63. continue;
64. }
65. if ($this->smtp_send($this->host_name, $mail_from, $rcpt_to, $header, $body)) {
66. $this->log_write("E-mail has been sent to <" . $rcpt_to . ">; ");
67. } else {
68. $this->log_write("Error: Cannot send email to <" . $rcpt_to . ">; ");
69. $sent = false;
70. }
71. fclose($this->sock);
72. $this->log_write("Disconnected from remote host ");
73. }
74. return $sent;
75. }

76. /* Private Functions */

77. function smtp_send($helo, $from, $to, $header, $body = "")
78. {
79. if (!$this->smtp_putcmd("HELO", $helo)) {
80. return $this->smtp_error("sending HELO command");
81. }
82. // auth
83. if ($this->auth) {
84. if (!$this->smtp_putcmd("AUTH LOGIN", base64_encode($this->user))) {
85. return $this->smtp_error("sending HELO command");
86. }
87. if (!$this->smtp_putcmd("", base64_encode($this->pass))) {
88. return $this->smtp_error("sending HELO command");
89. }
90. }
91. if (!$this->smtp_putcmd("MAIL", "FROM:<" . $from . ">;")) {
92. return $this->smtp_error("sending MAIL FROM command");
93. }
94. if (!$this->smtp_putcmd("RCPT", "TO:<" . $to . ">;")) {
95. return $this->smtp_error("sending RCPT TO command");
96. }
97. if (!$this->smtp_putcmd("DATA")) {
98. return $this->smtp_error("sending DATA command");
99. }
100. if (!$this->smtp_message($header, $body)) {
101. return $this->smtp_error("sending message");
102. }
103. if (!$this->smtp_eom()) {
104. return $this->smtp_error("sending ;;.;; [EOM]");
105. }
106. if (!$this->smtp_putcmd("QUIT")) {
107. return $this->smtp_error("sending QUIT command");
108. }
109. return true;
110. }
111. function smtp_sockopen($address)
112. {
113. if ($this->relay_host == "") {
114. return $this->smtp_sockopen_mx($address);
115. } else {
116. return $this->smtp_sockopen_relay();
117. }
118. }
119. function smtp_sockopen_relay()
120. {
121. $this->log_write("Trying to " . $this->relay_host . ":" . $this->smtp_port . " ");
122. $this->sock = @fsockopen($this->relay_host, $this->smtp_port, $errno, $errstr, $this->time_out);
123. if (!($this->sock && $this->smtp_ok())) {
124. $this->log_write("Error: Cannot connenct to relay host " . $this->relay_host . " ");
125. $this->log_write("Error: " . $errstr . " (" . $errno . ") ");
126. return false;
127. }
128. $this->log_write("Connected to relay host " . $this->relay_host . " ");
129. return true;;
130. }
131. function smtp_sockopen_mx($address)
132. {
133. $domain = ereg_replace("^.+@([^@]+)$", "1", $address);
134. if (!@getmxrr($domain, $MXHOSTS)) {
135. $this->log_write("Error: Cannot resolve MX "" . $domain . "" ");
136. return false;
137. }
138. foreach ($MXHOSTS as $host) {
139. $this->log_write("Trying to " . $host . ":" . $this->smtp_port . " ");
140. $this->sock = @fsockopen($host, $this->smtp_port, $errno, $errstr, $this->time_out);
141. if (!($this->sock && $this->smtp_ok())) {
142. $this->log_write("Warning: Cannot connect to mx host " . $host . " ");
143. $this->log_write("Error: " . $errstr . " (" . $errno . ") ");
144. continue;
145. }
146. $this->log_write("Connected to mx host " . $host . " ");
147. return true;
148. }
149. $this->log_write("Error: Cannot connect to any mx hosts (" . implode(", ", $MXHOSTS) . ") ");
150. return false;
151. }
152. function smtp_message($header, $body)
153. {
154. fputs($this->sock, $header . " " . $body);
155. $this->smtp_debug(">; " . str_replace(" ", " " . ">; ", $header . " >; " . $body . " >; "));
156. return true;
157. }
158. function smtp_eom()
159. {
160. fputs($this->sock, " . ");
161. $this->smtp_debug(". [EOM] ");
162. return $this->smtp_ok();
163. }
164. function smtp_ok()
165. {
166. $response = str_replace(" ", "", fgets($this->sock, 512));
167. $this->smtp_debug($response . " ");
168. if (!ereg("^[23]", $response)) {
169. fputs($this->sock, "QUIT ");
170. fgets($this->sock, 512);
171. $this->log_write("Error: Remote host returned "" . $response . "" ");
172. return false;
173. }
174. return true;
175. }
176. function smtp_putcmd($cmd, $arg = "")
177. {
178. if ($arg != "") {
179. if ($cmd == "") $cmd = $arg;
180. else $cmd = $cmd . " " . $arg;
181. }
182. fputs($this->sock, $cmd . " ");
183. $this->smtp_debug(">; " . $cmd . " ");
184. return $this->smtp_ok();
185. }
186. function smtp_error($string)
187. {
188. $this->log_write("Error: Error occurred while " . $string . ". ");
189. return false;
190. }
191. function log_write($message)
192. {
193. $this->smtp_debug($message);
194. if ($this->log_file == "") {
195. return true;
196. }
197. $message = date("M d H:i:s ") . get_current_user() . "[" . getmypid() . "]: " . $message;
198. if (!@file_exists($this->log_file) || !($fp = @fopen($this->log_file, "a"))) {
199. $this->smtp_debug("Warning: Cannot open log file "" . $this->log_file . "" ");
200. return false;;
201. }
202. flock($fp, LOCK_EX);
203. fputs($fp, $message);
204. fclose($fp);
205. return true;
206. }
207. function strip_comment($address)
208. {
209. $comment = "([^()]*)";
210. while (ereg($comment, $address)) {
211. $address = ereg_replace($comment, "", $address);
212. }
213. return $address;
214. }
215. function get_address($address)
216. {
217. $address = ereg_replace("([ ])+", "", $address);
218. $address = ereg_replace("^.*<(.+)>;.*$", "1", $address);
219. return $address;
220. }
221. function smtp_debug($message)
222. {
223. if ($this->debug) {
224. echo $message . ";";
225. }
226. }
227. }
228. ?>