java微信个人订阅号发信息_微信个人公众号开发-java

一：申请公众号

无聊的去申请一个个人公众号，试了下微信实现自定义菜单与自定义对话的一些基本功能，如果多花点时间，金钱(= =!)还是有不少功能可以使用，还是蛮有意思的。

废话不多说，先看一下申请的流程。首先进入微信公众平台申请一个个人的订阅号，其实它自带的功能里就有自动回复的设置，不过还是试试开发接口去实现，更有意思。

二：接口实现

在开发-基本配置里，服务器配置就是当前公众号和我们自己服务器建立连接的配置。

controller：该方法的路径就是基本配置里的服务器地址(URL)

/**

* 微信接入

* @param

* @return

* @throws IOException

*/

@RequestMapping(value="/wechat/connect",method = {RequestMethod.GET, RequestMethod.POST})

@ResponseBody

public void connectWeixin(HttpServletRequest request, HttpServletResponse response) throws IOException {

// 将请求、响应的编码均设置为UTF-8(防止中文乱码)

request.setCharacterEncoding("UTF-8"); //微信服务器POST消息时用的是UTF-8编码，在接收时也要用同样的编码，否则中文会乱码；

response.setCharacterEncoding("UTF-8"); //在响应消息(回复消息给用户)时，也将编码方式设置为UTF-8，原理同上；boolean isGet = request.getMethod().toLowerCase().equals("get");

PrintWriter out = response.getWriter();

try {

if (RequestMethod.GET.name().equals(request.getMethod())) {

String signature = request.getParameter("signature");// 微信加密签名

String timestamp = request.getParameter("timestamp");// 时间戳

String nonce = request.getParameter("nonce");// 随机数

String echostr = request.getParameter("echostr");//随机字符串

// 通过检验signature对请求进行校验，若校验成功则原样返回echostr，表示接入成功，否则接入失败

if (SignUtil.checkSignature(DNBX_TOKEN, signature, timestamp, nonce)) {

LOGGER.info("Connect the weixin server is successful.");

response.getWriter().write(echostr);

} else {

LOGGER.error("Failed to verify the signature!");

}

}else{

String respMessage = "";

try {

respMessage = wechatService.weixinPost(request);

out.write(respMessage);

LOGGER.info("The request completed successfully");

LOGGER.info("to weixin server "+respMessage);

} catch (Exception e) {

LOGGER.error("Failed to convert the message from weixin!", e);

}

}

} catch (Exception e) {

LOGGER.error("Connect the weixin server is error.", e);

}finally{

out.close();

}

}

校验的代码如下：

public class SignUtil {

/**

* 验证签名

*

* @param token 微信服务器token，在env.properties文件中配置的和在开发者中心配置的必须一致

* @param signature 微信服务器传过来sha1加密的证书签名

* @param timestamp 时间戳

* @param nonce 随机数

* @return

*/

public static boolean checkSignature(String token,String signature, String timestamp, String nonce) {

String[] arr = new String[] { token, timestamp, nonce };

// 将token、timestamp、nonce三个参数进行字典序排序

Arrays.sort(arr);

// 将三个参数字符串拼接成一个字符串进行sha1加密

String tmpStr = SHA1.encode(arr[0] + arr[1] + arr[2]);

// 将sha1加密后的字符串可与signature对比，标识该请求来源于微信

return tmpStr != null ? tmpStr.equals(signature.toUpperCase()) : false;

}

}

import java.security.MessageDigest;

/**

* 微信公众平台(JAVA) SDK

*

* SHA1算法

*

* @author helijun 2016/06/15 19:49

*/

