Github开源项目：微信公众号开发框架wechatty介绍-低调大师

Github开源项目：微信公众号开发框架wechatty介绍

2019-08-30 1394

Wechattty Project是一个基于JAVA的微信公众号（包括服务号和订阅号）和微信企业号的开发框架，封装良好的API让开发者可以专注于业务逻辑的开发，提高开发效率。

简单使用教程

引入依赖

这里使用maven来引入依赖。

<dependency>
  <groupId>space.chensheng.wechatty</groupId>
  <artifactId>wechatty-mp</artifactId>
  <version>2.0.0</version>
</dependency>

初始化

MpAppContext是公众号API的统一调用入口，使用WechatMpBootstrap对其进行初始化。

WechatMpBootstrap bootstrap = new WechatMpBootstrap();
bootstrap.addMsgListener(new TextMessageListener());
MpAppContext mpAppContext = bootstrap.build();

如果项目使用spring来管理，可实现一个FactoryBean来初始化MpAppContext，以便后续引用。

@Component
public class MpAppContextFactoryBean implements FactoryBean<MpAppContext> {

    @Override
    public MpAppContext getObject() throws Exception {
        WechatMpBootstrap bootstrap = new WechatMpBootstrap();
        bootstrap.addMsgListener(new TextMessageListener());
        return bootstrap.build();
    }

    @Override
    public Class<?> getObjectType() {
        return MpAppContext.class;
    }

    @Override
    public boolean isSingleton() {
        return true;
    }
}

配置

配置方式有两种，一种是配置文件，另一种是 JAVA代码配置。其中JAVA代码配置的优先级高于配置文件。

配置文件

新建配置文件wechat-mp.properties, 将该文件放在项目类路径下。比如maven项目，可将该文件放在src/main/resources目录下。一般的配置如下:

token=thisIsToken
aesKey=thisIsAesKey
appId=thisIsYourAppId
appSecret=thisIsAppSecret

JAVA代码配置

在MpAppConetxt初始化时，调用WechatMpBootstrap的customizeWechatContext方法来进行配置。

WechatMpBootstrap bootstrap = new WechatMpBootstrap();
bootstrap.customizeWechatContext(new MpWechatContextCustomizer() {
    @Override
    public void customize(MpWechatContext wechatContext) {
    wechatContext.setToken("thisIsToken");
    wechatContext.setAesKey("thisIsAeskey");
    wechatContext.setAppId("thisIsAppId");
    wechatContext.setAppSecret("thisIsAppSecret");
    }
});

配置参数说明

必填参数	说明
token	公众号的token，可在公众号后台查看.
aesKey	加密用的key，可在公众号后台查看.
appId	公众号appId，可在公众号后台查看。
appSecret	公众号的appSecret，可在公众号后台查看。

可选参数	说明
enableCryptedMode	是否开启回调加密模式，默认true。如果开启则要下载JCE无限制权限策略文件,覆盖jdk中的相关文件，具体可查看微信常见错误举例。
autoUpdateAccessToken	出现access_token相关错误时是否自动更新access_token，默认false，应用可自己通过定时任务来更新，后面将详细介绍。
accessTokenStrategyClass	access_token存取策略，默认是space.chensheng.wechatty.common.http.MemoryAccessTokenStrategy，将access_token存在内存中，应用可实现自己的存取策略，比如存在数据库中，后面将详细介绍。
payKey	微信支付key
payCertFile	微信支付证书文件路径
payCertPassword	微信支付证书密码
payMchId	微信支付商户id
payClientIp	调用支付的机器ip
poolingHttpProxyEnable	是否通过代理服务器给微信服务器必请求，默认false
poolingHttpProxyHostname	代理服务器的hostname，比如www.chensheng.space
poolingHttpProxyPort	代理服务器端口
poolingHttpProxyUsername	代理服务器用户名
poolingHttpProxyPassword	代理服务器密码
poolingHttpMaxPerRoute	http连接池每条链路最大并发连接数，默认为50
poolingHttpMaxTotal	http连接池最大并发连接数，默认200
poolingHttpSocketTimeoutMillis	socket超时毫秒数，默认10000
poolingHttpConnectTimeoutMillis	连接到微信服务器超时毫秒数，默认10000
poolingHttpConnectionRequestTimeoutMillis	从htttp连接池获取连接超时毫秒数，默认10000
poolingHttpTcpNoDelay	是否开启tpcNoDelay,默认true

