您的位置:首页 > 理论基础 > 计算机网络

HttpClient(4.5) 使用实例(微信API,网页授权Oauth2.0)

2016-09-30 10:25 956 查看
设置头信息:

[java]
view plain
copy
print?





CloseableHttpClient httpClient = HttpClientBuilder.create().  
                setKeepAliveStrategy(new DefaultConnectionKeepAliveStrategy()).  
                setRedirectStrategy(new DefaultRedirectStrategy()).setDefaultHeaders(new ArrayList<Header>()).  
                setDefaultCookieStore(cookieStore).  
                setDefaultRequestConfig(requestConfig).build();  
  
        HttpGet httpGet = new HttpGet(url);  
        httpGet.setHeader("Content-Type", "application/x-www-form-urlencoded");  



CloseableHttpClient httpClient = HttpClientBuilder.create().
setKeepAliveStrategy(new DefaultConnectionKeepAliveStrategy()).
setRedirectStrategy(new DefaultRedirectStrategy()).setDefaultHeaders(new ArrayList<Header>()).
setDefaultCookieStore(cookieStore).
setDefaultRequestConfig(requestConfig).build();

HttpGet httpGet = new HttpGet(url);
httpGet.setHeader("Content-Type", "application/x-www-form-urlencoded");


HttpClientUtil:

[java]
view plain
copy
print?





import org.apache.http.Consts;  
import org.apache.http.HttpEntity;  
import org.apache.http.NameValuePair;  
import org.apache.http.ParseException;  
import org.apache.http.client.CookieStore;  
import org.apache.http.client.config.AuthSchemes;  
import org.apache.http.client.config.CookieSpecs;  
import org.apache.http.client.config.RequestConfig;  
import org.apache.http.client.entity.UrlEncodedFormEntity;  
import org.apache.http.client.methods.CloseableHttpResponse;  
import org.apache.http.client.methods.HttpGet;  
import org.apache.http.client.methods.HttpPost;  
import org.apache.http.client.protocol.HttpClientContext;  
import org.apache.http.config.Registry;  
import org.apache.http.config.RegistryBuilder;  
import org.apache.http.conn.socket.ConnectionSocketFactory;  
import org.apache.http.conn.socket.PlainConnectionSocketFactory;  
import org.apache.http.conn.ssl.NoopHostnameVerifier;  
import org.apache.http.conn.ssl.SSLConnectionSocketFactory;  
import org.apache.http.cookie.Cookie;  
import org.apache.http.impl.client.*;  
import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;  
import org.apache.http.util.EntityUtils;  
  
import javax.net.ssl.SSLContext;  
import javax.net.ssl.TrustManager;  
import javax.net.ssl.X509TrustManager;  
import java.io.IOException;  
import java.security.KeyManagementException;  
import java.security.NoSuchAlgorithmException;  
import java.security.cert.CertificateException;  
import java.security.cert.X509Certificate;  
import java.util.Arrays;  
import java.util.List;  
  
/** 
 * Created by Administrator on 2015/11/28. 
 */  
public class HttpClientUtil {  
    private static HttpClientContext context = HttpClientContext.create();  
    private static RequestConfig requestConfig = RequestConfig.custom().setConnectTimeout(120000).setSocketTimeout(60000)  
            .setConnectionRequestTimeout(60000).setCookieSpec(CookieSpecs.STANDARD_STRICT).  
                    setExpectContinueEnabled(true).  
                    setTargetPreferredAuthSchemes(Arrays.asList(AuthSchemes.NTLM, AuthSchemes.DIGEST)).  
                    setProxyPreferredAuthSchemes(Arrays.asList(AuthSchemes.BASIC)).build();  
  
    //https  
    private static SSLConnectionSocketFactory socketFactory;  
    private static TrustManager manager = new X509TrustManager() {  
  
        @Override  
        public void checkClientTrusted(X509Certificate[] x509Certificates, String s) throws CertificateException {  
  
        }  
  
        @Override  
        public void checkServerTrusted(X509Certificate[] x509Certificates, String s) throws CertificateException {  
  
        }  
  
        @Override  
        public X509Certificate[] getAcceptedIssuers() {  
            return null;  
        }  
    };  
  
