如何實(shí)現(xiàn)java程序與微信公眾平臺之間實(shí)現(xiàn)消息推送

java程序與微信公眾平臺之間實(shí)現(xiàn)消息推送方法:

創(chuàng)新互聯(lián)專業(yè)為企業(yè)提供興業(yè)網(wǎng)站建設(shè)、興業(yè)做網(wǎng)站、興業(yè)網(wǎng)站設(shè)計(jì)、興業(yè)網(wǎng)站制作等企業(yè)網(wǎng)站建設(shè)、網(wǎng)頁設(shè)計(jì)與制作、興業(yè)企業(yè)網(wǎng)站模板建站服務(wù)，10多年興業(yè)做網(wǎng)站經(jīng)驗(yàn)，不只是建網(wǎng)站，更提供有價值的思路和整體網(wǎng)絡(luò)服務(wù)。

1、本地數(shù)據(jù)庫中存放著小程序用戶表和微信公眾號的表，下面就是向某一個小程序用戶推送微信公眾號信息

2、在小程序用戶表中任意取一個用戶A信息，用戶A的openId和unionId，通過unionId到公眾號表里去檢索對應(yīng)的A用戶微信公眾號的openId

3、在微信公眾號上選擇一個模板消息，編輯完要發(fā)送的的內(nèi)容后，再請求發(fā)送模板消息的接口

關(guān)于微信公眾號不能推送的，或者推送報錯的，推送的miniprogram下的appid對應(yīng)的小程序必須是已審核并發(fā)布的才可以推送。

推送軟件用極光推送，實(shí)現(xiàn)多種消息類型，開發(fā)者可以輕松地通過極光發(fā)送各個移動平臺的系統(tǒng)通知，還可以在控制臺編輯多種富文本展示模板； 極光還提供自定義消息的透傳，客戶端接到消息內(nèi)容后根據(jù)自己的邏輯自由處理。

如何用java開發(fā)微信

說明：

本次的教程主要是對微信公眾平臺開發(fā)者模式的講解，網(wǎng)絡(luò)上很多類似文章，但很多都讓初學(xué)微信開發(fā)的人一頭霧水，所以總結(jié)自己的微信開發(fā)經(jīng)驗(yàn)，將微信開發(fā)的整個過程系統(tǒng)的列出，并對主要代碼進(jìn)行講解分析，讓初學(xué)者盡快上手。

在閱讀本文之前，應(yīng)對微信公眾平臺的官方開發(fā)文檔有所了解，知道接收和發(fā)送的都是xml格式的數(shù)據(jù)。另外，在做內(nèi)容回復(fù)時用到了圖靈機(jī)器人的api接口，這是一個自然語言解析的開放平臺，可以幫我們解決整個微信開發(fā)過程中最困難的問題，此處不多講，下面會有其詳細(xì)的調(diào)用方式。

1.1 在登錄微信官方平臺之后，開啟開發(fā)者模式，此時需要我們填寫url和token，所謂url就是我們自己服務(wù)器的接口，用WechatServlet.java來實(shí)現(xiàn)，相關(guān)解釋已經(jīng)在注釋中說明，代碼如下：

[java]?view plain?copy

package?demo.servlet;

import?java.io.BufferedReader;

import?java.io.IOException;

import?java.io.InputStream;

import?java.io.InputStreamReader;

import?java.io.OutputStream;

import?javax.servlet.ServletException;

import?javax.servlet.http.HttpServlet;

import?javax.servlet.http.HttpServletRequest;

import?javax.servlet.http.HttpServletResponse;

import?demo.process.WechatProcess;

/**

*?微信服務(wù)端收發(fā)消息接口

*

*?@author?pamchen-1

*

*/