access_token更新问题

自动更新：如果开启了自动更新，则在因为access_token错误而导致请求微信接口失败的情况下，框架会自动更新access_token。
定时更新：在应用中使用定时任务(比如quartz)来定时执行mpAppContext.getAccessTokenFetcher().updateAccessToken()，一般每1.5小时执行一次，因为access_token的过期时间为2小时。
自动更新和定时更新可共存，如果多个线程并发执行更新access_token，只有一个线程会去请求微信服务器来更新access_token，其他线程会立即返回，不执行任何操作。

access_token存取策略问题

Web应用单机部署：如果您的应用是单机部署，则可直接使用默认的策略，将access_token存储在内存中。
Web应用集群部署：如果您的应用是集群部署，则要实现自己的access_token存取策略，将access_token存放在集群共享的媒介（比如数据库）来达到access_token中控管理的目的。实现完自己的策略类后，要在wechat-mp.properties中添加配置accessTokenStrategyClass=your.package.name.YourAccessTokenStrategy。以下是一个accesss_token数据库存取的策略：

import space.chensheng.wechatty.common.http.AccessTokenStrategy;

//因为这个策略类的实例化不是通过Spring来管理的，所以在这个类中不能使用Autowired来注入bean，
//要通过ApplicationContext#getBean方法来获取。
public class DatabaseAccessTokenStrategy implements AccessTokenStrategy{
    
    //将access_token存到数据库中去
    @Override
    public void doSave(String accessToken) {
        TokenService tokenService = ApplicationContextUtil
        .getApplicationContext().getBean(TokenService.class);
    tokenService.doSave(accessToken);
    }
    
    //从数据库中取出access_token
    @Override
    public String doQuery() {
        TokenService tokenService = ApplicationContextUtil
        .getApplicationContext().getBean(TokenService.class);
    return tokenService.doQuery();
    }
}

接收消息

在MpAppContext初始化时，通过WechatMpBootstrap添加消息监听器来接收消息(关于message listener会在后面介绍):

WechatMpBootstrap bootstrap = new WechatMpBootstrap();
bootstrap.addMsgListener(new TextMessageListener());
bootstrap.addMsgListener(new SubscribeEventListener());
bootstrap.addMsgListener(new UnsubscribeEventListener());

验证微信服务器的开启回调请求

如果你已经在微信公众号后台设置了回调URL，微信服务器会向这个URL发送一个GET请求来验证，开发者需要在Web应用中处理这个请求。以下是一个SpringMVC的验证例子：

@RestController
@RequestMapping(value = "/wechat-mp")
public class CallbackController extends BaseController{

    @Autowired
    private MpAppContext mpAppContext;
    
    //验证请求，并回复字符串
    @RequestMapping(value = "/callback", method = RequestMethod.GET)
    public String verify(String msg_signature, String timestamp, String nonce, String echostr) {
        String reply = mpAppContext.getCallbackModeVerifier().verify(msg_signature, timestamp, nonce, echostr);
    return reply;
    }
    
}

消息回调请求处理

验证完开启回调请求后，回调模式就真正开启了。如果用户发了个消息给公众号，微信服务器会向回调URL发送一个POST请求，将消息转发到这个URL上，开发者需要在Web应用中处理这个请求，以下是一个SpringMVC的例子（和前面验证开启回调的例子在一个controller中）：

@RestController
@RequestMapping(value = "/wechat-mp")
public class CallbackController extends BaseController{

    @Autowired
    private MpAppContext mpAppContext;
    
    //接收回调消息，并回复相应xml消息
    @RequestMapping(value = "/callback", method = RequestMethod.POST)
    public String verify(String msg_signature, String timestamp, String nonce) {
        //postBody是请求体内容，String格式，开发者可以通过HttpServletRequest来解析
        String replyXml = mpAppContext.getMpMessageDispatcher().dispatch(msg_signature(), timestamp, nonce, postBody);
    return replyXml;
    }
}

回调消息的监听

开发者可以通过继承space.chensheng.wechatty.common.message.MessageListener来监听特定类型的消息。以下是一个监听用户发送的文本消息的例子:

public class TextMessageListener extends MessageListener<TextInboundMessage> {

    @Override
    protected ReplyMessage onMessage(TextInboundMessage message) {
        String content = message.getContent();
    
    //根据消息内容来回复用户
    if ("1".equals(content)) {
        TextReplyMessage replyMsg = new TextReplyMessage();
        replyMsg.setContent("this is reply message content");
        replyMsg.setFromUserName(message.getToUserName());
        replyMsg.setToUserName(message.getFromUserName());
        replyMsg.setCreateTime(System.currentTimeMillis());
        return replyMsg;
    }
    
    //返回null表示不回复用户
    return null;
    }
}

可监听的消息类型

消息	说明
TextInboundMessage	文本消息
ImageInboundMessage	图片消息
LinkInboundMessage	跳转图文消息
LocationInboundMessage	共享位置消息
ShortVideoInboundMessage	小视频消息
VideoInboundMessage	视频消息
VoiceInboundMessage	语音消息
ClickEventMessage	点击普通菜单消息
ViewEventMessage	点击跳转链接菜单消息
LocationEventMessage	位置事件消息
SubscribeEventMessage	用户关注公众号消息
UnsubscribeEventMessage	用记取消关注公众号消息
ScanEventMessage	用户扫描二维码消息
MassSendJobFinishEventMessage	群发消息发送完成报告

可回复的消息类型

消息	说明
TextReplyMessage	文本回复
ImageReplyMessage	图片回复
MusicReplyMessage	音乐回复
NewsReplyMessage	图文回复
VideoReplyMessage	视频回复
VoiceReplyMessage	语音回复

发送消息

公众号可以主动发送消息给用户，包括群发消息和客服消息两大类型消息。所有消息统一使用space.chensheng.wechatty.mp.message.MpMessageSender来发送。

群发消息

TextMassMessage message = new TextMassMessage();
message.setIsToAll(true);
message.setContent("群发消息测试");
mpAppContext.getMpMessageSender().send(message, 3);

群发消息类型	说明
TextMassMessage	文本群发
ImageMassMessage	图片群发
MpnewsMassMessage	微信内图文群发
MpvideoMassMessage	视频群发
VoiceMassMessage	语音群发
WxcardMassMessage	微信卡券群发

客服消息

TextCsMessage message = new TextCsMessage();
message.setToUser("thisIsUserOpenId");
message.setContent("客服消息测试 \n 212");
mpAppContext.getMpMessageSender().send(message, 3);

客服消息类型	说明
TextCsMessage	文本客服
ImageCsMessage	图片客服
MpnewsCsMessage	微信内图文客服
NewsCsMessage	外部图文客服
VideoCsMessage	视频客服
VoiceCsMessage	语音客服
WxcardCsMessage	微信卡券客服

素材管理

素材管理主要是进行素材的上传、查询、修改、删除，素材类型包括图片、视频、语音、图文。

上传素材

上传素材通过操作对应的素材上传类来完成，下面是一个上传图片的例子：

File image = new File("/this/is/image/path.jpg");
ImagePermanentMedia material = new ImagePermanentMedia(mpAppContext, image);
UploadResponse resp = material.upload();

素材上传类	说明
ImagePermanentMedia	永久图片
ThumbPermanentMedia	永久缩略图
VideoPermanentMedia	永久视频
VoicePermanentMedia	永久语音
PermanentNews	永久图文
PermanentNewsImg	永久图文中的图片
ImageTemporaryMedia	临时图片
ThumbTemporaryMedia	临时缩略图
VideoTemporaryMedia	临时视频
VoiceTemporaryMedia	临时语音

查询素材

查询素材操作通过工具类space.chensheng.wechatty.mp.material.MaterialQuery和space.chensheng.wechatty.mp.material.MaterialFinder完成。

查询素材的数量信息：mpAppContext.getMaterialQuery().count()
查询图文素材：mpAppContext.getMaterialQuery().listNews(int offset, int count)
查询其他素材：mpAppContext.getMaterialQuery().listMedia(MediaType mediaType, int offset, int count)
根据mediaId查找图文：mpAppContext.getMaterialFinder().findNews(String mediaId)
根据mediaId查找永久视频：mpAppContext.getMaterialFinder().findPermanentVideo(String mediaId)
根据mediaId查找临时视频：mpAppContext.getMaterialFinder().findTemporaryVideo(String mediaId)
根据mediaId下载永久素材：mpAppContext.getMaterialFinder().downloadPermanentMedia(String mediaId, String saveDir, String fileName)
根据mediaId下载临时素材：mpAppContext.getMaterialFinder().downloadTemporaryMedia(String mediaId, String saveDir, String fileName)