    private static void enableSSL() {  
        try {  
            SSLContext sslContext = SSLContext.getInstance("TLS");  
            sslContext.init(null, new TrustManager[]{manager}, null);  
            socketFactory = new SSLConnectionSocketFactory(sslContext, NoopHostnameVerifier.INSTANCE);  
        } catch (NoSuchAlgorithmException e) {  
            e.printStackTrace();  
        } catch (KeyManagementException e) {  
            e.printStackTrace();  
        }  
    }  
  
    /** 
     * https get 
     * @param url 
     * @param data 
     * @return 
     * @throws IOException 
     */  
    public static CloseableHttpResponse doHttpsGet(String url, String data){  
        enableSSL();  
        Registry<ConnectionSocketFactory> socketFactoryRegistry = RegistryBuilder.<ConnectionSocketFactory>create()  
                .register("http", PlainConnectionSocketFactory.INSTANCE).register("https", socketFactory).build();  
        PoolingHttpClientConnectionManager connectionManager = new PoolingHttpClientConnectionManager(socketFactoryRegistry);  
        CloseableHttpClient httpClient = HttpClients.custom().setConnectionManager(connectionManager)  
                .setDefaultRequestConfig(requestConfig).build();  
        HttpGet httpGet = new HttpGet(url);  
        CloseableHttpResponse response = null;  
        try {  
            response = httpClient.execute(httpGet, context);  
        }catch (Exception e){  
            e.printStackTrace();  
        }  
  
        return response;  
    }  
  
    /** 
     * https post 
     * @param url 
     * @param values 
     * @return 
     * @throws IOException 
     */  
    public static CloseableHttpResponse doHttpsPost(String url, List<NameValuePair> values) {  
        enableSSL();  
        Registry<ConnectionSocketFactory> socketFactoryRegistry = RegistryBuilder.<ConnectionSocketFactory>create()  
                .register("http", PlainConnectionSocketFactory.INSTANCE).register("https", socketFactory).build();  
        PoolingHttpClientConnectionManager connectionManager = new PoolingHttpClientConnectionManager(socketFactoryRegistry);  
        CloseableHttpClient httpClient = HttpClients.custom().setConnectionManager(connectionManager)  
                .setDefaultRequestConfig(requestConfig).build();  
        HttpPost httpPost = new HttpPost(url);  
        UrlEncodedFormEntity entity = new UrlEncodedFormEntity(values, Consts.UTF_8);  
        httpPost.setEntity(entity);  
        CloseableHttpResponse response = null;  
        try {  
            response = httpClient.execute(httpPost, context);  
        }catch (Exception e){}  
        return response;  
    }  
  
    /** 
     * http get 
     * 
     * @param url 
     * @param data 
     * @return 
     */  
    public static CloseableHttpResponse doGet(String url, String data) {  
        CookieStore cookieStore = new BasicCookieStore();  
        CloseableHttpClient httpClient = HttpClientBuilder.create().  
                setKeepAliveStrategy(new DefaultConnectionKeepAliveStrategy()).  
                setRedirectStrategy(new DefaultRedirectStrategy()).  
                setDefaultCookieStore(cookieStore).  
                setDefaultRequestConfig(requestConfig).build();  
  
        HttpGet httpGet = new HttpGet(url);  
        CloseableHttpResponse response = null;  
        try {  
            response = httpClient.execute(httpGet, context);  
        }catch (Exception e){}  
        return response;  
    }  
  
