微信拉取用户信息,主动推送消息代码,Java代码库,德仔网

代码语言
代码分类
【Java】微信拉取用户信息,主动推送消息
作者:滄海一夢 / 发布于2013/8/20/ 1922

	public class WeixinAPIHelper {
	/**
	 * 获取token接口
	 */
	private String getTokenUrl = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid={0}&secret={1}";
	/**
	 * 拉微信用户信息接口
	 */
	private String getUserInfoUrl = "https://api.weixin.qq.com/cgi-bin/user/info?access_token={0}&openid={1}";
	/**
	 * 主动推送信息接口
	 */
	private String sendMsgUrl = "https://api.weixin.qq.com/cgi-bin/message/send?access_token={0}";

	private HttpClient webClient;

	private Log log = LogFactory.getLog(getClass());
	public void initWebClient(String proxyHost, int proxyPort){
	 this.initWebClient();
	 if(webClient != null && !StringUtils.isEmpty(proxyHost)){
	 HttpHost proxy = new HttpHost(proxyHost, proxyPort);
	 webClient.getParams().setParameter(ConnRoutePNames.DEFAULT_PROXY, proxy);
	 }
	}

	/**
	 * @desc 初始化创建 WebClient
	 */
	public void initWebClient() {
	 log.info("initWebClient start....");
	 try {
	 PoolingClientConnectionManager tcm = new PoolingClientConnectionManager();
	 tcm.setMaxTotal(10);
	 SSLContext ctx = SSLContext.getInstance("TLS");
	 X509TrustManager tm = new X509TrustManager() {

	 public void checkClientTrusted(X509Certificate[] arg0, String arg1) throws CertificateException {

	 }

	 public void checkServerTrusted(X509Certificate[] arg0, String arg1) throws CertificateException {

	 }

	 public X509Certificate[] getAcceptedIssuers() {
	 return null;
	 }
	 };
	 ctx.init(null, new X509TrustManager[] { tm }, null);
	 SSLSocketFactory ssf = new SSLSocketFactory(ctx, SSLSocketFactory.ALLOW_ALL_HOSTNAME_VERIFIER);
	 Scheme sch = new Scheme("https", 443, ssf);
	 tcm.getSchemeRegistry().register(sch);
	 webClient = new DefaultHttpClient(tcm);
	 } catch (Exception ex) {
	 log.error("initWebClient exception", ex);
	 } finally {
	 log.info("initWebClient end....");
	 }
	}

	/**
	 * @desc 获取授权token
	 * @param appid
	 * @param secret
	 * @return
	 */
	public String getAccessToken(String appid, String secret) {
	 String accessToken = null;
	 try {
	 log.info("getAccessToken start.{appid=" + appid + ",secret:" + secret + "}");
	 String url = MessageFormat.format(this.getTokenUrl, appid, secret);
	 String response = executeHttpGet(url);
	 accessToken = JsonUtils.read(response, "access_token");
	 } catch (Exception e) {
	 log.error("get access toekn exception", e);
	 }
	 return accessToken;
	}
	/**
	 * @desc 推送信息
	 * @param token
	 * @param msg
	 * @return
	 */
	public String sendMessage(String token,String msg){
	 try{
	 log.info("sendMessage start.token:"+token+",msg:"+msg);
	 String url = MessageFormat.format(this.sendMsgUrl, token);
	 HttpPost post = new HttpPost(url);
	 ResponseHandler<?> responseHandler = new BasicResponseHandler();
	 StringEntity entity = new StringEntity(msg);
	 post.setEntity(entity);
	 String response = (String) this.webClient.execute(post, responseHandler);
	 log.info("return response=====start======");
	 log.info(response);
	 log.info("return response=====end======");
	 return response;
	
	 }catch (Exception e) {
	 log.error("get user info exception", e);
	 return null;
	 }
	}
	/**
	 * @desc 拉取用户信息
	 * @param token
	 * @param openid
	 * @return
	 */
	public WeixinOpenUser getUserInfo(String token, String openid) {
	 try {
	 log.info("getUserInfo start.{token:" + token + ",openid:" + openid + "}");
	 String url = MessageFormat.format(this.getUserInfoUrl, token, openid);
	 String response = executeHttpGet(url);
	 JsonNode json = JsonUtils.read(response);
	 if (json.get("openid") != null) {
	 WeixinOpenUser user = new WeixinOpenUser();
	 user.setOpenUserId(json.get("openid").asText());
	 user.setState(json.get("subscribe").asText());
	 if ("1".equals(user.getState())) {
	 user.setUserName(json.get("nickname").asText());
	 user.setSex(json.get("sex").asText());
	 user.setCity(json.get("city").asText());
	 user.setLanguage(json.get("language").asText());
	 }
	 return user;
	 }
	 } catch (Exception e) {
	 log.error("get user info exception", e);
	 }
	 return null;
	}

	/**
	 * @desc 发起HTTP GET请求返回数据
	 * @param url
	 * @return
	 * @throws IOException
	 * @throws ClientProtocolException
	 */
	private String executeHttpGet(String url) throws IOException, ClientProtocolException {
	 ResponseHandler<?> responseHandler = new BasicResponseHandler();
	 String response = (String) this.webClient.execute(new HttpGet(url), responseHandler);
	 log.info("return response=====start======");
	 log.info(response);
	 log.info("return response=====end======");
	 return response;
	}

	
	}
试试其它关键字
同语言下
可能有用的
滄海一夢贡献的其它代码(1)
.微信拉取用户信息,主动推送消息