删除素材

删除素材操作通过工具类space.chensheng.wechatty.mp.material.MaterialDeleter完成。

根据mediaId删除素材：mpAppContext.getMaterialDeleter().delete(String mediaId)

帐号管理

生成带参数二维码

生成带参数二维码通过工具类space.chensheng.wechatty.mp.account.QRCodeCreator完成。

生成带参数临时二维码：mpAppContext.getQRCodeCreator().createTemporary(int expireSeconds, int sceneId)
生成带整型参数永久二维码：mpAppContext.getQRCodeCreator().createPermanent(int sceneId)
生成带字符串参数永久二维码：mpAppContext.getQRCodeCreator().createPermanent(String sceneStr)

查询用户信息

查询用户信息通过UserInfoQuery实现。

查询单个用户信息: mpAppConext.getUserInfoQuery().get(String openId)
批量查询用户信息：mpAppContext.getUserInfoQuery().batchGet(List<String> openIds)

微信授权

用户授权

用户授权通过AuthHelper实现。

通过授权链接的code获取auth access token: mpAppContext.getAuthHelper().fetchAuthAccessToken(String code)
刷新auth access token: mpAppContext.getAuthHelper().refreshAuthAccessToken(String refreshAccessToken)
通过auth access token获取用户信息: mpAppContext.getAuthHelper().fetchAuthUserInfo(String authAccessToken, String openId)

以下是一段用户授权的伪代码:

public WxAuthLoginDto authAndLogin(String code) {
    AuthAccessTokenResponse authResp = mpAppContext.getAuthHelper().fetchAuthAccessToken(code);
    if (authResp == null || !authResp.isOk()) {
        //授权失败，执行相应业务逻辑
        return new WxAuthLoginDto("fail");
    }
        
    String openId = authResp.getOpenId();
    AuthUserInfoResponse wxUserInfo = mpAppContext.getAuthHelper().fetchAuthUserInfo(authResp.getAccessToken(), authResp.getOpenId())
    //根据微信用户信息在数据库里查找系统对应的用户，或新建一个用户
    
    //进行登录相关业务逻辑处理
    return new WxAuthLoginDto("success");
}

jsapi授权

jsapi授权通过JsapiHelper实现。

获取jsapi ticket(可使用定时任务来定时获取ticket并存于数据库中): mpAppContext.getJsapiHelper().fetchTicket()
生成jsapi签名信息: mpAppContext.getJsapiHelper().generateSignature(String jsapiTicket, String nonceStr, long timestamp, String url)

微信支付

初始化MpAppContext时，调用WechatMpBootstrap的enablePayCert()方法来启用微信支付，并配置相关参数。(具体参数查看配置模块)

WechatMpBootstrap bootstrap = new WechatMpBootstrap();
bootstrap.enablePayCert();

发送普通红包: mpAppContext.getPayHelper().sendRedPack(RedPackRequest request)
发送群红包: mpAppContext.getPayHelper().sendGroupRedPack(GroupRedPackRequest request)
转账: mpAppContext.getPayHelper().transfers(TransfersRequest request)
生成预付款订单: mpAppContext.getPayHelper().unifiedOrder(UnifiedOrderRequest request)
解析支付回调: mpAppContext.getPayHelper().parsePayNotify(String notifyContent)
校验支付回调: mpAppContext.getPayHelper().validatePayNotify(PayNotifyResponse response)
支付订单查询: mpAppContext.getPayHelper().orderQuery(OrderQueryRequest request)
关闭支付订单: mpAppContext.getPayHelper().closeOrder(CloseOrderRequest request)
生成短链接: mpAppContext.getPayHelper().shortUrl(String longUrl)
生成js支付参数: mpAppContext.getPayHelper().generateJsapiPayParams(String prepayId, PaySignType signType)
发起退款: mpAppContext.getPayHelper().refund(RefundRequest request)
解析退款回调: mpAppContext.getPayHelper().parseRefundNotify(String notifyContent)

