首页 > 代码库 > 新浪微博API Oauth2.0 认证
新浪微博API Oauth2.0 认证
原文链接: http://rsj217.diandian.com/post/2013-04-17/40050093587
本意是在注销账号前保留之前的一些数据。决定用python 爬取收藏。可是未登录无法爬取。想要登录有两种办法,伪造浏览器登录。第二就是注册新浪开发者账号,通过Oauth认证调用其API。
Oauth 的原理搞了一天才明白。很多网站都提供多语言的Oauth。而 1.0 和 2.0 的最大差别就是多了一个 callback 回调页面。关于这方面的说明很少,搞得我一头雾水折腾了好久。总算明白了。
Oauth的原理
现在多用 oauth2.0. 具体可以看其官方文档。用下面的图简单说明:
Consumer指应用程序,User是用户,Service是服务器。大致过程为,User使用程序Consumer。C 向 Service请求一个未授权的令牌(Request_token),这个时候 S 验证 C的合法性(通过开发者的 APP_KEY 和 APP_SECREST)。然后重定向到一个授权页面(通常由服务方提供)。此时用户进行授权,即输入用户名和密码,用户会自动向服务器发送 authorize request_token。得到授权的 request_token。再然后,授权通过后,跳转到一个 callback 页面。通过request_token用来向服务器请求,换取 acess_token。至此,认证结束。接下来要请求数据,只需要根据文档 把 acess_token 当参数传给服务器。
这样说比较抽象,举个简单的例子:
有一个人 U 想去银行 S 取钱。U 没事情去柜台,就委托朋友 C 去柜台。当C 去了银行S,给S说:我要帮 U 取钱。S 先验证 C 的身份,是合法公民。然后 S 打电话给 U。说:C 要帮你取钱,你确定么,确定的话就输入用户名和密码。 U 确定了。此时,S 就给了一个 钥匙给 C。说:我们不提供自动服务,给你钥匙,自己去库房取。然后 C 拿着钥匙,就去取钱了。取完之后给力 U。U 很感激。
通过上面的解释,应该可以知道整个过程中有三个URL请求地址,如下图:
这写地址由服务方提供,上面那个就是 qq 公共平台的url。新浪有新浪自己的。关于第一步,请求 request_token的时候,服务器也要认证开发者帐号,也就是银行认证 C 的合法身份。
每个 开发者都有app_key 和 app_secret. app_key称为密钥, app_secret为密匙。开发者和服务都知道。然后 ,开发者通过 app_key 和 app_secret 通过 一种加密(sha1)得到一个字符串secretcode 公钥。再把 app_key 和 secretcode 发送给服务器。服务器接收之后,将发送到 app_key和服务器存储的 app_secret 通过同样的加密手段得到一个 secretcode2 和发送过来的secretcode进行对比,如果一样,则可以证明是通过。这一点好处是安全。不怕被抓包。
新浪 Oauth的运用
简单知道原理,就可以进行认证。
准备工作
需要向新浪申请开发者帐号,然后创建一个应用。之后会得到一个 app_key 和 app_secret。需要注意是一定要填写下面的回调地址:
新浪的是可以设置 本地的,例如 http://127.0.0.1/oauth/callback.php
豆瓣的需要公网可以访问的回调地址,不同api不一样。
布署
可以下载 官方提供的 SDK ,根据语言选择。这里选择 php。理由是 php的web环境可以一键安装。需要注意到是,新浪的 SDK需要 php 开启 curl。不然会报错。
文档结构如下:
config.php 开发者配置文件
index.php 登录主入口
callback.php 回调处理
saetv2.ex.class.php SDK 主文件,提供认证和api调用
weibolist.php 认证成功之后的数据请求和展示
引用官方的 SDK ,根据demo使用就行。这里重写一下 SDK 的请求过程。
index.php
1 <?php 2 session_start(); 3 4 include_once( ‘config.php‘ ); 5 include_once( ‘saetv2.ex.class.php‘ ); 6 7 $o = new SaeTOAuthV2( WB_AKEY , WB_SKEY ); 8 //获取请求 request_token 的 url 9 $code_url = $o->getAuthorizeURL( WB_CALLBACK_URL );10 11 ?>12 <!DOCTYPE html>13 <html>14 <head>15 <meta http-equiv="Content-Type" content="text/html; charset=utf-8" />16 <title>新浪微博登录</title>17 </head>18 19 <body>20 <!-- 授权按钮 -->21 <p><a href="http://www.mamicode.com/<?php echo $code_url?>"><img src="http://www.mamicode.com/weibo_login.png" title="点击进入授权页面" alt="点击进入授权页面" border="0" /></a></p>22 </body>23 </html>
主要做的事情和I获取 请求 request_token 的url。然后跳转到官方提供的授权页面:
授权之后会重定向到回调 callback.pho.
1 <?php 2 session_start(); 3 4 include_once( ‘config.php‘ ); 5 include_once( ‘saetv2.ex.class.php‘ ); 6 7 $o = new SaeTOAuthV2( WB_AKEY , WB_SKEY ); 8 9 if (isset($_REQUEST[‘code‘])) {10 $keys = array();11 $keys[‘code‘] = $_REQUEST[‘code‘];12 $keys[‘redirect_uri‘] = WB_CALLBACK_URL;13 try {14 $token = $o->getAccessToken( ‘code‘, $keys ) ;15 } catch (OAuthException $e) {16 }17 }18 19 if ($token) {20 $_SESSION[‘token‘] = $token;21 setcookie( ‘weibojs_‘.$o->client_id, http_build_query($token) );22 ?>23 授权完成,<a href="http://www.mamicode.com/weibolist.php">进入你的微博列表页面</a><br />24 <?php25 } else {26 ?>27 授权失败。28 <?php29 }30 ?>
这一步主要是根据授权之后返回的 code 进行调用,请求 acess_token。
前面两部的方法 ,都在
saetv2.ex.class.php里实现,代码如下:
1 <?php 2 /** 3 * @ignore 4 */ 5 class OAuthException extends Exception { 6 // pass 7 } 8 9 10 /** 11 * 新浪微博 OAuth 认证类(OAuth2) 12 * 13 * 授权机制说明请大家参考微博开放平台文档:{@link http://open.weibo.com/wiki/Oauth2} 14 * 15 * @package sae 16 * @author Elmer Zhang 17 * @version 1.0 18 */ 19 class SaeTOAuthV2 { 20 21 public $client_id; 22 public $client_secret; 23 public $access_token; 24 public $http_code; 25 public $url; 26 public $host = "https://api.weibo.com/2/"; 27 public $timeout = 30; 28 public $connecttimeout = 30; 29 public $ssl_verifypeer = FALSE; 30 public $format = ‘json‘; 31 public $decode_json = TRUE; 32 public $http_info; 33 public $useragent = ‘Sae T OAuth2 v0.1‘; 34 public $debug = FALSE; 35 public static $boundary = ‘‘; 36 37 /** 38 * Set API URLS 39 */ 40 /** 41 * @ignore 42 */ 43 function accessTokenURL() { return ‘https://api.weibo.com/oauth2/access_token‘; } 44 /** 45 * @ignore 46 */ 47 function authorizeURL() { return ‘https://api.weibo.com/oauth2/authorize‘; } 48 49 /** 50 * construct WeiboOAuth object 51 */ 52 function __construct($client_id, $client_secret, $access_token = NULL) { 53 $this->client_id = $client_id; 54 $this->client_secret = $client_secret; 55 $this->access_token = $access_token; 56 } 57 58 /** 59 * authorize接口 60 * 61 * 对应API:{@link http://open.weibo.com/wiki/Oauth2/authorize Oauth2/authorize} 62 * 63 * @param string $url 授权后的回调地址,站外应用需与回调地址一致,站内应用需要填写canvas page的地址 64 * @param string $response_type 支持的值包括 code 和token 默认值为code 65 * @param string $state 用于保持请求和回调的状态。在回调时,会在Query Parameter中回传该参数 66 * @param string $display 授权页面类型 可选范围: 67 * - default 默认授权页面 68 * - mobile 支持html5的手机 69 * - popup 弹窗授权页 70 * - wap1.2 wap1.2页面 71 * - wap2.0 wap2.0页面 72 * - js js-sdk 专用 授权页面是弹窗,返回结果为js-sdk回掉函数 73 * - apponweibo 站内应用专用,站内应用不传display参数,并且response_type为token时,默认使用改display.授权后不会返回access_token,只是输出js刷新站内应用父框架 74 * @return array 75 */ 76 function getAuthorizeURL( $url, $response_type = ‘code‘, $state = NULL, $display = NULL ) { 77 $params = array(); 78 $params[‘client_id‘] = $this->client_id; 79 $params[‘redirect_uri‘] = $url; 80 $params[‘response_type‘] = $response_type; 81 $params[‘state‘] = $state; 82 $params[‘display‘] = $display; 83 return $this->authorizeURL() . "?" . http_build_query($params); 84 } 85 86 /** 87 * access_token接口 88 * 89 * 对应API:{@link http://open.weibo.com/wiki/OAuth2/access_token OAuth2/access_token} 90 * 91 * @param string $type 请求的类型,可以为:code, password, token 92 * @param array $keys 其他参数: 93 * - 当$type为code时: array(‘code‘=>..., ‘redirect_uri‘=>...) 94 * - 当$type为password时: array(‘username‘=>..., ‘password‘=>...) 95 * - 当$type为token时: array(‘refresh_token‘=>...) 96 * @return array 97 */ 98 function getAccessToken( $type = ‘code‘, $keys ) { 99 $params = array();100 $params[‘client_id‘] = $this->client_id;101 $params[‘client_secret‘] = $this->client_secret;102 if ( $type === ‘code‘ ) {103 $params[‘grant_type‘] = ‘authorization_code‘;104 $params[‘code‘] = $keys[‘code‘];105 $params[‘redirect_uri‘] = $keys[‘redirect_uri‘];106 } else {107 throw new OAuthException("wrong auth type");108 }109 110 $response = $this->oAuthRequest($this->accessTokenURL(), ‘POST‘, $params);111 $token = json_decode($response, true);112 if ( is_array($token) && !isset($token[‘error‘]) ) {113 $this->access_token = $token[‘access_token‘];114 } else {115 throw new OAuthException("get access token failed." . $token[‘error‘]);116 }117 return $token;118 }119 120 /**121 * Format and sign an OAuth / API request122 *123 * @return string124 * @ignore125 */126 function oAuthRequest($url, $method, $parameters, $multi = false) {127 128 if (strrpos($url, ‘http://‘) !== 0 && strrpos($url, ‘https://‘) !== 0) {129 $url = "{$this->host}{$url}.{$this->format}";130 }131 132 switch ($method) {133 case ‘GET‘:134 $url = $url . ‘?‘ . http_build_query($parameters);135 return $this->http($url, ‘GET‘);136 default:137 $headers = array();138 if (!$multi && (is_array($parameters) || is_object($parameters)) ) {139 $body = http_build_query($parameters);140 } else {141 $body = self::build_http_query_multi($parameters);142 $headers[] = "Content-Type: multipart/form-data; boundary=" . self::$boundary;143 }144 return $this->http($url, $method, $body, $headers);145 }146 }147 148 /**149 * Make an HTTP request150 *151 * @return string API results152 * @ignore153 */154 function http($url, $method, $postfields = NULL, $headers = array()) {155 $this->http_info = array();156 $ci = curl_init();157 /* Curl settings */158 curl_setopt($ci, CURLOPT_HTTP_VERSION, CURL_HTTP_VERSION_1_0);159 curl_setopt($ci, CURLOPT_USERAGENT, $this->useragent);160 curl_setopt($ci, CURLOPT_CONNECTTIMEOUT, $this->connecttimeout);161 curl_setopt($ci, CURLOPT_TIMEOUT, $this->timeout);162 curl_setopt($ci, CURLOPT_RETURNTRANSFER, TRUE);163 curl_setopt($ci, CURLOPT_ENCODING, "");164 curl_setopt($ci, CURLOPT_SSL_VERIFYPEER, $this->ssl_verifypeer);165 curl_setopt($ci, CURLOPT_HEADERFUNCTION, array($this, ‘getHeader‘));166 curl_setopt($ci, CURLOPT_HEADER, FALSE);167 168 switch ($method) {169 case ‘POST‘:170 curl_setopt($ci, CURLOPT_POST, TRUE);171 if (!empty($postfields)) {172 curl_setopt($ci, CURLOPT_POSTFIELDS, $postfields);173 $this->postdata = http://www.mamicode.com/$postfields;174 }175 break;176 case ‘DELETE‘:177 curl_setopt($ci, CURLOPT_CUSTOMREQUEST, ‘DELETE‘);178 if (!empty($postfields)) {179 $url = "{$url}?{$postfields}";180 }181 }182 183 if ( isset($this->access_token) && $this->access_token )184 $headers[] = "Authorization: OAuth2 ".$this->access_token;185 186 $headers[] = "API-RemoteIP: " . $_SERVER[‘REMOTE_ADDR‘];187 curl_setopt($ci, CURLOPT_URL, $url );188 curl_setopt($ci, CURLOPT_HTTPHEADER, $headers );189 curl_setopt($ci, CURLINFO_HEADER_OUT, TRUE );190 191 $response = curl_exec($ci);192 $this->http_code = curl_getinfo($ci, CURLINFO_HTTP_CODE);193 $this->http_info = array_merge($this->http_info, curl_getinfo($ci));194 $this->url = $url;195 196 if ($this->debug) {197 echo "=====post data=http://www.mamicode.com/=====/r/n";198 var_dump($postfields);199 200 echo ‘=====info=====‘."\r\n";201 print_r( curl_getinfo($ci) );202 203 echo ‘=====$response=====‘."\r\n";204 print_r( $response );205 }206 curl_close ($ci);207 return $response;208 }209 210 /**211 * Get the header info to store.212 *213 * @return int214 * @ignore215 */216 function getHeader($ch, $header) {217 $i = strpos($header, ‘:‘);218 if (!empty($i)) {219 $key = str_replace(‘-‘, ‘_‘, strtolower(substr($header, 0, $i)));220 $value = trim(substr($header, $i + 2));221 $this->http_header[$key] = $value;222 }223 return strlen($header);224 }225 226 /**227 * @ignore228 */229 public static function build_http_query_multi($params) {230 if (!$params) return ‘‘;231 232 uksort($params, ‘strcmp‘);233 234 $pairs = array();235 236 self::$boundary = $boundary = uniqid(‘------------------‘);237 $MPboundary = ‘--‘.$boundary;238 $endMPboundary = $MPboundary. ‘--‘;239 $multipartbody = ‘‘;240 241 foreach ($params as $parameter => $value) {242 243 if( in_array($parameter, array(‘pic‘, ‘image‘)) && $value{0} == ‘@‘ ) {244 $url = ltrim( $value, ‘@‘ );245 $content = file_get_contents( $url );246 $array = explode( ‘?‘, basename( $url ) );247 $filename = $array[0];248 249 $multipartbody .= $MPboundary . "\r\n";250 $multipartbody .= ‘Content-Disposition: form-data; name="‘ . $parameter . ‘"; filename="‘ . $filename . ‘"‘. "\r\n";251 $multipartbody .= "Content-Type: image/unknown\r\n\r\n";252 $multipartbody .= $content. "\r\n";253 } else {254 $multipartbody .= $MPboundary . "\r\n";255 $multipartbody .= ‘content-disposition: form-data; name="‘ . $parameter . "\"\r\n\r\n";256 $multipartbody .= $value."\r\n";257 }258 259 }260 261 $multipartbody .= $endMPboundary;262 return $multipartbody;263 }264 }265 ?>
getAuthorizeURL 方法是用来获取请求 request_token的地址。
getAccessToken 方法是获取 access_token
oAuthRequest 方法是用来发送请求
getHeader 我没发现有地方调用,但是没有他有不行,暂时不知道为什么。
至此Oauth认证结束。
认证就是为了得倒 access_token。本来我是要爬数据。才为了登录。后来发现直接使用 新浪的 api 测试接口,自动生成access_token。爬虫就直接用。当然,早没有发现,才促使我去研究了 Oauth认证,额外的收获吧。总而言之,人总是在逼迫中才能进步。
新浪微博API Oauth2.0 认证