public final class SHA1 {

private static final char[] HEX_DIGITS = {'0', '1', '2', '3', '4', '5',

'6', '7', '8', '9', 'A', 'B', 'C', 'D', 'E', 'F' };

/**

* Takes the raw bytes from the digest and formats them correct.

*

* @param bytes the raw bytes from the digest.

* @return the formatted bytes.

*/

private static String getFormattedText(byte[] bytes) {

int len = bytes.length;

StringBuilder buf = new StringBuilder(len * 2);

// 把密文转换成十六进制的字符串形式

for (int j = 0; j < len; j++) {

buf.append(HEX_DIGITS[(bytes[j] >> 4) & 0x0f]);

buf.append(HEX_DIGITS[bytes[j] & 0x0f]);

}

return buf.toString();

}

public static String encode(String str) {

if (str == null) {

return null;

}

try {

MessageDigest messageDigest = MessageDigest.getInstance("SHA1");

messageDigest.update(str.getBytes());

return getFormattedText(messageDigest.digest());

} catch (Exception e) {

throw new RuntimeException(e);

}

}

}

其中加密字段分别为：signature：微信加密签名 　　timestamp：时间戳　　nonce：随机数　　echostr：随机字符串，

而代码中的DNBX_TOKEN 就是公众号里配置的 令牌(Token)。如果校验成功就把echostr返回给微信端即可。

再来看看如何处理具体的post请求：

import com.alibaba.fastjson.JSON;

import com.alibaba.fastjson.JSONObject;

import com.yxy.nova.bean.wechat.TextMessage;

import com.yxy.nova.util.MessageUtil;

import com.yxy.nova.util.SimpleHttpClient;

import com.yxy.nova.util.wechat.weather.TianQiCityID;

import com.yxy.nova.util.wechat.weather.TianQiWeatherHelper;

import com.yxy.nova.web.util.WebUtil;

import org.apache.commons.lang3.StringUtils;

import org.apache.http.NameValuePair;

import org.apache.http.message.BasicNameValuePair;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.beans.factory.annotation.Value;

import org.springframework.stereotype.Service;

import javax.servlet.http.HttpServletRequest;

import java.io.IOException;

import java.util.Map;

/**

* @date 2021/1/22 上午11:38

* @Description

*/

@Service

