微信公众号开发系统入门教程（公众号注册、开发环境搭建、获取access_token步骤...）
微信公众号的通讯机制
微信公众号简介
微信公众号分为服务号、订阅号、企业号，订阅号可以个人申请，服务号和企业号要有企业资质才可以。
我们所说的微信公众号开发指的是订阅号和服务号。关于订阅号和服务器的区别，官方是这样解释的
- 服务号**：主要偏向于服务交互（功能类似12315，114，银行，提供绑定信息，服务交互），每月可群发4条消息；服务号**适用人群：**媒体、企业、政府或其他组织。
- 订阅号**：主要偏向于为用户传达资讯，（功能类似报纸杂志，为用户提供新闻信息或娱乐趣事），每天可群发1条消息；订阅号适用人群：个人、媒体、企业、政府或其他组织。
1.注册微信公众号
进入微信公众号注册页面点击公众号右上方的注册按钮,进入注册界面,填写基本信息,选择订阅号, 完成身份认证, 此处我选择的是个人订阅号,如下完善即可:
然后注册成功之后进入微信公众平台后台,然后完善微信号名称和微信号ID:
微信号名称默认是新注册公众号,还需要修改微信号名称, 修改的时候需要经过微信认证,并且审核通过之后才可以使用该公众号.
2.注册测试公众号
个人订阅号有一些接口是没有权限的，也就是说个人订阅号无法调用一些高级的权限接口,如生成二维码、网页授权、自定义菜单、微信支付这样的接口权限个人订阅号是没有调用权限的, 幸运的是，微信公众平台提供了测试公众账号，测试公众号有很多个人订阅号不具备的权限, 测试公众号的注册地址为：
用微信扫描页面中的二维码进行登录，登录成功后，就可以看到腾讯分配给我们的测试公众号的信息了，如下图所示, 接下来我们就可以搭建环境,进行开发测试了
测试公众号的所拥有的接口权限如下：
3.搭建微信本地调试环境
开发基于微信公众号的应用最大的痛苦之处就是调试问题，每次实现一个功能后都需要部署到一个公网服务器进行测试，因为微信用户每次向公众号发起请求时，微信服务器会先接收到用户的请求，然后再转发到我们的服务器上，也就是说，微信服务器是要和我们的服务器进行网络交互，所以我们必须保证我们的服务器外网可以访问到，这种部署到公网服务器进行测试的做法对于我们开发者来说简直是噩梦。所以我们要想一个办法可以做到本地部署，本地调试代码，而要做到这一点，那么我们要解决的问题就是将内网的部署服务器映射到外网，让微信服务器可以正常访问到，幸运的是，借助于第三方软件Ngrok，我们就可以做得到。Ngrok是一个免费的软件Ngrok,使用Ngrok后,我们就可以实现内网穿透,也就是说我们可以将内网的服务器映射到外网给别人访问,这对于我们在本地开发环境中调试微信代码是以及给用户演示一些东西非常快速和有帮助的,因为可以直接使用我们自己的内网的电脑作为服务器。不过需要翻墙访问.
国内提供Ngrok服务比较好的网站是:,如下图所示:
1)下载客户端natapp:
2)安装natapp:
具体参考, 这个网址里详细介绍了win/Mac/Linux下安装步骤
- 解压缩到目录D:\Program Files\natapp
- 直接双击打开失败，需要配置环境变量,编辑环境变量Path,新建natapp目录
- 打开cmd, 执行命令 natapp, 显示认证错误
- 这个时候是需要token认证的, 所以我们的主要工作就是如何获得authtoken
进入，根据提示注册并创建免费隧道, 注册的时候需要用支付宝实名认证的手机号注册
根据《中华人民共和国网络安全法》,以及防止隧道被非法使用,Natapp实行实名认证制度. 本站承诺身份信息仅用于身份验证识别,不做任何其他用途,且严格加密存储杜绝泄漏风险 本实名认证系统基于阿里大数据的强个人识别验证.手机,身份证信息须匹配,比如手机号是你的支付宝实名认证的手机号,日常正常使用的.如其他小号可能无法通过验证 目前创建免费隧道强制要求实名认证.付费隧道可通过支付宝支付来实名认证
- 复制authtoken, cmd进入natapp目录执行 natapp -authtoken yourauthtoken 出现下图即为成功
- 此时外网的用户可以直接使用这个域名访问到我内网的服务器了,如下图所示:
使用了ngrok之后,我们就可以把内网的服务器当成公网服务器来使用了.访问的速度也还在可以接受的范围内吧，截止到目前为止ngrok是可用的，微信公众号服务器是可以访问的，这样一来也就不妨碍我们做本地调式了。到此，我们的微信本地调试开发环境就算是搭建好了。
4.微信公众号接入(校验签名)
在微信公众平台开发者文档上，关于公众号接入这一节内容在接入指南上写的比较详细的，文档中说接入公众号需要3个步骤，分别是：
1、填写服务器配置
2、验证服务器地址的有效性
3、依据接口文档实现业务逻辑
其实，第3步已经不能算做公众号接入的步骤，而是接入之后，开发人员可以根据微信公众号提供的接口所能做的一些开发。
第1步中服务器配置包含服务器地址（URL）、令牌(Token) 和 消息加解密密钥(EncodingAESKey)。
可在开发–>基本配置–>服务器配置中配置
服务器地址即公众号后台提供业务逻辑的入口地址，目前只支持80端口，之后包括接入验证以及任何其它的操作的请求（例如消息的发送、菜单管理、素材管理等）都要从这个地址进入。接入验证和其它请求的区别就是，接入验证时是get请求，其它时候是post请求；
Token可由开发者可以任意填写，用作生成签名（该Token会和接口URL中包含的Token进行比对，从而验证安全性）；
EncodingAESKey由开发者手动填写或随机生成，将用作消息体加解密密钥。本例中全部以未加密的明文消息方式，不涉及此配置项。
第2步，验证服务器地址的有效性，当点击“提交”按钮后，微信服务器将发送一个http的get请求到刚刚填写的服务器地址，并且携带四个参数：
接到请求后，我们需要做如下三步，若确认此次GET请求来自微信服务器，原样返回echostr参数内容，则接入生效，否则接入失败。
1. 将token、timestamp、nonce三个参数进行字典序排序2. 将三个参数字符串拼接成一个字符串进行sha1加密 (可逆加密解密函数)3. 开发者获得加密后的字符串可与signature对比，标识该请求来源于微信
下面我们用Java代码来演示一下这个验证过程
使用IDE(Eclipse或者IntelliJ IDEA)创建一个JavaWeb项目,新建servlet weChatAccounts,代码如下:
package weChatServlet;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import javax.activation.DataHandler;import javax.activation.FileDataSource;import javax.mail.*;import javax.mail.internet.*;import javax.servlet.ServletException;import javax.servlet.http.HttpServlet;import javax.servlet.http.HttpServletRequest;import javax.servlet.http.HttpServletResponse;import java.io.IOException;import java.security.MessageDigest;import java.security.NoSuchAlgorithmException;import java.util.Arrays;import java.util.Calendar;import java.util.Date;import java.util.Properties;publicclassweChatAccountsextendsHttpServlet{static Logger logger = LoggerFactory.getLogger(weChatAccounts.class);privatefinal String TOKEN ="cherry";@OverrideprotectedvoiddoPost(HttpServletRequest req, HttpServletResponse resp)throws ServletException, IOException {doGet(req,resp);}@OverridepublicvoiddoGet(HttpServletRequest req, HttpServletResponse resp)throws ServletException, IOException {System.out.println("-----开始校验签名-----");String signature = req.getParameter("signature");String timestamp = req.getParameter("timestamp");String nonce = req.getParameter("nonce");String echostr = req.getParameter("echostr");String sortStr =sort(TOKEN,timestamp,nonce);String mySignature =shal(sortStr);if(!"".equals(signature)&&!"".equals(mySignature)&& signature.equals(mySignature)){System.out.println("-----签名校验通过-----");resp.getWriter().write(echostr);}else{System.out.println("-----校验签名失败-----");}}public String sort(String token, String timestamp, String nonce){String[] strArray ={token, timestamp, nonce};Arrays.sort(strArray);StringBuilder sb =newStringBuilder();for(String str : strArray){sb.append(str);}return sb.toString();}public String shal(String str){try{MessageDigest digest = MessageDigest.getInstance("SHA-1");digest.update(str.getBytes());byte messageDigest[]= digest.digest();StringBuffer hexString =newStringBuffer();for(int i =0; i < messageDigest.length; i++){String shaHex = Integer.toHexString(messageDigest[i]&0xFF);if(shaHex.length()<2){hexString.append(0);}hexString.append(shaHex);}return hexString.toString();}catch(NoSuchAlgorithmException e){e.printStackTrace();}return"";}}在中配置 servlet:
<?xml version="" encoding="UTF-8"?><web-appxmlns=""xmlns:xsi=""xsi:schemaLocation="/web-app_3_1.xsd"version=""><welcome-file-list><welcome-file></welcome-file></welcome-file-list><servlet><servlet-name>weChatServlet</servlet-name><servlet-class>weChatServlet.weChatAccounts</servlet-class></servlet><servlet-mapping><servlet-name>weChatServlet</servlet-name><url-pattern>/weChatServlet</url-pattern></servlet-mapping></web-app>然后在中写hello world 测试:
<%-- Created by IntelliJ IDEA.--%><%@ page language="java" contentType="text/html; charset=UTF-8" pageEncoding="UTF-8"%><html><head><title></title></head><body><h3>微信公众号测试!</h3></body></html>启动项目结果如下:
然后启动natapp,进行内网透传 natapp -authtoken mytoken
根据动态生成的ip地址访问.,得到如下效果,则表示外网可以成功访问:
进入微信测试公众号管理界面，在接口配置信息中填入映射的外网地址和代码中声明的token，如下图所示：
点击提交,会显示配置成功, 控制台就会打印信息, 显示签名校验通过.
注意: URL是 外网的ip地址加上 中配置的servlet名称
到此，我们的公众号应用已经能够和微信服务器正常通信了，也就是说我们的公众号已经接入到微信公众平台了。
管理
我们的公众号和微信服务器对接成功之后，接下来要做的就是根据我们的业务需求调用微信公众号提供的接口来实现相应的逻辑了。在使用微信公众号接口中都需要一个access_token。
1)access_token介绍
access_token是公众号的全局唯一接口调用凭据，公众号调用各接口时都需使用access_token。开发者需要进行妥善保存。access_token的存储至少要保留512个字符空间。access_token的有效期目前为2个小时，需定时刷新，重复获取将导致上次获取的access_token失效。
总结以上说明，access_token需要做到以下两点：
1.因为access_token有2个小时的时效性，要有一个机制保证最长2个小时重新获取一次。
2.因为接口调用上限每天2000次，所以不能调用太频繁。
2)获取access_token步骤
公众号可以使用AppID和AppSecret调用本接口来获取access_token。AppID和AppSecret可在“微信公众平台-开发-基本配置”页中获得（需要已经成为开发者，且帐号没有异常状态）。调用接口时，请登录“微信公众平台-开发-基本配置”提前将服务器IP地址添加到IP白名单中，点击查看设置方法，否则将无法调用成功。
接口调用请求说明
https请求方式: GET
参数说明
| 参数 | 是否必须 | 说明 |
|---|---|---|
| grant_type | 是 | 获取access_token填写client_credential |
| appid | 是 | 第三方用户唯一凭证 |
| secret | 是 | 第三方用户唯一凭证密钥，即appsecret |
返回说明
正常情况下，微信会返回下述JSON数据包给公众号：
{"access_token":"ACCESS_TOKEN","expires_in":7200}
参数说明
| 参数 | 说明 |
|---|---|
| access_token | 获取到的凭证 |
| expires_in | 凭证有效时间，单位：秒 |
错误时微信会返回错误码等信息，JSON数据包示例如下（该示例为AppID无效错误）:
{"errcode":40013,"errmsg":"invalid appid"}
返回码说明
| 返回码 | 说明 |
|---|---|
| -1 | 系统繁忙，此时请开发者稍候再试 |
| 0 | 请求成功 |
| 40001 | AppSecret错误或者AppSecret不属于这个公众号，请开发者确认AppSecret的正确性 |
| 40002 | 请确保grant_type字段值为client_credential |
| 40164 | 调用接口的IP地址不在白名单中，请在接口IP白名单中进行设置 |
3)代码实现获取access_token
定义一个默认启动的servlet，在init方法中启动一个Thread,这个进程中定义一个无限循环的方法，用来获取access_token，当获取成功后，此进程休眠7000秒(7000秒=小时)，否则休眠3秒钟继续获取。流程图如下：
定义一个dto AccessToken:
package AccessToken;publicclassAccessToken{private String tokenName;privateint expireSecond;public String getTokenName(){return tokenName;}publicvoidsetTokenName(String tokenName){this.tokenName = tokenName;}publicintgetExpireSecond(){return expireSecond;}publicvoidsetExpireSecond(int expireSecond){this.expireSecond = expireSecond;}}package AccessToken;import AccessToken.AccessToken;publicclassAccessTokenInfo{publicstatic AccessToken accessToken = null;}编写一个用于发起https请求的工具类NetWorkUtil,代码如下:
getHttpsResponse方法是请求一个https地址，参数requestMethod为字符串“GET”或者“POST”，传null或者“”默认为get方式。
package AccessToken;import javax.net.ssl.*;import java.io.BufferedReader;import java.io.IOException;import java.io.InputStream;import java.io.InputStreamReader;import java.net.MalformedURLException;import java.net.URL;import java.security.KeyManagementException;import java.security.NoSuchAlgorithmException;import java.security.cert.CertificateException;import java.security.cert.X509Certificate;publicclassNetWorkUtil{public String getHttpsResponse(String reqUrl, String requestMethod){URL url;InputStream is;String result ="";try{url =newURL(reqUrl);HttpsURLConnection con =(HttpsURLConnection) url.openConnection();TrustManager[] tm ={xtm};SSLContext ctx = SSLContext.getInstance("TLS");ctx.init(null, tm, null);con.setSSLSocketFactory(ctx.getSocketFactory());con.setHostnameVerifier(newHostnameVerifier(){@Overridepublicbooleanverify(String arg0, SSLSession arg1){returntrue;}});con.setDoInput(true);con.setDoOutput(false);con.setUseCaches(false);if(null != requestMethod &&!requestMethod.equals("")){con.setRequestMethod(requestMethod);}else{con.setRequestMethod("GET");}is = con.getInputStream();InputStreamReader isr =newInputStreamReader(is);BufferedReader bufferReader =newBufferedReader(isr);String inputLine;while((inputLine = bufferReader.readLine())!= null){result += inputLine +"\n";}System.out.println(result);}catch(Exception e){e.printStackTrace();}return result;}X509TrustManager xtm =newX509TrustManager(){@Overridepublic X509Certificate[]getAcceptedIssuers(){return null;}@OverridepublicvoidcheckServerTrusted(X509Certificate[] arg0, String arg1)throws CertificateException {}@OverridepublicvoidcheckClientTrusted(X509Certificate[] arg0, String arg1)throws CertificateException {}};}定义一个默认启动的servlet，在init方法中启动一个新的线程去获取accessToken:
此处需要将JSON数据解析为object, 需要用到fastjson.jar
package AccessToken;import com.alibaba.fastjson.JSON;import com.alibaba.fastjson.JSONObject;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import javax.servlet.ServletException;import javax.servlet.http.HttpServlet;publicclassAccessTokenServletextendsHttpServlet{static Logger logger = LoggerFactory.getLogger(AccessTokenServlet.class);@Overridepublicvoidinit()throws ServletException {System.out.println("-----启动AccessTokenServlet-----");super.init();final String appId =getInitParameter("appId");final String appSecret =getInitParameter("appSecret");newThread(newRunnable(){@Overridepublicvoidrun(){while(true){try{AccessTokenInfo.accessToken =getAccessToken(appId, appSecret);if(AccessTokenInfo.accessToken != null){Thread.sleep(7000*1000);}else{Thread.sleep(1000*3);}}catch(Exception e){System.out.println("发生异常："+ e.getMessage());e.printStackTrace();try{Thread.sleep(1000*10);}catch(Exception e1){e.printStackTrace();}}}}}).start();}private AccessToken getAccessToken(String appId, String appSecret){NetWorkUtil netHelper =newNetWorkUtil();String Url = String.format("", appId, appSecret);String result = netHelper.getHttpsResponse(Url,"");System.out.println("获取到的access_token="+result);JSONObject json = JSON.parseObject(result);AccessToken token =newAccessToken();token.setTokenName(json.getString("access_token"));token.setExpireSecond(json.getInteger("expires_in"));return token;}}然后在中配置AccessTokenServlet:
<servlet><servlet-name>accessTokenServlet</servlet-name><servlet-class>weChatServlet.AccessTokenServlet</servlet-class></servlet><servlet-mapping><servlet-name>accessTokenServlet</servlet-name><url-pattern>/accessTokenServlet</url-pattern></servlet-mapping>:
<%-- Created by IntelliJ IDEA. --%>
<%@ page language="java" contentType="text/html; charset=UTF-8" pageEncoding="UTF-8"%>
<%@ taglib uri="" prefix="c" %>
<%@ taglib uri="" prefix="fmt" %>
<%@ taglib uri="" prefix="fn" %>
<c:set var="basePath" value="${ }"></c:set>
<%@ page import=""%>
<html><head><title></title></head><body><h3>微信公众号测试!</h3><form action="${}/weChatServlet" method="get"><button οnclick="submit">测试微信公众号</button></form><hr/><%--获取access_token--%><form action="${}/accessTokenServlet" method="get"><button οnclick="submit">获取access_token</button></form><c:if test=" != null">access_token为：<%=.getTokenName()%></c:if></body>
</html>
启动项目, 点击获取access_token按钮: 获取出错, 返回码40013,表示AppID无效错误
-----启动AccessTokenServlet-----
SLF4J: Failed to load class "".
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.
{"errcode":40013,"errmsg":"invalid appid hint: [OwC0oa06551466]"}获取到的access_token={"errcode":40013,"errmsg":"invalid appid hint: [OwC0oa06551466]"}
再次确认appID和appsecret没有错误之后,再次获取token:
至此, access_token获取成功 !
6.总结一下项目启动之后, 通过微信公众号测试的全过程:
- 开启外网访问 : CMD进入natapp目录下, 运行命令natapp -authtoken yourauthtoken , 得到外网访问的域名
- Tomcat启动项目
- 进入微信公众号测试管理平台, 修改接口配置信息URL为: 新域名/weChatServlet , 待签名校验通过,就可以测试
- 进入测试公众号, 发送消息进行测试
7.被动发送用户消息
业务逻辑(一) — 发送文本消息
经过上述的三步,我们开发前的准备工作已经完成了,接下来要做的就是接收微信服务器发送的消息并做出响应
从微信公众平台接口消息指南中可以了解到，当用户向公众帐号发消息时，微信服务器会将消息通过POST方式提交给我们在接口配置信息中填写的URL，而我们就需要在URL所指向的请求处理类WxServlet的doPost方法中接收消息、处理消息和响应消息。
可以参考微信API文档 – 被动回复用户消息 wiki?t=resource/res_main&id=mp1421140543
1)编写一个用于处理消息的工具类
这个工具类主要是解析消息, 构建消息
package weChatServlet;import org.dom4j.Document;import org.dom4j.Element;import org.dom4j.io.SAXReader;import javax.servlet.http.HttpServletRequest;import java.io.InputStream;import java.text.DateFormat;import java.text.SimpleDateFormat;import java.util.Date;import java.util.HashMap;import java.util.List;import java.util.Map;publicclassMessageUtil{publicstatic Map<String,String>parseXml(HttpServletRequest request)throws Exception {Map<String,String> map =newHashMap();InputStream inputStream = request.getInputStream();System.out.println("获取输入流");SAXReader reader =newSAXReader();Document document = reader.read(inputStream);Element root = document.getRootElement();List<Element> elementList = root.elements();for(Element e : elementList){System.out.println(e.getName()+"|"+ e.getText());map.put(e.getName(), e.getText());}inputStream.close();inputStream = null;return map;}publicstatic String buildXml(Map<String,String> map){String result;String msgType = map.get("MsgType").toString();System.out.println("MsgType:"+ msgType);if(msgType.toUpperCase().equals("TEXT")){result =buildTextMessage(map,"Cherry的小小窝, 请问客官想要点啥?");}else{String fromUserName = map.get("FromUserName");String toUserName = map.get("ToUserName");result = String.format("<xml>"+"<ToUserName><![CDATA[%s]]></ToUserName>"+"<FromUserName><![CDATA[%s]]></FromUserName>"+"<CreateTime>%s</CreateTime>"+"<MsgType><![CDATA[text]]></MsgType>"+"<Content><![CDATA[%s]]></Content>"+"</xml>",fromUserName, toUserName,getUtcTime(),"请回复如下关键词：\n文本\n图片\n语音\n视频\n音乐\n图文");}return result;}privatestatic String buildTextMessage(Map<String,String> map, String content){String fromUserName = map.get("FromUserName");String toUserName = map.get("ToUserName");return String.format("<xml>"+"<ToUserName><![CDATA[%s]]></ToUserName>"+"<FromUserName><![CDATA[%s]]></FromUserName>"+"<CreateTime>%s</CreateTime>"+"<MsgType><![CDATA[text]]></MsgType>"+"<Content><![CDATA[%s]]></Content>"+"</xml>",fromUserName, toUserName,getUtcTime(), content);}privatestatic String getUtcTime(){Date dt =newDate();DateFormat df =newSimpleDateFormat("yyyyMMddhhmm");String nowTime = df.format(dt);long dd =(long)0;try{dd = df.parse(nowTime).getTime();}catch(Exception e){}return String.valueOf(dd);}}2)在WxServlet的doPost方法中处理请求
WxServlet的doPost方法的代码如下:
package weChatServlet;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import javax.servlet.ServletException;import javax.servlet.http.HttpServlet;import javax.servlet.http.HttpServletRequest;import javax.servlet.http.HttpServletResponse;import java.io.IOException;import java.security.MessageDigest;import java.security.NoSuchAlgorithmException;import java.util.Arrays;import java.util.Map;publicclassWeChatAccountsextendsHttpServlet{static Logger logger = LoggerFactory.getLogger(WeChatAccounts.class);privatefinal String TOKEN ="cherry";@OverrideprotectedvoiddoPost(HttpServletRequest req, HttpServletResponse resp)throws ServletException, IOException {req.setCharacterEncoding("UTF-8");resp.setCharacterEncoding("UTF-8");System.out.println("请求进入");String result ="";try{Map<String,String> map = MessageUtil.parseXml(req);System.out.println("开始构造消息");result = MessageUtil.buildXml(map);System.out.println(result);if(result.equals("")){result ="未正确响应";}}catch(Exception e){e.printStackTrace();System.out.println("发生异常："+ e.getMessage());}resp.getWriter().println(result);}@OverridepublicvoiddoGet(HttpServletRequest req, HttpServletResponse resp)throws ServletException, IOException {System.out.println("-----开始校验签名-----");..............................}}将WxStudy部署到Tomcat服务器,启动服务器,记得使用ngrok将本地Tomcat服务器的8080端口映射到外网,保证接口配置信息的URL地址:可以正常与微信服务器通信
登录到我们的测试公众号的管理后台,然后用微信扫描一下测试号的二维码,如下图所示:
关注成功后,我们开发好的公众号应用会先给用户发一条提示用户操作的文本消息,微信用户根据提示操作输入"文本",我们的公众号应用接收到用户请求后就给用户回复了一条我们自己构建好的文本消息,如下图所示:
我们公众号获取到的输入流如下:
第一次关注时获取的输入流, 消息类型为事件event, 订阅
ToUserName|gh_fbcf752402d4
FromUserName|oEG9V1PeFHnsQviezVY9D4IDcyAk
CreateTime|1514461156
MsgType|event
Event|subscribe
EventKey|第一次发送消息内容为"文本"获取的输入流, 消息类型是text
ToUserName|gh_fbcf752402d4
FromUserName|oEG9V1PeFHnsQviezVY9D4IDcyAk
CreateTime|1514461351
MsgType|text
Content|文本
MsgId|6504561974052876654
我们公众号应用响应给微信用户的文本消息的XML数据如下:
关注之后返回的消息是:
MsgType:event
<xml><ToUserName><![CDATA[oEG9V1PeFHnsQviezVY9D4IDcyAk]]></ToUserName><FromUserName><![CDATA[gh_fbcf752402d4]]></FromUserName> <CreateTime>1514417940000</CreateTime><MsgType><![CDATA[text]]></MsgType><Content><![CDATA[请回复如下关键词：文本图片语音视频音乐图文]]></Content>
</xml>输入文本之后返回的消息是:
<xml><ToUserName><![CDATA[oEG9V1PeFHnsQviezVY9D4IDcyAk]]></ToUserName><FromUserName><![CDATA[gh_fbcf752402d4]]></FromUserName><CreateTime>1514418120000</CreateTime><MsgType><![CDATA[text]]></MsgType><Content><![CDATA[Cherry的小小窝, 请问客官想要点啥?]]></Content>
</xml>
业务逻辑(二) — 上传素材获取Media_id
图片,语音,视频的回复消息构造,这三种消息构造时的都需要一个mediaId,而这个mediaId是通过素材管理接口上传多媒体文件得到的,为了构造图片,语音,视频的这几种回复消息,我事先准备好了测试素材,
如图片路径为: C:\Users\Chen Xiuhong\Pictures\timg (1).jpg
然后通过微信公众号平台提供的素材管理接口将图片,语音,视频上传到微信服务器上,上传成功后,微信服务器会给我们返回一个mediaId,用于标识上传成功的多媒体素材,上传素材的工具类代码如下:
package weChatServlet;import AccessToken.AccessToken;import AccessToken.NetWorkUtil;import com.alibaba.fastjson.JSON;import com.alibaba.fastjson.JSONException;import com.alibaba.fastjson.JSONObject;import org.apache.commons.httpclient.HttpClient;import org.apache.commons.httpclient.HttpException;import org.apache.commons.httpclient.HttpStatus;import org.apache.commons.httpclient.methods.PostMethod;import org.apache.commons.httpclient.methods.multipart.FilePart;import org.apache.commons.httpclient.methods.multipart.MultipartRequestEntity;import org.apache.commons.httpclient.methods.multipart.Part;import org.apache.commons.httpclient.methods.multipart.StringPart;import org.apache.commons.httpclient.protocol.Protocol;import org.apache.commons.httpclient.protocol.SSLProtocolSocketFactory;import org.apache.commons.httpclient.util.HttpURLConnection;import java.io.*;import java.net.URL;publicclassUploadMediaApiUtil{privatestaticfinal String ACCESS_TOKEN ="";privatestaticfinal String UPLOAD_MEDIA ="";privatestaticfinal String DOWNLOAD_MEDIA ="";publicstatic String getTokenUrl(String appId, String appSecret){return String.format(ACCESS_TOKEN, appId, appSecret);}publicstatic String getDownloadUrl(String token, String mediaId){return String.format(DOWNLOAD_MEDIA, token, mediaId);}public String getAccessToken(String appId, String appSecret){NetWorkUtil netHelper =newNetWorkUtil();String Url = String.format("", appId, appSecret);String result = netHelper.getHttpsResponse(Url,"");JSONObject json = JSON.parseObject(result);return json.getString("access_token");}public JSONObject uploadMedia(File file, String token, String type){if(file == null || token == null || type == null){return null;}if(!file.exists()){System.out.println("上传文件不存在,请检查!");return null;}JSONObject jsonObject = null;PostMethod post =newPostMethod(UPLOAD_MEDIA);post.setRequestHeader("Connection","Keep-Alive");post.setRequestHeader("Cache-Control","no-cache");FilePart media;HttpClient httpClient =newHttpClient();Protocol myhttps =newProtocol("https",newSSLProtocolSocketFactory(),443);Protocol.registerProtocol("https", myhttps);try{media =newFilePart("media", file);Part[] parts =newPart[]{newStringPart("access_token", token),newStringPart("type", type),media};MultipartRequestEntity entity =newMultipartRequestEntity(parts,post.getParams());post.setRequestEntity(entity);int status = httpClient.executeMethod(post);if(status == HttpStatus.SC_OK){String text = post.getResponseBodyAsString();jsonObject = JSONObject.parseObject(text);}else{System.out.println("upload Media failure status is:"+ status);}}catch(FileNotFoundException e){e.printStackTrace();}catch(HttpException e){e.printStackTrace();}catch(IOException e){e.printStackTrace();}return jsonObject;}publicstatic File downloadMedia(String fileName, String token, String mediaId){String path =getDownloadUrl(token, mediaId);if(fileName == null || path == null){return null;}File file = null;HttpURLConnection conn = null;InputStream inputStream = null;FileOutputStream fileOut = null;try{URL url =newURL(path);conn =(HttpURLConnection) url.openConnection();conn.setDoOutput(true);conn.setDoInput(true);conn.setUseCaches(false);conn.setRequestMethod("GET");inputStream = conn.getInputStream();if(inputStream != null){file =newFile(fileName);}else{return file;}fileOut =newFileOutputStream(file);if(fileOut != null){int c = inputStream.read();while(c !=-1){fileOut.write(c);c = inputStream.read();}}}catch(Exception e){}finally{if(conn != null){conn.disconnect();}try{inputStream.close();fileOut.close();}catch(IOException execption){}}return file;}}package weChatServlet;import com.alibaba.fastjson.JSONObject;import javax.servlet.ServletException;import javax.servlet.annotation.WebServlet;import javax.servlet.http.HttpServlet;import javax.servlet.http.HttpServletRequest;import javax.servlet.http.HttpServletResponse;import java.io.File;import java.io.IOException;@WebServlet(name ="UploadMediaServlet")publicclassUploadMediaServletextendsHttpServlet{@OverrideprotectedvoiddoPost(HttpServletRequest request, HttpServletResponse response)throws ServletException, IOException {}@OverrideprotectedvoiddoGet(HttpServletRequest request, HttpServletResponse response)throws ServletException, IOException {UploadMediaApiUtil uploadMediaApiUtil =newUploadMediaApiUtil();String appId ="wx0aa26453a7ec9df7";String appSecret ="2819f0c98199daef39cb6220b4d01b96";String accessToken = uploadMediaApiUtil.getAccessToken(appId,appSecret);String filePath ="C:\\Users\\Chen Xiuhong\\Pictures\\timg (1).jpg";File file =newFile(filePath);String type ="IMAGE";JSONObject jsonObject = uploadMediaApiUtil.uploadMedia(file,accessToken,type);System.out.println(jsonObject.toString());}}运行的时候老是在PostMethod处报错, 错误信息显示缺包
百度之后发现Http协议使用封装jar包（、commons-httpclient-.jar、）, 所以还缺少一个包, 添加三个包之后就成功运行,可以得到media_id
可以看到,素材上传成功后,微信服务器就会返回一个media_id,用于标识上传后的文件.有了这个media_id后,我们就可以构建我们想要的图片,语音,视频回复消息了.
业务逻辑(三) — 发送图片消息
在第7部分中我们已经上传了一个图片素材, 并且也获得了media_id
UCWXNCogK5ub6YFFQf7QcEpvDIYLf3Zh0L5W9i4aEp2ehfnTrASeV59x3LMD88SS
接下来我们就使用media_id来构造图片消息:
privatestatic String buildImageMessage(Map<String, String> map, String picUrl){String fromUserName = map.get("FromUserName");String toUserName = map.get("ToUserName");String media_id = map.get("MediaId");return String.format("<xml>"+"<ToUserName><![CDATA[%s]]></ToUserName>"+"<FromUserName><![CDATA[%s]]></FromUserName>"+"<CreateTime>%s</CreateTime>"+"<MsgType><![CDATA[image]]></MsgType>"+"<Image>"+" <MediaId><![CDATA[%s]]></MediaId>"+"</Image>"+"</xml>",fromUserName,toUserName,getUtcTime(),media_id);}用户发送图片时,公众号返回给用户我之前上传的素材; 或者将用户发送的图片又返回一次
业务逻辑(四) — 发送语音消息
privatestatic String buildVoiceMessage(Map<String, String> map){String fromUserName = map.get("FromUserName");String toUserName = map.get("ToUserName");String media_id = map.get("MediaId");return String.format("<xml>"+"<ToUserName><![CDATA[%s]]></ToUserName>"+"<FromUserName><![CDATA[%s]]></FromUserName>"+"<CreateTime>%s</CreateTime>"+"<MsgType><![CDATA[voice]]></MsgType>"+"<Voice>"+" <MediaId><![CDATA[%s]]></MediaId>"+"</Voice>"+"</xml>",fromUserName,toUserName,getUtcTime(),media_id);}业务逻辑(五) — 发送视频消息
首先需要调用业务逻辑(二)上传一段小视频,获取media_id,上传的视频不大于10MB，支持MP4格式, 然后当用户发送视频格式时,公众号就回复视频格式
privatestatic String buildVideoMessage(Map<String, String> map){String fromUserName = map.get("FromUserName");String toUserName = map.get("ToUserName");String title ="客官发过来的视频哟~~";String description ="客官您呐,现在肯定很开心,对不啦 嘻嘻?";String media_id ="hTl1of-w78xO-0cPnF_Wax1QrTwhnFpG1WBkAWEYRr9Hfwxw8DYKPYFX-22hAwSs";return String.format("<xml>"+"<ToUserName><![CDATA[%s]]></ToUserName>"+"<FromUserName><![CDATA[%s]]></FromUserName>"+"<CreateTime>%s</CreateTime>"+"<MsgType><![CDATA]></MsgType>"+"<Video>"+" <MediaId><![CDATA[%s]]></MediaId>"+" <Title><![CDATA[%s]]></Title>"+" <Description><![CDATA[%s]]></Description>"+"</Video>"+"</xml>",fromUserName,toUserName,getUtcTime(),media_id,title,description);}展示效果如下:
注意: media_id只能用上传的视频的id, 不能使用用户发送视频时的那个id, 至于原因待探究
业务逻辑(六) — 发送音乐消息
privatestatic String buildMusicMessage(Map<String, String> map){String fromUserName = map.get("FromUserName");String toUserName = map.get("ToUserName");String title ="亲爱的路人";String description ="多听音乐 心情棒棒 嘻嘻?";String hqMusicUrl ="";return String.format("<xml>"+"<ToUserName><![CDATA[%s]]></ToUserName>"+"<FromUserName><![CDATA[%s]]></FromUserName>"+"<CreateTime>%s</CreateTime>"+"<MsgType><![CDATA[music]]></MsgType>"+"<Music>"+" <Title><![CDATA[%s]]></Title>"+" <Description><![CDATA[%s]]></Description>"+" <MusicUrl>< ![CDATA[%s] ]></MusicUrl>"+" <HQMusicUrl><![CDATA[%s]]></HQMusicUrl>"+"</Music>"+"</xml>",fromUserName,toUserName,getUtcTime(),title,description,hqMusicUrl,hqMusicUrl);}
业务逻辑(七) — 发送图文消息
privatestatic String buildNewsMessage(Map<String, String> map){String fromUserName = map.get("FromUserName");String toUserName = map.get("ToUserName");String title1 ="HAP审计的实现和使用";String description1 ="由于HAP框架用的是Spring+SpringMVC+Mybatis，其中Mybatis中的拦截器可以选择在被拦截的方法前后执行自己的逻辑。所以我们通过拦截器实现了审计功能，当用户对某个实体类进行增删改操作时，拦截器可以拦截，然后将操作的数据记录在审计表中，便于用户以后审计。";String picUrl1 ="";String textUrl1 ="";String title2 ="KendoUI之Grid的问题详解";String description2 ="kendoLov带出的值出现 null和undefined";String picUrl2 ="";String textUrl2 ="";return String.format("<xml>"+"<ToUserName><![CDATA[%s]]></ToUserName>"+"<FromUserName><![CDATA[%s]]></FromUserName>"+"<CreateTime>%s</CreateTime>"+"<MsgType><![CDATA[news]]></MsgType>"+"<ArticleCount>2</ArticleCount>"+"<Articles>"+"<item>"+"<Title><![CDATA[%s]]></Title> "+"<Description><![CDATA[%s]]></Description>"+"<PicUrl><![CDATA[%s]]></PicUrl>"+"<Url><![CDATA[%s]]></Url>"+"</item>"+"<item>"+"<Title><![CDATA[%s]]></Title>"+"<Description><![CDATA[%s]]></Description>"+"<PicUrl><![CDATA[%s]]]></PicUrl>"+"<Url><![CDATA[%s]]]></Url>"+"</item>"+"</Articles>"+"</xml>",fromUserName,toUserName,getUtcTime(),title1,description1,picUrl1,textUrl1,title2,description2,picUrl2,textUrl2);}
网络不太好,所以图片没有加载出来, 在手机上测试是可以看到图片的.
8.天气预报功能开发
借助百度API查询天气, 所以首先我们要在百度开发平台注册信息
申请天气查询的API, 然后获取AK
但是查询天气的时候AK并不能使用, 显示APP服务被禁用
看来用百度的API这一步行不通, 只能使用Webservice网站上公开的接口
调用WebService查询天气预报
直接使用wsimport 通过该地址生成Java文件时，会报错。因为该wsdl里面包含 ref = “s:schema” 这样的引用。而jaxb是不支持的。所以需要手动将该wsdl下载下来做下修改，然后再生成java文件。
wsimport -keep
D:\Eclipse Files\TEST_EMAIL\src\weatherService>wsimport -keep
正在解析 WSDL...[WARNING] : 解析组件 's:schema' 时出错。在该组件中检测到 's:schema' 位于名称空间 '' 中, 但无法从方案文档 'http://
ws.webxml.com.cn/WebServices/WeatherWS.asmx?wsdl#types?schema1' 引用此名称空间的组件。如果这是不正确的名称空间, 则很可能需要更改 's:schema' 的前缀。如果这是正确
的名称空间, 则应将适当的 'import' 标记添加到 '#types?schema1'。#types?schema1的第 15 行[WARNING] src-resolve: 无法将名称 's:schema' 解析为 'element declaration' 组件。#types?schema1的第 15 行[ERROR] undefined element declaration 's:schema'的第 15 行[ERROR] undefined element declaration 's:schema'的第 61 行[ERROR] undefined element declaration 's:schema'的第 101 行Exception in thread "main" com.sun.tools.internal.ws.wscompile.AbortExceptionat com.sun.tools.internal.ws.processor.modeler.wsdl.JAXBModelBuilder.bind()at com.sun.tools.internal.ws.processor.modeler.wsdl.WSDLModeler.buildJAXBModel()at com.sun.tools.internal.ws.processor.modeler.wsdl.WSDLModeler.internalBuildModel()at com.sun.tools.internal.ws.processor.modeler.wsdl.WSDLModeler.buildModel()at com.sun.tools.internal.ws.wscompile.WsimportTool.buildWsdlModel()at com.sun.tools.internal.ws.wscompile.WsimportTool.run()at com.sun.tools.internal.ws.wscompile.WsimportTool.run()at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)at sun.reflect.NativeMethodAccessorImpl.invoke()at sun.reflect.DelegatingMethodAccessorImpl.invoke()at java.lang.reflect.Method.invoke()at com.sun.tools.internal.ws.Invoker.invoke()at com.sun.tools.internal.ws.WsImport.main()解决方法:
1) 打开 , 页面另存为xml文件;2)将所有的
<s:element ref="s:schema" />
<s:any />
改成 <s:any minOccurs="2" maxOccurs="2"/>，一共有三处需要修改，建议查找<s:element ref="s:schema" />，修改时把<s:any />也要删掉
3)运行命令
wsimport -keep D:\需要注意的是，要修改文件中wsdl的url，因为我们用的是本地文件生成的，要修改成网站的
url：
然后就可以调用生成的代码(cityName,null);,来查询天气:
publicstatic String buildXml(Map<String,String> map){String result ="";String msgType = map.get("MsgType").toString().toUpperCase();String content = map.get("Content");if("TEXT".equals(msgType)){if(content.contains("天气")&&!"".equals(content)){if(content.contains(":")){String cityName = content.substring(content.lastIndexOf(":")+1,content.length());WeatherInfo weather =newWeatherInfo();String weaInfo = weather.getWeatherInfo(cityName);result =buildTextMessage(map,weaInfo);}else{String notice ="查询天气的正确姿势: 天气:城市名\n请客官输入正确的格式哟~";result =buildTextMessage(map,notice);}}else{result =buildTextMessage(map,"");}}return result;}package weChatServlet;import cn.com.webxml.ArrayOfString;import cn.com.webxml.WeatherWS;import cn.com.webxml.WeatherWSSoap;import java.util.List;publicclassWeatherInfo{public String getWeatherInfo(String cityName){WeatherWS weatherWS =newWeatherWS();WeatherWSSoap weatherWSSoap = weatherWS.getWeatherWSSoap();StringBuffer sb =newStringBuffer();ArrayOfString weatherInfo = weatherWSSoap.getWeather(cityName,null);List<String> listWeatherInfo = weatherInfo.getString();for(String str : listWeatherInfo){if(!str.contains(".gif")){sb.append(str);sb.append("\n");System.out.println(str);System.out.println("------------------------");}}return sb.toString();}}结果如下: 查询天气的格式为: 天气:城市名
9.翻译功能开发(有道智云)
网络上有很多翻译API，大家可以根据自己的需求进行选择。这里我们选择应用比较广泛的，翻译功能还比较不错的有道翻译API，下面对这种API的相关信息进行分析。
之前,我们可以使用有道翻译API
关于有道翻译API使用 ,请参考链接:
有道翻译API key申请,请参考链接:
有道翻译API已经禁用,所以我们要去有道智云寻求方法(), 首先需要注册,注册之后账户里默认有100元的额度,使用有道智云是有字数限制的,资费如下:
然后我们需要创建应用, 绑定服务之后,就可以生成appKey和密钥 , 这两个数据在调用API中会用到
有道智云的API文档:
下边就详细介绍如何调用有道智云API
1) 接口调用参数:
调用API需要向接口发送以下字段来访问服务。
| 字段名 | 类型 | 含义 | 必填 | 备注 |
|---|---|---|---|---|
| q | text | 要翻译的文本 | True | 必须是UTF-8编码 |
| from | text | 源语言 | True | 语言列表 (可设置为auto) |
| to | text | 目标语言 | True | 语言列表 (可设置为auto) |
| appKey | text | 应用 ID | True | 可在 应用管理 查看 |
| salt | text | 随机数 | True | |
| sign | text | 签名，通过md5(appKey+q+salt+密钥)生成 | True | appKey+q+salt+密钥的MD5值 |
签名生成方法如下：
- 将请求参数中的
appKey，翻译文本q(注意为UTF-8编码)，随机数salt和密钥（可在 应用管理 查看）， 按照appKey+q+salt+密钥的顺序拼接得到字符串str。 - 对字符串
str做md5，得到32位大写的sign(参考Java生成MD5示例)
注意:
- 请先将需要翻译的文本转换为 UTF-8 编码
- 在发送 HTTP 请求之前需要对各字段做 URL encode。
- 在生成签名拼接
appKey+q+salt+密钥字符串时，q不需要做 URL encode，在生成签名之后，发送 HTTP 请求之前才需要对要发送的待翻译文本字段q做 URL encode。
我们代码中需要使用CloseableHttpClient, 所以需要引入两个jar包 和 httpcore-4.4.6.jar
2) 输出结果
返回的结果是json格式，包含字段与FROM和TO的值有关，具体说明如下：
| 字段名 | 类型 | 含义 | 备注 |
|---|---|---|---|
| errorCode | text | 错误返回码 | 一定存在 |
| query | text | 源语言 | 查询正确时，一定存在 |
| translation | text | 翻译结果 | 查询正确时一定存在 |
| basic | text | 词义 | 基本词典,查词时才有 |
| web | text | 词义 | 网络释义，该结果不一定存在 |
| l | text | 源语言和目标语言 | 一定存在 |
| dict | text | 词典deeplink | 查询语种为支持语言时，存在 |
| webdict | text | webdeeplink | 查询语种为支持语言时，存在 |
3)支持的语言表
| 语言 | 代码 |
|---|---|
| 中文 | zh-CHS |
| 日文 | ja |
| 英文 | EN |
| 韩文 | ko |
| 法文 | fr |
| 俄文 | ru |
| 葡萄牙文 | pt |
| 西班牙文 | es |
4) 错误代码列表
| 错误码 | 含义 |
|---|---|
| 101 | 缺少必填的参数，出现这个情况还可能是et的值和实际加密方式不对应 |
| 102 | 不支持的语言类型 |
| 103 | 翻译文本过长 |
| 104 | 不支持的API类型 |
| 105 | 不支持的签名类型 |
| 106 | 不支持的响应类型 |
| 107 | 不支持的传输加密类型 |
| 108 | appKey无效，注册账号， 登录后台创建应用和实例并完成绑定， 可获得应用ID和密钥等信息，其中应用ID就是appKey（ 注意不是应用密钥） |
| 109 | batchLog格式不正确 |
| 110 | 无相关服务的有效实例 |
| 111 | 开发者账号无效，可能是账号为欠费状态 |
| 201 | 解密失败，可能为DES,BASE64,URLDecode的错误 |
| 202 | 签名检验失败 |
| 203 | 访问IP地址不在可访问IP列表 |
| 301 | 辞典查询失败 |
| 302 | 翻译查询失败 |
| 303 | 服务端的其它异常 |
| 401 | 账户已经欠费停 |
5) DEMO
result = (httpEntity, “utf-8”); 返回的是JSON对象格式的字符串,如下:
{"web":[{"value":["Hello","How do you do","hi"],"key":"你好"},{"value":["How are you","How Do You Do","Harvey, how are you Harvey"],"key":"你好吗"},{"value":["Teacher Kim Bong-du","My Teacher Mr Kim","Seonsaeng Kim Bong-du"],"key":"老师你好"}],"query":"你好","translation":["How are you"],"errorCode":"0","dict":{"url":"yddict://"},"webdict":{"url":"http://"},"basic":{"explains":["hello","hi"]},"l":"zh-CHS2EN"
}
所以需要将JSON字符串转换为实体类对象DTO
/*处理JSON字符串为实体对象TranslateResponseDto*/
TranslateResponseDto dto = new TranslateResponseDto();
dto=(result, );
YouDaoAPI.java
package translate;import com.alibaba.fastjson.JSON;import com.alibaba.fastjson.JSONArray;import com.alibaba.fastjson.JSONObject;import org.apache.http.HttpEntity;import org.apache.http.client.entity.UrlEncodedFormEntity;import org.apache.http.client.methods.CloseableHttpResponse;import org.apache.http.client.methods.HttpPost;import org.apache.http.impl.client.CloseableHttpClient;import org.apache.http.impl.client.HttpClients;import org.apache.http.message.BasicNameValuePair;import org.apache.http.util.EntityUtils;import java.io.IOException;import java.io.UnsupportedEncodingException;import java.net.URLEncoder;import java.security.MessageDigest;import java.security.NoSuchAlgorithmException;import java.util.ArrayList;import java.util.HashMap;import java.util.Iterator;import java.util.List;import java.util.Map;import java.util.Map.Entry;publicclassYouDaoAPI{public String translate(String q)throws Exception{String appKey ="2d156317f9da5d91";String query = q;String salt = String.valueOf(System.currentTimeMillis());String from ="auto";String to ="auto";String sign =md5(appKey + query + salt+"PXwLK5mGbARMsbtjIfpZBM7sDwt40YAL");Map params =newHashMap();params.put("q", query);params.put("from", from);params.put("to", to);params.put("sign", sign);params.put("salt", salt);params.put("appKey", appKey);returnrequestForHttp("", params);}public String requestForHttp(String url,Map requestParams)throws Exception{String result = null;StringBuffer sb =newStringBuffer();CloseableHttpClient httpClient = HttpClients.createDefault();HttpPost httpPost =newHttpPost(url);List params =newArrayList();Iterator it = requestParams.entrySet().iterator();while(it.hasNext()){Entry<String, String> en =(Entry)it.next();String key = en.getKey();String value = en.getValue();if(value != null){params.add(newBasicNameValuePair(key, value));}}httpPost.setEntity(newUrlEncodedFormEntity(params,"UTF-8"));CloseableHttpResponse httpResponse = httpClient.execute(httpPost);try{HttpEntity httpEntity = httpResponse.getEntity();result = EntityUtils.toString(httpEntity,"utf-8");TranslateResponseDto dto =newTranslateResponseDto();dto=JSON.parseObject(result, TranslateResponseDto.class);if(!"".equals(dto.getQuery())&& dto.getQuery()!= null){sb.append("原文:"+dto.getQuery()+"\n");}if(!"".equals(dto.getTranslation())&& dto.getTranslation()!= null){sb.append("翻译结果:");List<String> translation = dto.getTranslation();for(String s : translation){sb.append(s +"\n");}}if(!"".equals(dto.getBasic())&& dto.getBasic()!= null){Map<String, List<String>> basic = dto.getBasic();sb.append("词义:");for(Map.Entry<String, List<String>> entry : basic.entrySet()){sb.append(entry.getValue()+"\n");}}if(!"".equals(dto.getErrorCode())&& dto.getErrorCode()!= null &&!"0".equals(dto.getErrorCode())){if("103".equals(dto.getErrorCode())){sb.append("翻译出错:翻译文本过长\n");}else{sb.append("翻译出错:错误代码为"+dto.getErrorCode()+"\n");}}}finally{try{if(httpResponse!=null){httpResponse.close();}}catch(IOException e){e.printStackTrace();}}return sb.toString();}publicstatic String md5(String string){if(string == null){return null;}char hexDigits[]={'0','1','2','3','4','5','6','7','8','9','A','B','C','D','E','F'};try{byte[] btInput = string.getBytes("utf-8");MessageDigest mdInst = MessageDigest.getInstance("MD5");mdInst.update(btInput);byte[] md = mdInst.digest();int j = md.length;char str[]=newchar[j *2];int k =0;for(byte byte0 : md){str[k++]= hexDigits[byte0 >>>4&0xf];str[k++]= hexDigits[byte0 &0xf];}returnnewString(str);}catch(NoSuchAlgorithmException | UnsupportedEncodingException e){return null;}}publicstatic String getUrlWithQueryString(String url, Map params){if(params == null){return url;}StringBuilder builder =newStringBuilder(url);if(url.contains("?")){builder.append("&");}else{builder.append("?");}int i =0;for(String key :(List<String>)params.keySet()){String value =(String) params.get(key);if(value == null){continue;}if(i !=0){builder.append('&');}builder.append(key);builder.append('=');builder.append(encode(value));i++;}return builder.toString();}publicstatic String encode(String input){if(input == null){return"";}try{return URLEncoder.encode(input,"utf-8");}catch(UnsupportedEncodingException e){e.printStackTrace();}return input;}}if(content.contains("翻译")&&!"".equals(content)){if(content.contains(":")){String word = content.substring(content.lastIndexOf(":")+1,content.length()).trim();YouDaoAPI translateInfo =newYouDaoAPI();String weaInfo = translateInfo.translate(word);result =buildTextMessage(map,weaInfo);}else{String notice ="翻译的正确姿势: 翻译:翻译文本\n请客官输入正确的格式哟~";result =buildTextMessage(map,notice);}
10.发送emoji表情
关于普通表情和emoji表情的处理可以参考:
一般的表情是/:: 或者 [heart] 或者 空白的(其实是有特殊编码的), 所以此处我们要对emoji转换为unicode编码, 代码如下:
package weChatServlet;import java.util.Formatter;import java.util.HashMap;import java.util.Map;import java.util.regex.Matcher;import java.util.regex.Pattern;publicclassEmojiUtil{publicstatic String escapeUnicode(String input){StringBuilder sb =newStringBuilder(input.length());@SuppressWarnings("resource")Formatter format =newFormatter(sb);for(char c : input.toCharArray()){if(c <128){sb.append(c);}else{format.format("\\u%04x",(int) c);}}return sb.toString();}public String filterEmoji(String source){if(source != null){Pattern emoji = Pattern.compile("[\ue000-\uefff]", Pattern.CASE_INSENSITIVE);Matcher emojiMatcher = emoji.matcher(source);Map<String, String> tmpMap =newHashMap<>();while(emojiMatcher.find()){String key = emojiMatcher.group();String value =escapeUnicode(emojiMatcher.group());tmpMap.put(key, value);}if(!tmpMap.isEmpty()){for(Map.Entry<String, String> entry : tmpMap.entrySet()){String key = entry.getKey().toString();String value = entry.getValue().toString();source = source.replace(key, value);}}}return source;}}在messageUtil中调用emoji工具类
String content = map.get("Content");EmojiUtil emojiUtil =newEmojiUtil();
String unicodeEmoji = emojiUtil.filterEmoji(content);if(content.contains("/:")|| content.contains("\\:")|| content.contains("[")&& content.contains("]")|| unicodeEmoji.contains("\\")){result =buildTextMessage(map,"客官发送的内容很特别哟~/:heart "+ content);}结果如下:
THE END