微信关注我们

原文链接：https://yq.aliyun.com/articles/716582

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

Coding and Paper Letter（七十）

资源整理。 1 Coding: 1.JupyterHub的流量模拟器。 hubtraf 2.前端面试手册。 front end interview handbook 3.Python学习课程。 learn python 4.从ArcGIS/ESRI格式中提取栅格数据。从Readme来看，似乎在寻求GDAL大佬加持共同构建程序。 ArcRasterRescue 5.OCP-Hack项目是为参加OCP HackFest的伙伴准备的动手实验指导，主要是帮助伙伴在Azure上快速了解和运用Azure IoT Services, Azure Cognitiver Services, Azure Machine Learning等。本项目会持续更新以方便伙伴学习到最新的Azure内容。 OCPOpenHack 6.PaddlePaddle (PArallel Distributed Deep LEarning) 是一个简单易用、高效灵活、可扩展的深度学习平台，最初由百度科学家和工程师共同开发，目的是将深度学习技术应用到百度的众多产品中。 Paddle 7.“通过逐步堆叠高效培训BERT”的源代码。...

2019-08-31

610

Java 最全异常讲解导引问题实际工作中，遇到的情况不可能是非常完美的。比如：你写的某个模块，用户输入不一定符合你的要求、你的程序要打开某个文件，这个文件可能不存在或者文件格式不对，你要读取数据库的数据，数据可能是空的等。我们的程序再跑着，内存或硬盘可能满了。等等。软件程序在运行过程中，非常可能遇到刚刚提到的这些异常问题，我们叫异常，英文是：Exception，意思是例外。这些，例外情况，或者叫异常，怎么让我们写的程序做出合理的处理。而不至于程序崩溃。 1.1 常见的错误：用户输入错误设备错误。硬件问题，比如打印机关掉、服务器问题物理限制。磁盘满了代码限制。数组下标越界等设计良好的程序应该在异常发生时提供处理这些错误的方法，使得程序不会因为异常的发生而终断或产生不可预见的结果。如果没有异常处理机制，那么： 1.2 两个坏处：1．逻辑代码和错误处理代码放一起！ 2．程序员本身需要考虑的例外情况较复杂，对程序员本身要求较高！异常机制就是当程序出现错误，程序如何安全退出的机制。异常（Exception）的概念Java 如何处理异常？第一个异常示例和解析： public stati...

2019-08-31

537

资源下载

更多资源

腾讯云软件源

为解决软件依赖安装时官方源访问速度慢的问题，腾讯云为一些软件搭建了缓存服务。您可以通过使用腾讯云软件源站来提升依赖包的安装速度。为了方便用户自由搭建服务架构，目前腾讯云软件源站支持公网访问和内网访问。

Spring

Spring框架（Spring Framework）是由Rod Johnson于2002年提出的开源Java企业级应用框架，旨在通过使用JavaBean替代传统EJB实现方式降低企业级编程开发的复杂性。该框架基于简单性、可测试性和松耦合性设计理念，提供核心容器、应用上下文、数据访问集成等模块，支持整合Hibernate、Struts等第三方框架，其适用范围不仅限于服务器端开发，绝大多数Java应用均可从中受益。

Rocky Linux

Rocky Linux（中文名：洛基）是由Gregory Kurtzer于2020年12月发起的企业级Linux发行版，作为CentOS稳定版停止维护后与RHEL（Red Hat Enterprise Linux）完全兼容的开源替代方案，由社区拥有并管理，支持x86_64、aarch64等架构。其通过重新编译RHEL源代码提供长期稳定性，采用模块化包装和SELinux安全架构，默认包含GNOME桌面环境及XFS文件系统，支持十年生命周期更新。

Sublime Text

Sublime Text具有漂亮的用户界面和强大的功能，例如代码缩略图，Python的插件，代码段等。还可自定义键绑定，菜单和工具栏。Sublime Text 的主要功能包括：拼写检查，书签，完整的 Python API ， Goto 功能，即时项目切换，多选择，多窗口等等。Sublime Text 是一个跨平台的编辑器，同时支持Windows、Linux、Mac OS X等操作系统。