java后台接收微信服務號/訂閱號消息

1.申請訂閱號(適合個人)或者服務號(適合企業)
微信公眾平台

2.填寫配置

服務器地址： 需要接收消息 的服務端接口地址

令牌：通話識別碼，隨便寫，后端接收時，使用一樣的就可以了。

消息加密秘鑰 ：(目前不用)

提交這些配置信息，就能與后端通訊了，這個項目使用的是SSM框架，springboot項目做的后端接收。
注：

因為項目在本地測試，需要用到內網穿透相關。

這里就不一一敘述了這里有教程，不懂可以問我。QQ:794171011

內網穿透工具 

實現的效果 : 接收到 用戶給公眾號發送的消息，並處理。

有圖有真相

我這里的功能比較簡單只是過濾消息中的 鏈接 

附上代碼：

@Controller
@RequestMapping("/wecha")
public class WeChaturlController extends BaseController {

    private final static Logger logger = Logger.getLogger(WeChaturlController.class.getName());

    @Resource
    private INewsCommentService newsCommentService;
    @Resource
    private IReviewNewsService reviewNewsService;
    @Resource
    protected IWaitParseDao waitParseDao;
    
    public static String BIND_TOKEN = "CX_TEST";
    private static SAXReader saxReader = new SAXReader();

    /**
     * 消息接收端
     * @param response
     * @param request
     */
    @RequestMapping(value = "/get")
    public void msgIn(HttpServletResponse response, HttpServletRequest request) {
        if ("GET".equals(request.getMethod())) {
            bindMsg(response, request);
        } else if ("POST".equals(request.getMethod())) {
            if (WxBaseCheck.checkSignature(request, BIND_TOKEN)) {
                handleMsgIn(response, request);
            } else {
                logger.warn("消息驗證失敗，來源不是微信！");
            }
        }
    }

    /**
     *  騰訊通過GET請求進行綁定
     * @param response
     * @param request
     */
    public void bindMsg(HttpServletResponse response, HttpServletRequest request) {
        try {
            String echostr = request.getParameter("echostr");
            // System.out.println(WxBaseCheck.checkSignature(request,
            // BIND_TOKEN));
            if (WxBaseCheck.checkSignature(request, BIND_TOKEN)) {
                logger.warn("公眾平台與本系統成功綁定！可以開始通信~~~");
                response.getWriter().write(echostr);
            } else {
                response.getWriter().write("");
            }
        } catch (IOException e) {
            logger.warn("綁定URL時：" + e.getMessage());
            e.printStackTrace();
        }
    }

    /**
     * 處理騰訊服務器發送過來的消息
     * @param response
     * @param request
     */
    public void handleMsgIn(HttpServletResponse response, HttpServletRequest request) {
        try {
            // 使用response的時候必須要設置響應頭，不然會亂碼~~~
            response.setHeader("Content-type", "text/xml;charset=UTF-8");
            // 從request中取得輸入流
            // 讀取輸入流
            Document document = saxReader.read(request.getInputStream());
            // 得到xml根元素
            Element element = document.getRootElement();
            // System.out.println("接口接受xml:"+element.asXML());
            // 將解析結果存儲在HashMap中
            Map<String, String> msgMap = XmlHandler.xmlToMap(element);
            String text = msgMap.get("Content");
            System.out.println("微信收到消息:" + text);
            Pattern pattern = GetUrl.WEB_URL;
            Matcher matcher = pattern.matcher(text);
            if (matcher.find()) {
                // 取字符串中的鏈接,鏈接結尾必須有空格 必須有http 或 https開頭
//                System.out.println(matcher.group());
                if (new BrandUrlUtil().isBrandUrl(matcher.group())) {
                    // 鏈接初始化入庫
                     this.newsCommentService.initNews(matcher.group());
                } else {
                    // 鏈接 未收錄
//                    WaitParse waitParse = new WaitParse();
//                    waitParse.setUrl(matcher.group());
//                    waitParse.setInfoType(0);
//                    WaitParse dbWaitParse = this.waitParseDao.getWaitParse(waitParse);
//                    if (dbWaitParse == null) {
//                        waitParse.setCreateTime(new Date());
//                        this.waitParseDao.insertWaitParse(waitParse);
//                    }
                    logger.warn("微信公眾號收到的鏈接,系統未收錄[" + matcher.group() + "]");
                }
            } else {
                // 其他消息 不包含鏈接
            }

        } catch (Exception e) {
            logger.warn("微信收錄鏈接時:" + e.toString());
        }
    }

}