热门搜索:
您现在的位置是：首页 > 文章详情

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

日期：2019-08-30点击：1080

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业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

转载内容版权归作者及来源网站所有，本站原创内容转载请注明来源。

相关文章

    文章评论

    共有0条评论来说两句吧...

    文章二维码

    扫描即可查看该文章

    点击排行

    推荐阅读

    最新文章