    /** 
     * http post 
     * 
     * @param url 
     * @param values 
     * @return 
     */  
    public static CloseableHttpResponse doPost(String url, List<NameValuePair> values) {  
        CookieStore cookieStore = new BasicCookieStore();  
        CloseableHttpClient httpClient = HttpClientBuilder.create().  
                setKeepAliveStrategy(new DefaultConnectionKeepAliveStrategy()).  
                setRedirectStrategy(new DefaultRedirectStrategy()).  
                setDefaultCookieStore(cookieStore).  
                setDefaultRequestConfig(requestConfig).build();  
  
        HttpPost httpPost = new HttpPost(url);  
        UrlEncodedFormEntity entity = new UrlEncodedFormEntity(values, Consts.UTF_8);  
        httpPost.setEntity(entity);  
        CloseableHttpResponse response = null;  
        try {  
            response = httpClient.execute(httpPost, context);  
        }catch (Exception e){}  
        return response;  
    }  
  
  
    /** 
     * 直接把Response内的Entity内容转换成String 
     * 
     * @param httpResponse 
     * @return 
     */  
    public static String toString(CloseableHttpResponse httpResponse) {  
        // 获取响应消息实体  
        String result = null;  
        try {  
            HttpEntity entity = httpResponse.getEntity();  
            if (entity != null) {  
                result = EntityUtils.toString(entity,"UTF-8");  
            }  
        }catch (Exception e){}finally {  
            try {  
                httpResponse.close();  
            } catch (IOException e) {  
                e.printStackTrace();  
            }  
        }  
        return result;  
    }  
  
    public static void main(String[] args){  
        CloseableHttpResponse response = HttpClientUtil.doHttpsGet("https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=wxb2ebe42765aad029&secret=720661590f720b1f501ab3f390f80d52","");  
        System.out.println(HttpClientUtil.toString(response));  
    }  
}  



import org.apache.http.Consts;
import org.apache.http.HttpEntity;
import org.apache.http.NameValuePair;
import org.apache.http.ParseException;
import org.apache.http.client.CookieStore;
import org.apache.http.client.config.AuthSchemes;
import org.apache.http.client.config.CookieSpecs;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.client.entity.UrlEncodedFormEntity;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.client.protocol.HttpClientContext;
import org.apache.http.config.Registry;
import org.apache.http.config.RegistryBuilder;
import org.apache.http.conn.socket.ConnectionSocketFactory;
import org.apache.http.conn.socket.PlainConnectionSocketFactory;
import org.apache.http.conn.ssl.NoopHostnameVerifier;
import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
import org.apache.http.cookie.Cookie;
import org.apache.http.impl.client.*;
import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
import org.apache.http.util.EntityUtils;

import javax.net.ssl.SSLContext;
import javax.net.ssl.TrustManager;
import javax.net.ssl.X509TrustManager;
import java.io.IOException;
import java.security.KeyManagementException;
import java.security.NoSuchAlgorithmException;
import java.security.cert.CertificateException;
import java.security.cert.X509Certificate;
import java.util.Arrays;
import java.util.List;

