天天看点

微信公众平台向特定用户推送消息

最近研究微信公众平台,这里整理了一下向特定用户推送消息的思路

一、首先需要将微信的openid与系统用户绑定。

在用户关注公众平台的时候,回复一个链接,要求用户绑定,可以设计如下消息进行回复,(openid最好进行加密处理,后者还需要用这个字段绑定fakeid)。

<code>欢迎关注有问必答平台,&lt;</code><code>a</code> <code>href='http://myweixin123.duapp.com/bind.html?openid=@openid'&gt;点击此处进行用户绑定&lt;/</code><code>a</code><code>&gt;!</code>

在bind.html页面将openid与系统的usercode进行绑定,这个绑定过程非常简单,这里不详叙述。

二、将openid与fakeid进行绑定

微信公众平台是一回一答的模式;但是在微信公众平台后台,可以向特定用户进行消息发送。我们利用这个机制使用代码去模拟这个过程来实现消息推送。

首先需要模拟登录:

<code>using</code> <code>System;</code>

<code>using</code> <code>System.Collections.Generic;</code>

<code>using</code> <code>System.Linq;</code>

<code>using</code> <code>System.Web;</code>

<code>using</code> <code>System.Security.Cryptography;</code>

<code>using</code> <code>System.Text;</code>

<code>using</code> <code>System.Net;</code>

<code>using</code> <code>System.IO;</code>

<code>using</code> <code>System.Security.Authentication;</code>

<code>using</code> <code>System.Security.Cryptography.X509Certificates;</code>

<code>/// &lt;summary&gt;</code>

<code>///WeiXinLogin 的摘要说明</code>

<code>/// &lt;/summary&gt;</code>

<code>public</code> <code>class</code> <code>WeiXinLogin</code>

<code>{</code>

<code>   </code> 

<code>    </code><code>/// &lt;summary&gt;</code>

<code>    </code><code>/// MD5 32位加密</code>

<code>    </code><code>/// &lt;/summary&gt;</code>

<code>    </code><code>/// &lt;param name="str"&gt;&lt;/param&gt;</code>

<code>    </code><code>/// &lt;returns&gt;&lt;/returns&gt;</code>

<code>    </code><code>static</code> <code>string</code> <code>GetMd5Str32(</code><code>string</code> <code>str)</code>

<code>    </code><code>{</code>

<code>        </code><code>MD5CryptoServiceProvider md5Hasher =</code><code>new</code> <code>MD5CryptoServiceProvider();</code>

<code>        </code><code>// Convert the input string to a byte array and compute the hash. </code>

<code>        </code><code>char</code><code>[] temp = str.ToCharArray();</code>

<code>        </code><code>byte</code><code>[] buf =</code><code>new</code> <code>byte</code><code>[temp.Length];</code>

<code>        </code><code>for</code> <code>(</code><code>int</code> <code>i = 0; i &lt; temp.Length; i++)</code>

<code>        </code><code>{</code>

<code>            </code><code>buf[i] = (</code><code>byte</code><code>)temp[i];</code>

<code>        </code><code>}</code>

<code>        </code><code>byte</code><code>[] data = md5Hasher.ComputeHash(buf);</code>

<code>        </code><code>// Create a new Stringbuilder to collect the bytes </code>

<code>        </code><code>// and create a string. </code>

<code>        </code><code>StringBuilder sBuilder =</code><code>new</code> <code>StringBuilder();</code>

<code>        </code><code>// Loop through each byte of the hashed data  </code>

<code>        </code><code>// and format each one as a hexadecimal string. </code>

<code>        </code><code>for</code> <code>(</code><code>int</code> <code>i = 0; i &lt; data.Length; i++)</code>

<code>            </code><code>sBuilder.Append(data[i].ToString(</code><code>"x2"</code><code>));</code>

<code>        </code><code>// Return the hexadecimal string. </code>

<code>        </code><code>return</code> <code>sBuilder.ToString();</code>

<code>    </code><code>}</code>

<code>    </code><code>public</code> <code>static</code> <code>bool</code> <code>ExecLogin(</code><code>string</code> <code>name,</code><code>string</code> <code>pass)</code>

<code>        </code><code>bool</code> <code>result =</code><code>false</code><code>;</code>

<code>        </code><code>string</code> <code>password = GetMd5Str32(pass).ToUpper();</code>

<code>        </code><code>string</code> <code>padata =</code><code>"username="</code> <code>+ name +</code><code>"&amp;pwd="</code> <code>+ password +</code><code>"&amp;imgcode=&amp;f=json"</code><code>;</code>

<code>        </code><code>string</code> <code>url =</code><code>"https://mp.weixin.qq.com/cgi-bin/login?lang=zh_CN "</code><code>;//请求登录的URL</code>

<code>        </code><code>try</code>

<code>            </code><code>CookieContainer cc =</code><code>new</code> <code>CookieContainer();</code><code>//接收缓存</code>

<code>            </code><code>byte</code><code>[] byteArray = Encoding.UTF8.GetBytes(padata);</code><code>// 转化</code>

<code>            </code><code>HttpWebRequest webRequest2 = (HttpWebRequest)WebRequest.Create(url); </code><code>//新建一个WebRequest对象用来请求或者响应url</code>

<code>            </code><code>ServicePointManager.CertificatePolicy =</code><code>new</code> <code>AcceptAllCertificatePolicy();</code>

<code>            </code><code>webRequest2.CookieContainer = cc;                                     </code><code>//保存cookie </code>

<code>            </code><code>webRequest2.Method =</code><code>"POST"</code><code>;                                         </code><code>//请求方式是POST</code>

<code>            </code><code>webRequest2.UserAgent =</code><code>"Mozilla/5.0 (Windows NT 6.1) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/30.0.1599.69 Safari/537.36"</code><code>;</code>

<code>            </code><code>webRequest2.Referer =</code><code>"https://mp.weixin.qq.com/"</code><code>;</code>

<code>            </code><code>webRequest2.ContentType =</code><code>"application/x-www-form-urlencoded"</code><code>;      </code><code>//请求的内容格式为application/x-www-form-urlencoded</code>

<code>            </code><code>webRequest2.ContentLength = byteArray.Length;</code>

<code>            </code><code>Stream newStream = webRequest2.GetRequestStream();          </code><code>//返回用于将数据写入 Internet 资源的 Stream。</code>

<code>            </code><code>// Send the data.</code>

<code>            </code><code>newStream.Write(byteArray, 0, byteArray.Length);   </code><code>//写入参数</code>

<code>            </code><code>newStream.Close();</code>

<code>            </code><code>HttpWebResponse response2 = (HttpWebResponse)webRequest2.GetResponse();</code>

<code>            </code><code>StreamReader sr2 =</code><code>new</code> <code>StreamReader(response2.GetResponseStream(), Encoding.Default);</code>

<code>            </code><code>string</code> <code>text2 = sr2.ReadToEnd();</code>

<code>            </code><code>//此处用到了newtonsoft来序列化</code>

<code>            </code><code>WeiXinRetInfo retinfo = Newtonsoft.Json.JsonConvert.DeserializeObject&lt;WeiXinRetInfo&gt;(text2);</code>

<code>            </code><code>string</code> <code>token =</code><code>string</code><code>.Empty;</code>

<code>            </code><code>if</code> <code>(retinfo.ErrMsg.Length &gt; 0)</code>

<code>            </code><code>{</code>

<code>                </code><code>token = retinfo.ErrMsg.Split(</code><code>new</code> <code>char</code><code>[] {</code><code>'&amp;'</code> <code>})[2].Split(</code><code>new</code> <code>char</code><code>[] {</code><code>'='</code> <code>})[1].ToString();</code><code>//取得令牌</code>

<code>                </code><code>LoginInfo.LoginCookie = cc;</code>

<code>                </code><code>LoginInfo.CreateDate = DateTime.Now;</code>

<code>                </code><code>LoginInfo.Token = token;</code>

<code>                </code><code>result =</code><code>true</code><code>;</code>

<code>            </code><code>}</code>

<code>        </code><code>catch</code> <code>(Exception ex)</code>

<code>          </code> 

<code>            </code><code>throw</code> <code>new</code> <code>Exception(ex.StackTrace);</code>

<code>        </code><code>return</code> <code>result;</code>

<code>    </code><code>public</code> <code>static</code> <code>class</code> <code>LoginInfo</code>

<code>        </code><code>/// &lt;summary&gt;</code>

<code>        </code><code>/// 登录后得到的令牌</code>

<code>        </code><code>/// &lt;/summary&gt;       </code>

<code>        </code><code>public</code> <code>static</code> <code>string</code> <code>Token {</code><code>get</code><code>;</code><code>set</code><code>; }</code>

<code>        </code><code>/// 登录后得到的cookie</code>

<code>        </code><code>/// &lt;/summary&gt;</code>

<code>        </code><code>public</code> <code>static</code> <code>CookieContainer LoginCookie {</code><code>get</code><code>;</code><code>set</code><code>; }</code>

<code>        </code><code>/// 创建时间</code>

<code>        </code><code>public</code> <code>static</code> <code>DateTime CreateDate {</code><code>get</code><code>;</code><code>set</code><code>; }</code>

<code>    </code><code>internal</code> <code>class</code> <code>AcceptAllCertificatePolicy : ICertificatePolicy</code>

<code>        </code><code>public</code> <code>AcceptAllCertificatePolicy()</code>

<code>        </code><code>public</code> <code>bool</code> <code>CheckValidationResult(ServicePoint sPoint,</code>

<code>           </code><code>X509Certificate cert, WebRequest wRequest,</code><code>int</code> <code>certProb)</code>

<code>            </code><code>// Always accept </code>

<code>            </code><code>return</code> <code>true</code><code>;</code>

<code>    </code><code>} </code>

<code>}</code>

获取fakeid

<code>public</code> <code>static</code> <code>ArrayList SubscribeMP()</code>

<code>    </code><code>try</code>

<code>        </code><code>CookieContainer cookie =</code><code>null</code><code>;</code>

<code>        </code><code>string</code> <code>token =</code><code>null</code><code>;</code>

<code>        </code><code>cookie = WeiXinLogin.LoginInfo.LoginCookie;</code><code>//取得cookie</code>

<code>        </code><code>token = WeiXinLogin.LoginInfo.Token;</code><code>//取得token</code>

<code>        </code><code>/*获取用户信息的url,这里有几个参数给大家讲一下,1.token此参数为上面的token 2.pagesize此参数为每一页显示的记录条数</code>

<code>        </code><code>3.pageid为当前的页数,4.groupid为微信公众平台的用户分组的组id,当然这也是我的猜想不一定正确*/</code>

<code>        </code><code>string</code> <code>Url =</code><code>"https://mp.weixin.qq.com/cgi-bin/contactmanage?t=user/index&amp;pagesize=10&amp;pageidx=0&amp;type=0&amp;groupid=0&amp;token="</code> <code>+ token +</code><code>"&amp;lang=zh_CN"</code><code>;</code>

<code>        </code><code>HttpWebRequest webRequest2 = (HttpWebRequest)WebRequest.Create(Url);</code>

<code>        </code><code>webRequest2.CookieContainer = cookie;</code>

<code>        </code><code>webRequest2.ContentType =</code><code>"text/html; charset=UTF-8"</code><code>;</code>

<code>        </code><code>webRequest2.Method =</code><code>"GET"</code><code>;</code>

<code>        </code><code>webRequest2.UserAgent =</code><code>"Mozilla/5.0 (Windows NT 5.1; rv:2.0.1) Gecko/20100101 Firefox/4.0.1"</code><code>;</code>

<code>        </code><code>webRequest2.ContentType =</code><code>"application/x-www-form-urlencoded"</code><code>;</code>

<code>        </code><code>HttpWebResponse response2 = (HttpWebResponse)webRequest2.GetResponse();</code>

<code>        </code><code>StreamReader sr2 =</code><code>new</code> <code>StreamReader(response2.GetResponseStream(), Encoding.Default);</code>

<code>        </code><code>string</code> <code>text2 = sr2.ReadToEnd();</code>

<code>        </code><code>MatchCollection mc;</code>

<code>        </code><code>//由于此方法获取过来的信息是一个html网页所以此处使用了正则表达式,注意:(此正则表达式只是获取了fakeid的信息如果想获得一些其他的信息修改此处的正则表达式就可以了。)</code>

<code>        </code><code>Regex r =</code><code>new</code> <code>Regex(</code><code>"\"id\"\\:\\d+,\"nick_name\""</code><code>);</code><code>//定义一个Regex对象实例</code>

<code>        </code><code>mc = r.Matches(text2);</code>

<code>        </code><code>Int32 friendSum = mc.Count;         </code><code>//好友总数</code>

<code>        </code><code>string</code> <code>fackID =</code><code>""</code><code>;</code>

<code>        </code><code>ArrayList fackID1 =</code><code>new</code> <code>ArrayList();</code>

<code>        </code><code>for</code> <code>(</code><code>int</code> <code>i = 0; i &lt; friendSum; i++)</code>

<code>            </code><code>//"id":208989515,"nick_name"</code>

<code>            </code><code>fackID = mc[i].Value.Replace(</code><code>",\"nick_name\""</code><code>,</code><code>""</code><code>).Split(</code><code>new</code> <code>char</code><code>[] {</code><code>':'</code> <code>})[1];</code>

<code>            </code><code>fackID = fackID.Replace(</code><code>"\""</code><code>,</code><code>""</code><code>).Trim();</code>

<code>            </code><code>fackID1.Add(fackID);</code>

<code>        </code><code>return</code> <code>fackID1;</code>

<code>    </code><code>catch</code> <code>(Exception ex)</code>

<code>        </code><code>throw</code> <code>new</code> <code>Exception(ex.StackTrace);</code>

根据fakeid获取openid

微信公众平台向特定用户推送消息
微信公众平台向特定用户推送消息

由于之前有建立openid与usercode的关系,所以可以根据usercode找到openid,又可以根据openid找到fakeid。使用下面代码进行推送:

<code>public</code> <code>static</code> <code>bool</code> <code>SendMessage(</code><code>string</code> <code>Message,</code><code>string</code> <code>fakeid)</code>

<code>    </code><code>bool</code> <code>result =</code><code>false</code><code>;</code>

<code>    </code><code>CookieContainer cookie =</code><code>null</code><code>;</code>

<code>    </code><code>string</code> <code>token =</code><code>null</code><code>;</code>

<code>    </code><code>cookie = WeiXinLogin.LoginInfo.LoginCookie;</code><code>//取得cookie</code>

<code>    </code><code>token =  WeiXinLogin.LoginInfo.Token;</code><code>//取得token</code>

<code>    </code><code>string</code> <code>strMsg = System.Web.HttpUtility.UrlEncode(Message); </code><code>//对传递过来的信息进行url编码</code>

<code>    </code><code>string</code> <code>padate =</code><code>"type=1&amp;content="</code> <code>+ strMsg +</code><code>"&amp;error=false&amp;tofakeid="</code> <code>+ fakeid +</code><code>"&amp;token="</code> <code>+ token +</code><code>"&amp;ajax=1"</code><code>;</code>

<code>    </code><code>string</code> <code>url =</code><code>"https://mp.weixin.qq.com/cgi-bin/singlesend?t=ajax-response&amp;lang=zh_CN"</code><code>;</code>

<code>    </code><code>byte</code><code>[] byteArray = Encoding.UTF8.GetBytes(padate);</code><code>// 转化</code>

<code>    </code><code>HttpWebRequest webRequest2 = (HttpWebRequest)WebRequest.Create(url);</code>

<code>    </code><code>webRequest2.CookieContainer = cookie;</code><code>//登录时得到的缓存</code>

<code>    </code><code>webRequest2.Referer =</code><code>"https://mp.weixin.qq.com/cgi-bin/singlemsgpage?token="</code> <code>+ token +</code><code>"&amp;fromfakeid="</code> <code>+ fakeid +</code><code>"&amp;msgid=&amp;source=&amp;count=20&amp;t=wxm-singlechat&amp;lang=zh_CN"</code><code>;</code>

<code>    </code><code>webRequest2.Method =</code><code>"POST"</code><code>;</code>

<code>    </code><code>webRequest2.UserAgent =</code><code>"Mozilla/5.0 (Windows NT 5.1; rv:2.0.1) Gecko/20100101 Firefox/4.0.1"</code><code>;</code>

<code>    </code><code>webRequest2.ContentType =</code><code>"application/x-www-form-urlencoded"</code><code>;</code>

<code>    </code><code>webRequest2.ContentLength = byteArray.Length;</code>

<code>    </code><code>Stream newStream = webRequest2.GetRequestStream();</code>

<code>    </code><code>// Send the data.           </code>

<code>    </code><code>newStream.Write(byteArray, 0, byteArray.Length);   </code><code>//写入参数   </code>

<code>    </code><code>newStream.Close();</code>

<code>    </code><code>HttpWebResponse response2 = (HttpWebResponse)webRequest2.GetResponse();</code>

<code>    </code><code>StreamReader sr2 =</code><code>new</code> <code>StreamReader(response2.GetResponseStream(), Encoding.Default);</code>

<code>    </code><code>string</code> <code>text2 = sr2.ReadToEnd();</code>

<code>    </code><code>if</code> <code>(text2.Contains(</code><code>"ok"</code><code>))</code>

<code>        </code><code>result =</code><code>true</code><code>;</code>

<code>    </code><code>return</code> <code>result;</code>

  

可以写一个长期运行的windows服务用于建立fakeid和openid的关系,这里不再详诉。

本文转自麒麟博客园博客,原文链接:http://www.cnblogs.com/zhuqil/p/3354640.html,如需转载请自行联系原作者

继续阅读