前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >微信公众号关注或取关后再处理我们自己的业务逻辑

微信公众号关注或取关后再处理我们自己的业务逻辑

原创
作者头像
悟空码字
发布2023-03-04 12:30:17
6510
发布2023-03-04 12:30:17
举报

大家好,我是小悟

在做微信小程序或公众号开发的有时候,难免会遇到需要在用户关注或取关公众号后处理业务逻辑的需求,只需要几步就可以搞定。

1、配置

首先我们需要在微信公众号后台进行服务器配置,登录公众号后台->开发->基本配置->服务器配置,如下:

服务器地址就是我们写的一个controller(代码在下面),用来给微信校验,和接收微信发过来的消息,如果地址错误或者token错误,提交信息的时候会报错

2、代码实现

SignUtil

代码语言:javascript
复制
/**
 * @description
 */
public class SignUtil {

        /**
         * 验证签名
         * @param token
         * @param signature 签名用来核实最后的结果是否一致
         * @param timestamp 时间标记
         * @param nonce 随机数字标记
         * @return 一个布尔值确定最后加密得到的是否与signature一致
         */
        public static boolean checkSignature(String token, String signature, String timestamp, String nonce) {
            //将传入参数变成一个String数组然后进行字典排序
            String[] arr = new String[] { token, timestamp, nonce };
            // 将token、timestamp、nonce三个参数进行字典排序
            Arrays.sort(arr);
            //创建一个对象储存排序后三个String的结合体
            StringBuilder content = new StringBuilder();
            for (int i = 0; i < arr.length; i++) {
                content.append(arr[i]);
            }
            MessageDigest md = null;
            String tmpStr = null;

            try {
                md = MessageDigest.getInstance("SHA-1");
                byte[] digest = md.digest(content.toString().getBytes());
                tmpStr = byteToStr(digest);
            } catch (NoSuchAlgorithmException e) {
                e.printStackTrace();
            }

            content = null;
            // 将sha1加密后的字符串可与signature对比
            return tmpStr != null ? tmpStr.equals(signature.toUpperCase()) : false;
        }

        /**
         * 将字节数组转换为十六进制字符串
         * @param byteArray
         * @return
         */
        private static String byteToStr(byte[] byteArray) {
            String strDigest = "";
            for (int i = 0; i < byteArray.length; i++) {
                strDigest += byteToHexStr(byteArray[i]);
            }
            return strDigest;
        }

        /**
         * 将每一个字节转换为十六进制字符串
         * @param mByte
         * @return
         */
        private static String byteToHexStr(byte mByte) {
            //转位数参照表
            char[] Digit = { '0', '1', '2', '3', '4', '5', '6', '7', '8', '9', 'A', 'B', 'C', 'D', 'E', 'F' };
            char[] tempArr = new char[2];
            tempArr[0] = Digit[(mByte >>> 4) & 0X0F];
            tempArr[1] = Digit[mByte & 0X0F];
            //得到进制码的字符串
            String s = new String(tempArr);
            return s;
        }
}

MsgUtil

代码语言:javascript
复制
/**
 * @description
 */
public class MsgUtil {

    public static final String MSGTYPE_EVENT = "event";//消息类型--事件
    public static final String MESSAGE_SUBSCIBE = "subscribe";//消息事件类型--订阅事件
    public static final String MESSAGE_UNSUBSCIBE = "unsubscribe";//消息事件类型--取消订阅事件
    public static final String MESSAGE_TEXT = "text";//消息类型--文本消息

    /**
     * 组装文本消息
     */
    public static String textMsg(String toUserName,String fromUserName,String content){
        TextMsg text = new TextMsg();
        text.setFromUserName(toUserName);
        text.setToUserName(fromUserName);
        text.setMsgType(MESSAGE_TEXT);
        text.setCreateTime(new Date().getTime());
        text.setContent(content);
        return XmlUtil.textMsgToxml(text);
    }

    /**
     * 响应订阅事件--回复文本消息
     */
    public static String subscribeForText(String toUserName,String fromUserName,String content){
        return textMsg(toUserName, fromUserName, content);
    }

    /**
     * 响应取消订阅事件
     */
    public static String unsubscribeForText(String toUserName,String fromUserName,String content){
        System.out.println("用户:"+ fromUserName +"取消关注~");
        return "";
    }
}

