关于小米手机网站抢购的一点技术分析

news/2024/5/20 3:09:24/文章来源:https://blog.csdn.net/weixin_34128237/article/details/91953902

2019独角兽企业重金招聘Python工程师标准>>>

先PS一下：最近小米手机火了，看起来好像地球人已经不能阻止它的发展趋势了

其实本文论述的技术也并非小米手机专用，只是用小米手机来做借鉴，但课题起源于朋友请求帮忙购买小米手机，于是借助专业知识写了一个抢购的工具，拿出来和大家分享一下。说叫抢购工具，其实就是自动下订单而已，因为小米手机网站的订单只要在72小时内完成支付就可以，所以在第一时间完成下单以后找闲暇时间进行支付就可以了。

再PS一下：【声明】本工具原理为模拟浏览器访问和执行页面，不包含任何入侵和破坏行为。本工具的优点只是自动化处理以及节省不必要的流量耗费。

1、首先分析任务实现需要操作的步骤：

　　a、登录系统，此步骤中小米商城网站使用了通行证认证模式，即需要将表单提交到passport.xiaomi.com，认证成功后通过token传递回商城网站的callback页面。

　　b、清空购物车，本步骤可选。因为是工具自动购买，防止错误下单，可在每次执行操作前自动清空购物车，购物车清空后会302到购物车页面，http://order.xiaomi.com/cart，页面提示“清空购物车成功”。

　　c、将商品放入购物车。此步骤小米网站没有使用post，而是get，通过url将商品id以及数量传递给服务器，并且还使用了友好url，例如 http://order.xiaomi.com/cart/add/1016-0-1 是将小米手机M1放入购物车，其中1016为小米手机的商品id，0表示此商品为单品（非组合套装），1表示购买一个。以此类推。放入购物车以后会自动302到购物车页面，不过此时url为 http://order.xiaomi.com/cart/index，显示购物车中的商品。

　　d、提交订单。本步骤同样为get方式，直接请求地址 http://order.xiaomi.com/buy/checkout 即开始将购物车中的商品作为一个订单进行提交，此时进入订单详细信息填写页面，填写收货人、收货地址、电话、发票等信息，确认订单需要post，请求的地址仍然是 http://order.xiaomi.com/buy/checkout。

2、关键技术点分析及实现

　　清楚了任务要求，接下来分析技术点，鉴于本人对C#比较熟悉，故选用C#语言实现，采用了Winform项目框架。

　　a、核心需求即是通过http协议下载页面，以下为本人使用的核心代码：

View Code
Uri uri = rawUri;
HttpWebSession session = new HttpWebSession()
{
RequestUri = uri,
};
var _request = session.Request =
(HttpWebRequest)WebRequest.Create(uri);
_httpWebSessions.Add(session);
if (Proxy != null)
{
_request.Proxy = Proxy;
}
_request.AllowAutoRedirect = false;
if (Uri.UriSchemeHttps == uri.Scheme)
{
ServicePointManager.ServerCertificateValidationCallback = new RemoteCertificateValidationCallback(RemoteCertificateValidation);//
}
if (Credentials != null)
{
_request.Credentials = Credentials;
}
if (!string.IsNullOrEmpty(Accept))
{
_request.Accept = Accept;
}

