Skip to content

微信公众号消息网关, 基于注解分发消息@WxController、@WxEvent、@WxMessage, 提供脚手架项目。

Notifications You must be signed in to change notification settings

lkqm/weixin-gateway

Repository files navigation

weixin-gateway

Maven Central

微信公众号消息网关, 基于注解分发消息, 提供脚手架项目。

@WxController
public class InvoiceHandler {
    @WxEvent("user_authorize_invoice")
    public void authorEvent(InvoiceAuthEventMessage message) {
        System.out.println("电子发票授权事件");
    }
}

支持: JDK1.7 +

脚手架项目: weixin-gateway-web

快速开始

  1. 引入依赖
    <dependency>
        <groupId>com.github.lkqm</groupId>
        <artifactId>weixin-gateway-spring-boot-starter</artifactId>
        <version>${version}</version>
    </dependency>
  2. 添加配置(application.properties)
    wx.gateway.enabled = ture                      # 是否开启, 关闭后不会自动注入WxPortalController
    wx.gateway.dev = false                         # 开发者模式, 处理消息跳过签名校验
    wx.gateway.prefix = /wx/gateway                # 设置回掉路径前缀, 访问地址: /wx/gateway, /wx/gateway/{key}
    wx.gateway.config.default.appId = @appId       # 配置一个微信配置访问路径key=default, 当key=default访问地址{key}可省略
    wx.gateway.config.default.token = @token
    wx.gateway.config.default.aesKey = @aesKey
    
    wx.gateway.pool.namePrefix = wx-router-        # 线程名称前缀
    wx.gateway.pool.coreSize = 10                  # 核心线程大小
    wx.gateway.pool.maxSize = 100                  # 最大线程大小
    wx.gateway.pool.keepAlive = 5000               # 空闲线程存活时间(ms)
    wx.gateway.pool.queueCapacity=                 # 工作队列大小
  3. 增加相关的业务处理器
    @WxController
    public class InvoiceHandler {
        @WxEvent("user_authorize_invoice")
        public void authEvent(InvoiceAuthMessage authMessage, @WxBody String xml, 
                              @WxParam("FromUserName") String fromUser, @WxParam("CreateTime") Integer createTime) {
        }
    }

你需要知道的?

消息分发

所有的消息分发处理均是异步, 处理消息或事件类型不能重复声明。

  • @WxController: 标记类为消息处理类
  • @WxEvent: 注解用于事件匹配
  • @WxMessage: 注解用于消息匹配

参数注入

响应微信消息的处理方法, 支持注入4种参数, 解析顺序依次向下:

  • @WxParam: 方法参数指定注解@WxParam, 会自定注入指定xml标记的值(不支持多层嵌套)
  • @WxBody: 方法参数指定注解@WxBody, 并且类型String, 会自动注入值为微信请求的xml(非密文)
  • 自定义参数解析: a.实现接口HandlerMethodArgumentResolver, b.注入容器
  • 普通bean: 普通JavaBean, 字段命名需要按照驼峰命名(内部是xml转json, 然后json转对象)

注意: 基本类型参数只会注入默认值

多公众号

可以实现多公众号, 控制层路径地址: /wx/gateway/{key}, 配置自定义参数解析可以实现: HandlerMethodArgumentResolver

@Component
public class WxMpServiceArgumentResolver implements HandlerMethodArgumentResolver {
    
    private Map<String, WxMpService> appIdToWxMpServiceMap = new ConcurrentHashMap<>();

    @Override
    public boolean supportsParameter(Class<?> type) {
        return WxMpService.class.isAssignableFrom(type);
    }

    @Override
    public Object resolveArgument(Message message) {
        WxConfig config = message.getWxConfig();
        return appIdToWxMpServiceMap.get(config.getAppId());
    }
}

About

微信公众号消息网关, 基于注解分发消息@WxController、@WxEvent、@WxMessage, 提供脚手架项目。

Topics

Resources

Stars

Watchers

Forks

Packages

No packages published

Languages