微信服务器发来的消息代码_代码发送微信消息

hacker|
158

文章目录:

微信公众平台如何通过php代码给会员发送被动响应消息

明确在哪接收消息

从微信公众平台接口消息指南中可以了解到,当用户向公众帐号发消息时,微信服务器会将消息通过POST方式提交给我们在接口配置信息中填写的URL,而我们就需要在URL所指向的请求处理类CoreServlet的doPost方法中接收消息、处理消息和响应消息。

接收、处理、响应消息

下面先来看我已经写好的CoreServlet的完整代码:

package org.liufeng.course.servlet;

import java.io.IOException;

import java.io.PrintWriter;

import javax.servlet.ServletException;

import javax.servlet.http.HttpServlet;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletResponse;

import org.liufeng.course.service.CoreService;

import org.liufeng.course.util.SignUtil;

/**

* 核心请求处理类

*

* @author liufeng

* @date 2013-05-18

*/

public class CoreServlet extends HttpServlet {

private static final long serialVersionUID = 4440739483644821986L;

/**

* 确认请求来自微信服务器

*/

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

// 微信加密签名

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

// 时间戳

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

// 随机数

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

// 随机字符串

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

PrintWriter out = response.getWriter();

// 通过检验signature对请求进行校验,若校验成功则原样返回echostr,表示接入成功,否则接入失败

if (SignUtil.checkSignature(signature, timestamp, nonce)) {

out.print(echostr);

}

out.close();

out = null;

}

/**

* 处理微信服务器发来的消息

*/

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

// 将请求、响应的编码均设置为UTF-8(防止中文乱码)

request.setCharacterEncoding("UTF-8");

response.setCharacterEncoding("UTF-8");

// 调用核心业务类接收消息、处理消息

String respMessage = CoreService.processRequest(request);

// 响应消息

PrintWriter out = response.getWriter();

out.print(respMessage);

out.close();

}

}

代码说明:

1)第51行代码:微信服务器POST消息时用的是UTF-8编码,在接收时也要用同样的编码,否则中文会乱码;

2)第52行代码:在响应消息(回复消息给用户)时,也将编码方式设置为UTF-8,原理同上;

3)第54行代码:调用CoreService类的processRequest方法接收、处理消息,并得到处理结果;

4)第57~59行:调用response.getWriter().write()方法将消息的处理结果返回给用户

从doPost方法的实现可以看到,它是通过调用CoreService类的processRequest方法接收、处理消息的,这样做的目的是为了解耦,即业务相关的操作都不在Servlet里处理,而是完全交由业务核心类CoreService去做。下面来看CoreService类的代码实现:

package org.liufeng.course.service;

import java.util.Date;

import java.util.Map;

import javax.servlet.http.HttpServletRequest;

import org.liufeng.course.message.resp.TextMessage;

import org.liufeng.course.util.MessageUtil;

/**

* 核心服务类

*

* @author liufeng

* @date 2013-05-20

*/

public class CoreService {

/**

* 处理微信发来的请求

*

* @param request

* @return

*/

public static String processRequest(HttpServletRequest request) {

String respMessage = null;

try {

// 默认返回的文本消息内容

String respContent = "请求处理异常,请稍候尝试!";

// xml请求解析

MapString, String requestMap = MessageUtil.parseXml(request);

// 发送方帐号(open_id)

String fromUserName = requestMap.get("FromUserName");

// 公众帐号

String toUserName = requestMap.get("ToUserName");

// 消息类型

String msgType = requestMap.get("MsgType");

// 回复文本消息

TextMessage textMessage = new TextMessage();

textMessage.setToUserName(fromUserName);

textMessage.setFromUserName(toUserName);

textMessage.setCreateTime(new Date().getTime());

textMessage.setMsgType(MessageUtil.RESP_MESSAGE_TYPE_TEXT);

textMessage.setFuncFlag(0);

// 文本消息

if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_TEXT)) {

respContent = "您发送的是文本消息!";

}

// 图片消息

else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_IMAGE)) {

respContent = "您发送的是图片消息!";

}

// 地理位置消息

else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_LOCATION)) {

respContent = "您发送的是地理位置消息!";

}

// 链接消息

else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_LINK)) {

respContent = "您发送的是链接消息!";

}

// 音频消息

else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_VOICE)) {

respContent = "您发送的是音频消息!";

}

// 事件推送

else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_EVENT)) {

// 事件类型

String eventType = requestMap.get("Event");

// 订阅

if (eventType.equals(MessageUtil.EVENT_TYPE_SUBSCRIBE)) {

respContent = "谢谢您的关注!";

}

// 取消订阅

else if (eventType.equals(MessageUtil.EVENT_TYPE_UNSUBSCRIBE)) {

// TODO 取消订阅后用户再收不到公众号发送的消息,因此不需要回复消息

}

// 自定义菜单点击事件

else if (eventType.equals(MessageUtil.EVENT_TYPE_CLICK)) {

// TODO 自定义菜单权没有开放,暂不处理该类消息

}

}

textMessage.setContent(respContent);

respMessage = MessageUtil.textMessageToXml(textMessage);

} catch (Exception e) {

e.printStackTrace();

}

return respMessage;

}

}

代码说明:

1)第29行:调用消息工具类MessageUtil解析微信发来的xml格式的消息,解析的结果放在HashMap里;

2)32~36行:从HashMap中取出消息中的字段;

3)39-44、84行:组装要返回的文本消息对象;

4)47~82行:演示了如何接收微信发送的各类型的消息,根据MsgType判断属于哪种类型的消息;

5)85行:调用消息工具类MessageUtil将要返回的文本消息对象TextMessage转化成xml格式的字符串;

关于事件推送(关注、取消关注、菜单点击)

对于消息类型的判断,像文本消息、图片消息、地理位置消息、链接消息和语音消息都比较好理解,有很多刚接触的朋友搞不懂事件推送消息有什么用,或者不清楚该如何判断用户关注的消息。那我们就专门来看下事件推送,下图是官方消息接口文档中关于事件推送的说明:

如何调用处理微信服务器发来的消息代码

您好,

主存中各区内相同块号的数据块都可以分别调入缓存中块号相同的地址中,但同时只能有一个区的块存入缓存。由于主、缓存块号相同,因此,目录登记时,只记录调入块的区号即可。主、缓存块号及块内地址两个字段完全相同。目录表存放在高速小容量存储器中,其中包括二部分:数据块在主存的区号和有效位。目录表的容量与缓存的块数相同。

优点:地址映象方式简单,数据访问时,只需检查区号是否相等即可,因而可以得到比较快的访问速度,硬件设备简单。

缺点:替换操作频繁,命中率比较低。

3.组相联映象方式

组相联的映象规则:

(1) 主存和Cache按同样大小划分成块。

(2) 主存和Cache按同样大小划分成组。

(3) 主存容量是缓存容量的整数倍,将主存空间按缓冲区的大小分成区,主存中每一区的组数与缓存的组数相同。

微信公众平台开发模式怎么查看源代码

微信平台的后台代码被托管在一个服务器上,也就是部署,微信上填写的那个URL只是个接受微信服务器发来消息处理的开始接口, 如果你想看源码,可以给他要一个SVN地址,自己check下来下,研究呗

类似部署在BAE上的 你知道了SVN地址了就可以搞代码了

如何使用C#建立响应微信接入和自动回复的代码

打开Visual Studio 2010, 新建一个ASPX WEB应用程序类型的项目, Visual Studio 会帮我们自动地创建一些得得啵啵的文件,直接不理会,创建完毕后,如下图右击项目,选择“添加”-“新建项”,如下图选择“一般处理程序”,并且命名为"mp.ashx"。

创建好了,添加如下的引用:

using System;

using System.Collections.Generic;

using System.Linq;

using System.Web;

using System.Data.SqlClient;

using System.IO;

using System.Text;

using System.Xml;

using System.Xml.XPath;using System.Security;

using System.Net;

using System.Collections;

using System.Security.Cryptography;

提示:一般处理程序,可以返回各种格式的HTTP响应数据,甚至包括但不限于GIF等图像的格式哦,非常地强大而且灵活,但开发难度有点高,有一点类似LOL 中的盲僧,因微信公众平台支持探返回的数据格式一般是XML,但也包括一些非XML的字串什么的,所以我们使用一般处理程序可以非常好完成任务。

2 编写signature校验函数

接口的接入过程其实很简单,用糙人的一句话就是,哥我喊一个“哎。。。”,妹纸你回一个“哎。。。”,咱就结婚成功了(程序直接回复echostr参数),当然要更深度的结合,决不止那么简单。

哥哥您想呀,如果夜半三更,爬上妹妹床头的不是哥哥您,而是一个叫dosboy的骇客,后果我都没有办法再想下去了,所以微信开通前,妹纸您要告诉哥哥(微信平台)口令(在微信中预设一个令牌Token)。

哥哥每回有接入要求的时候,妹纸验明正身就可以拉,因为网络都是明文(dosboy会在窗下偷听的哦),所以这个验证不能直接传递Token,而要通过一定算法,微信的文档下:

根据微信的文档,开发者提交信息后,微信服务器将发送GET请求到填写的URL上,GET请求携带四个参数:

参数

描述

signature 微信加密签名,signature结合了开发者填写的token参数和请求中的timestamp参数、nonce参数。

timestamp 时间戳

nonce 随机数

echostr 随机字符串

开发者通过检验signature对请求进行校验(下面有校验方式)。若确认此次GET请求来自微信服务器,请原样返回echostr参数内容,则接入生效,成为开发者成功,否则接入失败。

加密/校验流程如下: 1. 将token、timestamp、nonce三个参数进行字典序排序 2. 将三个参数字符串拼接成一个字符串进行sha1加密 3. 开发者获得加密后的字符串可与signature对比,

根据以上信息,我写了一个函数,这个函数一定要使用,如果您坚持不验明正身,平台代码也可以接入的,但是危险程度您自己判断:

private bool checkSignature(string signature,string timestamp,string nonce,string token)

{

ArrayList tmpArray = new ArrayList();

tmpArray.Add(token);

tmpArray.Add(timestamp);

tmpArray.Add(nonce);

tmpArray.Sort();

string tmpStr = (string)tmpArray[0] + (string)tmpArray[1] + (string)tmpArray[2];

//建立SHA1对象

SHA1 sha = new SHA1CryptoServiceProvider();

//将mystr转换成byte[]

ASCIIEncoding enc = new ASCIIEncoding();

byte[] dataToHash = enc.GetBytes(tmpStr);

//Hash运算

byte[] dataHashed = sha.ComputeHash(dataToHash);

//将运算结果转换成string

string hash = BitConverter.ToString(dataHashed).Replace("-", "");

log("hash:" + hash); //记录日志,不需要可以注释掉

if(hash.ToLower()==signature.ToLower())

return true;

else

return false;

}

程序中我用了一个记录日志的函数,在这里我也贴上来,如果大家不需可以可以注释掉红色的那行:

private void log(string stringinput)

{

StreamWriter sw = new StreamWriter("C:\\微信日志.txt", true);

sw.WriteLine(DateTime.Now.ToString() + "," + stringinput);

sw.Close();

}

3 接入接口写入数据库代码

想搞微信平台就要接入几百个或更多公众号,必竟委托给你的妹纸起码三宫六院,做好管理还是有必要的,数据库的技术是必须滴,所以在这里,我使用了SQL SERVER 2008R2,把所有的接入信息都写入数据库的“微信号列表”,这里我就简简单单使用了数据库的Update,函数为 LandMPUpdateSQLServer() 代码如下:

表的结构我就截个图,如果看官只想测试一下如何接入,直接闪现到下一节。

private void LandMPUpdateSQLServer(HttpContext context)

{

SqlConnection connMpDb = new SqlConnection(connectionString); //connectionString为预先定义的连接串

connMpDb.Open();

SqlCommand comMpDb = new SqlCommand("update 微信号列表 set signature=@signature,timestamp=@timestamp,nonce=@nonce,echostr=@echostr,[验证]=1 Where ID=*****", connMpDb);

foreach (string s in OpenParameters) //OpenParameters 为4个参数名的数组,即 "signature","timestamp","nonce","echostr"

{

SqlParameter sp = comMpDb.Parameters.Add("@" + s, System.Data.SqlDbType.VarChar);

if (context.Request.QueryString.AllKeys.Contains(s))

sp.Value = context.Request.QueryString[s];

else

sp.Value = "No Value";

}

comMpDb.ExecuteNonQuery();

connMpDb.Close();

}

4 完成代码编写接入接口

(1)请加上变量声明:

在如下的位置后面,即mp类里填加上2个类的变量的定义

public class mp : IHttpHandler

{

//接入参数

private string[] OpenParameters = { "signature", "timestamp", "nonce", "echostr" };

//SQL连接字串,您可以定义成一个字符串,我是从系统设置里取的

private string connectionString = System.Configuration.ConfigurationManager.ConnectionStrings["testmpConnectionString"].ConnectionString;

(2)请完成主程序:

请在

public void ProcessRequest(HttpContext context) 内填加上如下的语句

提示: 这是一个系统函数,每次微信有事件发生时(比如有人给你发消息拉,加你为关注拉什么的)的微信就会主动出动联系你给它填的URL地址,这个函数内的代码就会激发运行!

【自动回复】 如下的代码运行,不仅仅会让您的程序接入微信的公众平台,并且还能自动重复回复别人发的话,看看如下的效果图,你和你的小伙伴是不是已经惊呆了!如果您不要这个功能的话这个程序,您只要保留

1-16行的代码,其它全删除!就已经完全做到接入微信公众平台,如果您再想您的程序智能一点,比如您的妹纸给你发,“我现在就要”,你自动回复 “本人正在忙”(活该你单身),请改造17行以后的代码,完全够用了。

【数据库】 不想碰数据库,就注释掉14行

1 bool isLanding = true;

2 foreach (string s in OpenParameters)

3 {

4 if (!context.Request.QueryString.AllKeys.Contains(s))

5 isLanding = false;

6

7 }

8

9 //toke 为 AAA时验证是否是微信的请求

10 if (isLanding checkSignature(context.Request.QueryString["signature"], context.Request.QueryString["timestamp"], context.Request.QueryString["nonce"],"AAA"))

11 {

12 context.Response.ContentType = "text/plain";

13 string echoString = context.Request.QueryString["echostr"];

14 LandMPUpdateSQLServer(context);

15 context.Response.Write(echoString);

16 }

17 else

18 {

19 //读取发过来的信息到inputXml变量中

20 Stream sin = context.Request.InputStream;

21 byte[] readBytes;

22 readBytes = new byte[sin.Length];

23 sin.Read(readBytes, 0, readBytes.Length);

24 string inputXml = Encoding.UTF8.GetString(readBytes);

25

26 //使用XMLDocument加载信息结构

27 XmlDocument xmlDoc = new XmlDocument();

28 xmlDoc.LoadXml(inputXml);

29 string stringMsgId = xmlDoc.SelectSingleNode("//MsgId").InnerText;

30

31 //把传过来的XML数据各个字段区分出来,并且填到fields这个字典变量中去

32 Dictionarystring, string fields = new Dictionarystring, string();

33 foreach (XmlNode x in xmlDoc.SelectSingleNode("/xml").ChildNodes)

34 {

35 fields.Add(x.Name, x.InnerText);

36

37 }

38 //形成返回格式的XML文档

39 string returnXml = "xmlToUserName![CDATA[" +

40 fields["FromUserName"] + "]]/ToUserNameFromUserName![CDATA[" +

41 fields["ToUserName"] + "]]/FromUserNameCreateTime" +

42 DateTime.Now.Subtract(new DateTime(1970, 1, 1, 8, 0, 0)).TotalSeconds.ToString() + "/CreateTimeMsgType![CDATA[text]]/MsgTypeContent![CDATA[" +

43 fields["Content"] + "]]/Content/xml";

44

45 context.Response.ContentType = "text/xml";

46 context.Response.Write(returnXml);

47

48 }

5 把程序发布到互联网上(此处不解释),注意一定要80端口

(此处省略18000字,记得记上稿费)

6 在微信公众平台上,做如下设置:

在公众平台网站的高级功能 – 开发模式页,点击“成为开发者”按钮,填写URL和Token,其中URL是开发者用来接收微信服务器数据的接口URL。Token可由开发者任意填写, 用作生成签名(该Token会和接口URL中包含的Token进行比对,从而验证安全性)。

怎么查看微信网页的源代码

微信平台的后台代码被托管在一个服务器上,也就是部署,微信上填写的那个URL只是个接受微信服务器发来消息处理的开始接口, 如果你想看源码,可以给对方要一个SVN地址,自己check下来下.

微信出现连接服务器错误代码(1-4)但是,可以登录,可以发信息,可以看朋友圈,就是不能接受信息

这是服务器端的故障,可以试试注销账号重新登录或者清除缓存试试

4条大神的评论

  • avatar
    访客 2022-07-19 上午 04:32:20

    sgType = requestMap.get("MsgType"); // 回复文本消息 TextMessage textMessage = new Tex

  • avatar
    访客 2022-07-18 下午 10:08:35

    什么的,所以我们使用一般处理程序可以非常好完成任务。2 编写signature校验函数接口的接入过程其实很简单,用糙人的一句话就是,哥我喊一个“哎。。。”,妹纸你回一个“哎。。。”,咱就

  • avatar
    访客 2022-07-19 上午 01:00:45

    (string s in OpenParameters) 3 { 4 if (!context.Request.QueryS

  • avatar
    访客 2022-07-18 下午 11:13:22

    误代码(1-4)但是,可以登录,可以发信息,可以看朋友圈,就是不能接受信息微信公众平台如何通过php代码给会员发送被动响应消息明确在哪接收消息从微信公众平台接口消息指南中可以了解到,当用户向公众帐号发消息时,微信服务器会将消息通过POST方式提

发表评论