/**
* Created by Administrator on 2015/11/28.
*/
public class HttpClientUtil {
private static HttpClientContext context = HttpClientContext.create();
private static RequestConfig requestConfig = RequestConfig.custom().setConnectTimeout(120000).setSocketTimeout(60000)
.setConnectionRequestTimeout(60000).setCookieSpec(CookieSpecs.STANDARD_STRICT).
setExpectContinueEnabled(true).
setTargetPreferredAuthSchemes(Arrays.asList(AuthSchemes.NTLM, AuthSchemes.DIGEST)).
setProxyPreferredAuthSchemes(Arrays.asList(AuthSchemes.BASIC)).build();

//https
private static SSLConnectionSocketFactory socketFactory;
private static TrustManager manager = new X509TrustManager() {

@Override
public void checkClientTrusted(X509Certificate[] x509Certificates, String s) throws CertificateException {

}

@Override
public void checkServerTrusted(X509Certificate[] x509Certificates, String s) throws CertificateException {

}

@Override
public X509Certificate[] getAcceptedIssuers() {
return null;
}
};

private static void enableSSL() {
try {
SSLContext sslContext = SSLContext.getInstance("TLS");
sslContext.init(null, new TrustManager[]{manager}, null);
socketFactory = new SSLConnectionSocketFactory(sslContext, NoopHostnameVerifier.INSTANCE);
} catch (NoSuchAlgorithmException e) {
e.printStackTrace();
} catch (KeyManagementException e) {
e.printStackTrace();
}
}

/**
* https get
* @param url
* @param data
* @return
* @throws IOException
*/
public static CloseableHttpResponse doHttpsGet(String url, String data){
enableSSL();
Registry<ConnectionSocketFactory> socketFactoryRegistry = RegistryBuilder.<ConnectionSocketFactory>create()
.register("http", PlainConnectionSocketFactory.INSTANCE).register("https", socketFactory).build();
PoolingHttpClientConnectionManager connectionManager = new PoolingHttpClientConnectionManager(socketFactoryRegistry);
CloseableHttpClient httpClient = HttpClients.custom().setConnectionManager(connectionManager)
.setDefaultRequestConfig(requestConfig).build();
HttpGet httpGet = new HttpGet(url);
CloseableHttpResponse response = null;
try {
response = httpClient.execute(httpGet, context);
}catch (Exception e){
e.printStackTrace();
}

return response;
}

/**
* https post
* @param url
* @param values
* @return
* @throws IOException
*/
public static CloseableHttpResponse doHttpsPost(String url, List<NameValuePair> values) {
enableSSL();
Registry<ConnectionSocketFactory> socketFactoryRegistry = RegistryBuilder.<ConnectionSocketFactory>create()
.register("http", PlainConnectionSocketFactory.INSTANCE).register("https", socketFactory).build();
PoolingHttpClientConnectionManager connectionManager = new PoolingHttpClientConnectionManager(socketFactoryRegistry);
CloseableHttpClient httpClient = HttpClients.custom().setConnectionManager(connectionManager)
.setDefaultRequestConfig(requestConfig).build();
HttpPost httpPost = new HttpPost(url);
UrlEncodedFormEntity entity = new UrlEncodedFormEntity(values, Consts.UTF_8);
httpPost.setEntity(entity);
CloseableHttpResponse response = null;
try {
response = httpClient.execute(httpPost, context);
}catch (Exception e){}
return response;
}

/**
* http get
*
* @param url
* @param data
* @return
*/
public static CloseableHttpResponse doGet(String url, String data) {
CookieStore cookieStore = new BasicCookieStore();
CloseableHttpClient httpClient = HttpClientBuilder.create().
setKeepAliveStrategy(new DefaultConnectionKeepAliveStrategy()).
setRedirectStrategy(new DefaultRedirectStrategy()).
setDefaultCookieStore(cookieStore).
setDefaultRequestConfig(requestConfig).build();

HttpGet httpGet = new HttpGet(url);
CloseableHttpResponse response = null;
try {
response = httpClient.execute(httpGet, context);
}catch (Exception e){}
return response;
}

/**
* http post
*
* @param url
* @param values
* @return
*/
public static CloseableHttpResponse doPost(String url, List<NameValuePair> values) {
CookieStore cookieStore = new BasicCookieStore();
CloseableHttpClient httpClient = HttpClientBuilder.create().
setKeepAliveStrategy(new DefaultConnectionKeepAliveStrategy()).
setRedirectStrategy(new DefaultRedirectStrategy()).
setDefaultCookieStore(cookieStore).
setDefaultRequestConfig(requestConfig).build();

HttpPost httpPost = new HttpPost(url);
UrlEncodedFormEntity entity = new UrlEncodedFormEntity(values, Consts.UTF_8);
httpPost.setEntity(entity);
CloseableHttpResponse response = null;
try {
response = httpClient.execute(httpPost, context);
}catch (Exception e){}
return response;
}

/**
* 直接把Response内的Entity内容转换成String
*
* @param httpResponse
* @return
*/
public static String toString(CloseableHttpResponse httpResponse) {
// 获取响应消息实体
String result = null;
try {
HttpEntity entity = httpResponse.getEntity();
if (entity != null) {
result = EntityUtils.toString(entity,"UTF-8");
}
}catch (Exception e){}finally {
try {
httpResponse.close();
} catch (IOException e) {
e.printStackTrace();
}
}
return result;
}

public static void main(String[] args){
CloseableHttpResponse response = HttpClientUtil.doHttpsGet("https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=wxb2ebe42765aad029&secret=720661590f720b1f501ab3f390f80d52","");
System.out.println(HttpClientUtil.toString(response));
}
}

AccessTokenResult:

[java]
view plain
copy
print?





