新浪Java模拟登陆源码

package cn.edu.gdut.weibo.login;

import java.io.IOException;
import java.net.URLDecoder;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;

import org.apache.commons.codec.binary.Base64;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.http.HttpException;
import org.apache.http.HttpResponse;
import org.apache.http.NameValuePair;
import org.apache.http.ParseException;
import org.apache.http.client.ClientProtocolException;
import org.apache.http.client.HttpClient;
import org.apache.http.client.entity.UrlEncodedFormEntity;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.message.BasicNameValuePair;
import org.apache.http.protocol.HTTP;
import org.apache.http.util.EntityUtils;
import org.json.JSONException;
import org.json.JSONObject;

import cn.edu.gdut.util.BigIntegerRSA;
import cn.edu.gdut.util.FileUtil;
import cn.edu.gdut.util.HttpConnectionManager;
import cn.edu.gdut.weibo.model.PreLoginInfo;

/**
 * 
 * @author Joe
 * 
 */
public class WeiboLogin {

    public static String SINA_PK = "EB2A38568661887FA180BDDB5CABD5F21C7BFD59C090CB2D24"
            + "5A87AC253062882729293E5506350508E7F9AA3BB77F4333231490F915F6D63C55FE2F08A49B353F444AD39"
            + "93CACC02DB784ABBB8E42A9B1BBFFFB38BE18D78E87A0E41B9B8F73A928EE0CCEE"
            + "1F6739884B9777E4FE9E88A1BBE495927AC4A799B3181D6442443";
    public static String username = FileUtil.getUname();//FileUtil就是获取配置文件
    public static String passwd = FileUtil.getPwd();

    private static final Log logger = LogFactory.getLog(WeiboLogin.class);

    public static HttpClient getLoginStatus() {

        final HttpClient client = HttpConnectionManager.getHttpClient();
        HttpPost post = new HttpPost(
                "http://login.sina.com.cn/sso/login.php?client=ssologin.js(v1.4.2)");

        PreLoginInfo info = null;
        try {
            info = getPreLoginBean(client);
        } catch (HttpException e) {
            e.printStackTrace();
            logger.error(e);
        } catch (IOException e) {
            e.printStackTrace();
            logger.error("登陆失败，请确认已连接正确网络！" + e);
            return null;
        } catch (JSONException e) {
            e.printStackTrace();
            logger.error(e);
        }

        long servertime = info.servertime;
        String nonce = info.nonce;

        String pwdString = servertime + "\t" + nonce + "\n" + passwd;
        String sp = new BigIntegerRSA().rsaCrypt(SINA_PK, "10001", pwdString);

        List<NameValuePair> nvps = new ArrayList<NameValuePair>();
        nvps.add(new BasicNameValuePair("entry", "weibo"));
        nvps.add(new BasicNameValuePair("gateway", "1"));
        nvps.add(new BasicNameValuePair("from", ""));
        nvps.add(new BasicNameValuePair("savestate", "7"));
        nvps.add(new BasicNameValuePair("useticket", "1"));
        nvps.add(new BasicNameValuePair("ssosimplelogin", "1"));
        nvps.add(new BasicNameValuePair("vsnf", "1"));
        // new NameValuePair("vsnval", ""),
        nvps.add(new BasicNameValuePair("su", encodeUserName(username)));
        nvps.add(new BasicNameValuePair("service", "miniblog"));
        nvps.add(new BasicNameValuePair("servertime", servertime + ""));
        nvps.add(new BasicNameValuePair("nonce", nonce));
        nvps.add(new BasicNameValuePair("pwencode", "rsa2"));
        nvps.add(new BasicNameValuePair("rsakv", info.rsakv));
        nvps.add(new BasicNameValuePair("sp", sp));
        nvps.add(new BasicNameValuePair("encoding", "UTF-8"));
        nvps.add(new BasicNameValuePair("prelt", "115"));
        nvps.add(new BasicNameValuePair("returntype", "META"));
        nvps.add(new BasicNameValuePair(
                "url",
                "http://weibo.com/ajaxlogin.php?framelogin=1&callback=parent.sinaSSOController.feedBackUrlCallBack"));

        try {
            post.setEntity(new UrlEncodedFormEntity(nvps, HTTP.UTF_8));
            HttpResponse response = client.execute(post);
            String entity = EntityUtils.toString(response.getEntity());
            if (entity.indexOf("code=0") == -1) {
                logger.error("登陆失败:"
                        + URLDecoder.decode(entity.substring(
                                entity.indexOf("reason=") + 7,
                                entity.indexOf("&#39;\"/>"))));
                System.out.println("登陆失败:"
                        + URLDecoder.decode(entity.substring(
                                entity.indexOf("reason=") + 7,
                                entity.indexOf("&#39;\"/>"))));
                return null;
            }

            String url = entity.substring(
                    entity.indexOf("http://weibo.com/ajaxlogin.php?"),
                    entity.indexOf("code=0") + 6);

            HttpGet getMethod = new HttpGet(url);
            response = client.execute(getMethod);
            entity = EntityUtils.toString(response.getEntity());
            logger.info("用户名:"
                    + username
                    + "登陆成功！\n"
                    + entity.substring(entity.indexOf("({"),
                            entity.indexOf(";</script>")));
        } catch (ParseException e) {
            e.printStackTrace();
            logger.error(e);
        } catch (ClientProtocolException e) {
            e.printStackTrace();
            logger.error(e);
        } catch (IOException e) {
            e.printStackTrace();
            logger.error(e);
        }
        return client;
    }

