Java后端服务器实现极光推送
Java后端服务器实现极光推送的两种方式
极光推送后台与移动端交互图解
移动端通过别名或者标签的注册去指定某台账号的设备进行推送
其实发起推送请求，只是将信息发布到了极光服务器之上，这个信息有一个保存时限，默认一天（time_to_live = 86400），只要用户登录，极光服务器就会将信息自动推送到对应别名的手机上，信息并不是由我们后台直接推送到手机，而是通过极光服务器这个中转。
1.这里别名alias建议使用userID；（我们的项目里里采用的是userID，貌似都是酱紫。这样的好处就是不需要再去单独随机生成一个别名，往数据库中保存这个字段了。）
2.第二种方式更加简洁易用，记得引入jar包
pom.xml里<dependency> <groupId>cn.jpush.api</groupId> <artifactId>jpush-client</artifactId> <version>3.3.13</version> </dependency>
:{“sound”:“default”,
“badge”:"+1", //设置推送的数量 +1 推送一条
“content-available”:1}
apns_production : true or false
Java后台实现极光推送有两种方式：
1. 一种是使用极光推送官方提供的推送请求API：https://api.jpush.cn/v3/push
package jpush.push;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import org.apache.http.HttpResponse;
import org.apache.http.client.HttpClient;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.DefaultHttpClient;
import org.apache.http.util.EntityUtils;
import sun.misc.BASE64Encoder;
/**
* java后台极光推送方式一：使用Http API
* 此种方式需要自定义http请求发送客户端:HttpClient
*/
public class PushToOne {
private String masterSecret = "XXXXXXX";
private String appKey = "XXXXXXX";
private String pushUrl = "https://api.jpush.cn/v3/push";
private boolean apns_production = true;//为true生产环境 ，为false测试环境，项目上线的时候修改
private int time_to_live = 86400;//有效时间默认一天
private static final String ALERT = "推送信息的内容";
/**
* 极光推送
*/
public void jiguangPush(){
String alias = "123456";//声明别名
try{
String result = push(pushUrl,alias,ALERT,appKey,masterSecret,apns_production,time_to_live);
JSONObject resData = JSONObject.parseObject(result);
if(resData.containsKey("error")){
System.out.println("针对别名为" + alias + "的信息推送失败！");
JSONObject error = JSONObject.parseObject((String) resData.get("error"));
System.out.println("错误信息为：" + error.get("message").toString());
}
System.out.println("针对别名为" + alias + "的信息推送成功！");
}catch(Exception e){
System.out.println("针对别名为" + alias + "的信息推送失败！");
}
}
/**
* 组装极光推送专用json串
* @param alias
* @param alert
* @return json
*/
public static JSONObject generateJson(String alias,String alert,boolean apns_production,int time_to_live){
JSONObject json = new JSONObject();
JSONArray platform = new JSONArray();//限制平台
platform.add("android");
platform.add("ios");
JSONObject audience = new JSONObject();//推送目标
JSONArray alias1 = new JSONArray();
alias1.add(alias);
audience.put("alias", alias1);
JSONObject notification = new JSONObject();//通知内容
JSONObject android = new JSONObject();//android通知内容
android.put("alert", alert);
android.put("builder_id", 1);
JSONObject android_extras = new JSONObject();//android额外参数
android_extras.put("type", "infomation");
android.put("extras", android_extras);
JSONObject ios = new JSONObject();//ios通知内容
ios.put("alert", alert);
ios.put("sound", "default");
ios.put("badge", "+1");
JSONObject ios_extras = new JSONObject();//ios额外参数
ios_extras.put("type", "infomation");
ios.put("extras", ios_extras);
notification.put("android", android);
notification.put("ios", ios);
JSONObject options = new JSONObject();//设置有效期参数默认一天86400
options.put("time_to_live", Integer.valueOf(time_to_live));
options.put("apns_production", apns_production);
json.put("platform", platform);
json.put("audience", audience);
json.put("notification", notification);
json.put("options", options);
return json;
}
/**
* 推送方法-调用极光API
* @param reqUrl
* @param alias
* @param alert
* @return result
*/
public static String push(String reqUrl,String alias,String alert,String appKey,String masterSecret,boolean apns_production,int time_to_live){
String base64_auth_string = encryptBASE64(appKey + ":" + masterSecret);
String authorization = "Basic " + base64_auth_string;
return sendPostRequest(reqUrl,generateJson(alias,alert,apns_production,time_to_live).toString(),"UTF-8",authorization);
}
/**
* 发送Post请求（json格式）
* @param reqURL
* @param data
* @param encodeCharset
* @param authorization
* @return result
*/
@SuppressWarnings({ "resource" })
public static String sendPostRequest(String reqURL, String data, String encodeCharset,String authorization){
HttpPost httpPost = new HttpPost(reqURL);
HttpClient client = new DefaultHttpClient();
HttpResponse response = null;
String result = "";
try {
StringEntity entity = new StringEntity(data, encodeCharset);
entity.setContentType("application/json");
httpPost.setEntity(entity);
httpPost.setHeader("Authorization",authorization.trim());
response = client.execute(httpPost);
result = EntityUtils.toString(response.getEntity(), encodeCharset);
} catch (Exception e) {
System.out.println("请求通信[" + reqURL + "]时偶遇异常,堆栈轨迹如下");
}finally{
client.getConnectionManager().shutdown();
}
return result;
}
/**
* BASE64加密工具
*/
public static String encryptBASE64(String str) {
byte[] key = str.getBytes();
BASE64Encoder base64Encoder = new BASE64Encoder();
String strs = base64Encoder.encodeBuffer(key);
return strs;
}
}
2. 另一种则是使用官方提供的第三方Java SDK（个人推荐）
1）setPlatform：设置接受的平台
2）setAudience：设置推动方式。registrationId是每个手机的唯一标识，当用户安装此App后，就会生成一个唯一的此标识。
3）setOptions：True 表示推送生产环境，False 表示要推送开发环境
4）setAlert：设置App显示的通知内容
5）addExtras：可以通过此字段来做一些定制需求，App根据传的值，跳转到不同的页面。
6）masterSecret、appKey ：这两个参数是注册极光的账户的时候，极光分配的。
package jpush.push;
import cn.jiguang.common.ClientConfig;
import cn.jiguang.common.resp.APIConnectionException;
import cn.jiguang.common.resp.APIRequestException;
import cn.jpush.api.JPushClient;
import cn.jpush.api.push.PushResult;
import cn.jpush.api.push.model.Options;
import cn.jpush.api.push.model.Platform;
import cn.jpush.api.push.model.PushPayload;
import cn.jpush.api.push.model.audience.Audience;
import cn.jpush.api.push.model.notification.AndroidNotification;
import cn.jpush.api.push.model.notification.IosNotification;
import cn.jpush.api.push.model.notification.Notification;
import lombok.extern.slf4j.Slf4j;
/**
* java后台极光推送方式二：使用Java SDK
*/
@Slf4j
//@SuppressWarnings({ "deprecation", "restriction" })
public class PushToOneSDK {
private static String masterSecret = "XXXXXXX";
private static String appKey = "XXXXXXX";
private static final String ALERT = "推送信息";
/**
* 极光推送
*/
public void jiguangPush(){
String alias = "";//声明别名
System.out.println("对别名" + alias + "的用户推送信息");
PushResult result = push(alias,ALERT);
if(result != null && result.isResultOK()){
System.out.println("针对别名" + alias + "的信息推送成功！");
}else{
System.out.println("针对别名" + alias + "的信息推送失败！");
}
}
/**
* 生成极光推送对象PushPayload（采用java SDK）
* @param alias
* @param alert
* @return PushPayload
*/
public static PushPayload buildPushObject_android_ios_alias_alert(String alias,String alert){
return PushPayload.newBuilder()
.setPlatform(Platform.android_ios())
.setAudience(Audience.alias(alias))
//.setAudience(Audience.all()) //全员推送
.setNotification(Notification.newBuilder()
.addPlatformNotification(AndroidNotification.newBuilder()
.addExtra("type", "infomation")
.setAlert(alert)
.build())
.addPlatformNotification(IosNotification.newBuilder()
.addExtra("type", "infomation")
.setAlert(alert)
.build())
.build())
.setOptions(Options.newBuilder()
.setApnsProduction(false)//true-推送生产环境 false-推送开发环境（测试使用参数）
.setTimeToLive(90)//消息在JPush服务器的失效时间（测试使用参数）
.build())
.build();
}
/**
* 极光推送方法(采用java SDK)
* @param alias
* @param alert
* @return PushResult
*/
public static PushResult push(String alias,String alert){
ClientConfig clientConfig = ClientConfig.getInstance();
JPushClient jpushClient = new JPushClient(masterSecret, appKey, null, clientConfig);
PushPayload payload = buildPushObject_android_ios_alias_alert(alias,alert);
try {
return jpushClient.sendPush(payload);
} catch (APIConnectionException e) {
System.out.println("Connection error. Should retry later. "+e);
return null;
} catch (APIRequestException e) {
System.out.println("Error response from JPush server. Should review and fix it. "+ e);
System.out.println("HTTP Status: " + e.getStatus());
System.out.println("Error Code: " + e.getErrorCode());
System.out.println("Error Message: " + e.getErrorMessage());
System.out.println("Msg ID: " + e.getMsgId());
return null;
}
}
}
在下才疏学浅，如有说的不准确的地方或者有什么补充欢迎大佬们指出，谢谢！
原文地址:https://blog.csdn.net/weixin_44172352/article/details/103203919