public class AccessTokenResult implements Serializable{  
    private static final long serialVersionUID = -5429222736793133180L;  
    private String access_token;  
    private int expires_in;  
    private String refresh_token;  
    private String openid;  
    private String scope;  
    private String unionid;  
  
    public String getAccess_token() {  
        return access_token;  
    }  
  
    public void setAccess_token(String access_token) {  
        this.access_token = access_token;  
    }  
  
    public int getExpires_in() {  
        return expires_in;  
    }  
  
    public void setExpires_in(int expires_in) {  
        this.expires_in = expires_in;  
    }  
  
    public String getRefresh_token() {  
        return refresh_token;  
    }  
  
    public void setRefresh_token(String refresh_token) {  
        this.refresh_token = refresh_token;  
    }  
  
    public String getOpenid() {  
        return openid;  
    }  
  
    public void setOpenid(String openid) {  
        this.openid = openid;  
    }  
  
    public String getScope() {  
        return scope;  
    }  
  
    public void setScope(String scope) {  
        this.scope = scope;  
    }  
  
    public String getUnionid() {  
        return unionid;  
    }  
  
    public void setUnionid(String unionid) {  
        this.unionid = unionid;  
    }  
  
    @Override  
    public String toString() {  
        return "AccessTokenResult{" +  
                "access_token='" + access_token + '\'' +  
                ", expires_in=" + expires_in +  
                ", refresh_token='" + refresh_token + '\'' +  
                ", openid='" + openid + '\'' +  
                ", scope='" + scope + '\'' +  
                ", unionid='" + unionid + '\'' +  
                '}';  
    }  
}  



public class AccessTokenResult implements Serializable{
private static final long serialVersionUID = -5429222736793133180L;
private String access_token;
private int expires_in;
private String refresh_token;
private String openid;
private String scope;
private String unionid;

public String getAccess_token() {
return access_token;
}

public void setAccess_token(String access_token) {
this.access_token = access_token;
}

public int getExpires_in() {
return expires_in;
}

public void setExpires_in(int expires_in) {
this.expires_in = expires_in;
}

public String getRefresh_token() {
return refresh_token;
}

public void setRefresh_token(String refresh_token) {
this.refresh_token = refresh_token;
}

public String getOpenid() {
return openid;
}

public void setOpenid(String openid) {
this.openid = openid;
}

public String getScope() {
return scope;
}

public void setScope(String scope) {
this.scope = scope;
}

public String getUnionid() {
return unionid;
}

public void setUnionid(String unionid) {
this.unionid = unionid;
}

@Override
public String toString() {
return "AccessTokenResult{" +
"access_token='" + access_token + '\'' +
", expires_in=" + expires_in +
", refresh_token='" + refresh_token + '\'' +
", openid='" + openid + '\'' +
", scope='" + scope + '\'' +
", unionid='" + unionid + '\'' +
'}';
}
}


ErrorInfoResult:

[java]
view plain
copy
print?





public class ErrorInfoResult implements Serializable{  
    private static final long serialVersionUID = -7644965943068191814L;  
  
    private int errcode;  
    private String errmsg;  
  
    public int getErrcode() {  
        return errcode;  
    }  
  
    public void setErrcode(int errcode) {  
        this.errcode = errcode;  
    }  
  
    public String getErrmsg() {  
        return errmsg;  
    }  
  
    public void setErrmsg(String errmsg) {  
        this.errmsg = errmsg;  
    }  
}  



public class ErrorInfoResult implements Serializable{
private static final long serialVersionUID = -7644965943068191814L;

private int errcode;
private String errmsg;

public int getErrcode() {
return errcode;
}

public void setErrcode(int errcode) {
this.errcode = errcode;
}

public String getErrmsg() {
return errmsg;
}

public void setErrmsg(String errmsg) {
this.errmsg = errmsg;
}
}


UserInfoResult:

[java]
view plain
copy
print?





public class UserInfoResult implements Serializable {  
    private static final long serialVersionUID = 7897488657400830591L;  
    private String openid;  
    private String nickname;  
    private String sex;  
    private String province;  
    private String city;  
    private String country;  
    private String headimgurl;  
    private String unionid;  
  