public?class?WechatServlet?extends?HttpServlet?{

/**

*?The?doGet?method?of?the?servlet.?br

*

*?This?method?is?called?when?a?form?has?its?tag?value?method?equals?to?get.

*

*?@param?request

*????????????the?request?send?by?the?client?to?the?server

*?@param?response

*????????????the?response?send?by?the?server?to?the?client

*?@throws?ServletException

*?????????????if?an?error?occurred

*?@throws?IOException

*?????????????if?an?error?occurred

*/

public?void?doGet(HttpServletRequest?request,?HttpServletResponse?response)

throws?ServletException,?IOException?{

request.setCharacterEncoding("UTF-8");

response.setCharacterEncoding("UTF-8");

/**?讀取接收到的xml消息?*/

StringBuffer?sb?=?new?StringBuffer();

InputStream?is?=?request.getInputStream();

InputStreamReader?isr?=?new?InputStreamReader(is,?"UTF-8");

BufferedReader?br?=?new?BufferedReader(isr);

String?s?=?"";

while?((s?=?br.readLine())?!=?null)?{

sb.append(s);

}

String?xml?=?sb.toString();?//次即為接收到微信端發(fā)送過來的xml數(shù)據(jù)

String?result?=?"";

/**?判斷是否是微信接入激活驗(yàn)證，只有首次接入驗(yàn)證時才會收到echostr參數(shù)，此時需要把它直接返回?*/

String?echostr?=?request.getParameter("echostr");

if?(echostr?!=?null??echostr.length()??1)?{

result?=?echostr;

}?else?{

//正常的微信處理流程

result?=?new?WechatProcess().processWechatMag(xml);

}

try?{

OutputStream?os?=?response.getOutputStream();

os.write(result.getBytes("UTF-8"));

os.flush();

os.close();

}?catch?(Exception?e)?{

e.printStackTrace();

}

}

/**

*?The?doPost?method?of?the?servlet.?br

*

*?This?method?is?called?when?a?form?has?its?tag?value?method?equals?to

*?post.

*

*?@param?request

*????????????the?request?send?by?the?client?to?the?server

*?@param?response

*????????????the?response?send?by?the?server?to?the?client

*?@throws?ServletException

*?????????????if?an?error?occurred

*?@throws?IOException

*?????????????if?an?error?occurred

*/

public?void?doPost(HttpServletRequest?request,?HttpServletResponse?response)

throws?ServletException,?IOException?{

doGet(request,?response);

}

}

1.2 相應(yīng)的web.xml配置信息如下，在生成WechatServlet.java的同時，可自動生成web.xml中的配置。前面所提到的url處可以填寫例如：http;//服務(wù)器地址/項(xiàng)目名/wechat.do

[html]?view plain?copy

?xml?version="1.0"?encoding="UTF-8"?

web-app?version="2.5"

xmlns=""

xmlns:xsi=""

xsi:schemaLocation="

"

servlet

descriptionThis?is?the?description?of?my?J2EE?component/description

display-nameThis?is?the?display?name?of?my?J2EE?component/display-name

servlet-nameWechatServlet/servlet-name

servlet-classdemo.servlet.WechatServlet/servlet-class

/servlet

servlet-mapping

servlet-nameWechatServlet/servlet-name

url-pattern/wechat.do/url-pattern

/servlet-mapping

welcome-file-list

welcome-fileindex.jsp/welcome-file

/welcome-file-list

/web-app

1.3 通過以上代碼，我們已經(jīng)實(shí)現(xiàn)了微信公眾平臺開發(fā)的框架，即開通開發(fā)者模式并成功接入、接收消息和發(fā)送消息這三個步驟。

下面就講解其核心部分——解析接收到的xml數(shù)據(jù)，并以文本類消息為例，通過圖靈機(jī)器人api接口實(shí)現(xiàn)智能回復(fù)。

2.1 首先看一下整體流程處理代碼，包括：xml數(shù)據(jù)處理、調(diào)用圖靈api、封裝返回的xml數(shù)據(jù)。

[java]?view plain?copy

package?demo.process;

import?java.util.Date;

import?demo.entity.ReceiveXmlEntity;

/**

*?微信xml消息處理流程邏輯類

*?@author?pamchen-1

*

*/

public?class?WechatProcess?{

/**

*?解析處理xml、獲取智能回復(fù)結(jié)果（通過圖靈機(jī)器人api接口）

*?@param?xml?接收到的微信數(shù)據(jù)

*?@return??最終的解析結(jié)果（xml格式數(shù)據(jù)）

*/

public?String?processWechatMag(String?xml){

/**?解析xml數(shù)據(jù)?*/

ReceiveXmlEntity?xmlEntity?=?new?ReceiveXmlProcess().getMsgEntity(xml);

/**?以文本消息為例，調(diào)用圖靈機(jī)器人api接口，獲取回復(fù)內(nèi)容?*/

String?result?=?"";

if("text".endsWith(xmlEntity.getMsgType())){

result?=?new?TulingApiProcess().getTulingResult(xmlEntity.getContent());

}

/**?此時，如果用戶輸入的是“你好”，在經(jīng)過上面的過程之后，result為“你也好”類似的內(nèi)容

*??因?yàn)樽罱K回復(fù)給微信的也是xml格式的數(shù)據(jù)，所有需要將其封裝為文本類型返回消息

*?*/

result?=?new?FormatXmlProcess().formatXmlAnswer(xmlEntity.getFromUserName(),?xmlEntity.getToUserName(),?result);

return?result;

}

}

2.2 解析接收到的xml數(shù)據(jù)，此處有兩個類，ReceiveXmlEntity.java和ReceiveXmlProcess.java，通過反射的機(jī)制動態(tài)調(diào)用實(shí)體類中的set方法，可以避免很多重復(fù)的判斷，提高代碼效率，代碼如下：

