基于HTML实现其他类别网站_php实现msn协议的类_sendmsg(HTML源码+数据集+项目使用说明).rar

<?php require_once('msnpauth.php'); define('ERR_AUTHENTICATION_FAILED', 911); define('ERR_SERVER_UNAVAILABLE', 600); define('ERR_USER_OFFLINE', 217); define('ERR_TOO_MANY_SESSIONS', 800); define('OK', 1); class sendMsg { var $_passport; var $_password; var $_account; var $_sockets; var $_msg; var $result; var $error; function simpleSend($passport, $password, $recipient, $message) { $this->login($passport, $password); if ($this->result > 1) { return; } $this->createSession($recipient); $this->sendMessage($message); } function login($passport, $password) { $this->_passport = $passport; $this->_password = $password; $this->_connect('NS'); $this->_send_data('NS', 'VER 0 MSNP8'); $this->_read(); } function createSession($account) { // Stop if login failed. if ($this->result > 1) { return; } $this->_account = $account; $this->_send_data('NS', 'XFR 5 SB'); $this->_read(); } function sendMessage($message, $font = NULL, $color = NULL) { // Stop if login failed. if ($this->result > 1) { return; } $head = "MIME-Version: 1.0\r\nContent-Type: text/plain; charset=UTF-8\r\n"; if (isset($font)) { $font = rawurlencode($font); $head .= "X-MMS-IM-Format: FN=$font; EF=; CO=$color; CS=0; PF=22\r\n"; } $head .= "\r\n"; $len = strlen($head.$message); $this->_send_data('SB', "MSG 3 U $len\r\n$head$message"); $this->result = OK; } function _connect($socket, $server = 'messenger.hotmail.com') { // This part does a DNS lookup on the server, and fails with error if it is not found. // fsockopen doesn't return an error on DNS lookup failures, instead it outputs a warning (which we want to suppress). if ((gethostbyname($server) == $server) && !is_numeric(str_replace('.', '', $server))) { $this->result = ERR_SERVER_UNAVAILABLE; $this->error = 'Host not found'.$server; return false; } ini_set('default_socket_timeout', 2); $this->_sockets[$socket] = @fsockopen($server, 1863, $errno, $errstr, 2); if ($this->_sockets[$socket] == false) { $this->result = $errno; $this->error = $errstr; return false; } return true; } function _read($socket = 'NS') { $r = false; while ($this->_sockets[$socket] && !feof($this->_sockets[$socket]) && !$r) { $data = fgets($this->_sockets[$socket], 1024); if (!$data) { continue; } $data = substr($data, 0, -2); $r = $this->_process_data($data); if ($r) { return; } } } function _send_data($socket, $data) { if (substr($data, 0, 3) == 'MSG') { // Don't send appending new line if it's a payload command. (MSG) fputs($this->_sockets[$socket], $data); } else { fputs($this->_sockets[$socket], "$data\r\n"); } } function _process_data($data) { $params = explode(' ', $data); switch ($params[0]) { case 'VER': $this->_send_data('NS', 'CVR 1 0x0409 winnt 5.1 i386 MSNMSGR 6.0.0254 MSMSGS '.$this->_passport); break; case 'CVR': $this->_send_data('NS', 'USR 2 TWN I '.$this->_passport); break; case 'XFR': $subParams = explode(':', $params[3]); $r = $this->_connect($params[2], $subParams[0]); if (!$r) { return true; } if ($params[2] == 'NS') { $this->_send_data('NS', 'VER 0 MSNP8'); } elseif ($params[2] == 'SB') { $this->_send_data('SB', 'USR 1 '.$this->_passport.' '.$params[5]); } $this->_read($params[2]); return true; break; case 'USR': if ($params[2] == 'TWN') { $msnpauth = new MSNPAuth($this->_passport, $this->_password, $params[4]); $hash = $msnpauth->getKey(); if (!$hash) { $this->result = ERR_AUTHENTICATION_FAILED; $this->_send_data('NS', 'OUT'); return false; } $this->_send_data('NS', 'USR 3 TWN S '.$hash); } elseif ($params[2] == 'OK') { if (count($params) == 7) { $this->_send_data('NS', 'CHG 4 NLN'); return true; } else { $this->_send_data('SB', 'CAL 0 '.$this->_account); } } break; case 'JOI': return true; break; // Error code handling case '500': case '600': case '601': case '910': case '911': case '921': case '928': $this->result = ERR_SERVER_UNAVAILABLE; return true; break; case '800': $this->result = ERR_TOO_MANY_SESSIONS; return true; break; case '217': $this->result = ERR_USER_OFFLINE; return true; break; } return false; } } ?>