    public String getUnionid() {  
        return unionid;  
    }  
  
    public void setUnionid(String unionid) {  
        this.unionid = unionid;  
    }  
  
    public String getHeadimgurl() {  
        return headimgurl;  
    }  
  
    public void setHeadimgurl(String headimgurl) {  
        this.headimgurl = headimgurl;  
    }  
  
    public String getCountry() {  
        return country;  
    }  
  
    public void setCountry(String country) {  
        this.country = country;  
    }  
  
    public String getCity() {  
        return city;  
    }  
  
    public void setCity(String city) {  
        this.city = city;  
    }  
  
    public String getProvince() {  
        return province;  
    }  
  
    public void setProvince(String province) {  
        this.province = province;  
    }  
  
    public String getSex() {  
        return sex;  
    }  
  
    public void setSex(String sex) {  
        this.sex = sex;  
    }  
  
    public String getNickname() {  
        return nickname;  
    }  
  
    public void setNickname(String nickname) {  
        this.nickname = nickname;  
    }  
  
    public String getOpenid() {  
        return openid;  
    }  
  
    public void setOpenid(String openid) {  
        this.openid = openid;  
    }  
  
    @Override  
    public String toString() {  
        return "UserInfoResult{" +  
                "openid='" + openid + '\'' +  
                ", nickname='" + nickname + '\'' +  
                ", sex='" + sex + '\'' +  
                ", province='" + province + '\'' +  
                ", city='" + city + '\'' +  
                ", country='" + country + '\'' +  
                ", headimgurl='" + headimgurl + '\'' +  
                ", unionid='" + unionid + '\'' +  
                '}';  
    }  
}  



public class UserInfoResult implements Serializable {
private static final long serialVersionUID = 7897488657400830591L;
private String openid;
private String nickname;
private String sex;
private String province;
private String city;
private String country;
private String headimgurl;
private String unionid;

public String getUnionid() {
return unionid;
}

public void setUnionid(String unionid) {
this.unionid = unionid;
}

public String getHeadimgurl() {
return headimgurl;
}

public void setHeadimgurl(String headimgurl) {
this.headimgurl = headimgurl;
}

public String getCountry() {
return country;
}

public void setCountry(String country) {
this.country = country;
}

public String getCity() {
return city;
}

public void setCity(String city) {
this.city = city;
}

public String getProvince() {
return province;
}

public void setProvince(String province) {
this.province = province;
}

public String getSex() {
return sex;
}

public void setSex(String sex) {
this.sex = sex;
}

public String getNickname() {
return nickname;
}

public void setNickname(String nickname) {
this.nickname = nickname;
}

public String getOpenid() {
return openid;
}

public void setOpenid(String openid) {
this.openid = openid;
}

@Override
public String toString() {
return "UserInfoResult{" +
"openid='" + openid + '\'' +
", nickname='" + nickname + '\'' +
", sex='" + sex + '\'' +
", province='" + province + '\'' +
", city='" + city + '\'' +
", country='" + country + '\'' +
", headimgurl='" + headimgurl + '\'' +
", unionid='" + unionid + '\'' +
'}';
}
}


WxConstants:

[java]
view plain
copy
print?





public class WxConstants {  
    //appId;  
    public final static String appId = "wxb2ebe42765aad029";  
    //  
    public final static String appSecret = "720661590f720b1f501ab3f390f80d52";  
}  



public class WxConstants {
//appId;
public final static String appId = "wxb2ebe42765aad029";
//
public final static String appSecret = "720661590f720b1f501ab3f390f80d52";
}


WxUtil:

[java]
view plain
copy
print?





public class WxUtil {  
    private static Gson gson = new GsonBuilder().setDateFormat("yyyy-MM-dd").disableHtmlEscaping().create();  
    /** 
     * 生成授权URL 
     * @param callbackUrl 
     * @return 
     */  
    public static String authorizeUrl(String callbackUrl){  
        StringBuilder sb = new StringBuilder();  
        try {  
            sb.append("https://open.weixin.qq.com/connect/oauth2/authorize?appid=").  
                    append(WxConstants.appId).  
                    append("&redirect_uri=").  
                    append(URLEncoder.encode(callbackUrl,"UTF-8")).  
                    append("&response_type=code").  
                    //append("&scope=snsapi_base ").  
                    append("&scope=snsapi_userinfo").  
                    append("&state=STATE").  
                    append("#wechat_redirect");  
        } catch (UnsupportedEncodingException e) {  
            e.printStackTrace();  
        }  
  
        return sb.toString();  
    }  
  