[java]?view plain?copy

package?demo.entity;

/**

*?接收到的微信xml實(shí)體類

*?@author?pamchen-1

*

*/

public?class?ReceiveXmlEntity?{

private?String?ToUserName="";

private?String?FromUserName="";

private?String?CreateTime="";

private?String?MsgType="";

private?String?MsgId="";

private?String?Event="";

private?String?EventKey="";

private?String?Ticket="";

private?String?Latitude="";

private?String?Longitude="";

private?String?Precision="";

private?String?PicUrl="";

private?String?MediaId="";

private?String?Title="";

private?String?Description="";

private?String?Url="";

private?String?Location_X="";

private?String?Location_Y="";

private?String?Scale="";

private?String?Label="";

private?String?Content="";

private?String?Format="";

private?String?Recognition="";

public?String?getRecognition()?{

return?Recognition;

}

public?void?setRecognition(String?recognition)?{

Recognition?=?recognition;

}

public?String?getFormat()?{

return?Format;

}

public?void?setFormat(String?format)?{

Format?=?format;

}

public?String?getContent()?{

return?Content;

}

public?void?setContent(String?content)?{

Content?=?content;

}

public?String?getLocation_X()?{

return?Location_X;

}

public?void?setLocation_X(String?locationX)?{

Location_X?=?locationX;

}

public?String?getLocation_Y()?{

return?Location_Y;

}

public?void?setLocation_Y(String?locationY)?{

Location_Y?=?locationY;

}

public?String?getScale()?{

return?Scale;

}

public?void?setScale(String?scale)?{

Scale?=?scale;

}

public?String?getLabel()?{

return?Label;

}

public?void?setLabel(String?label)?{

Label?=?label;

}

public?String?getTitle()?{

return?Title;

}

public?void?setTitle(String?title)?{

Title?=?title;

}

public?String?getDescription()?{

return?Description;

}

public?void?setDescription(String?description)?{

Description?=?description;

}

public?String?getUrl()?{

return?Url;

}

public?void?setUrl(String?url)?{

Url?=?url;

}

public?String?getPicUrl()?{

return?PicUrl;

}

public?void?setPicUrl(String?picUrl)?{

PicUrl?=?picUrl;

}

public?String?getMediaId()?{

return?MediaId;

}

public?void?setMediaId(String?mediaId)?{

MediaId?=?mediaId;

}

public?String?getEventKey()?{

return?EventKey;

}

public?void?setEventKey(String?eventKey)?{

EventKey?=?eventKey;

}

public?String?getTicket()?{

return?Ticket;

}

public?void?setTicket(String?ticket)?{

Ticket?=?ticket;

}

public?String?getLatitude()?{

return?Latitude;

}

public?void?setLatitude(String?latitude)?{

Latitude?=?latitude;

}

public?String?getLongitude()?{

return?Longitude;

}

public?void?setLongitude(String?longitude)?{

Longitude?=?longitude;

}

public?String?getPrecision()?{

return?Precision;

}

public?void?setPrecision(String?precision)?{

Precision?=?precision;

}

public?String?getEvent()?{

return?Event;

}

public?void?setEvent(String?event)?{

Event?=?event;

}

public?String?getMsgId()?{

return?MsgId;

}

public?void?setMsgId(String?msgId)?{

MsgId?=?msgId;

}

public?String?getToUserName()?{

return?ToUserName;

}

public?void?setToUserName(String?toUserName)?{

JAVA微信公眾號開發(fā)回復(fù)消息能回復(fù)多條嗎？具體怎么代碼實(shí)現(xiàn)？

public void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {

// 將請求、響應(yīng)的編碼均設(shè)置為UTF-8（防止中文亂碼）

request.setCharacterEncoding("UTF-8");

response.setCharacterEncoding("UTF-8");

// 接收參數(shù)微信加密簽名、 時間戳、隨機(jī)數(shù)

String signature = request.getParameter("signature");

String timestamp = request.getParameter("timestamp");

String nonce = request.getParameter("nonce");

PrintWriter out = response.getWriter();

// 請求校驗(yàn)

boolean checkSignature = SignUtil.checkSignature(signature, timestamp, nonce);

if (checkSignature) {

// 調(diào)用核心服務(wù)類接收處理請求

String respXml = processRequest(request);

out.print(respXml);

}

out.close();

out = null;

}

微信公眾平臺發(fā)送客服消息基于java怎么實(shí)現(xiàn)，求具體代碼？謝謝

這個代碼可能比較多。?？次⑿殴娖脚_的api，里面寫的很清楚，其實(shí)就是一個http請求，加上指定的報文就可以了，用java寫還比較簡單的。。