这篇文章主要介绍了 php 基于 socket 实现 SMTP 发送邮件的方法, 实例分析了 php 采用 socket 实现 smtp 发送邮件的原理与技巧, 具有一定参考借鉴价值, 需要的朋友可以参考下
本文实例讲述了 php 基于 socket 实现 SMTP 发送邮件的方法分享给大家供大家参考具体分析如下:
php 采用 socket 通过 SMTP 发送邮件
用的是 php 的 php-sockets 扩展, 可以发送纯文本和 html 格式的邮件代码如下:
代码如下:
- <?php
- /**
- * 邮件发送类
- * 支持发送纯文本邮件和 HTML 格式的邮件
- * @example
- * $config = array(* "from" => "*****",
- * "to" => "***",
- * "subject" => "test",
- * "body" => "test",
- * "username" => "***",
- * "password" => "****",
- * "isHTML" => true
- * );
- *
- * $mail = new MySendMail();
- *
- * $mail->setServer("smtp.126.com");
- *
- * $mail->setMailInfo($config);
- * if(!$mail->sendMail()) {
- * echo $mail->error();
- * return 1;
- * }
- */
- class MySendMail {
- /**
- * @var 邮件传输代理用户名
- * @access private
- */
- private $_userName;
- /**
- * @var 邮件传输代理密码
- * @access private
- */
- private $_password;
- /**
- * @var 邮件传输代理服务器地址
- * @access protected
- */
- protected $_sendServer;
- /**
- * @var 邮件传输代理服务器端口
- * @access protected
- */
- protected $_port=25;
- /**
- * @var 发件人
- * @access protected
- */
- protected $_from;
- /**
- * @var 收件人
- * @access protected
- */
- protected $_to;
- /**
- * @var 主题
- * @access protected
- */
- protected $_subject;
- /**
- * @var 邮件正文
- * @access protected
- */
- protected $_body;
- /**
- * @var 是否是 HTML 格式的邮件
- * @access protected
- */
- protected $_isHTML=false;
- /**
- * @var socket 资源
- * @access protected
- */
- protected $_socket;
- /**
- * @var 错误信息
- * @access protected
- */
- protected $_errorMessage;
- public function __construct($from="", $to="", $subject="", $body="", $server="", $username="", $password="",$isHTML="", $port="") {
- if(!empty($from)){
- $this->_from = $from;
- }
- if(!empty($to)){
- $this->_to = $to;
- }
- if(!empty($subject)){
- $this->_subject = $subject;
- }
- if(!empty($body)){
- $this->_body = $body;
- }
- if(!empty($isHTML)){
- $this->_isHTML = $isHTML;
- }
- if(!empty($server)){
- $this->_sendServer = $server;
- }
- if(!empty($port)){
- $this->_port = $port;
- }
- if(!empty($username)){
- $this->_userName = $username;
- }
- if(!empty($password)){
- $this->_password = $password;
- }
- }
- /**
- * 设置邮件传输代理
- * @param string $server 代理服务器的 ip 或者域名
- * @param int $port 代理服务器的端口, smtp 默认 25 号端口
- * @param int $localPort 本地端口
- * @return boolean
- */
- public function setServer($server, $port=25) {
- if(!isset($server) || empty($server) || !is_string($server)) {
- $this->_errorMessage = "first one is an invalid parameter";
- return false;
- }
- if(!is_numeric($port)){
- $this->_errorMessage = "first two is an invalid parameter";
- return false;
- }
- $this->_sendServer = $server;
- $this->_port = $port;
- return true;
- }
- /**
- * 设置邮件
- * @access public
- * @param array $config 邮件配置信息
- * 包含邮件发送人接收人主题内容邮件传输代理的验证信息
- * @return boolean
- */
- public function setMailInfo($config) {
- if(!is_array($config) || count($config) < 6){
- $this->_errorMessage = "parameters are required";
- return false;
- }
- $this->_from = $config['from'];
- $this->_to = $config['to'];
- $this->_subject = $config['subject'];
- $this->_body = $config['body'];
- $this->_userName = $config['username'];
- $this->_password = $config['password'];
- if(isset($config['isHTML'])){
- $this->_isHTML = $config['isHTML'];
- }
- return true;
- }
- /**
- * 发送邮件
- * @access public
- * @return boolean
- */
- public function sendMail() {
- $command = $this->getCommand();
- $this->socket();
- foreach ($command as $value) {
- if($this->sendCommand($value[0], $value[1])) {
- continue;
- }
- else{
- return false;
- }
- }
- $this->close(); // 其实这里也没必要关闭, smtp 命令: QUIT 发出之后, 服务器就关闭了连接, 本地的 socket 资源会自动释放
- echo 'Mail OK!';
- return true;
- }
- /**
- * 返回错误信息
- * @return string
- */
- public function error(){
- if(!isset($this->_errorMessage)) {
- $this->_errorMessage = "";
- }
- return $this->_errorMessage;
- }
- /**
- * 返回 mail 命令
- * @access protected
- * @return array
- */
- protected function getCommand() {
- if($this->_isHTML) {
- $mail = "MIME-Version:1.0\r\n";
- $mail .= "Content-type:text/html;charset=utf-8\r\n";
- $mail .= "FROM:test<" . $this->_from . ">\r\n";
- $mail .= "TO:<" . $this->_to . ">\r\n";
- $mail .= "Subject:" . $this->_subject ."\r\n\r\n";
- $mail .= $this->_body . "\r\n.\r\n";
- }
- else{
- $mail = "FROM:test<" . $this->_from . ">\r\n";
- $mail .= "TO:<" . $this->_to . ">\r\n";
- $mail .= "Subject:" . $this->_subject ."\r\n\r\n";
- $mail .= $this->_body . "\r\n.\r\n";
- }
- $command = array(
- array("HELO sendmail\r\n", 250),
- array("AUTH LOGIN\r\n", 334),
- array(base64_encode($this->_userName) . "\r\n", 334),
- array(base64_encode($this->_password) . "\r\n", 235),
- array("MAIL FROM:<" . $this->_from . ">\r\n", 250),
- array("RCPT TO:<" . $this->_to . ">\r\n", 250),
- array("DATA\r\n", 354),
- array($mail, 250),
- array("QUIT\r\n", 221)
- );
- return $command;
- }
- /**
- * @access protected
- * @param string $command 发送到服务器的 smtp 命令
- * @param int $code 期望服务器返回的响应吗
- * @param boolean
- */
- protected function sendCommand($command, $code) {
- echo 'Send command:' . $command . ',expected code:' . $code . '
- ';
- // 发送命令给服务器
- try{
- if(socket_write($this->_socket, $command, strlen($command))){
- // 读取服务器返回
- $data = trim(socket_read($this->_socket, 1024));
- echo 'response:' . $data . '
- ';
- if($data) {
- $pattern = "/^".$code."/";
- if(preg_match($pattern, $data)) {
- return true;
- }
- else{
- $this->_errorMessage = "Error:" . $data . "|**| command:";
- return false;
- }
- }
- else{
- $this->_errorMessage = "Error:" . socket_strerror(socket_last_error());
- return false;
- }
- }
- else{
- $this->_errorMessage = "Error:" . socket_strerror(socket_last_error());
- return false;
- }
- }catch(Exception $e) {
- $this->_errorMessage = "Error:" . $e->getMessage();
- }
- }
- /**
- * 建立到服务器的网络连接
- * @access private
- * @return boolean
- */
- private function socket() {
- if(!function_exists("socket_create")) {
- $this->_errorMessage = "extension php-sockets must be enabled";
- return false;
- }
- // 创建 socket 资源
- $this->_socket = socket_create(AF_INET, SOCK_STREAM, getprotobyname('tcp'));
- if(!$this->_socket) {
- $this->_errorMessage = socket_strerror(socket_last_error());
- return false;
- }
- // 连接服务器
- if(!socket_connect($this->_socket, $this->_sendServer, $this->_port)) {
- $this->_errorMessage = socket_strerror(socket_last_error());
- return false;
- }
- socket_read($this->_socket, 1024);
- return true;
- }
- /**
- * 关闭 socket
- * @access private
- * @return boolean
- */
- private function close() {
- if(isset($this->_socket) && is_object($this->_socket)) {
- $this->_socket->close();
- return true;
- }
- $this->_errorMessage = "no resource can to be close";
- return false;
- }
- }
- /**************************** Test ***********************************/
- $config = array(
- "from" => "XXXXX",
- "to" => "XXXXX",
- "subject" => "test",
- "body" => "test",
- "username" => "XXXXX",
- "password" => "******",
- //"isHTML" => true
- );
- $mail = new MySendMail();
- $mail->setServer("smtp.126.com");
- $mail->setMailInfo($config);
- if(!$mail->sendMail()) {
- echo $mail->error();
- return 1;
- }
来源: https://www.php1.cn/detail/php-db5594e46d.html