public class WechatServiceImpl implements WechatService {

private final Logger LOGGER = LoggerFactory.getLogger(getClass());

private static JSONObject accessToken = new JSONObject();

@Value("${wechat-AppId}")

private String appleId;

@Value("${wechat-AppSecret}")

private String appSecret;

@Autowired

private SimpleHttpClient simpleHttpClient;

/**

* 处理微信发来的请求

*

* @param request

* @return

*/

@Override

public String weixinPost(HttpServletRequest request) {

String respMessage = null;

try {

// xml请求解析

Map requestMap = MessageUtil.xmlToMap(request);

// 发送方帐号(open_id)

String fromUserName = requestMap.get("FromUserName");

// 公众帐号

String toUserName = requestMap.get("ToUserName");

// 消息类型

String msgType = requestMap.get("MsgType");

// 消息内容

String content = requestMap.get("Content");

LOGGER.info("FromUserName is:" + fromUserName + ", ToUserName is:" + toUserName + ", MsgType is:" + msgType);

// 文本消息

if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_TEXT)) {

//这里根据关键字执行相应的逻辑，只有你想不到的，没有做不到的

TianQiCityID ci = new TianQiCityID();

if(ci.getCityIDMap().get(content) !=null){

TextMessage text = new TextMessage();

TianQiWeatherHelper tianQiWeatherHelper = new TianQiWeatherHelper();

tianQiWeatherHelper.setSimpleHttpClient(simpleHttpClient);

text.setContent(tianQiWeatherHelper.getWeatherReportByCityName(content));

text.setToUserName(fromUserName);

text.setFromUserName(toUserName);

text.setCreateTime(System.currentTimeMillis() + "");

text.setMsgType(msgType);

respMessage = MessageUtil.textMessageToXml(text);

}

if ("天气".equals(content)) {

TextMessage text = new TextMessage();

TianQiWeatherHelper tianQiWeatherHelper = new TianQiWeatherHelper();

tianQiWeatherHelper.setSimpleHttpClient(simpleHttpClient);

text.setContent(tianQiWeatherHelper.getWeatherReportByIP(WebUtil.getRemoteAddr(request)));

text.setToUserName(fromUserName);

text.setFromUserName(toUserName);

text.setCreateTime(System.currentTimeMillis() + "");

text.setMsgType(msgType);

respMessage = MessageUtil.textMessageToXml(text);

}

//自动回复

// TextMessage text = new TextMessage();

// text.setContent("the text is" + content);

// text.setToUserName(fromUserName);

// text.setFromUserName(toUserName);

// text.setCreateTime(System.currentTimeMillis() + "");

// text.setMsgType(msgType);

// respMessage = MessageUtil.textMessageToXml(text);

}

// else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_EVENT)) {// 事件推送

// String eventType = requestMap.get("Event");// 事件类型

//

// if (eventType.equals(MessageUtil.EVENT_TYPE_SUBSCRIBE)) {// 订阅

// respContent = "欢迎关注xxx公众号！";

// return MessageResponse.getTextMessage(fromUserName , toUserName , respContent);

// } else if (eventType.equals(MessageUtil.EVENT_TYPE_CLICK)) {// 自定义菜单点击事件

// String eventKey = requestMap.get("EventKey");// 事件KEY值，与创建自定义菜单时指定的KEY值对应

// logger.info("eventKey is:" +eventKey);

// return xxx;

// }

// }

//开启微信声音识别测试 2015-3-30

// else if(msgType.equals("voice"))

// {

// String recvMessage = requestMap.get("Recognition");

// //respContent = "收到的语音解析结果："+recvMessage;

// if(recvMessage!=null){

// respContent = TulingApiProcess.getTulingResult(recvMessage);

// }else{

// respContent = "您说的太模糊了，能不能重新说下呢？";

// }

// return MessageResponse.getTextMessage(fromUserName , toUserName , respContent);

// }

//拍照功能

// else if(msgType.equals("pic_sysphoto"))

// {

//

// }

// else

// {

// return MessageResponse.getTextMessage(fromUserName , toUserName , "返回为空");

// }

// 事件推送

else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_EVENT)) {

String eventType = requestMap.get("Event");// 事件类型

// 订阅

if (eventType.equals(MessageUtil.EVENT_TYPE_SUBSCRIBE)) {

TextMessage text = new TextMessage();

text.setContent("欢迎关注，xxx");

text.setToUserName(fromUserName);

text.setFromUserName(toUserName);

text.setCreateTime(System.currentTimeMillis() + "");

text.setMsgType(MessageUtil.RESP_MESSAGE_TYPE_TEXT);

respMessage = MessageUtil.textMessageToXml(text);

}

// TODO 取消订阅后用户再收不到公众号发送的消息，因此不需要回复消息

else if (eventType.equals(MessageUtil.EVENT_TYPE_UNSUBSCRIBE)) {// 取消订阅

}

// 自定义菜单点击事件

else if (eventType.equals(MessageUtil.EVENT_TYPE_CLICK)) {

String eventKey = requestMap.get("EventKey");// 事件KEY值，与创建自定义菜单时指定的KEY值对应

if (eventKey.equals("weather")) {

TextMessage text = new TextMessage();

text.setContent("请输入城市名称");

text.setToUserName(fromUserName);

text.setFromUserName(toUserName);

text.setCreateTime(System.currentTimeMillis() + "");

text.setMsgType(MessageUtil.RESP_MESSAGE_TYPE_TEXT);

respMessage = MessageUtil.textMessageToXml(text);

}

}

}

}

catch (Exception e) {

LOGGER.error("error......");

}

return respMessage;

}

}

如上面的代码，我在文本消息中，简单的实现了根据城市名称查询天气情况。接口的实现就不贴出来了，就是一个简单的接口对接。

三：第三方接口

网上有关于 www.weather.com.cn网站获取天气情况的接口，但是本人测试使用发现返回字段比较少，而且刷新的不是很及时，

现在推荐一个免费的第三方接口：https://www.tianqiapi.com/，在api接口中有三个免费的接口，可以实现一些简单的功能了。

我在demo中使用的就是：免费实况天气接口:https://www.tianqiapi.com/index/doc?version=v6，用完感受还是不错的。

至此，已经实现了公众号的部分功能，其实微信的接口文档还有很多，还有很多更好玩的功能，比如微信对话开放平台，有兴趣的可以申请开发权限，去探索一下吧。