    private static PreLoginInfo getPreLoginBean(HttpClient client)
            throws HttpException, IOException, JSONException {

        String serverTime = getPreLoginInfo(client);
        JSONObject jsonInfo = new JSONObject(serverTime);
        PreLoginInfo info = new PreLoginInfo();
        info.nonce = jsonInfo.getString("nonce");
        info.pcid = jsonInfo.getString("pcid");
        info.pubkey = jsonInfo.getString("pubkey");
        info.retcode = jsonInfo.getInt("retcode");
        info.rsakv = jsonInfo.getString("rsakv");
        info.servertime = jsonInfo.getLong("servertime");
        return info;
    }

    public static String getPreLoginInfo(HttpClient client)
            throws ParseException, IOException {
        String preloginurl = "http://login.sina.com.cn/sso/prelogin.php?entry=sso&"
                + "callback=sinaSSOController.preloginCallBack&su="
                + "dW5kZWZpbmVk"
                + "&rsakt=mod&client=ssologin.js(v1.4.2)"
                + "&_=" + getCurrentTime();
        HttpGet get = new HttpGet(preloginurl);

        HttpResponse response = client.execute(get);

        String getResp = EntityUtils.toString(response.getEntity());

        int firstLeftBracket = getResp.indexOf("(");
        int lastRightBracket = getResp.lastIndexOf(")");

        String jsonBody = getResp.substring(firstLeftBracket + 1,
                lastRightBracket);
        // System.out.println(jsonBody);
        return jsonBody;

    }

    private static String getCurrentTime() {
        long servertime = new Date().getTime() / 1000;
        return String.valueOf(servertime);
    }

    private static String encodeUserName(String email) {
        email = email.replaceFirst("@", "%40");// MzM3MjQwNTUyJTQwcXEuY29t
        email = Base64.encodeBase64String(email.getBytes());
        return email;
    }

}

package cn.edu.gdut.util;


import java.io.UnsupportedEncodingException;
import java.math.BigInteger;
import java.security.InvalidKeyException;
import java.security.KeyFactory;
import java.security.NoSuchAlgorithmException;
import java.security.interfaces.RSAPublicKey;
import java.security.spec.InvalidKeySpecException;
import java.security.spec.RSAPublicKeySpec;

import javax.crypto.BadPaddingException;
import javax.crypto.Cipher;
import javax.crypto.IllegalBlockSizeException;
import javax.crypto.NoSuchPaddingException;

import org.apache.commons.codec.binary.Hex;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

public class BigIntegerRSA {
    private static final Log logger = LogFactory.getLog(BigIntegerRSA.class);
    public static String SINA_PUB = "EB2A38568661887FA180BDDB5CABD5F21C7BFD59C090CB2D24"
            + "5A87AC253062882729293E5506350508E7F9AA3BB77F4333231490F915F6D63C55FE2F08A49B353F444AD39"
            + "93CACC02DB784ABBB8E42A9B1BBFFFB38BE18D78E87A0E41B9B8F73A928EE0CCEE"
            + "1F6739884B9777E4FE9E88A1BBE495927AC4A799B3181D6442443";
    
