APP极光推送工具类

package com.donghui.oa.util;

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.Message;

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.audience.AudienceTarget;

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 org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import java.util.ArrayList;

import java.util.List;

/**

* @Description //TODO  极光推送工具类

* @Author wjq

* @time: 2020/9/16 17:22

* 官方示例 https://github.com/jpush/jpush-api-java-client

*/

public class JgPushClientUtil {

    private static Logger logger =LoggerFactory.getLogger(JgPushClientUtil.class);

private JPushClient jPushClient;

public JgPushClientUtil(String APP_KEY,String MASTER_SECRET) {

        this.jPushClient =new JPushClient(MASTER_SECRET, APP_KEY,null,ClientConfig.getInstance());

}

    public JPushClient getJPushClient(){

        return jPushClient;

}

    // 极光单词最多发送一千个用户

    // 将发用户集合 分割成 1000个元素为一组的 二位数组

    private ArrayList<List> allotAliasList(ArrayList<List> arrayLists,List<String> alias,

int listSize,int startIndex,int constantLimitSize){

        if (listSize > constantLimitSize) {

            List<String> list =new ArrayList<>();

list.addAll(alias.subList(startIndex, startIndex+constantLimitSize));

arrayLists.add(list);

listSize = listSize - constantLimitSize;

startIndex = startIndex + constantLimitSize;

allotAliasList(arrayLists,alias,listSize,startIndex,constantLimitSize);

}else{

            arrayLists.add(alias.subList(startIndex, startIndex + listSize));

}

        return arrayLists;

}

    /**

    * 推送给设备标识参数的用户

    * @param totalAlias 设备标识

    * @param notification_title 通知内容标题

    * @param msg_title 消息内容标题

    * @param msg_content 消息内容

    * @param extrasparam 扩展字段（通常传跳转的链接）

    * @return 0推送失败，1推送成功

    */

    public int sendToRegistrationId(List<String> totalAlias,String notification_title,String msg_title,String msg_content,String extrasparam,Boolean apnsProduction) {

        int result =1;

ArrayList<List> lists =null;

try {

            lists = allotAliasList(new ArrayList<List>(), totalAlias, totalAlias.size(),0,1000);

}catch (Exception e){

            e.printStackTrace();

}

        for (List alias : lists) {

            PushPayload pushPayload= buildPushObject_all_alias_alertWithTitle(alias,notification_title,msg_title,msg_content,extrasparam,apnsProduction);

try {

                PushResult pushResult=jPushClient.sendPush(pushPayload);

if(pushResult.getResponseCode()==200){

                }else{

                    result =0;

}

                logger.info("[极光推送]PushResult result is " +pushResult);

} catch (APIConnectionException e) {

                result =0;

logger.error("[极光推送]Connection error. Should retry later. ", e);

} catch (APIRequestException e) {

                result =0;

logger.error("[极光推送]Error response from JPush server. Should review and fix it. ", e);

logger.info("[极光推送]HTTP Status: " + e.getStatus());

logger.info("[极光推送]Error Code: " + e.getErrorCode());

logger.info("[极光推送]Error Message: " + e.getErrorMessage());

}

}

        jPushClient.close();

return result;

}

    private PushPayload buildPushObject_all_alias_alertWithTitle(List<String> alias,String notification_title,String msg_title,String msg_content,String extrasparam,Boolean apnsProduction) {

        return PushPayload.newBuilder()

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

                .setPlatform(Platform.all())

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

                .setAudience(Audience.alias(alias))

                //.setAudience(Audience.registrationId(registrationId))

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

                .setNotification(Notification.newBuilder()

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

                        .addPlatformNotification(AndroidNotification.newBuilder()

                                .setAlert(msg_content)

                                .setTitle(notification_title)

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

                                .addExtra("param", extrasparam)

                                .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）

                                .addExtra("param", extrasparam)

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

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

                                // .setContentAvailable(true)

                                .build())

                        .build())

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

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

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

                .setMessage(Message.newBuilder()

                        .setMsgContent(msg_content)

                        .setTitle(msg_title)

                        .addExtra("url", extrasparam)

                        .build())

                .setOptions(Options.newBuilder()

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

                        .setApnsProduction(apnsProduction)

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

                        .setSendno(1)

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

                        .setTimeToLive(86400)

                        .build())

                .build();

}

    public PushPayload buildPushObject_ios_audienceMore_messageWithExtras() {

        return PushPayload.newBuilder()

                .setPlatform(Platform.android_ios())

                .setAudience(Audience.newBuilder()

                        .addAudienceTarget(AudienceTarget.tag("2787"))

                        .addAudienceTarget(AudienceTarget.alias("2787"))

                        .build())

                .setMessage(Message.newBuilder()

                        .setMsgContent("MSG_CONTENT")

                        .addExtra("from","JPush")

                        .build())

                .build();

}

    public PushPayload buildPushObject_all_all_alert() {

        return PushPayload.alertAll("Test from API Example - alert");

}

    public PushPayload buildPushObject_all_alias_alert() {

        return PushPayload.newBuilder()

                .setPlatform(Platform.all())

                .setAudience(Audience.alias("2787"))

                .setNotification(Notification.alert("Test from API Example - alert"))

                .build();

}

    public static void main(String[] args) {

        JgPushClientUtil jgPushClientUtil =new JgPushClientUtil("d74310dd52bf5e59e67fa29e","5850bd282763077e38362588");

ArrayList<String> list =new ArrayList<>();

list.add("354");

jgPushClientUtil.sendToRegistrationId(list,"title","msg_title","中秋通知",

"{\"business_code\":\"100\",\"data\":{\"id\":"+1+"}}",false);

//        List alias = new ArrayList<>();

//        for (int i = 0; i < 11; i++) {

//            alias.add(i+"");

//        }

//

//        ArrayList lists = jgPushClientUtil.allotAliasList(new ArrayList(), alias,

//                alias.size(), 0, 10);

//

//        System.out.println(lists);

    }

}

©著作权归作者所有,转载或内容合作请联系作者
平台声明：文章内容（如有图片或视频亦包括在内）由作者上传并发布，文章内容仅代表作者本人观点，简书系信息发布平台，仅提供信息存储服务。

推荐阅读更多精彩内容

  • 极光推送工具类
    本文主要介绍对接对接极光推送，包括发送自定义消息等。需要的朋友可以参考一下。 1.springboot对接极光推送...
    owen_7815阅读 1,199评论 0赞 1
  • 极光推送工具类
    所选依赖： 工具类：一、 package com.xxx.core.util.push.enums; /** 配置...
    Y_LY阅读 1,909评论 0赞 2
  • 极光推送1
    package com.jpxx.jpwgh.util; import net.sf.json.JSONObjec...
    蛋皮皮652阅读 334评论 0赞 0
  • 【极光推送】给指定用户发送消息
    前言 如果你还没有搭建极光推送服务器，建议你根据情况，先从服务器搭建开始。 前文标题： 《【极光推送】jpush服...
    左岸花不开阅读 11,184评论 1赞 6
  • 极光推送总结
    应用场景：在我们的项目中我们用的是创建视频会议和预警消息通知推送这两种情况，首先创建视频会议和中途邀请人参加会议我...
    蛋皮皮652阅读 3,699评论 1赞 2