    /** 
     * 获取access_token 
     * @param code 
     * @return 
     */  
    public static AccessTokenResult accessToken(String code){  
        AccessTokenResult accessTokenResult = null;  
        StringBuilder sb = new StringBuilder();  
        sb.append("https://api.weixin.qq.com/sns/oauth2/access_token?appid=").  
                append(WxConstants.appId).  
                append("&secret=").  
                append(WxConstants.appSecret).  
                append("&code=").  
                append(code).  
                append("&grant_type=authorization_code");  
        String result = HttpClientUtil.toString(HttpClientUtil.doHttpsGet(sb.toString(), ""));  
        if(result != null){  
            accessTokenResult = gson.fromJson(result,AccessTokenResult.class);  
        }  
        return accessTokenResult;  
    }  
  
    /** 
     * refreshToken 重新获取 accessToken 
     * @param refreshToken 
     * @return 
     */  
    public static AccessTokenResult refreshToken(String refreshToken){  
        AccessTokenResult accessTokenResult = null;  
        StringBuilder sb = new StringBuilder();  
        sb.append("https://api.weixin.qq.com/sns/oauth2/refresh_token?appid=").  
                append(WxConstants.appId).  
                append("&refresh_token=").  
                append(refreshToken).  
                append("&grant_type=refresh_token");  
        String result = HttpClientUtil.toString(HttpClientUtil.doHttpsGet(sb.toString(), ""));  
        if(result != null){  
            accessTokenResult = gson.fromJson(result,AccessTokenResult.class);  
        }  
        return accessTokenResult;  
    }  
  
    /** 
     * 获取用户信息 需要snstype 为 userinfo 非 base 
     * @param accessToken 
     * @param openId 
     * @return 
     */  
    public static UserInfoResult userInfo(String accessToken,String openId){  
        UserInfoResult userInfoResult = null;  
        StringBuilder sb = new StringBuilder();  
        sb.append("https://api.weixin.qq.com/sns/userinfo?access_token=").  
                append(accessToken).  
                append("&openid=").  
                append(openId).  
                append("&lang=zh_CN");  
        String result = HttpClientUtil.toString(HttpClientUtil.doHttpsGet(sb.toString(), ""));  
        if(result != null){  
            userInfoResult = gson.fromJson(result,UserInfoResult.class);  
        }  
        return userInfoResult;  
    }  
  
    /** 
     * 判断accesstoken 是否有效 
     * @param accessToken 
     * @param openId 
     * @return 
     */  
    public static boolean authAccessToken(String accessToken,String openId){  
        ErrorInfoResult errorInfoResult = null;  
        boolean isValid = false;  
        StringBuilder sb = new StringBuilder();  
        sb.append("https://api.weixin.qq.com/sns/auth?access_token=").  
                append(accessToken).  
                append("&openid=").  
                append(openId);  
        String result = HttpClientUtil.toString(HttpClientUtil.doHttpsGet(sb.toString(), ""));  
        if(result != null){  
            errorInfoResult = gson.fromJson(result,ErrorInfoResult.class);  
            if(0 == errorInfoResult.getErrcode()){  
                isValid = true;  
            }  
        }  
        return isValid;  
    }  
  
    public static void main(String[] args){  
        String url = WxUtil.authorizeUrl("http://zszs.ngrok.cc/index.jsp");  
        System.out.println(url);  
  
        System.out.println(HttpClientUtil.toString(HttpClientUtil.doGet("http://dpcola2.ngrok.cc/activityvip/customized/externalColaDrawLottery?activity=03D39BCAF4AAC406&prizePackage=FAB7B93B21645FAC&_dpKey=2656cola1455875399784&phoneNum=13917114404","")));  
    }  
}  