    public String rsaCrypt(String modeHex, String exponentHex, String messageg){
        
        BigInteger m = new BigInteger(modeHex, 16); /* public exponent */
        BigInteger e = new BigInteger(exponentHex, 16); /* modulus */
        RSAPublicKeySpec spec = new RSAPublicKeySpec(m, e);
        
        RSAPublicKey pub;
        byte[] encryptedContentKey = null;
        try {
            KeyFactory factory = KeyFactory.getInstance("RSA");
            pub = (RSAPublicKey) factory.generatePublic(spec);
            Cipher enc = Cipher.getInstance("RSA");
            enc.init(Cipher.ENCRYPT_MODE, pub);
            encryptedContentKey = enc.doFinal(messageg.getBytes("GB2312"));
        } catch (InvalidKeySpecException e1) {
            logger.error( e1);
        } catch (NoSuchAlgorithmException e1) {
            logger.error( e1);
        } catch (NoSuchPaddingException e1) {
            logger.error( e1);
        } catch (InvalidKeyException e1) {
            logger.error( e1);
        } catch (IllegalBlockSizeException e1) {
            logger.error( e1);
        } catch (BadPaddingException e1) {
            logger.error( e1);
        } catch (UnsupportedEncodingException e1) {
            logger.error( e1);
        }
         
        return new String(Hex.encodeHex(encryptedContentKey));
    }
}

package cn.edu.gdut.util;

import org.apache.http.HttpHost;
import org.apache.http.client.HttpClient;
import org.apache.http.client.params.ClientPNames;
import org.apache.http.conn.routing.HttpRoute;
import org.apache.http.conn.scheme.PlainSocketFactory;
import org.apache.http.conn.scheme.Scheme;
import org.apache.http.conn.scheme.SchemeRegistry;
import org.apache.http.conn.ssl.SSLSocketFactory;
import org.apache.http.cookie.Cookie;
import org.apache.http.cookie.CookieOrigin;
import org.apache.http.cookie.CookieSpec;
import org.apache.http.cookie.CookieSpecFactory;
import org.apache.http.cookie.MalformedCookieException;
import org.apache.http.impl.client.DefaultHttpClient;
import org.apache.http.impl.conn.PoolingClientConnectionManager;
import org.apache.http.impl.cookie.BrowserCompatSpec;
import org.apache.http.params.BasicHttpParams;
import org.apache.http.params.HttpConnectionParams;
import org.apache.http.params.HttpParams;

public class HttpConnectionManager {

    public static HttpClient getHttpClient() {
        HttpParams params = new BasicHttpParams();
        /* 连接超时 */
        HttpConnectionParams.setConnectionTimeout(params, 3000);
        /* 请求超时 */
        HttpConnectionParams.setSoTimeout(params, 10000);
        SchemeRegistry schemeRegistry = new SchemeRegistry();
        schemeRegistry.register(new Scheme("http", 80, PlainSocketFactory
                .getSocketFactory()));
        schemeRegistry.register(new Scheme("https", 443, SSLSocketFactory
                .getSocketFactory()));

        PoolingClientConnectionManager cm = new PoolingClientConnectionManager(
                schemeRegistry);
        // Increase max total connection to 200
        cm.setMaxTotal(200);
        // Increase default max connection per route to 20
        cm.setDefaultMaxPerRoute(20);
        // Increase max connections for localhost:80 to 50
        HttpHost localhost = new HttpHost("locahost", 80);
        cm.setMaxPerRoute(new HttpRoute(localhost), 50);

        DefaultHttpClient httpClient = new DefaultHttpClient(cm, params);
        // 自定义cookies*****************
        CookieSpecFactory csf = new CookieSpecFactory() {
            public CookieSpec newInstance(HttpParams params) {
                return new BrowserCompatSpec() {
                    @Override
                    public void validate(Cookie cookie, CookieOrigin origin)
                            throws MalformedCookieException {
                        // Oh, I am easy
                    }
                };
            }
        };

        httpClient.getCookieSpecs().register("easy", csf);
        httpClient.getParams().setParameter(ClientPNames.COOKIE_POLICY, "easy");
        // 自定义cookies*****************
        return httpClient;
    }

}

public class PreLoginInfo {
    public long servertime;
    public String nonce;
    public String pubkey;
    public String pcid;
    public int retcode;
    public String rsakv;
    
    
}

上面三个就是新浪模拟登陆的代码，应该不难。。。BigIntegerRSA是用来对密码进行2次sha加密的。HttpConnectionManager其实就是用来设置HttpClient参数的。还有问题留言吧。