点击上方 Java后端，选择 设为星标
优质文章，及时送达
顾名思义，我们就是来做一个订阅号机器人，大致是这样一个过程
公众号接收用户消息 -> 微信平台发送消息给我们的服务器 -> 我们的服务器处理消息 -> 返回处理结果给微信平台 -> 微信平台发送内容给用户。
基于这样一个大前提就有了下面的步骤。
1、填写服务器配置，可以接收微信平台发送的内容
2、开发服务端，并验证服务器地址的有效性
3、处理具体的业务逻辑
1. 配置微信公众号
首先肯定需要有一个订阅号，然后在订阅号后台点击 开发者->基本配置进入如下页面，点击确定
然后进入配置页面，我们一一对配置进行讲解
-
开发者ID，开发者调用的唯一标示，调用接口的时候需要传递。
-
开发者密码，这个很重要一定要保存在自己的服务器上面，用于验证安全性。
-
服务地址，这个就是我们用来接收微信平台转发的用户消息的服务的地址
-
令牌，用户接收信息时候做验证是否请求来自微信平台
-
用于加密消息，防止被截获，如果 6 设置为明文模式不需要这个配置。
-
是否加密传输消息
-
是我们具体的服务器地址，path是 weixin/receive 这个下文中具体代码部分会详细讲解
-
Token 随便生成一个 UUID 就可以
-
随机生成，后面如果调用 API 会用到。
2. 编写服务端
<repositories>
<repository>
<id>developer-weapons-repository</id>
<url>https://raw.githubusercontent.com/developer-weapons/repository/master</url>
</repository>
</repositories>
<dependency>
<groupId>com.github.developer.weapons</groupId>
<artifactId>wechat-spring-boot-starter</artifactId>
<version>1.2.6</version>
</dependency>@Autowired
private WechatOfficialService wechatOfficialService;
@Value("${weixin.token}")
private String token;
@RequestMapping(value = "/weixin/receive", method = RequestMethod.GET)
public void receive(
@RequestParam(value = "signature") String signature,
@RequestParam(value = "timestamp") String timestamp,
@RequestParam(value = "nonce") String nonce,
@RequestParam(value = "echostr") String echostr,
HttpServletResponse response) throws IOException {
boolean valid = wechatOfficialService.isValid(signature, timestamp, nonce, token);
PrintWriter writer = response.getWriter();
if (valid) {
writer.print(echostr);
} else {
writer.print("error");
}
writer.flush();
writer.close();
}
3. 处理业务逻辑
@RequestMapping(value = "/weixin/receive", method = RequestMethod.POST)
public void receive(
@RequestParam(value = "signature") String signature,
@RequestParam(value = "timestamp") String timestamp,
@RequestParam(value = "nonce") String nonce,
HttpServletRequest request,
HttpServletResponse response) throws IOException {
request.setCharacterEncoding("UTF-8");
response.setCharacterEncoding("UTF-8");
boolean valid = wechatOfficialService.isValid(signature, timestamp, nonce, token);
PrintWriter writer = response.getWriter();
if (!valid) {
writer.print("error");
writer.flush();
writer.close();
return;
}
try {
Map<String, String> map = wechatOfficialService.toMap(request.getInputStream());
if (map.get("MsgType").equals("image")) {
String msg = OfficialAutoReplyMessage.build()
.withContent("接收到图片链接为：" + map.get("PicUrl"))
.withMsgtype(MessageTypeEnum.TEXT)
.withFromUserName(map.get("ToUserName"))
.withToUserName(map.get("FromUserName"))
.toXml();
writer.print(msg);
writer.flush();
writer.close();
return;
}
} catch (Exception e) {
log.error("WeixinController receive error", e);
}
writer.print("success");
writer.flush();
writer.close();
}wechatOfficialService.toMap方法解析出接收消息的内容，当前判断比较简单，直接判断是否是图片消息，然后返回图片的 URL 给发送消息的用户。效果图如下：
《怒爬某 Hub 资源就为撸了一个鉴黄平台》
，现在我们直接把相关代码怼上。
if (map.get("MsgType").equals("image")) {
String res = checkService.check(publicKey, privateKey, map.get("PicUrl"));
OfficialAutoReplyMessage officialAutoReplyMessage =
OfficialAutoReplyMessage.build()
.withMsgtype(MessageTypeEnum.TEXT)
.withFromUserName(map.get("ToUserName"))
.withToUserName(map.get("FromUserName"));
if (StringUtils.equals("forbid", res)) {
officialAutoReplyMessage.withContent("小哥，你的图片有点问题哦");
} else {
officialAutoReplyMessage.withContent("骚年，你这图片刚刚的没问题");
}
writer.print(officialAutoReplyMessage.toXml());
writer.flush();
writer.close();
return;
}
Java后端交流群已成立
公众号运营至今，离不开小伙伴们的支持。为了给小伙伴们提供一个互相交流的平台，特地开通了官方交流群。扫描下方二维码备注 进群 或者关注公众号 Java后端 后获取进群通道。
推 荐 阅 读 1. GET 和 POST 两种基本请求方法的区别 2. 牛逼！IntelliJ IDEA 从入门到上瘾！ 3. REST API URI 设计的七准则 4. Java 项目实战天天酷跑 5. 基于 Spring Boot 的 QQ 登陆实战
本文分享自微信公众号 - Java后端（web_resource）。
如有侵权，请联系 support@oschina.cn 删除。
本文参与“OSC源创计划”，欢迎正在阅读的你也加入，一起分享。
相关文章
暂无评论...
致力于称为最好的程序员导航网站