public class WxUtil {
private static Gson gson = new GsonBuilder().setDateFormat("yyyy-MM-dd").disableHtmlEscaping().create();
/**
* 生成授权URL
* @param callbackUrl
* @return
*/
public static String authorizeUrl(String callbackUrl){
StringBuilder sb = new StringBuilder();
try {
sb.append("https://open.weixin.qq.com/connect/oauth2/authorize?appid=").
append(WxConstants.appId).
append("&redirect_uri=").
append(URLEncoder.encode(callbackUrl,"UTF-8")).
append("&response_type=code").
//append("&scope=snsapi_base ").
append("&scope=snsapi_userinfo").
append("&state=STATE").
append("#wechat_redirect");
} catch (UnsupportedEncodingException e) {
e.printStackTrace();
}

return sb.toString();
}

/**
* 获取access_token
* @param code
* @return
*/
public static AccessTokenResult accessToken(String code){
AccessTokenResult accessTokenResult = null;
StringBuilder sb = new StringBuilder();
sb.append("https://api.weixin.qq.com/sns/oauth2/access_token?appid=").
append(WxConstants.appId).
append("&secret=").
append(WxConstants.appSecret).
append("&code=").
append(code).
append("&grant_type=authorization_code");
String result = HttpClientUtil.toString(HttpClientUtil.doHttpsGet(sb.toString(), ""));
if(result != null){
accessTokenResult = gson.fromJson(result,AccessTokenResult.class);
}
return accessTokenResult;
}

/**
* refreshToken 重新获取 accessToken
* @param refreshToken
* @return
*/
public static AccessTokenResult refreshToken(String refreshToken){
AccessTokenResult accessTokenResult = null;
StringBuilder sb = new StringBuilder();
sb.append("https://api.weixin.qq.com/sns/oauth2/refresh_token?appid=").
append(WxConstants.appId).
append("&refresh_token=").
append(refreshToken).
append("&grant_type=refresh_token");
String result = HttpClientUtil.toString(HttpClientUtil.doHttpsGet(sb.toString(), ""));
if(result != null){
accessTokenResult = gson.fromJson(result,AccessTokenResult.class);
}
return accessTokenResult;
}

/**
* 获取用户信息 需要snstype 为 userinfo 非 base
* @param accessToken
* @param openId
* @return
*/
public static UserInfoResult userInfo(String accessToken,String openId){
UserInfoResult userInfoResult = null;
StringBuilder sb = new StringBuilder();
sb.append("https://api.weixin.qq.com/sns/userinfo?access_token=").
append(accessToken).
append("&openid=").
append(openId).
append("&lang=zh_CN");
String result = HttpClientUtil.toString(HttpClientUtil.doHttpsGet(sb.toString(), ""));
if(result != null){
userInfoResult = gson.fromJson(result,UserInfoResult.class);
}
return userInfoResult;
}

/**
* 判断accesstoken 是否有效
* @param accessToken
* @param openId
* @return
*/
public static boolean authAccessToken(String accessToken,String openId){
ErrorInfoResult errorInfoResult = null;
boolean isValid = false;
StringBuilder sb = new StringBuilder();
sb.append("https://api.weixin.qq.com/sns/auth?access_token=").
append(accessToken).
append("&openid=").
append(openId);
String result = HttpClientUtil.toString(HttpClientUtil.doHttpsGet(sb.toString(), ""));
if(result != null){
errorInfoResult = gson.fromJson(result,ErrorInfoResult.class);
if(0 == errorInfoResult.getErrcode()){
isValid = true;
}
}
return isValid;
}

public static void main(String[] args){
String url = WxUtil.authorizeUrl("http://zszs.ngrok.cc/index.jsp");
System.out.println(url);

System.out.println(HttpClientUtil.toString(HttpClientUtil.doGet("http://dpcola2.ngrok.cc/activityvip/customized/externalColaDrawLottery?activity=03D39BCAF4AAC406&prizePackage=FAB7B93B21645FAC&_dpKey=2656cola1455875399784&phoneNum=13917114404","")));
}
}
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: