极光推送V3版本,V2版本代码.docx

使用极光推送()向安卓手机推送消息【服务端向客户端主送推送】，C#语言
在VisualStudio2010中新建网站JPushAndroid。添加引用json帮助类库Newtonsoft.Json.dll。
在web.config增加appkey和mastersecret,可以在极光官网申请。web.config源码：

<?xml version="1.0"?>
<!--
有关如何配置 ASP.NET 应用程序的详细信息，请访问

-->
<configuration>
<appSettings>
<add key="AppKey" value="b232c57153afc71ed74ae3da"/>
<add key="MasterSecret" value="1ed5fcf68f44ea2a6b01e854"/>
</appSettings>
<system.web>
<compilation debug="true" targetFramework="4.0"/>
</system.web>
</configuration>

添加类JPushV3，会弹出保存类在App_code文件夹下，确定。
JpushV3代码如下：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;
using System.Net;
using System.Text;
using System.IO;
using System.Configuration;
using System.Collections;

/*
* 参考文档： 选择里面的：服务器端 API，Push-API-V3
*
* 极光推送的网站的网址是：
* 旧版本V2
* 最新版本V3
*
* 其中服务端的接口以及示例代码都在这里：
*/

/// <summary>
/// 极光推送的最新版：PUSH-API-V3
/// 参考地址
/// POST
/// </summary>
public class JPushV3
{
/// <summary>
/// 应用标识：极光推送的用户名
/// </summary>
private readonly string AppKey = ConfigurationManager.AppSettings["AppKey"];
/// <summary>
/// 极光推送的密码
/// </summary>
private readonly string MasterSecret = ConfigurationManager.AppSettings["MasterSecret"];
/// <summary>
/// 极光推送请求的url地址
/// </summary>
private readonly string RequestUrl = "
/// <summary>
/// 查询推送结果请求的Url地址
/// </summary>
private readonly string ReceivedUrl = "

/// <summary>
/// 发送推送请求到JPush，使用HttpWebRequest
/// </summary>
/// <param name="method">传入POST或GET</param>
/// <param name="url">固定地址</param>
/// <param name="auth">用户名AppKey和密码MasterSecret形成的Base64字符串</param>
/// <param name="reqParams">请求的json参数，一般由Platform(平台)、Audience(设备对象标识)、Notification(通知)、Message(自定义消息)、Options(推送可选项)组成</param>
/// <returns></returns>
public string SendRequest(String method, String url, String auth, String reqParams)
{
string resultJson = "";

HttpWebRequest myReq = null;
HttpWebResponse response = null;
try
{
myReq = (HttpWebRequest)WebRequest.Create(url);
myReq.Method = method;
myReq.ContentType = "application/json";
if (!String.IsNullOrEmpty(auth))
{
myReq.Headers.Add("Authorization", "Basic " + auth);
}
if (method == "POST")
{
byte[] bs = UTF8Encoding.UTF8.GetBytes(reqParams);
myReq.ContentLength = bs.Length;
using (Stream reqStream = myReq.GetRequestStream())
{
reqStream.Write(bs, 0, bs.Length);
reqStream.Close();
}
}
response = (HttpWebResponse)myReq.GetResponse();
HttpStatusCode statusCode = response.StatusCode;

if (Equals(response.StatusCode, HttpStatusCode.OK))
{
using (StreamReader reader = new StreamReader(response.GetResponseStream(), System.Text.Encoding.UTF8))
{
resultJson = reader.ReadToEnd();
try
{
object json = Newtonsoft.Json.JsonConvert.DeserializeObject(resultJson);
}
catch
{
resultJson = string.Format("{{\"error\": {{\"message\": \"{0}\", \"code\": 10086}}}}", "响应的结果不是正确的json格式");
}
}
}
}
catch (WebException ex)
{
if (ex.Status == WebExceptionStatus.ProtocolError)
{
HttpStatusCode errorCode = ((HttpWebResponse)ex.Response).StatusCode;
string statusDescription = ((HttpWebResponse)ex.Response).StatusDescription;
using (StreamReader sr = new StreamReader(((HttpWebResponse)ex.Response).GetResponseStream(), System.Text.Encoding.UTF8))
{
resultJson = sr.ReadToEnd();
//{"errcode":404,"errmsg":"request api doesn't exist"}
Dictionary<string, object> dict = JsonToDictionary(resultJson);
string errCode = "10086";
string errMsg = "发送推送的请求地址不存在或无法连接";
if (dict.ContainsKey("errcode"))
{
errCode = dict["errcode"].ToString();
}
if (dict.ContainsKey("errmsg"))
{
errMsg = dict["errmsg"].ToString();
}
resultJson = string.Format("{{\"error\": {{\"message\": \"{0}\", \"code\": {1}}}}}", errMsg, errCode);
}
}
else
{
//这里一定是error作为键名（自定义错误号10086），和极光推送失败时的json格式保持一致 如 {"error": {"message": "Missing parameter", "code": 1002}}
resultJson = string.Format("{{\"error\": {{\"message\": \"{0}\", \"code\": 10086}}}}", ex.Message.Replace("\"", " ").Replace("'", " "));
}
}
catch (System.Exception ex)
{
resultJson = string.Format("{{\"error\": {{\"message\": \"{0}\", \"code\": 10086}}}}", ex.Message.Replace("\"", " ").Replace("'", " "));
}
finally
{
if (response != null)
{
response.Close();
}
if (myReq != null)
{
myReq.Abort();
}
}
return resultJson;
}

/// <summary>
/// 通过用户名AppKey和密码获取验证码
/// </summary>
/// <returns></returns>
private string GetBase64Auth()
{
string str = this.AppKey + ":" + this.MasterSecret;
byte[] bytes = Encoding.Default.GetBytes(str);
return Convert.ToBase64String(bytes);
}

/// <summary>
/// 发送推送请求到JPush
/// </summary>
/// <param name="method">POST或GET</param>
/// <param name="reqParams">请求的json参数，一般由Platform(平台)、Audience(设备对象标识)、Notification(通知)、Message(自定义消息)、Options(推送可选项)组成</param>
/// <returns></returns>
public string SendRequest(String method, String reqParams)
{
string auth = GetBase64Auth();
return SendRequest(method, this.RequestUrl, auth, reqParams);
}

/// <summary>
/// 发送Post请求
/// </summary>
/// <param name="reqParams">请求的json参数，一般由Platform(平台)、Audience(设备对象标识)、Notification(通知)、Message(自定义消息)、Options(推送可选项)组成</param>
/// <returns></returns>
public string SendPostRequest(String reqParams)
{
string auth = GetBase64Auth();
return SendRequest("POST", this.RequestUrl, auth, reqParams);
}

/// <summary>
/// 发送Get请求
/// </summary>
/// <param name="reqParams">请求的json参数，一般由Platform(平台)、Audience(设备对象标识)、Notification(通知)、Message(自定义消息)、Options(推送可选项)组成</param>
/// <returns></returns>
public string SendGetRequest(String reqParams)
{
string auth = GetBase64Auth();
return SendRequest("GET", this.RequestUrl, auth, reqParams);
}

/*
* 生成唯一的sendNo的方法： 取序列号
* 查看返回结果的方法
*/

/// <summary>
/// 查询推送的结果
/// </summary>
/// <param name="msg_ids">生成的json信息唯一id</param>
/// <returns></returns>
public string GetReceivedResult(String msg_ids)
{
string url = this.ReceivedUrl + "?msg_ids=" + msg_ids;
String auth = GetBase64Auth();
return SendRequest("GET", url, auth, null); ;
}

/*
* 1.正确时返回结果{"sendno":"123456","msg_id":"1799597405"}
* 或者 {"sendno":"0","msg_id":"351403900"}
* 2.入参json完全正确，但找不到要到达的设备。错误时：返回
* {"msg_id": 3125719446, "error": {"message": "cannot find user by this audience", "code": 1011}}
* 3.传入空字符串 或者 非json格式，或者没有必须的选项：{"error": {"message": "Missing parameter", "code": 1002}}
* 传入的键（键区分大小写）、值不符合要求 {"error": {"message": "Audience value must be JSON Array format!", "code": 1003}}
*/

/// <summary>
/// 将返回的json转换为Hashtable对象
/// </summary>
/// <param name="jsonString"></param>
/// <returns></returns>
public Hashtable JsonToHashtable(string jsonString)
{
/*
* 正确时返回结果{"sendno":"123456","msg_id":"1799597405"}
* {"sendno":"0","msg_id":"351403900"}
* 入参json完全正确，但找不到要到达的设备。错误时：返回 {"msg_id": 3125719446, "error": {"message": "cannot find user by this audience", "code": 1011}}
* 传入空字符串 或者 非json格式，或者没有必须的选项：{"error": {"message": "Missing parameter", "code": 1002}}
* 传入的键值不符合要求 {"error": {"message": "Audience value must be JSON Array format!", "code": 1003}} 键区分大小写
*/
Hashtable ht = new Hashtable();
object json = Newtonsoft.Json.JsonConvert.DeserializeObject(jsonString);
//返回的结果一定是一个json对象
Newtonsoft.Json.Linq.JObject jsonObject = json as Newtonsoft.Json.Linq.JObject;
if (jsonObject == null)
{
return ht;
}
foreach (Newtonsoft.Json.Linq.JProperty jProperty in jsonObject.Properties())
{
Newtonsoft.Json.Linq.JToken jToken = jProperty.Value;
string value = "";
if (jToken != null)
{
value = jToken.ToString();
}
ht.Add(jProperty.Name, value);
}
return ht;
}

/// <summary>
/// 根据json返回的结果判断是否推送成功
/// </summary>
/// <param name="jsonString">响应的json</param>
/// <param name="errorMessage">错误信息</param>
/// <param name="errorCode">错误号</param>
/// <returns></returns>
public bool IsSuccess(string jsonString, out string errorMessage, out string errorCode)
{
Hashtable ht = JsonToHashtable(jsonString);
errorMessage = "";
errorCode = "";
foreach (string key in ht.Keys)
{
//如果存在error键,说明推送出错
if (key == "error")
{
string errJson = ht[key].ToString();
Hashtable htError = JsonToHashtable(errJson);
errorMessage = htError["message"].ToString();
errorCode = htError["code"].ToString();
return false;
}
}
return true;
}

/// <summary>
/// 根据返回的响应json来判断推送是否成功，成功时记录sendno与msg_id。
/// 失败时记录错误信息errorMessage、错误号errCode等
/// </summary>
/// <param name="jsonString">响应的json</param>
/// <param name="errorMessage">错误信息</param>
/// <param name="errorCode">错误号</param>
/// <param name="sendno">用户自定义的推送编号（从序列号中获取），不设置则为0，成功后返回该编号</param>
/// <param name="msg_id">极光服务器处理后返回的信息编号</param>
/// <returns></returns>
public bool IsSuccess(string jsonString, out string errorMessage, out string errorCode, out string sendno, out string msg_id)
{
bool result = IsSuccess(jsonString, out errorMessage, out errorCode);
Hashtable ht = JsonToHashtable(jsonString);
sendno = "";
msg_id = "";
if (result) //推送成功时，只有键sendno、msg_id
{
sendno = ht["sendno"].ToString();
msg_id = ht["msg_id"].ToString();
}
else //如果失败时存在msg_id键，则记录msg_id的值
{
if (ht.ContainsKey("msg_id"))
{
msg_id = ht["msg_id"].ToString();
}
}
return result;
}

/// <summary>
/// 将返回的json转换为字典Dictionary对象
/// </summary>
/// <param name="jsonString"></param>
/// <returns></returns>
public Dictionary<string, object> JsonToDictionary(string jsonString)
{
Dictionary<string, object> ht = new Dictionary<string, object>();
object json = Newtonsoft.Json.JsonConvert.DeserializeObject(jsonString);
//返回的结果一定是一个json对象
Newtonsoft.Json.Linq.JObject jsonObject = json as Newtonsoft.Json.Linq.JObject;
if (jsonObject == null)
{
return ht;
}
foreach (Newtonsoft.Json.Linq.JProperty jProperty in jsonObject.Properties())
{
Newtonsoft.Json.Linq.JToken jToken = jProperty.Value;
string value = "";
if (jToken != null)
{
value = jToken.ToString();
}
ht.Add(jProperty.Name, value);
}
return ht;
}
}

☆JPushV2类代码

using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;
using System.Configuration;
using System.Text;
using System.Net;
using System.IO;
using System.Security.Cryptography;

/*
* 参考文档： 选择里面的：服务器端 API，Push-API-V3
*
* 极光推送的网站的网址是：
* 旧版本V2
* 最新版本V3
*
* 其中服务端的接口以及示例代码都在这里：
*/

/// <summary>
/// 这个版本是Push-API-v2版本，只能用到2015-12-31，建议直接使用最新版v3
/// post处理地址 :8800/v2/push
/// </summary>
public class JPushV2
{
/// <summary>
/// Android ApiKey
/// </summary>
private readonly string AppKey = ConfigurationManager.AppSettings["AppKey"];
/// <summary>
/// Android密码
/// </summary>
private readonly string APIMasterSecret = ConfigurationManager.AppSettings["MasterSecret"];

/// <summary>
/// Android极光推送:开始推送方法
/// </summary>
/// <param name="RegistrationID">设备号 RV1D41L5F1T</param>
public void PushAndroid(string RegistrationID)
{
try
{
Random ran = new Random();
int sendno = ran.Next(1, 2100000000);//随机生成的一个编号
string app_key = AppKey;
string masterSecret = APIMasterSecret;
int receiver_type = 4;//接收者类型。2、指定的 tag。3、指定的 alias。4、广播：对 app_key 下的所有用户推送消息。5、根据 RegistrationID 进行推送。当前只是 Android SDK r1.6.0 版本支持
string receiver_value = RegistrationID;

/*
int msg_type = 1;//1、通知 2、自定义消息（只有 Android 支持）
//通过json来推送消息内容。title-标题 content-推送的内容
string Title = "要推送的标题";
string Content = "要推送的内容";
string msg_content = "{\"n_builder_id\":\"00\",\"n_title\":\"" + Title + "\",\"n_content\":\"" + Content