application.yml

代码语言:javascript
复制
parameter:
  #微信公众号
  publicAppId: 微信公众号AppId
  publicAppSecret: 微信公众号AppSecret

WxPublicController

代码语言:javascript
复制
/**
 * @description
 */
@Controller
@RequestMapping(value = "/message/weixin")
public class WxPublicController {

    protected static Logger logger = LoggerFactory.getLogger(WxPublicController.class);
   //填写和公众号后台配置的一样的token
    private static final String TOKENN = "";

    /**
     * 微信公众号appId
     */
    @Value("${parameter.publicAppId}")
    private String publicAppId;
    /**
     * 微信公众号appSecret
     */
    @Value("${parameter.publicAppSecret}")
    private String publicAppSecret;

    @RequestMapping(method = RequestMethod.GET)
    public void get(HttpServletRequest request, HttpServletResponse response) {
        // 微信加密签名,signature结合了开发者填写的token参数和请求中的timestamp参数、nonce参数。
        String signature = request.getParameter("signature");
        // 时间戳
        String timestamp = request.getParameter("timestamp");
        // 随机数
        String nonce = request.getParameter("nonce");
        // 随机字符串
        String echostr = request.getParameter("echostr");
        PrintWriter out = null;
        try {
            out = response.getWriter();
            // 通过检验signature对请求进行校验,若校验成功则原样返回echostr,否则接入失败
            if (SignUtil.checkSignature(TOKENN, signature, timestamp, nonce)) {
                out.print(echostr);
            }
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            if (out != null ) {
                out.close();
            }
        }
    }

    @RequestMapping(method = RequestMethod.POST)
    public void post(HttpServletRequest request, HttpServletResponse response) {
        // 响应消息
        PrintWriter out = null;
        String resMessage = "";
        try {
            request.setCharacterEncoding("UTF-8");
            response.setCharacterEncoding("UTF-8");
            //把微信返回的xml信息转义成map
            Map<String, String> map = XmlUtil.parseXml(request);
            //消息来源用户标识
            String fromUserName = map.get("FromUserName");
            //消息目的用户标识
            String toUserName = map.get("ToUserName");
            //消息创建时间(整型)
            String createTime = map.get("CreateTime");
            //消息类型
            String msgType = map.get("MsgType");
            //事件类型:subscribe/unsubscribe
            String eventType = map.get("Event");
            //如果为事件类型
            if(MsgUtil.MSGTYPE_EVENT.equals(msgType)){
                //处理订阅事件
                if(MsgUtil.MESSAGE_SUBSCIBE.equals(eventType)){
                    resMessage = MsgUtil.subscribeForText(toUserName, fromUserName, "您好,谢谢您的关注!!!");
                    //TODO 业务逻辑
                    //处理取消订阅消息
                } else if(MsgUtil.MESSAGE_UNSUBSCIBE.equals(eventType)) {
                    //TODO 业务逻辑
                }
                logger.info("eventType:"+eventType+",fromUserName:"+fromUserName+",toUserName:"+toUserName+",msgType:"+msgType+",createTime:"+createTime);
            }
            out = response.getWriter();
            out.println(resMessage);
        } catch (UnsupportedEncodingException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            if (out != null ) {
                out.close();
            }
        }
    }
}

您的一键三连,是我更新的最大动力,谢谢

山水有相逢,来日皆可期,谢谢阅读,我们再会

我手中的金箍棒,上能通天,下能探海

上一篇:微信小程序模板消息接口下线了,不用慌,调用统一服务消息接口来实现相同功能

原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。

如有侵权,请联系 cloudcommunity@tencent.com 删除。

原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。

如有侵权,请联系 cloudcommunity@tencent.com 删除。

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 2、代码实现
相关产品与服务
云开发 CloudBase
云开发(Tencent CloudBase,TCB)是腾讯云提供的云原生一体化开发环境和工具平台,为200万+企业和开发者提供高可用、自动弹性扩缩的后端云服务,可用于云端一体化开发多种端应用(小程序、公众号、Web 应用等),避免了应用开发过程中繁琐的服务器搭建及运维,开发者可以专注于业务逻辑的实现,开发门槛更低,效率更高。
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档