if (!string.IsNullOrEmpty(AcceptLanguage))
{
_request.Headers.Add("Accept-Language", AcceptLanguage);
}
if (!string.IsNullOrEmpty(AcceptCharset))
{
_request.Headers.Add("Accept-Charset", AcceptCharset);
}
_request.KeepAlive = KeepAlive;
if (!string.IsNullOrEmpty(RefererUrl))
{
_request.Referer = RefererUrl;
}
switch (_acceptEncoding)
{
case AcceptEncoding.GZIP:
{
_request.Headers.Add("Accept-Encoding", "gzip");
break;
}
case AcceptEncoding.DEFLATE:
{
_request.Headers.Add("Accept-Encoding", "deflate");
break;
}
case AcceptEncoding.BOTH:
{
_request.Headers.Add("Accept-Encoding", "gzip,deflate");
break;
}
}
if (_request.CachePolicy == null || _request.CachePolicy.Level != _cacheLevel)
{
_request.CachePolicy = new RequestCachePolicy(_cacheLevel);
}
if (_headers != null && _headers.Count > 0)
{
foreach (KeyValuePair<string, string> item in _headers)
{
try
{
_request.Headers.Add(item.Key, item.Value);
}
catch
{ }
}
}
_request.UserAgent = _userAgent;
_request.Referer = RefererUrl;
if (TimeOut != 0)
{
_request.Timeout = TimeOut;
}
if (postData == null)
{
if (postDictionary != null)
{
foreach (var item in postDictionary)
{
postText += item.Key + "=" + item.Value + "&";
}
postText = postText.Trim('&');
}
if (!string.IsNullOrEmpty(postText))
{
postData = _encoding.GetBytes(postText);
}
}
if (_cookieContainer != null)
{
string strCookieHeader = _cookieContainer.GetCookieHeader(uri);
if (!string.IsNullOrEmpty(strCookieHeader))
{
_request.Headers["Cookie"] = strCookieHeader;
}
}
if (postData != null)
{
session.PostedData = postData;
_request.Method = "POST";
_request.ContentType = "application/x-www-form-urlencoded";
_request.ContentLength = postData.Length;
Stream requestStream = _request.GetRequestStream();
requestStream.Write(postData, 0, postData.Length);
requestStream.Close();
}
var _response = session.Response = (HttpWebResponse)_request.GetResponse();
if (_cookieContainer != null)
{
string strSetCookieHeader = _response.Headers["Set-Cookie"];
if (!string.IsNullOrEmpty(strSetCookieHeader))
{
_cookieContainer.SetCookies(_response.ResponseUri, strSetCookieHeader);
}
}
StatusCode = _response.StatusCode;
_requestCookieCollection = _cookieContainer.GetCookieCollection(rawUri);
_response.Cookies = _cookieContainer.GetCookieCollection(_response.ResponseUri);
if (IsEncodingAccepted(_response, AcceptEncoding.GZIP))
{
responseStream = new GZipStream(_response.GetResponseStream(), CompressionMode.Decompress);
}
else if (IsEncodingAccepted(_response, AcceptEncoding.DEFLATE))
{
responseStream = new DeflateStream(_response.GetResponseStream(), CompressionMode.Decompress);
}
else
{
responseStream = _response.GetResponseStream();
}

if (StatusCode == HttpStatusCode.Redirect || StatusCode == HttpStatusCode.Moved)
{
if (_allowAutoRedirect)
{
responseStream.Close();
string strRedirectUrl = _response.Headers["Location"];
var stream = GetStream(new Uri(rawUri, strRedirectUrl), true, null, null, null, null, null);
return stream;
}
// return GetStream(
}
else if (StatusCode == HttpStatusCode.Unauthorized)
{
string strAuthorizition = OnAuthorizition();
if (!string.IsNullOrEmpty(strAuthorizition))
{

}
}

上述代码是本人多年积累的一个类库中的一点核心代码，解决了诸多常见问题，比如cookieContainer对domain识别异常，https访问等等，如有需要本人可提供下载。

　　b、逻辑处理的自动机

　　　鉴于web访问过程中容易出现的各种不确定性因素，经常会出现请求同一个地址却返回不一样的内容，多数为302活301。本人使用了注册处理函数的方式，每次请求完以后，根据返回的页面url找到相应的处理函数进行操作，比如登录时，发送的是指向http://passport.xiaomi.com/index.php?...的一个请求，但返回结果往往变成 http://www.xiaomi.com/，在相应的处理函数中就需要进行清空购物车或者将商品放入购物车。

View Code
protected virtual void ProcessHttpSessions(ProcessState state)
{
state.Processed = true;
if (RunState == RunState.Pauseing)
{
OnLog("==========被用户暂停==========");
ChangeState(RunState.Paused);
state.Break = true;
return;
}
if (RunState == RunState.PauseingByNetService)
{
OnLog("==========被换IP服务暂停==========");
ChangeState(RunState.PausedByNetService);
state.Break = true;
return;
}
if (RunState == RunState.Stopping)
{
OnLog("==========被用户停止==========");
ChangeState(RunState.Stoped);
state.Break = true;
return;
}

if (_httpClient == null || _httpClient.HttpWebSessions == null)
{
state.Continue = true;
return;
}
int oldSessionCount = _httpClient.HttpWebSessions.Count;
Action<ProcessState> processerAction = null;
if (string.IsNullOrEmpty(_httpClient.RequestUrl))
{
OnLogError("没有要处理的请求");
state.Break = true;
return;
}
if (httpSessionProcesser.ContainsKey(_httpClient.RequestUrl))
{
processerAction = httpSessionProcesser[_httpClient.RequestUrl];
}
if (processerAction == null)
{
foreach (var processer in httpSessionProcesser)
{
if (_httpClient.RequestUrl.StartsWith(processer.Key) ||
Regex.IsMatch(_httpClient.RequestUrl, processer.Key))
{
processerAction = processer.Value;
break;
}
}
}
if (processerAction != null)
{
processerAction(state);
if (state.Break || state.Continue)
{
return;
}
if (!state.Processed)
{
ProcessHttpSessions(state);
}
return;
}
OnLogError("出错了，RequestUrl：" + _httpClient.RequestUrl);
OnLogError("ResponseUrl：" + _httpClient.ResponseUrl);
OnLogError("ResponseText：" + _httpClient.ResponseText);
state.Break = true;
}