极光推送工具类

本文主要介绍对接对接极光推送，包括发送自定义消息等。需要的朋友可以参考一下。

1.springboot对接极光推送,pom文件增加如下配置：

<groupId>cn.jpush.api</groupId>

<artifactId>jpush-client</artifactId>

</dependency>

2.springboot对接application配置:

jpush:

appKey: 您的appKey

masterSecret: 您的masterSecret

liveTime: 1000

apnsProduction: true # 是否生成环境，true表示生成环境

3.JpushServiceImpl工具类

@Service

@Slf4j

public class JpushServiceImpl {

@Resource

JPushProperties jpushConfig;

/**

* 发送自定义消息，由APP端拦截信息后再决定是否创建通知(目前APP用此种方式)

* @param title App通知栏标题

* @param content App通知栏内容（为了单行显示全，尽量保持在22个汉字以下）

* @param extrasMap 额外推送信息（不会显示在通知栏，传递数据用）

* @param alias 别名数组，设定哪些用户手机能接收信息（为空则所有用户都推送）

* @return PushResult

public PushResult sendCustomPush(String title,String content,Map extrasMap,String... alias)throws APIConnectionException,APIRequestException {

ClientConfig clientConfig =ClientConfig.getInstance();

clientConfig.setTimeToLive(Long.parseLong(jpushConfig.getLiveTime()));

clientConfig.setApnsProduction(jpushConfig.isApnsProduction());

// 使用NativeHttpClient网络客户端，连接网络的方式，不提供回调函数

JPushClient jpushClient =new JPushClient(jpushConfig.getMasterSecret(),jpushConfig.getAppkey(),null,

clientConfig);

// 设置为消息推送方式为仅推送消息，不创建通知栏提醒

// PushPayload payload = buildCustomPushPayload(title, content, extrasMap, alias);

PushPayload payload = buildCustomPushPayload(title, content, extrasMap, alias);

PushResult result =jpushClient.sendPush(payload);

return result;

}

/**

* 发送通知消息

* @param title App通知栏标题

* @param content App通知栏内容（为了单行显示全，尽量保持在22个汉字以下）

* @param extrasMap 额外推送信息（不会显示在通知栏，传递数据用）

* @param alais 标签数组，设定哪些用户手机能接收信息（为空则所有用户都推送）

public PushResult sendPush(String title,String content,Map extrasMap,String... alais)throws APIConnectionException,APIRequestException {

ClientConfig clientConfig =ClientConfig.getInstance();

clientConfig.setTimeToLive(Long.valueOf(jpushConfig.getLiveTime()));

clientConfig.setApnsProduction(jpushConfig.isApnsProduction());

// 使用NativeHttpClient网络客户端，连接网络的方式，不提供回调函数

JPushClient jpushClient =new JPushClient(jpushConfig.getMasterSecret(),jpushConfig.getAppkey(),null,

clientConfig);

// 设置推送方式

PushPayload payload = buildPushLoadByAlias(title, content, extrasMap, alais);

PushResult result =jpushClient.sendPush(payload);

return result;

}

/**

* 异步请求推送方式

* 使用NettyHttpClient,异步接口发送请求，通过回调函数可以获取推送成功与否情况

* @param title 通知栏标题

* @param content 通知栏内容（为了单行显示全，尽量保持在22个汉字以下）

* @param extrasMap 额外推送信息（不会显示在通知栏，传递数据用）

* @param alias 需接收的用户别名数组（为空则所有用户都推送）

public void sendPushWithCallback(String title,String content,Map extrasMap,String... alias) {

ClientConfig clientConfig =ClientConfig.getInstance();

clientConfig.setTimeToLive(Long.valueOf(jpushConfig.getLiveTime()));

clientConfig.setApnsProduction(jpushConfig.isApnsProduction());

String host = (String)clientConfig.get(ClientConfig.PUSH_HOST_NAME);

NettyHttpClient client =new NettyHttpClient(

ServiceHelper.getBasicAuthorization(jpushConfig.getAppkey(),jpushConfig.getMasterSecret()),null,

clientConfig);

try {

URI uri =new URI(host +clientConfig.get(ClientConfig.PUSH_PATH));

PushPayload payload = buildPushPayload(title, content, extrasMap, alias);

client.sendRequest(HttpMethod.POST,payload.toString(),uri,new NettyHttpClient.BaseCallback() {

@Override

public void onSucceed(ResponseWrapper responseWrapper) {

if (200 == responseWrapper.responseCode) {

log.info("极光推送成功");

}else {

log.info("极光推送失败，返回结果: " + responseWrapper.responseContent);

}

});

}catch (URISyntaxException e) {

e.printStackTrace();

}finally {

// 需要手动关闭Netty请求进程,否则会一直保留

client.close();

}

/**

* 设置、更新、设备的 tag, alias 信息。

* @param registrationId 设备的registrationId

* @param alias 更新设备的别名属性

* @param tagsToAdd 添加设备的tag属性

* @param tagsToRemove 移除设备的tag属性

public void UpdateDeviceTagAlias(String registrationId,String alias,Set tagsToAdd,Set tagsToRemove)throws APIConnectionException,APIRequestException {

JPushClient jpushClient =new JPushClient(jpushConfig.getMasterSecret(),jpushConfig.getAppkey());

jpushClient.updateDeviceTagAlias(registrationId, alias, tagsToAdd, tagsToRemove);

}

/**

* 构建Android和IOS的推送通知对象

* @return PushPayload

private PushPayload buildPushPayload(String title,String content,Map extrasMap,String... alias) {

if (extrasMap ==null || extrasMap.isEmpty()) {

extrasMap =new HashMap();

}

// 批量删除数组中空元素

String[]newAlias = removeArrayEmptyElement(alias);

return PushPayload.newBuilder().setPlatform(Platform.android_ios())

// 别名为空，全员推送；别名不为空，按别名推送

.setAudience((null ==newAlias ||newAlias.length ==0) ?Audience.all() :Audience.alias(alias))

// .setAudience(Audience.registrationId("d"))

.setNotification(Notification.newBuilder().setAlert(content)

.addPlatformNotification(

AndroidNotification.newBuilder().setTitle(title).addExtras(extrasMap).build())

.addPlatformNotification(IosNotification.newBuilder().incrBadge(1).addExtras(extrasMap).build())

.build())

.build();

}

/**

* 根据标签推送相应的消息

* @param title 推送消息标题

* @param content 推送消息内容

* @param map 推送额外信息

* @param alias 推送的目标标签

* @return

public PushPayload buildPushLoadByAlias(String title,String content,Map map,String... alias) {

if(map.isEmpty()){

map =new HashMap<>();

}

//批量删除数组中的空元素

// String[] newTags = removeArrayEmptyElement(tags);

String[]newAlias = removeArrayEmptyElement(alias);

return PushPayload.newBuilder()

//设置推送平台为安卓

.setPlatform(Platform.android_ios())

//设置标签

.setAudience((null ==newAlias ||newAlias.length ==0) ?Audience.all() :Audience.alias(alias))

//设置推送的标签标题

// 设置通知方式(以alert方式提醒)

.setNotification(Notification.newBuilder().setAlert(content)

.addPlatformNotification(AndroidNotification.newBuilder().setTitle(title).addExtras(map).build()).build())

//sendno int 可选推送序号纯粹用来作为 API 调用标识

//离线消息保留时长推送当前用户不在线时，为该用户保留多长时间的离线消息(默认 86400 （1 天），最长 10 天。设置为 0 表示不保留离线消息，只有推送当前在线的用户可以收到)

//apns_production boolean 可选 APNs是否生产环境 True 表示推送生产环境，False 表示要推送开发环境；如果不指定则为推送生产环境

//big_push_duration int 可选定速推送时长（分钟）又名缓慢推送，把原本尽可能快的推送速度，降低下来，在给定的 n 分钟内，均匀地向这次推送的目标用户推送。最大值为 1440。未设置则不是定速推送

// .setOptions(Options.newBuilder().setApnsProduction(false).setTimeToLive(8600).setBigPushDuration(1).build())

//设置通知内容

// .setMessage(Message.newBuilder().setTitle("").setMsgContent("").setContentType("").build())

.build();

}

/**

* 构建Android和IOS的自定义消息的推送消息对象

* @return PushPayload

private PushPayload buildCustomPushPayload(String title,String content,Map extrasMap,String... alias) {

// 批量删除数组中空元素

String[]newAlias = removeArrayEmptyElement(alias);

return PushPayload.newBuilder().setPlatform(Platform.android_ios())

.setAudience((null ==newAlias ||newAlias.length ==0) ?Audience.all() :Audience.alias(alias))

.setNotification(Notification.newBuilder().setAlert(content)

.addPlatformNotification(AndroidNotification.newBuilder().setTitle(title).addExtras(extrasMap).build()).build())

// .setMessage(Message.newBuilder().setTitle(title).setMsgContent(content).addExtras(extrasMap).build())

.build();

}

/**

* 发送自定义消息，由APP端拦截信息后再决定是否创建通知(目前APP用此种方式)

* @param title App通知栏标题

* @param content App通知栏内容（为了单行显示全，尽量保持在22个汉字以下）

* @param extrasMap 额外推送信息（不会显示在通知栏，传递数据用）

* @param alias 别名数组，设定哪些用户手机能接收信息（为空则所有用户都推送）

* @return PushResult

public PushResult sendCustomPushByAlias(String notify_title,String title,String content,Map extrasMap,String... alias)throws APIConnectionException,APIRequestException {

ClientConfig clientConfig =ClientConfig.getInstance();

clientConfig.setTimeToLive(Long.parseLong(jpushConfig.getLiveTime()));

clientConfig.setApnsProduction(jpushConfig.isApnsProduction());

// 使用NativeHttpClient网络客户端，连接网络的方式，不提供回调函数

JPushClient jpushClient =new JPushClient(jpushConfig.getMasterSecret(),jpushConfig.getAppkey(),null,

clientConfig);

// 设置为消息推送方式为仅推送消息，不创建通知栏提醒

// PushPayload payload = buildCustomPushPayload(title, content, extrasMap, alias);

PushPayload payload = buildPushObject_all_alias_alertWithTitle(notify_title,title, content, extrasMap,alias);

PushResult result =jpushClient.sendPush(payload);

return result;

}

/**

* 推送自定义消息指定别名推送

* @param alias

* @param notification_title

* @param msg_title

* @param msg_content

* @param extrasMap

* @return

private PushPayload buildPushObject_all_alias_alertWithTitle(String notification_title,String msg_title,String msg_content,Map extrasMap,String... alias) {

//创建一个IosAlert对象，可指定APNs的alert、title等字段

//IosAlert iosAlert = IosAlert.newBuilder().setTitleAndBody("title", "alert body").build();

String[]newAlias = removeArrayEmptyElement(alias);

return PushPayload.newBuilder()

//指定要推送的平台，all代表当前应用配置了的所有平台，也可以传android等具体平台

.setPlatform(Platform.all())

//指定推送的接收对象，all代表所有人，也可以指定已经设置成功的tag或alias或该应应用客户端调用接口获取到的registration id

.setAudience((null ==newAlias ||newAlias.length ==0) ?Audience.all() :Audience.alias(alias))

//.setAudience(Audience.all()) //所有人

//.setAudience(Audience.registrationId(registrationId)) //注册ID

//jpush的通知，android的由jpush直接下发，iOS的由apns服务器下发，Winphone的由mpns下发

// .setNotification(Notification.newBuilder()

// //指定当前推送的android通知

// .addPlatformNotification(AndroidNotification.newBuilder()

// .setAlert(msg_content)

// .setTitle(notification_title)

// //此字段为透传字段，不会显示在通知栏。用户可以通过此字段来做一些定制需求，如特定的key传要指定跳转的页面（value）

// .addExtras(extrasMap)

// .build())

// //指定当前推送的iOS通知

// .addPlatformNotification(IosNotification.newBuilder()

// //传一个IosAlert对象，指定apns title、title、subtitle等

// .setAlert(msg_content)

// //直接传alert

// //此项是指定此推送的badge自动加1

// .incrBadge(1)

// //此字段的值default表示系统默认声音；传sound.caf表示此推送以项目里面打包的sound.caf声音来提醒，

// // 如果系统没有此音频则以系统默认声音提醒；此字段如果传空字符串，iOS9及以上的系统是无声音提醒，以下的系统是默认声音

// .setSound("sound.caf")

// //此字段为透传字段，不会显示在通知栏。用户可以通过此字段来做一些定制需求，如特定的key传要指定跳转的页面（value）

// .addExtras(extrasMap)

// //此项说明此推送是一个background推送，想了解background看：http://docs.jpush.io/client/ios_tutorials/#ios-7-background-remote-notification

// //取消此注释，消息推送时ios将无法在锁屏情况接收

// // .setContentAvailable(true)

// .build())

//Platform指定了哪些平台就会像指定平台中符合推送条件的设备进行推送。 jpush的自定义消息，

// sdk默认不做任何处理，不会有通知提示。建议看文档http://docs.jpush.io/guideline/faq/的

// [通知与自定义消息有什么区别？]了解通知和自定义消息的区别

.setMessage(Message.newBuilder()

.setMsgContent(msg_content)

.setTitle(msg_title)

.addExtras(extrasMap)

//.addExtra("url", extrasparam) //释放该字段会发送两次消息，第二次消息内容是扩展字段

.build())

.setOptions(Options.newBuilder()

//此字段的值是用来指定本推送要推送的apns环境，false表示开发，true表示生产；对android和自定义消息无意义

.setApnsProduction(true)

//此字段是给开发者自己给推送编号，方便推送者分辨推送记录

.setSendno(1)

//此字段的值是用来指定本推送的离线保存时长，如果不传此字段则默认保存一天，最多指定保留十天；秒为单位

.setTimeToLive(1 *60 *60 *24)

.build())

.build();

}

/**

* 删除别名中的空元素（需删除如：null,""," "）

* @param strArray

* @return String[]

private String[]removeArrayEmptyElement(String... strArray) {

if (null == strArray || strArray.length ==0) {

return null;

}

ListtempList =Arrays.asList(strArray);

ListstrList =new ArrayList();

Iteratoriterator =tempList.iterator();

while (iterator.hasNext()) {

String str =iterator.next();

// 消除空格后再做比较

if (null !=str && !"".equals(str.trim())) {

strList.add(str);

}

// 若仅输入"",则会将数组长度置为0

String[]newStrArray =strList.toArray(new String[strList.size()]);

return newStrArray;

}

4.JPushProperties配置

@Component

@ConfigurationProperties(prefix ="jpush")

@Data

public class JPushProperties {

/**

* 极光推送应用key

private String appkey;

/**

* 极光推送的密码

private String masterSecret;

/**

* 极光推送设置过期时间

private String liveTime;

private String adminUserId;

private boolean apnsProduction;

public boolean isApnsProduction() {

return apnsProduction;

}

public void setApnsProduction(boolean apnsProduction) {

this.apnsProduction = apnsProduction;

}

public String getAdminUserId() {

return adminUserId;

}

public void setAdminUserId(String adminUserId) {

this.adminUserId = adminUserId;

}

public String getAppkey() {

return appkey;

}

public void setAppkey(String appkey) {

this.appkey = appkey;

}

public String getMasterSecret() {

return masterSecret;

}

public void setMasterSecret(String masterSecret) {

this.masterSecret = masterSecret;

}

public String getLiveTime() {

return liveTime;

}

public void setLiveTime(String liveTime) {

this.liveTime = liveTime;

}

人面猴
序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
沈念sama阅读 215,133评论 6赞 497
死咒
序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
沈念sama阅读 91,682评论 3赞 390
救了他两次的神仙让他今天三更去死
文/潘晓璐我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
开封第一讲书人阅读 160,784评论 0赞 350
道士缉凶录：失踪的卖姜人
文/不坏的土叔我叫张陵，是天一观的道长。经常有香客问我，道长，这世上最难降的妖魔是什么？我笑而不...
开封第一讲书人阅读 57,508评论 1赞 288
港岛之恋（遗憾婚礼）
正文为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
茶点故事阅读 66,603评论 6赞 386
恶毒庶女顶嫁案：这布局不是一般人想出来的
文/花漫我一把揭开白布。她就那样静静地躺着，像睡着了一般。火红的嫁衣衬着肌肤如雪。梳的纹丝不乱的头发上，一...
开封第一讲书人阅读 50,607评论 1赞 293
城市分裂传说
那天，我揣着相机与录音，去河边找鬼。笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。我是一名探鬼主播，决...
沈念sama阅读 39,604评论 3赞 415
双鸳鸯连环套：你想象不到人心有多黑
文/苍兰香墨我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
开封第一讲书人阅读 38,359评论 0赞 270
万荣杀人案实录
序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
沈念sama阅读 44,805评论 1赞 307
护林员之死
正文独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋以下内容为张勋视角年9月15日...
茶点故事阅读 37,121评论 2赞 330
白月光启示录
正文我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
茶点故事阅读 39,280评论 1赞 344
活死人
序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
沈念sama阅读 34,959评论 5赞 339
日本核电站爆炸内幕
正文年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
茶点故事阅读 40,588评论 3赞 322
男人毒药：我在死后第九天来索命
文/蒙蒙一、第九天我趴在偏房一处隐蔽的房顶上张望。院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
开封第一讲书人阅读 31,206评论 0赞 21
一桩弑父案，背后竟有这般阴谋
文/苍兰香墨我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。一阵脚步声响...
开封第一讲书人阅读 32,442评论 1赞 268
情欲美人皮
我被黑心中介骗来泰国打工，没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。一个月前我还...
沈念sama阅读 47,193评论 2赞 367
代替公主和亲
正文我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
茶点故事阅读 44,144评论 2赞 352

极光推送工具类

推荐阅读更多精彩内容