devbox
空白诗007
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

java-极光推送（服务端）_极光推送java

作者：空白诗007 | 2024-08-08 23:06:17

赞

踩

极光推送java

目录

一.极光简介

1.极光官网地址

2.极光api地址

3.极光SDK下载地址

4.内容介绍

推送人群（Audience）

二.代码

1.导入依赖

2.极光推送工具类

1.一类

2.二类

3.三类

一.极光简介

1.极光官网地址

注册登录   应用管理创建应用进入应用设置  获取服务端需要用到AppKey和Master Secret

极光推送-中国领先的客户互动和营销科技服务商,助力企业运营、增长和变现极光基于海量数据为移动开发者提供消息推送、一键认证、短信发送、即时通讯、数据统计、统一消息系统等服务,以及一站式流量接入、行业应用的运营解决方案,助力企业运营、增长和变现.https://www.jiguang.cn/

2.极光api地址

极光文档极光文档，极光开发者文档https://docs.jiguang.cn/jpush/server/push/server_overview

3.极光SDK下载地址

极光文档极光文档，极光开发者文档https://docs.jiguang.cn/jpush/resources

4.内容介绍

推送平台：

JPush 当前支持 Android, iOS, QuickApp，Windows Phone 四个平台的推送。其关键字分别为："android", "ios", "quickapp"。

如果目标平台为 iOS 平台，推送 Notification 时需要在 options 中通过 apns_production 字段来设定推送环境。True 表示推送生产环境，False 表示要推送开发环境； 如果不指定则为推送生产环境；一次只能推送给一个环境。

推送目标：广播（所有用户）、alias（别名：用别名来标识一个用户）、tag（标签：用标签来进行大规模的设备属性、用户属性分群。 一次推送最多 20 个）等。

推送方式：通知、自定义消息，富媒体和本地通知。

  • 通知

或者说 Push Notification，即指在手机的通知栏（状态栏）上会显示的一条通知信息。 通知主要用来达到提示用户的目的，应用于新闻内容、促销活动、产品信息、版本更新提醒、订单状态提醒等多种场景

  • 自定义消息

自定义消息不是通知，所以不会被 SDK 展示到通知栏上。其内容完全由开发者自己定义。 自定义消息主要用于应用的内部业务逻辑。一条自定义消息推送过来，有可能没有任何界面显示。

  • 本地通知

本地通知 API 不依赖于网络，无网条件下依旧可以触发；本地通知的定时时间是自发送时算起的，不受中间关机等操作的影响。 本地通知与网络推送的通知是相互独立的，不受保留最近通知条数上限的限制。 本地通知适用于在特定时间发出的通知，如一些 Todo 和闹钟类的应用，在每周、每月固定时间提醒用户回到应用查看任务。

推送人群（Audience）

  1. 广播（所有人）
  2. 注册ID（RegistrationID）
  3. 别名（alias）
  4. 标签（tag，分组）
  5. 用户分群（Segment）

注册ID（RegistrationID）

RegistrationID 就是这台设备（以及当前这个 App），被推送服务器分配的唯一 ID。不同的设备、不同的 App 这个 ID 肯定不同的。

SDK 在第一次启动时会去服务器端进行注册并识别，服务器端会分配一个 RegistrationID。SDK 会把这个 ID 通过广播（或通知）的方式发给 App。SDK 也提供了获取 RegistrationID 的接口。

如果一个 App 在这台设备上之前安装过，然后被卸载掉。重新安装时，其获取到的 RegistrationID 有一定的可能性不变。这取决于平台以及条件。

  • Android 上 JPush 会综合利用多个条件来判断设备是否相同，从而 RegistrationID 不变的可能性很大。
  • iOS 老版本上，因为 device token 重新安装 App 时也不会变，从而 RegistrationID 也一般不会变。
  • iOS8 以后重新安装 App 会导致 device token 变更，iOS 上如果不启用 IDFA 则没有其他可用于识别设备的手段，从而 RegistrationID 一般会变化。或者说，服务器端无法识别重新安装。所以如果你的业务有需要，建议启用 IDFA。

使用 RegistrationID 推送的关键于，App 开发者需要在开发 App 时，获取到这个 RegistrationID，保存到 App 业务服务器上去，并且与自己的用户标识对应起来。

建议 App 开发者尽可能做这个保存动作。因为这是最精确地定位到设备的。

别名（alias）

别名可以理解为基于 RegistrationID，设置一个更容易理解的『别名』，比如直接设置为当前登录用户的 username。

一个设备（在一个 App 里）只能设置一个别名。

别名的本质是，把 App 用户体系里的用户ID与 RegistrationID 的对应关系，保存到推送服务器上，而不是保存到 App 业务服务器上去。（使用 RegistrationID 就是把对应关系保存到 App 业务服务器上去。）

设置了别名后，推送时服务器端指定别名即可。推送服务器端来把别名转化到 RegistrationID找到设备。

别名可以在客户端设置，服务器端也提供了 REST API 进行设置。但是，在一个 App 的生命周期中，强烈建议不要既在客户端又在服务器端进行设置，否则会导致混乱。

标签（tag）

又或者称为分组推送。对于大量的设置了同一个标签的终端，可以一次推送到到达。一个应用里一个标签绑定到的设备数没有限制。

一个设备（在一个 App里）可以设置多个标签。

标签与别名类似，其对应关系也是保存在推送服务器侧的。

与别名类似，标签也是可以在客户端设置，服务器端也开放了 REST API 进行设置。同样，也是强烈建议，不要既在客户端设置标签，又在服务器端设置标签，以免造成混乱。

用户分群（Segment）

这是相对高级的使用方式了，开发者可以根据一些已知的条件，任意组合，创建一个 SegmentID。然后基于这个 SegmentID 进行推送。

上面说到的可以用于用户分群的条件有：tags，App 版本，SDK 版本，平台版本，用户注册时间，用户活跃时间，用户所在城市等。

广播（所有人）

技术上广播很好理解，就是推送给所有安装的 App 的设备终端。

极光推送对广播有一个特殊的选项：延迟推送。这是个很有特色的功能，让推送在一定时长内平均分配，而不是在太短时间内完成，以免对 App 业务服务器造成太大的压力。

根据业务场景选择推送人群

以上以极光推送为例介绍了支持的推送人群类别。但是，任何技术都有一个使用场景的问题。开发者需要想清楚自己的使用场景，来选择适当的类别。

单用户推送

RegistrationID 与别名是设计用来单用户推送的。

如果别名只是在一个设备上被设置，则其效果与 RegistrationID 是类似的。

不同的是，一个别名是可以被设置到多设备上的。一个常见的场景是，把 App 的用户帐号 username 作为别名。一个 App用户帐号可以在多设备上登录（大多数这样），就可以在多设备上绑定为别名。这样推送给这个别名，多设备上都收到。

由于别名的绑定关系保存在推送服务器上，App 业务上要做变更就不够灵活。所以，别名更适合于简单的使用场景，也是适合「懒」的开发者。而 App 想要有灵活性，建议使用 RegistrationID 的方式。

别名在使用时，有可能被误使用为 tag，即大量的设备上都设置同一个别名，其实就是 tag 的使用方式。极光推送发现了不少 App 这样子用。

用户分群与标签

标签是个很灵活的分组方法，可以被用于业务强相关的各种场景。主要的种类有：订阅，用户属性。

订阅类，比如彩票 App 用于用户订阅不同彩票类型的最新开奖信息，阅读类 App 用于让用户订阅多个频道的最新资讯等。

用 tag 来标注用户的属性，比如性别、年龄段、喜好、关注等，也是个很常见的作法，这样推送时就可以基于这些属性来做。这也是精细化推送的基础。

事实上，很多标签被开发者定义为：App 版本，用户城市，使用语言等等。现在很多这类的 tags 可以不要了，只需要直接使用用户分群功能就可以了。

二.代码

1.导入依赖

  1.  <!-- jpush -->
  2.         <dependency>
  3.             <groupId>cn.jpush.api</groupId>
  4.             <artifactId>jpush-client</artifactId>
  5.             <version>3.3.9</version>
  6.         </dependency>
  7.  
  8.         <dependency>
  9.             <groupId>cn.jpush.api</groupId>
  10.             <artifactId>jiguang-common</artifactId>
  11.             <version>1.0.3</version>
  12.         </dependency>

2.极光推送工具类

1.一类

  1. package com.zh.erp.framework.util.jpush;
  2.  
  3. import cn.jiguang.common.ClientConfig;
  4. import cn.jiguang.common.ServiceHelper;
  5. import cn.jiguang.common.connection.NativeHttpClient;
  6. import cn.jiguang.common.connection.NettyHttpClient;
  7. import cn.jiguang.common.resp.APIConnectionException;
  8. import cn.jiguang.common.resp.APIRequestException;
  9. import cn.jiguang.common.resp.ResponseWrapper;
  10. import cn.jpush.api.JPushClient;
  11. import cn.jpush.api.push.CIDResult;
  12. import cn.jpush.api.push.GroupPushClient;
  13. import cn.jpush.api.push.PushResult;
  14. import cn.jpush.api.push.model.*;
  15. import cn.jpush.api.push.model.audience.Audience;
  16. import cn.jpush.api.push.model.audience.AudienceTarget;
  17. import cn.jpush.api.push.model.notification.*;
  18. import com.google.gson.Gson;
  19. import com.google.gson.GsonBuilder;
  20. import com.google.gson.JsonObject;
  21. import com.google.gson.JsonPrimitive;
  22. import io.netty.handler.codec.http.HttpMethod;
  23. import org.slf4j.Logger;
  24. import org.slf4j.LoggerFactory;
  25.  
  26. import java.net.URI;
  27. import java.net.URISyntaxException;
  28. import java.util.*;
  29.  
  30. public class PushExample {
  31.     protected static final Logger LOG = LoggerFactory.getLogger(PushExample.class);
  32.  
  33.     // demo App defined in resources/jpush-api.conf 
  34.     protected static final String APP_KEY1 = "274e2f473f13f6fa679368ae";
  35.     protected static final String APP_KEY = "ebd355e590e6f7f93ba51477";
  36.     protected static final String MASTER_SECRET1 = "896bb372344468fc0e3e47d4";
  37.     protected static final String MASTER_SECRET = "2604f3b0706d46bd47ba919b";
  38.     protected static final String GROUP_PUSH_KEY = "caff9bd51218a2def8d1a350";
  39.     protected static final String GROUP_MASTER_SECRET = "06edba1d32ca66d9a54fd787";
  40.  
  41.     public static final String TITLE = "Test from API example";
  42.     public static final String ALERT = "Test from API Example - alert";
  43.     public static final String MSG_CONTENT = "Test from API Example - msgContent";
  44.     public static final String REGISTRATION_ID = "0900e8d85ef";
  45.     public static final String TAG = "tag_api";
  46.     public static long sendCount = 0;
  47.     private static long sendTotalTime = 0;
  48.  
  49.     public static void main(String[] args) {
  50.  
  51.         // 回调参数可参考下面方法
  52.     //    testSendPushWithCustom();  //
  53.    //     testSendPushWithCustomField();  //
  54. //        testBatchSend();
  55.      //   testSendPushWithCustomConfig();  //
  56.         asynSendMessageWithCallback("user_1648_1062","您有一个新任务等待处理！","您有一个新任务等待处理！",
  57.                 "上海市浦东新区祝桥镇大沙路东海集贸市场","上海市浦东新区祝桥镇大沙路东海集贸市场","");
  58.         //pushAline("user_1648_1062","您有一个新任务等待处理！","上海市浦东新区祝桥镇大沙路东海集贸市场");
  59. //        testSendIosAlert();
  60. //		testSendPush();
  61. //        testGetCidList();
  62. //        testSendPushes();
  63.       //  testSendPush_fromJSON(); //
  64. //        testSendPushWithCallback();
  65. //		testSendPushWithCid();
  66.     }
  67.  
  68.     // 使用 NettyHttpClient 异步接口发送请求
  69.     public static void testSendPushWithCallback() {
  70.         ClientConfig clientConfig = ClientConfig.getInstance();
  71.         String host = (String) clientConfig.get(ClientConfig.PUSH_HOST_NAME);
  72.         final NettyHttpClient client = new NettyHttpClient(ServiceHelper.getBasicAuthorization(APP_KEY, MASTER_SECRET),
  73.                 null, clientConfig);
  74.         try {
  75.             URI uri = new URI(host + clientConfig.get(ClientConfig.PUSH_PATH));
  76.             PushPayload payload = buildPushObject_all_alias_alert();
  77.             client.sendRequest(HttpMethod.POST, payload.toString(), uri, new NettyHttpClient.BaseCallback() {
  78.                 @Override
  79.                 public void onSucceed(ResponseWrapper responseWrapper) {
  80.                     LOG.info("Got result: " + responseWrapper.responseContent);
  81.                 }
  82.             });
  83.         } catch (URISyntaxException e) {
  84.             e.printStackTrace();
  85.         }
  86.     }
  87.  
  88.     public static void testSendPush() {
  89.         ClientConfig clientConfig = ClientConfig.getInstance();
  90.         final JPushClient jpushClient = new JPushClient(MASTER_SECRET, APP_KEY, null, clientConfig);
  91. //        String authCode = ServiceHelper.getBasicAuthorization(APP_KEY, MASTER_SECRET);
  92.         // Here you can use NativeHttpClient or NettyHttpClient or ApacheHttpClient.
  93.         // Call setHttpClient to set httpClient,
  94.         // If you don't invoke this method, default httpClient will use NativeHttpClient.
  95.  
  96. //        ApacheHttpClient httpClient = new ApacheHttpClient(authCode, null, clientConfig);
  97. //        NettyHttpClient httpClient =new NettyHttpClient(authCode, null, clientConfig);
  98. //        jpushClient.getPushClient().setHttpClient(httpClient);
  99.         final PushPayload payload = buildPushObject_android_and_ios();
  100. //        // For push, all you need do is to build PushPayload object.
  101. //        PushPayload payload = buildPushObject_all_alias_alert();
  102.         try {
  103.             PushResult result = jpushClient.sendPush(payload);
  104.             LOG.info("Got result - " + result);
  105.             System.out.println(result);
  106.             // 如果使用 NettyHttpClient，需要手动调用 close 方法退出进程
  107.             // If uses NettyHttpClient, call close when finished sending request, otherwise process will not exit.
  108.             // jpushClient.close();
  109.         } catch (APIConnectionException e) {
  110.             LOG.error("Connection error. Should retry later. ", e);
  111.             LOG.error("Sendno: " + payload.getSendno());
  112.  
  113.         } catch (APIRequestException e) {
  114.             LOG.error("Error response from JPush server. Should review and fix it. ", e);
  115.             LOG.info("HTTP Status: " + e.getStatus());
  116.             LOG.info("Error Code: " + e.getErrorCode());
  117.             LOG.info("Error Message: " + e.getErrorMessage());
  118.             LOG.info("Msg ID: " + e.getMsgId());
  119.             LOG.error("Sendno: " + payload.getSendno());
  120.         }
  121.     }
  122.  
  123.     public static void testSendPushWithEncrypt() {
  124.         ClientConfig clientConfig = ClientConfig.getInstance();
  125.         clientConfig.setEncryptType(EncryptKeys.ENCRYPT_SMS2_TYPE);
  126.         final JPushClient jpushClient = new JPushClient(MASTER_SECRET, APP_KEY, null, clientConfig);
  127. //        String authCode = ServiceHelper.getBasicAuthorization(APP_KEY, MASTER_SECRET);
  128.         // Here you can use NativeHttpClient or NettyHttpClient or ApacheHttpClient.
  129.         // Call setHttpClient to set httpClient,
  130.         // If you don't invoke this method, default httpClient will use NativeHttpClient.
  131.  
  132. //        ApacheHttpClient httpClient = new ApacheHttpClient(authCode, null, clientConfig);
  133. //        NettyHttpClient httpClient =new NettyHttpClient(authCode, null, clientConfig);
  134. //        jpushClient.getPushClient().setHttpClient(httpClient);
  135.         final PushPayload payload = buildPushObject_android_and_ios();
  136. //        // For push, all you need do is to build PushPayload object.
  137. //        PushPayload payload = buildPushObject_all_alias_alert();
  138.         try {
  139.             PushResult result = jpushClient.sendPush(payload);
  140.             LOG.info("Got result - " + result);
  141.             System.out.println(result);
  142.             // 如果使用 NettyHttpClient，需要手动调用 close 方法退出进程
  143.             // If uses NettyHttpClient, call close when finished sending request, otherwise process will not exit.
  144.             // jpushClient.close();
  145.         } catch (APIConnectionException e) {
  146.             LOG.error("Connection error. Should retry later. ", e);
  147.             LOG.error("Sendno: " + payload.getSendno());
  148.  
  149.         } catch (APIRequestException e) {
  150.             LOG.error("Error response from JPush server. Should review and fix it. ", e);
  151.             LOG.info("HTTP Status: " + e.getStatus());
  152.             LOG.info("Error Code: " + e.getErrorCode());
  153.             LOG.info("Error Message: " + e.getErrorMessage());
  154.             LOG.info("Msg ID: " + e.getMsgId());
  155.             LOG.error("Sendno: " + payload.getSendno());
  156.         }
  157.     }
  158.  
  159.     //use String to build PushPayload instance
  160.     public static void testSendPush_fromJSON() {
  161.         ClientConfig clientConfig = ClientConfig.getInstance();
  162.         JPushClient jpushClient = new JPushClient(MASTER_SECRET, APP_KEY, null, clientConfig);
  163.         Gson gson = new GsonBuilder()
  164.                 .registerTypeAdapter(PlatformNotification.class, new InterfaceAdapter<PlatformNotification>())
  165.                 .create();
  166.         // Since the type of DeviceType is enum, thus the value should be uppercase, same with the AudienceType.
  167.         String payloadString = "{\"platform\":{\"all\":false,\"deviceTypes\":[\"IOS\"]},\"audience\":{\"all\":true,\"targets\":[{\"audienceType\":\"TAG_AND\",\"values\":[\"tag1\",\"tag_all\"]}]},\"notification\":{\"notifications\":[{\"soundDisabled\":false,\"badgeDisabled\":false,\"sound\":\"happy\",\"badge\":\"5\",\"contentAvailable\":false,\"alert\":\"Test from API Example - alert\",\"extras\":{\"from\":\"JPush\"},\"type\":\"cn.jpush.api.push.model.notification.IosNotification\"}]},\"message\":{\"msgContent\":\"Test from API Example - msgContent\"},\"options\":{\"sendno\":1429488213,\"overrideMsgId\":0,\"timeToLive\":-1,\"apnsProduction\":true,\"bigPushDuration\":0}}";
  168.         PushPayload payload = gson.fromJson(payloadString, PushPayload.class);
  169.         try {
  170.             PushResult result = jpushClient.sendPush(payloadString);
  171.             LOG.info("Got result - " + result);
  172.  
  173.         } catch (APIConnectionException e) {
  174.             LOG.error("Connection error. Should retry later. ", e);
  175.             // LOG.error("Sendno: " + payload.getSendno());
  176.  
  177.         } catch (APIRequestException e) {
  178.             LOG.error("Error response from JPush server. Should review and fix it. ", e);
  179.             LOG.info("HTTP Status: " + e.getStatus());
  180.             LOG.info("Error Code: " + e.getErrorCode());
  181.             LOG.info("Error Message: " + e.getErrorMessage());
  182.             LOG.info("Msg ID: " + e.getMsgId());
  183.             //LOG.error("Sendno: " + payload.getSendno());
  184.         }
  185.     }
  186.  
  187.     /**
  188.      * 测试多线程发送 2000 条推送耗时
  189.      */
  190.     public static void testSendPushes() {
  191.         ClientConfig clientConfig = ClientConfig.getInstance();
  192.         final JPushClient jpushClient = new JPushClient(MASTER_SECRET, APP_KEY, null, clientConfig);
  193.         String authCode = ServiceHelper.getBasicAuthorization(APP_KEY, MASTER_SECRET);
  194.         // Here you can use NativeHttpClient or NettyHttpClient or ApacheHttpClient.
  195.         NativeHttpClient httpClient = new NativeHttpClient(authCode, null, clientConfig);
  196.         // Call setHttpClient to set httpClient,
  197.         // If you don't invoke this method, default httpClient will use NativeHttpClient.
  198. //        ApacheHttpClient httpClient = new ApacheHttpClient(authCode, null, clientConfig);
  199.         jpushClient.getPushClient().setHttpClient(httpClient);
  200.         final PushPayload payload = buildPushObject_ios_tagAnd_alertWithExtrasAndMessage();
  201.         for (int i = 0; i < 10; i++) {
  202.             Thread thread = new Thread() {
  203.                 public void run() {
  204.                     for (int j = 0; j < 200; j++) {
  205.                         long start = System.currentTimeMillis();
  206.                         try {
  207.                             PushResult result = jpushClient.sendPush(payload);
  208.                             LOG.info("Got result - " + result);
  209.  
  210.                         } catch (APIConnectionException e) {
  211.                             LOG.error("Connection error. Should retry later. ", e);
  212.                             LOG.error("Sendno: " + payload.getSendno());
  213.  
  214.                         } catch (APIRequestException e) {
  215.                             LOG.error("Error response from JPush server. Should review and fix it. ", e);
  216.                             LOG.info("HTTP Status: " + e.getStatus());
  217.                             LOG.info("Error Code: " + e.getErrorCode());
  218.                             LOG.info("Error Message: " + e.getErrorMessage());
  219.                             LOG.info("Msg ID: " + e.getMsgId());
  220.                             LOG.error("Sendno: " + payload.getSendno());
  221.                         }
  222.  
  223.                         System.out.println("耗时" + (System.currentTimeMillis() - start) + "毫秒 sendCount:" + (++sendCount));
  224.                     }
  225.                 }
  226.             };
  227.             thread.start();
  228.         }
  229.     }
  230.  
  231.     public void testSendGroupPush() {
  232.         GroupPushClient groupPushClient = new GroupPushClient(GROUP_MASTER_SECRET, GROUP_PUSH_KEY);
  233.         final PushPayload payload = buildPushObject_android_and_ios();
  234.         try {
  235.             Map<String, PushResult> result = groupPushClient.sendGroupPush(payload);
  236.             for (Map.Entry<String, PushResult> entry : result.entrySet()) {
  237.                 PushResult pushResult = entry.getValue();
  238.                 PushResult.Error error = pushResult.error;
  239.                 if (error != null) {
  240.                     LOG.info("AppKey: " + entry.getKey() + " error code : " + error.getCode() + " error message: " + error.getMessage());
  241.                 } else {
  242.                     LOG.info("AppKey: " + entry.getKey() + " sendno: " + pushResult.sendno + " msg_id:" + pushResult.msg_id);
  243.                 }
  244.  
  245.             }
  246.         } catch (APIConnectionException e) {
  247.             LOG.error("Connection error. Should retry later. ", e);
  248.             LOG.error("Sendno: " + payload.getSendno());
  249.  
  250.         } catch (APIRequestException e) {
  251.             LOG.error("Error response from JPush server. Should review and fix it. ", e);
  252.             LOG.info("HTTP Status: " + e.getStatus());
  253.             LOG.info("Error Code: " + e.getErrorCode());
  254.             LOG.info("Error Message: " + e.getErrorMessage());
  255.             LOG.info("Msg ID: " + e.getMsgId());
  256.             LOG.error("Sendno: " + payload.getSendno());
  257.         }
  258.     }
  259.  
  260.     public static PushPayload buildPushObject_all_all_alert() {
  261.         return PushPayload.alertAll(ALERT);
  262.     }
  263.  
  264.     public static PushPayload buildPushObject_all_alias_alert() {
  265.         return PushPayload.newBuilder()
  266.                 .setPlatform(Platform.all())
  267.                 .setAudience(Audience.alias("alias1"))
  268.                 .setNotification(Notification.alert(ALERT))
  269.                 .build();
  270.     }
  271.  
  272.     public static PushPayload buildPushObject_android_tag_alertWithTitle() {
  273.         return PushPayload.newBuilder()
  274.                 .setPlatform(Platform.android())
  275.                 .setAudience(Audience.tag("tag1"))
  276.                 .setNotification(Notification.android(ALERT, TITLE, null))
  277.                 .build();
  278.     }
  279.  
  280.     public static PushPayload buildPushObject_android_and_ios() {
  281.         Map<String, String> extras = new HashMap<String, String>();
  282.         extras.put("test", "https://community.jiguang.cn/push");
  283.         return PushPayload.newBuilder()
  284.                 .setPlatform(Platform.android_ios())
  285.                 .setAudience(Audience.all())
  286.                 .setNotification(Notification.newBuilder()
  287.                         .setAlert("alert content")
  288.                         .addPlatformNotification(AndroidNotification.newBuilder()
  289.                                 .setTitle("Android Title")
  290.                                 .addExtras(extras).build())
  291.                         .addPlatformNotification(IosNotification.newBuilder()
  292.                                 .incrBadge(1)
  293.                                 .addExtra("extra_key", "extra_value").build())
  294.                         .build())
  295.                 .build();
  296.     }
  297.  
  298.     public static void buildPushObject_with_extra() {
  299.  
  300.         JsonObject jsonExtra = new JsonObject();
  301.         jsonExtra.addProperty("extra1", 1);
  302.         jsonExtra.addProperty("extra2", false);
  303.  
  304.         Map<String, String> extras = new HashMap<String, String>();
  305.         extras.put("extra_1", "val1");
  306.         extras.put("extra_2", "val2");
  307.  
  308.         PushPayload payload = PushPayload.newBuilder()
  309.                 .setPlatform(Platform.android_ios())
  310.                 .setAudience(Audience.tag("tag1"))
  311.                 .setNotification(Notification.newBuilder()
  312.                         .setAlert("alert content")
  313.                         .addPlatformNotification(AndroidNotification.newBuilder()
  314.                                 .setTitle("Android Title")
  315.                                 .addExtras(extras)
  316.                                 .addExtra("booleanExtra", false)
  317.                                 .addExtra("numberExtra", 1)
  318.                                 .addExtra("jsonExtra", jsonExtra)
  319.                                 .build())
  320.                         .addPlatformNotification(IosNotification.newBuilder()
  321.                                 .incrBadge(1)
  322.                                 .addExtra("extra_key", "extra_value").build())
  323.                         .build())
  324.                 .build();
  325.  
  326.         System.out.println(payload.toJSON());
  327.     }
  328.  
  329.     public static PushPayload buildPushObject_ios_tagAnd_alertWithExtrasAndMessage() {
  330.         JsonObject sound = new JsonObject();
  331.         sound.add("critical", new JsonPrimitive(1));
  332.         sound.add("name", new JsonPrimitive("default"));
  333.         sound.add("volume", new JsonPrimitive(0.2));
  334.         return PushPayload.newBuilder()
  335.                 .setPlatform(Platform.ios())
  336.                 .setAudience(Audience.tag_and("tag1", "tag_all"))
  337.                 .setNotification(Notification.newBuilder()
  338.                         .addPlatformNotification(IosNotification.newBuilder()
  339.                                 .setAlert(ALERT)
  340.                                 .setBadge(5)
  341.                                 .setMutableContent(false)
  342. //                                .setSound("happy")
  343.                                 .setSound(sound)
  344.                                 .addExtra("from", "JPush")
  345.                                 .build())
  346.                         .build())
  347.                 .setMessage(Message.content(MSG_CONTENT))
  348.                 .setOptions(Options.newBuilder()
  349.                         .setApnsProduction(true)
  350.                         .build())
  351.                 .build();
  352.     }
  353.  
  354.     public static PushPayload buildPushObject_android_newly_support() {
  355.  
  356.         JsonObject inbox = new JsonObject();
  357.         inbox.add("line1", new JsonPrimitive("line1 string"));
  358.         inbox.add("line2", new JsonPrimitive("line2 string"));
  359.         inbox.add("contentTitle", new JsonPrimitive("title string"));
  360.         inbox.add("summaryText", new JsonPrimitive("+3 more"));
  361.  
  362.         JsonObject intent = new JsonObject();
  363.         intent.add("url", new JsonPrimitive("intent:#Intent;component=com.jiguang.push/com.example.jpushdemo.SettingActivity;end"));
  364.  
  365.         Notification notification = Notification.newBuilder()
  366.                 .addPlatformNotification(AndroidNotification.newBuilder()
  367.                         .setAlert(ALERT)
  368.                         .setBigPicPath("path to big picture")
  369.                         .setBigText("long text")
  370.                         .setBuilderId(1)
  371.                         .setCategory("CATEGORY_SOCIAL")
  372.                         .setInbox(inbox)
  373.                         .setStyle(1)
  374.                         .setTitle("Alert test")
  375.                         .setPriority(1)
  376.                         .setLargeIcon("http://www.jiguang.cn/largeIcon.jpg")
  377.                         .setIntent(intent)
  378.                         .build())
  379.                 .build();
  380.         return PushPayload.newBuilder()
  381.                 .setPlatform(Platform.all())
  382.                 .setAudience(Audience.all())
  383.                 .setNotification(notification)
  384.                 .setOptions(Options.newBuilder()
  385.                         .setApnsProduction(true)
  386.                         .setSendno(ServiceHelper.generateSendno())
  387.                         .build())
  388.                 .build();
  389.     }
  390.  
  391.     public static PushPayload buildPushObject_ios_audienceMore_messageWithExtras() {
  392.         return PushPayload.newBuilder()
  393.                 .setPlatform(Platform.android_ios())
  394.                 .setAudience(Audience.newBuilder()
  395.                         .addAudienceTarget(AudienceTarget.tag("tag1", "tag2"))
  396.                         .addAudienceTarget(AudienceTarget.alias("alias1", "alias2"))
  397.                         .build())
  398.                 .setMessage(Message.newBuilder()
  399.                         .setMsgContent(MSG_CONTENT)
  400.                         .addExtra("from", "JPush")
  401.                         .build())
  402.                 .build();
  403.     }
  404.  
  405.     public static PushPayload buildPushObject_all_tag_not() {
  406.         return PushPayload.newBuilder()
  407.                 .setPlatform(Platform.all())
  408.                 .setAudience(Audience.tag_not("abc", "123"))
  409.                 .setNotification(Notification.alert(ALERT))
  410.                 .build();
  411.     }
  412.  
  413.     public static PushPayload buildPushObject_android_cid() {
  414.         Collection<String> list = new LinkedList<String>();
  415.         list.add("1507bfd3f79558957de");
  416.         list.add("1507bfd3f79554957de");
  417.         list.add("1507bfd3f79555957de");
  418.         list.add("1507bfd3f79556957de");
  419.         list.add("1507ffd3f79545957de");
  420.         list.add("1507ffd3f79457957de");
  421.         list.add("1507ffd3f79456757de");
  422.  
  423.  
  424.         return PushPayload.newBuilder()
  425.                 .setPlatform(Platform.android())
  426. //                .setAudience(Audience.registrationId("1507bfd3f79558957de"))
  427.                 .setAudience(Audience.registrationId(list))
  428.                 .setNotification(Notification.alert(ALERT))
  429.                 .setCid("cid")
  430.                 .build();
  431.     }
  432.  
  433.     public static void testSendPushWithCustomConfig() {
  434.         ClientConfig config = ClientConfig.getInstance();
  435.         // Setup the custom hostname
  436.         config.setPushHostName("https://api.jpush.cn");
  437.  
  438.         JPushClient jpushClient = new JPushClient(MASTER_SECRET, APP_KEY, null, config);
  439.  
  440.         // For push, all you need do is to build PushPayload object.
  441.         PushPayload payload = buildPushObject_all_all_alert();
  442.  
  443.         try {
  444.             PushResult result = jpushClient.sendPush(payload);
  445.             LOG.info("Got result - " + result);
  446.  
  447.         } catch (APIConnectionException e) {
  448.             LOG.error("Connection error. Should retry later. ", e);
  449.  
  450.         } catch (APIRequestException e) {
  451.             LOG.error("Error response from JPush server. Should review and fix it. ", e);
  452.             LOG.info("HTTP Status: " + e.getStatus());
  453.             LOG.info("Error Code: " + e.getErrorCode());
  454.             LOG.info("Error Message: " + e.getErrorMessage());
  455.             LOG.info("Msg ID: " + e.getMsgId());
  456.         }
  457.     }
  458.  
  459.     public static void testSendIosAlert() {
  460.         JPushClient jpushClient = new JPushClient(MASTER_SECRET, APP_KEY);
  461.  
  462.         IosAlert alert = IosAlert.newBuilder()
  463.                 .setTitleAndBody("test alert", "subtitle", "test ios alert json")
  464.                 .setActionLocKey("PLAY")
  465.                 .build();
  466.         try {
  467.             PushResult result = jpushClient.sendIosNotificationWithAlias(alert, new HashMap<String, String>(), "alias1");
  468.             LOG.info("Got result - " + result);
  469.         } catch (APIConnectionException e) {
  470.             LOG.error("Connection error. Should retry later. ", e);
  471.         } catch (APIRequestException e) {
  472.             LOG.error("Error response from JPush server. Should review and fix it. ", e);
  473.             LOG.info("HTTP Status: " + e.getStatus());
  474.             LOG.info("Error Code: " + e.getErrorCode());
  475.             LOG.info("Error Message: " + e.getErrorMessage());
  476.         }
  477.     }
  478.  
  479.     public static void testSendWithSMS() {
  480.         JPushClient jpushClient = new JPushClient(MASTER_SECRET, APP_KEY);
  481.         try {
  482. //            SMS sms = SMS.content(1, 10);
  483.             SMS sms = SMS.newBuilder()
  484.                     .setDelayTime(1000)
  485.                     .setTempID(2000)
  486.                     .addPara("Test", 1)
  487.                     .build();
  488.             PushResult result = jpushClient.sendAndroidMessageWithAlias("Test SMS", "test sms", sms, "alias1");
  489.             LOG.info("Got result - " + result);
  490.         } catch (APIConnectionException e) {
  491.             LOG.error("Connection error. Should retry later. ", e);
  492.         } catch (APIRequestException e) {
  493.             LOG.error("Error response from JPush server. Should review and fix it. ", e);
  494.             LOG.info("HTTP Status: " + e.getStatus());
  495.             LOG.info("Error Code: " + e.getErrorCode());
  496.             LOG.info("Error Message: " + e.getErrorMessage());
  497.         }
  498.     }
  499.  
  500.     public static void testGetCidList() {
  501.         JPushClient jPushClient = new JPushClient(MASTER_SECRET, APP_KEY);
  502.         try {
  503.             CIDResult result = jPushClient.getCidList(3, "push");
  504.             LOG.info("Got result - " + result);
  505.         } catch (APIConnectionException e) {
  506.             LOG.error("Connection error. Should retry later. ", e);
  507.         } catch (APIRequestException e) {
  508.             LOG.error("Error response from JPush server. Should review and fix it. ", e);
  509.             LOG.info("HTTP Status: " + e.getStatus());
  510.             LOG.info("Error Code: " + e.getErrorCode());
  511.             LOG.info("Error Message: " + e.getErrorMessage());
  512.         }
  513.     }
  514.  
  515.     public static void testSendPushWithCid() {
  516.         JPushClient jPushClient = new JPushClient(MASTER_SECRET, APP_KEY);
  517.         PushPayload pushPayload = buildPushObject_android_cid();
  518.         try {
  519.             PushResult result = jPushClient.sendPush(pushPayload);
  520.             LOG.info("Got result - " + result);
  521.         } catch (APIConnectionException e) {
  522.             LOG.error("Connection error. Should retry later. ", e);
  523.         } catch (APIRequestException e) {
  524.             LOG.error("Error response from JPush server. Should review and fix it. ", e);
  525.             LOG.info("HTTP Status: " + e.getStatus());
  526.             LOG.info("Error Code: " + e.getErrorCode());
  527.             LOG.info("Error Message: " + e.getErrorMessage());
  528.         }
  529.     }
  530.  
  531.     /**
  532.      * 批量单推接口
  533.      * https://docs.jiguang.cn/jpush/server/push/rest_api_v3_push/#vip
  534.      */
  535.     public static void testBatchSend() {
  536.  
  537.         JPushClient jPushClient = new JPushClient(MASTER_SECRET, APP_KEY);
  538.         try {
  539.             {
  540.                 List<PushPayload> pushPayloadList = new ArrayList<>();
  541.                 PushPayload.Builder builder1 = PushPayload.newBuilder();
  542.                 builder1.setMessage(Message.content("content1 by alias"))
  543.                         .setNotification(Notification.alert(ALERT))
  544.                         .setPlatform(Platform.all())
  545.                         .setAudience(Audience.all())
  546.                         .setOptions(Options.sendno())
  547.                         .setTarget("1507ffd3f79456757de");
  548.                 pushPayloadList.add(builder1.build());
  549.  
  550.                 PushPayload.Builder builder2 = PushPayload.newBuilder();
  551.                 builder2.setMessage(Message.content("content2 by alias"))
  552.                         .setNotification(Notification.alert(ALERT))
  553.                         .setPlatform(Platform.android())
  554.                         .setAudience(Audience.all())
  555.                         .setOptions(Options.sendno())
  556.                         .setTarget("1507ffd3f79456757de");
  557.                 pushPayloadList.add(builder2.build());
  558.  
  559.                 BatchPushResult result = jPushClient.batchSendPushByAlias(pushPayloadList);
  560.                 LOG.info("batchSendPushByAlias param: {}, result: {}", pushPayloadList, new Gson().toJson(result.getBatchPushResult()));
  561.             }
  562.  
  563.             {
  564.                 List<PushPayload> pushPayloadList = new ArrayList<>();
  565.                 PushPayload.Builder builder1 = PushPayload.newBuilder();
  566.                 builder1.setMessage(Message.content("content1 by regId"))
  567.                         .setNotification(Notification.alert(ALERT))
  568.                         .setPlatform(Platform.android())
  569.                         .setAudience(Audience.all())
  570.                         .setOptions(Options.sendno())
  571.                         .setTarget("1507ffd3f79456757de");
  572.                 pushPayloadList.add(builder1.build());
  573.  
  574.                 PushPayload.Builder builder2 = PushPayload.newBuilder();
  575.                 builder2.setMessage(Message.content("content2 by regId"))
  576.                         .setNotification(Notification.alert(ALERT))
  577.                         .setAudience(Audience.all())
  578.                         .setPlatform(Platform.ios())
  579.                         .setOptions(Options.sendno())
  580.                         .setTarget("1507ffd3f79456757de");
  581.                 pushPayloadList.add(builder2.build());
  582.  
  583.                 BatchPushResult result = jPushClient.batchSendPushByRegId(pushPayloadList);
  584.                 LOG.info("batchSendPushByRegId param: {}, result: {}", pushPayloadList, new Gson().toJson(result.getBatchPushResult()));
  585.             }
  586.  
  587.         } catch (APIConnectionException e) {
  588.             LOG.error("Connection error. Should retry later. ", e);
  589.         } catch (APIRequestException e) {
  590.             LOG.error("Error response from JPush server. Should review and fix it. ", e);
  591.             LOG.info("HTTP Status: " + e.getStatus());
  592.             LOG.info("Error Code: " + e.getErrorCode());
  593.             LOG.info("Error Message: " + e.getErrorMessage());
  594.         }
  595.     }
  596.  
  597.     /**
  598.      * 自定义发送参数名称, 华为客户可参考该方法
  599.      */
  600.     public static void testSendPushWithCustomField() {
  601.  
  602.         ClientConfig config = ClientConfig.getInstance();
  603.         // Setup the custom hostname
  604.         config.setPushHostName("https://api.jpush.cn");
  605.  
  606.         JPushClient jpushClient = new JPushClient(MASTER_SECRET, APP_KEY, null, config);
  607.  
  608.         Notification notification = Notification.newBuilder()
  609.                 .addPlatformNotification(AndroidNotification.newBuilder()
  610.                         .setAlert(ALERT)
  611.                         .setTitle("Alert test")
  612.                         .setLargeIcon("http://www.jiguang.cn/largeIcon.jpg")
  613.                         .addCustom("uri_activity", "uri_activity")
  614.                         .addCustom("uri_flag", "uri_flag")
  615.                         .addCustom("uri_action", "uri_action")
  616.                         .build())
  617.                 .build();
  618.  
  619.         PushPayload.Builder payloadBuilder = new PushPayload.Builder()
  620.                 .setPlatform(Platform.all())
  621.                 .setAudience(Audience.all())
  622.                 .setNotification(notification);
  623.  
  624.         try {
  625.             PushResult result = jpushClient.sendPush(payloadBuilder.build());
  626.             LOG.info("Got result - " + result);
  627.  
  628.         } catch (APIConnectionException e) {
  629.             LOG.error("Connection error. Should retry later. ", e);
  630.  
  631.         } catch (APIRequestException e) {
  632.             LOG.error("Error response from JPush server. Should review and fix it. ", e);
  633.             LOG.info("HTTP Status: " + e.getStatus());
  634.             LOG.info("Error Code: " + e.getErrorCode());
  635.             LOG.info("Error Message: " + e.getErrorMessage());
  636.             LOG.info("Msg ID: " + e.getMsgId());
  637.         }
  638.     }
  639.  
  640.     /**
  641.      * 回调参数示例
  642.      */
  643.     public static void testSendPushWithCustom() {
  644.  
  645.         ClientConfig config = ClientConfig.getInstance();
  646.         // Setup the custom hostname
  647.         config.setPushHostName("https://api.jpush.cn");
  648.  
  649.         JPushClient jpushClient = new JPushClient(MASTER_SECRET, APP_KEY, null, config);
  650.  
  651.         Notification notification = Notification.newBuilder()
  652.                 .addPlatformNotification(AndroidNotification.newBuilder()
  653.                         .setAlert(ALERT)
  654.                         .setTitle("Alert test")
  655.                         .build())
  656.                 .build();
  657.  
  658.         JsonObject callback = new JsonObject();
  659.         callback.addProperty("url", "https://www.jiguagn.cn/callback");
  660.         JsonObject params = new JsonObject();
  661.         params.addProperty("name", "joe");
  662.         params.addProperty("age", 26);
  663.         callback.add("params", params);
  664.         callback.addProperty("type", 3);
  665.  
  666.         PushPayload.Builder payloadBuilder = new PushPayload.Builder()
  667.                 .setPlatform(Platform.all())
  668.                 .setAudience(Audience.all())
  669.                 .setNotification(notification)
  670.                 .addCustom("callback", callback);
  671.  
  672.         try {
  673.             PushResult result = jpushClient.sendPush(payloadBuilder.build());
  674.             LOG.info("Got result - " + result);
  675.         } catch (APIConnectionException e) {
  676.             LOG.error("Connection error. Should retry later. ", e);
  677.         } catch (APIRequestException e) {
  678.             LOG.error("Error response from JPush server. Should review and fix it. ", e);
  679.             LOG.info("HTTP Status: " + e.getStatus());
  680.             LOG.info("Error Code: " + e.getErrorCode());
  681.             LOG.info("Error Message: " + e.getErrorMessage());
  682.             LOG.info("Msg ID: " + e.getMsgId());
  683.         }
  684.     }
  685.  
  686.     public static void asynSendMessageWithCallback(String alias, String notification_title, String msg_title, String msg_content, String extrasparam, String content_type) {
  687.         ClientConfig clientConfig = ClientConfig.getInstance();
  688.         String host = (String) clientConfig.get(ClientConfig.PUSH_HOST_NAME);
  689.         System.out.println(APP_KEY+"***"+MASTER_SECRET+";"+APP_KEY1+"***"+MASTER_SECRET1);
  690.         final NettyHttpClient client = new NettyHttpClient(ServiceHelper.getBasicAuthorization(APP_KEY, MASTER_SECRET),
  691.                 null, clientConfig);
  692.         final NettyHttpClient client1 = new NettyHttpClient(ServiceHelper.getBasicAuthorization(APP_KEY1, MASTER_SECRET1),
  693.                 null, clientConfig);
  694.         try {
  695.             URI uri = new URI(host + clientConfig.get(ClientConfig.PUSH_PATH));
  696.             PushPayload payload = buildPushObject_android_alias_alertWithTitle(alias, notification_title, msg_title, msg_content, extrasparam, content_type);
  697.             System.out.println("payload="+payload+";uri="+uri);
  698.             client.sendRequest(HttpMethod.POST, payload.toString(), uri, new NettyHttpClient.BaseCallback() {
  699.                 @Override
  700.                 public void onSucceed(ResponseWrapper responseWrapper) {
  701.                     LOG.info("Got result: " + responseWrapper.responseContent);
  702.                     System.out.println("Got result: " + responseWrapper.responseContent);
  703.                 }
  704.             });
  705.             client1.sendRequest(HttpMethod.POST, payload.toString(), uri, new NettyHttpClient.BaseCallback() {
  706.                 @Override
  707.                 public void onSucceed(ResponseWrapper responseWrapper) {
  708.                     LOG.info("Got result1: " + responseWrapper.responseContent);
  709.                     System.out.println("Got result1: " + responseWrapper.responseContent);
  710.                 }
  711.             });
  712.         } catch (URISyntaxException e) {
  713.             e.printStackTrace();
  714.         }
  715.     }
  716.  
  717.     private static PushPayload buildPushObject_android_alias_alertWithTitle(String alias, String notification_title, String msg_title, String msg_content, String extrasparam, String content_type) {
  718.         return PushPayload.newBuilder()
  719.                 //指定要推送的平台，all代表当前应用配置了的所有平台，也可以传android等具体平台
  720.                 .setPlatform(Platform.android())
  721.                 //指定推送的接收对象，all代表所有人，也可以指定已经设置成功的tag或alias或该应应用客户端调用接口获取到的registration id
  722.                 .setAudience(Audience.alias(alias))
  723.                 //.setAudience(Audience.all())
  724.                 //jpush的通知，android的由jpush直接下发，iOS的由apns服务器下发，Winphone的由mpns下发
  725.                 .setNotification(Notification.newBuilder()
  726.                         //指定当前推送的android通知
  727.                         .addPlatformNotification(AndroidNotification.newBuilder()
  728.                                 .setAlert(msg_content)
  729.                                 .setTitle(notification_title)
  730.                                 //此字段为透传字段，不会显示在通知栏。用户可以通过此字段来做一些定制需求，如特定的key传要指定跳转的页面（value）
  731.                                 .addExtra("data", extrasparam)
  732.                                 .build())
  733.                         .build()
  734.                 )
  735.                 //Platform指定了哪些平台就会像指定平台中符合推送条件的设备进行推送。 jpush的自定义消息，
  736.                 // sdk默认不做任何处理，不会有通知提示。建议看文档http://docs.jpush.io/guideline/faq/的
  737.                 // [通知与自定义消息有什么区别？]了解通知和自定义消息的区别
  738.                 .setMessage(Message.newBuilder()
  739.                         .setMsgContent(msg_content)
  740.                         .setTitle(msg_title)
  741.                         .setContentType(content_type)
  742.                         .addExtra("data", extrasparam)
  743.                         .build())
  744.                 .setOptions(Options.newBuilder()
  745.                         //此字段的值是用来指定本推送要推送的apns环境，false表示开发，true表示生产；对android和自定义消息无意义
  746.                         .setApnsProduction(true)
  747.                         //此字段是给开发者自己给推送编号，方便推送者分辨推送记录
  748.                         .setSendno(1)
  749.                         //此字段的值是用来指定本推送的离线保存时长，如果不传此字段则默认保存一天，最多指定保留十天，单位为秒
  750.                         .setTimeToLive(86400)
  751.                         .build())
  752.                 .build();
  753.     }
  754.  
  755.     public static void asynSendMessageWithCallbackAll(String tag, String notification_title, String msg_title, String msg_content, String extrasparam, String content_type) {
  756.         ClientConfig clientConfig = ClientConfig.getInstance();
  757.         String host = (String) clientConfig.get(ClientConfig.PUSH_HOST_NAME);
  758.         final NettyHttpClient client = new NettyHttpClient(ServiceHelper.getBasicAuthorization(APP_KEY, MASTER_SECRET),
  759.                 null, clientConfig);
  760.         try {
  761.             URI uri = new URI(host + clientConfig.get(ClientConfig.PUSH_PATH));
  762.             PushPayload payload = buildPushObject_android_alias_alertWithTitleAll(tag, notification_title, msg_title, msg_content, extrasparam, content_type);
  763.             client.sendRequest(HttpMethod.POST, payload.toString(), uri, new NettyHttpClient.BaseCallback() {
  764.                 @Override
  765.                 public void onSucceed(ResponseWrapper responseWrapper) {
  766.                     LOG.info("Got result: " + responseWrapper.responseContent);
  767.                 }
  768.             });
  769.         } catch (URISyntaxException e) {
  770.             e.printStackTrace();
  771.         }
  772.     }
  773.  
  774.     private static PushPayload buildPushObject_android_alias_alertWithTitleAll(String tag, String notification_title, String msg_title, String msg_content, String extrasparam, String content_type) {
  775.         return PushPayload.newBuilder()
  776.                 //指定要推送的平台，all代表当前应用配置了的所有平台，也可以传android等具体平台
  777.                 .setPlatform(Platform.android())
  778.                 //指定推送的接收对象，all代表所有人，也可以指定已经设置成功的tag或alias或该应应用客户端调用接口获取到的registration id
  779.                 .setAudience(Audience.tag(tag))
  780.                 //jpush的通知，android的由jpush直接下发，iOS的由apns服务器下发，Winphone的由mpns下发
  781.                 .setNotification(Notification.newBuilder()
  782.                         //指定当前推送的android通知
  783.                         .addPlatformNotification(AndroidNotification.newBuilder()
  784.                                 .setAlert(msg_content)
  785.                                 .setTitle(notification_title)
  786.                                 //此字段为透传字段，不会显示在通知栏。用户可以通过此字段来做一些定制需求，如特定的key传要指定跳转的页面（value）
  787.                                 .addExtra("data", extrasparam)
  788.                                 .build())
  789.                         .build()
  790.                 )
  791.                 //Platform指定了哪些平台就会像指定平台中符合推送条件的设备进行推送。 jpush的自定义消息，
  792.                 // sdk默认不做任何处理，不会有通知提示。建议看文档http://docs.jpush.io/guideline/faq/的
  793.                 // [通知与自定义消息有什么区别？]了解通知和自定义消息的区别
  794.                 .setMessage(Message.newBuilder()
  795.                         .setMsgContent(msg_content)
  796.                         .setTitle(msg_title)
  797.                         .setContentType(content_type)
  798.                         .addExtra("data", extrasparam)
  799.                         .build())
  800.                 .setOptions(Options.newBuilder()
  801.                         //此字段的值是用来指定本推送要推送的apns环境，false表示开发，true表示生产；对android和自定义消息无意义
  802.                         .setApnsProduction(true)
  803.                         //此字段是给开发者自己给推送编号，方便推送者分辨推送记录
  804.                         .setSendno(1)
  805.                         //此字段的值是用来指定本推送的离线保存时长，如果不传此字段则默认保存一天，最多指定保留十天，单位为秒
  806.                         .setTimeToLive(86400)
  807.                         .build())
  808.                 .build();
  809.     }
  810.  
  811.     public static void pushAline(String tag, String notification_title, String msg_content){
  812.         ClientConfig config = ClientConfig.getInstance();
  813.         JPushClient client = new JPushClient(MASTER_SECRET, APP_KEY, null, config);
  814.         PushPayload payload = PushPayload.newBuilder()
  815.                 .setPlatform(Platform.android())//推送平台
  816.                 .setAudience(Audience.alias(tag))//推送目标
  817.                 .setNotification(Notification.newBuilder().addPlatformNotification(AndroidNotification.newBuilder()
  818.                         .setAlert(msg_content)
  819.                         .setTitle(notification_title).build()).build())//通知消息（标题，内容）
  820.                 .setOptions(Options.newBuilder().setApnsProduction(true).setTimeToLive(86400).build()//离线消息保存时间
  821.                 )
  822.                 .build();
  823.         try {
  824.             PushResult result = client.sendPush(payload);//推送
  825.             System.out.println("推送结果：" + result.getResponseCode());
  826.         } catch (Exception e) {
  827.             e.printStackTrace();
  828.         }
  829.     }
  830.  
  831. }
  832.

2.二类

  1.  
  2.  
  3. import java.util.Dictionary;
  4. import java.util.HashMap;
  5. import java.util.Hashtable;
  6. import java.util.List;
  7. import java.util.Map;
  8.  
  9. import com.erenju.util.GlobleConfig;    
  10. import com.google.gson.Gson;
  11. import com.google.gson.GsonBuilder;
  12. import com.xhgx.domain.RestInfo;
  13. import com.xhgx.web.util.JSONObject;
  14.  
  15. import cn.jiguang.common.resp.APIConnectionException;
  16. import cn.jiguang.common.resp.APIRequestException;
  17. import cn.jpush.api.JPushClient;
  18. import cn.jpush.api.push.PushResult;
  19. import cn.jpush.api.push.model.Message;
  20. import cn.jpush.api.push.model.Options;
  21. import cn.jpush.api.push.model.Platform;
  22. import cn.jpush.api.push.model.PushPayload;
  23. import cn.jpush.api.push.model.audience.Audience;
  24. import cn.jpush.api.push.model.notification.AndroidNotification;
  25. import cn.jpush.api.push.model.notification.IosAlert;
  26. import cn.jpush.api.push.model.notification.IosNotification;
  27. import cn.jpush.api.push.model.notification.Notification;
  28. public class JpushUtil{
  29.  
  30. /**
  31.  * 推送通知：以广播形式推送给所有平台
  32. * @return
  33. */
  34. public static PushPayload buildPushObject_all_alias_alert(){
  35. return PushPayload.newBuilder()
  36.  .setPlatform(Platform.all())//推送平台 ：all代表全部 ,也可写具体的平台android或ios
  37. .setAudience(Audience.all())//推送目标：all表示以广播形式推送，所有用户都可接收到
  38.            .setNotification(Notification.alert("测试广播推送！"))//推送到通知栏的内容
  39.                .setOptions(Options.newBuilder()
  40.                        .setApnsProduction(true)//APNs是否为生产环境，false为开发环境
  41.                         .setSendno(1)//推送编号
  42.                          .setTimeToLive(86400)//指定本推送的离线保存时长(单位：秒)，如果不传此字段则默认保存一天，最多指定保留十天
  43.                    .build())
  44.                 .build();
  45.      }
  46.      /**
  47.       * 推送通知：根据alias推送给个人
  48.      * @param alias
  49.       * @param notification_title
  50.     * @param msg_title
  51.      * @param extrasparam
  52.       * @return
  53.       */
  54.      public static PushPayload buildPushObject_all_alias_alertWithTitle(String alias,String notification_title, String msg_title, Map<String,String> extrasparam){
  55.          String iosAlert = notification_title+":"+msg_title; 
  56.          //需要最新sdk版本
  57. //        IosAlert iosAlert = IosAlert.newBuilder().setTitleAndBody("title", "alert body").build();
  58.          //IosAlert.newBuilder().setTitleAndBody(notification_title, null, msg_title).setActionLocKey("PLAY").build()
  59.          return PushPayload.newBuilder()
  60.             //推送平台
  61.               .setPlatform(Platform.all())
  62.               //推送目标：all、tag、tag_and、tag_not、alias、registration_id等
  63.                 .setAudience(Audience.alias(alias))
  64.                 //通知
  65.                 .setNotification(Notification.newBuilder()
  66.                       .addPlatformNotification(AndroidNotification.newBuilder()//指定不同平台的推送内容
  67.                                  .setTitle(notification_title)//标题
  68.                                 .setAlert(msg_title)//内容
  69.                             //透传，不会显示在通知栏。用户可以通过此字段来做一些定制需求，如特定的key传要指定跳转的页面（value）
  70.  72                                 //另一种方式： addExtra(key,value)
  71.  73                                 .addExtras(extrasparam)
  72.  74                                 .build())
  73.  75                         .addPlatformNotification(IosNotification.newBuilder()
  74.  76                                 .setAlert(iosAlert)//传一个IosAlert对象，指定apns title、title、subtitle等
  75.  77                                 .incrBadge(1)//此项是指定此推送的badge自动加1
  76.  78                                 //.setSound("sound.caf")//设置声音
  77.  79                                 //透传，不会显示在通知栏。用户可以通过此字段来做一些定制需求，如特定的key传要指定跳转的页面（value）
  78.  80                                 //另一种方式： addExtra(key,value)
  79.  81                                 .addExtras(extrasparam)
  80.  82                                 .setContentAvailable(true)//是否可以在锁屏状态下接收
  81.  83                                 .build())    
  82.  84                     .build())
  83.  85                 //可选参数
  84.  86                 .setOptions(Options.newBuilder()
  85.  87                         .setApnsProduction(true)//APNs是否为生产环境，false为开发环境
  86.  88                         .setSendno(1)//推送编号
  87.  89                         .setTimeToLive(86400)//指定本推送的离线保存时长(单位：秒)，如果不传此字段则默认保存一天，最多指定保留十天
  88.  90                         .build())
  89.  91                 .build();
  90.  92     }
  91.  93     /**
  92.  94      * 推送通知:根据alias同时推送给多个用户
  93.  95      * @param aliases
  94.  96      * @param notification_title
  95.  97      * @param msg_title
  96.  98      * @param extrasparam
  97.  99      * @return
  98. 100      */
  99. 101     public static PushPayload buildPushObject_all_aliases_alertWithTitle(List<String> aliases,String notification_title, String msg_title, Map<String,String> extrasparam){
  100. 102         String iosAlert = notification_title+":"+msg_title; 
  101. 103         //需要最新sdk版本
  102. 104 //        IosAlert iosAlert = IosAlert.newBuilder().setTitleAndBody("title", "alert body").build();
  103. 105         //IosAlert.newBuilder().setTitleAndBody(notification_title, null, msg_title).setActionLocKey("PLAY").build()
  104. 106         return PushPayload.newBuilder()
  105. 107                 //推送平台
  106. 108                 .setPlatform(Platform.all())
  107. 109                 //推送目标：all、tag、tag_and、tag_not、alias、registration_id等
  108. 110                 .setAudience(Audience.alias(aliases))
  109. 111                 //通知
  110. 112                 .setNotification(Notification.newBuilder()
  111. 113                         .addPlatformNotification(AndroidNotification.newBuilder()//指定不同平台的推送内容
  112. 114                                 .setTitle(notification_title)//标题
  113. 115                                 .setAlert(msg_title)//内容
  114. 116                                 //透传，不会显示在通知栏。用户可以通过此字段来做一些定制需求，如特定的key传要指定跳转的页面（value）
  115. 117                                 //另一种方式： addExtra(key,value)
  116. 118                                 .addExtras(extrasparam)
  117. 119                                 .build())
  118. 120                         .addPlatformNotification(IosNotification.newBuilder()
  119. 121                                 .setAlert(iosAlert)//传一个IosAlert对象，指定apns title、title、subtitle等
  120. 122                                 .incrBadge(1)//此项是指定此推送的badge自动加1
  121. 123                                 //.setSound("sound.caf")//设置声音
  122. 124                                 //透传，不会显示在通知栏。用户可以通过此字段来做一些定制需求，如特定的key传要指定跳转的页面（value）
  123. 125                                 //另一种方式： addExtra(key,value)
  124. 126                                 .addExtras(extrasparam)
  125. 127                                 .setContentAvailable(true)//是否可以在锁屏状态下接收
  126. 128                                 .build())    
  127. 129                     .build())
  128. 130                 //可选参数
  129. 131                 .setOptions(Options.newBuilder()
  130. 132                         .setApnsProduction(true)//APNs是否为生产环境，false为开发环境
  131. 133                         .setSendno(1)//推送编号
  132. 134                         .setTimeToLive(86400)//指定本推送的离线保存时长(单位：秒)，如果不传此字段则默认保存一天，最多指定保留十天
  133. 135                         .build())
  134. 136                 .build();
  135. 137     }
  136. 138     
  137. 139     /**
  138. 140      * 推送通知和自定义消息：根据alias推给个人
  139. 141      * @param alias
  140. 142      * @param notification_title
  141. 143      * @param msg_title
  142. 144      * @param msg_content
  143. 145      * @param extrasparam
  144. 146      * @return
  145. 147      */
  146. 148     public static PushPayload buildPushObject_all_alias_alertAndmessage(String alias,String notification_title,String msg_title,String msg_content,Map<String, String> extrasparam ){
  147. 149         String iosAlert = notification_title+":"+msg_title;
  148. 150         //IosAlert.newBuilder().setTitleAndBody(notification_title, null, msg_title).setActionLocKey("PLAY").build()
  149. 151         
  150. 152         return PushPayload.newBuilder()
  151. 153                 //推送平台
  152. 154                 .setPlatform(Platform.all())
  153. 155                 //推送目标：all、tag、tag_and、tag_not、alias、registration_id等
  154. 156                 .setAudience(Audience.alias(alias))
  155. 157                 //通知
  156. 158                 .setNotification(Notification.newBuilder()
  157. 159                         .addPlatformNotification(AndroidNotification.newBuilder()//指定不同平台的推送内容
  158. 160                                 .setTitle(notification_title)//标题
  159. 161                                 .setAlert(msg_title)//内容
  160. 162                                 //透传，不会显示在通知栏。用户可以通过此字段来做一些定制需求，如特定的key传要指定跳转的页面（value）
  161. 163                                 //另一种方式： addExtra(key,value)
  162. 164                                 .addExtras(extrasparam)
  163. 165                                 .build())
  164. 166                         .addPlatformNotification(IosNotification.newBuilder()
  165. 167                                 .setAlert(iosAlert)//传一个IosAlert对象，指定apns title、body、subtitle等
  166. 168                                 .incrBadge(1)//此项是指定此推送的badge自动加1
  167. 169                                 //.setSound("sound.caf")//设置声音
  168. 170                                 //透传，不会显示在通知栏。用户可以通过此字段来做一些定制需求，如特定的key传要指定跳转的页面（value）
  169. 171                                 //另一种方式： addExtra(key,value)
  170. 172                                 .addExtras(extrasparam)
  171. 173                                 //.setContentAvailable(true)//是否可以在锁屏状态下接收
  172. 174                                 .build())    
  173. 175                     .build())
  174. 176                 //自定义消息
  175. 177                 .setMessage(Message.newBuilder()
  176. 178                         .setTitle(msg_title)//消息标题
  177. 179                         .setMsgContent(msg_content)//消息内容本身
  178. 180                         //.setContentType("json")//消息内容类型
  179. 181                         .addExtras(extrasparam)//json格式的可选参数
  180. 182                         .build())
  181. 183                 //可选参数
  182. 184                 .setOptions(Options.newBuilder()
  183. 185                         .setApnsProduction(true)//APNs是否为生产环境，false为开发环境
  184. 186                         .setSendno(1)//推送编号
  185. 187                         .setTimeToLive(86400)//指定本推送的离线保存时长(单位：秒)，如果不传此字段则默认保存一天，最多指定保留十天
  186. 188                         .build())
  187. 189                 .build();
  188. 190     }
  189. 191     /**
  190. 192      * 推送自定义消息：根据alias推给个人
  191. 193      * @param alias
  192. 194      * @param msg_title
  193. 195      * @param msg_content
  194. 196      * @param extrasparam
  195. 197      * @return
  196. 198      */
  197. 199     public static PushPayload buildPushObject_all_alias_message(String alias,String msg_title,String msg_content,Map<String, String> extrasparam ){
  198. 200         
  199. 201         return PushPayload.newBuilder()
  200. 202                 //推送平台
  201. 203                 .setPlatform(Platform.all())
  202. 204                 //推送目标：all、tag、tag_and、tag_not、alias、registration_id等
  203. 205                 .setAudience(Audience.alias(alias))
  204. 206                 //自定义消息
  205. 207                 .setMessage(Message.newBuilder()
  206. 208                         .setTitle(msg_title)//消息标题
  207. 209                         .setMsgContent(msg_content)//消息内容本身
  208. 210                         //.setContentType("json")//消息内容类型
  209. 211                         .addExtras(extrasparam)//json格式的可选参数
  210. 212                         .build())
  211. 213                 //可选参数
  212. 214                 .setOptions(Options.newBuilder()
  213. 215                         .setApnsProduction(true)//APNs是否为生产环境，false为开发环境
  214. 216                         .setSendno(1)//推送编号
  215. 217                         .setTimeToLive(86400)//指定本推送的离线保存时长(单位：秒)，如果不传此字段则默认保存一天，最多指定保留十天
  216. 218                         .build())
  217. 219                 .build();
  218. 220     }
  219. 221     /**
  220. 222      * 推送通知：根据tag推送给个人
  221. 223      * @param tag
  222. 224      * @param tag_add
  223. 225      * @param notification_title
  224. 226      * @param msg_title
  225. 227      * @param extrasparam
  226. 228      * @return
  227. 229      */
  228. 230     @SuppressWarnings("static-access")
  229. 231     public static PushPayload buildPushObject_all_tag_alertWithTitle(String tag,String tag_and,String notification_title, String msg_title, Map<String,String> extrasparam){
  230. 232         String iosAlert = notification_title+":"+msg_title; 
  231. 233         //需要最新sdk版本
  232. 234 //        IosAlert iosAlert = IosAlert.newBuilder().setTitleAndBody("title", "alert body").build();
  233. 235         //IosAlert.newBuilder().setTitleAndBody(notification_title, null, msg_title).setActionLocKey("PLAY").build()
  234. 236         return PushPayload.newBuilder()
  235. 237                 //推送平台
  236. 238                 .setPlatform(Platform.all())
  237. 239                 //推送目标：all、tag、tag_and、tag_not、alias、registration_id等
  238. 240                 .setAudience(Audience.tag(tag).tag_and(tag_and))
  239. 241                 //通知
  240. 242                 .setNotification(Notification.newBuilder()
  241. 243                         .addPlatformNotification(AndroidNotification.newBuilder()//指定不同平台的推送内容
  242. 244                                 .setTitle(notification_title)//标题
  243. 245                                 .setAlert(msg_title)//内容
  244. 246                                 //透传，不会显示在通知栏。用户可以通过此字段来做一些定制需求，如特定的key传要指定跳转的页面（value）
  245. 247                                 //另一种方式： addExtra(key,value)
  246. 248                                 .addExtras(extrasparam)
  247. 249                                 .build())
  248. 250                         .addPlatformNotification(IosNotification.newBuilder()
  249. 251                                 .setAlert(iosAlert)//传一个IosAlert对象，指定apns title、title、subtitle等
  250. 252                                 .incrBadge(1)//此项是指定此推送的badge自动加1
  251. 253                                 //.setSound("sound.caf")//设置声音
  252. 254                                 //透传，不会显示在通知栏。用户可以通过此字段来做一些定制需求，如特定的key传要指定跳转的页面（value）
  253. 255                                 //另一种方式： addExtra(key,value)
  254. 256                                 .addExtras(extrasparam)
  255. 257                                 //.setContentAvailable(true)//是否可以在锁屏状态下接收
  256. 258                                 .build())    
  257. 259                     .build())
  258. 260                 //可选参数
  259. 261                 .setOptions(Options.newBuilder()
  260. 262                         .setApnsProduction(true)//APNs是否为生产环境，false为开发环境
  261. 263                         .setSendno(1)//推送编号
  262. 264                         .setTimeToLive(86400)//指定本推送的离线保存时长(单位：秒)，如果不传此字段则默认保存一天，最多指定保留十天
  263. 265                         .build())
  264. 266                 .build();
  265. 267     }
  266. 268     /**
  267. 269      * 推送通知和自定义消息：根据tag推给个人
  268. 270      * @param tag
  269. 271      * @param tag_add
  270. 272      * @param notification_title
  271. 273      * @param msg_title
  272. 274      * @param msg_content
  273. 275      * @param extrasparam
  274. 276      * @return
  275. 277      */
  276. 278     @SuppressWarnings("static-access")
  277. 279     public static PushPayload buildPushObject_all_tag_alertAndmessage(String tag,String tag_and,String notification_title,String msg_title,String msg_content,Map<String, String> extrasparam ){
  278. 280         String iosAlert = notification_title+":"+msg_title;
  279. 281         //IosAlert.newBuilder().setTitleAndBody(notification_title, null, msg_title).setActionLocKey("PLAY").build()
  280. 282         
  281. 283         return PushPayload.newBuilder()
  282. 284                 //推送平台
  283. 285                 .setPlatform(Platform.all())
  284. 286                 //推送目标：all、tag、tag_and、tag_not、alias、registration_id等
  285. 287                 .setAudience(Audience.tag(tag).tag_and(tag_and))
  286. 288                 //通知
  287. 289                 .setNotification(Notification.newBuilder()
  288. 290                         .addPlatformNotification(AndroidNotification.newBuilder()//指定不同平台的推送内容
  289. 291                                 .setTitle(notification_title)//标题
  290. 292                                 .setAlert(msg_title)//内容
  291. 293                                 //透传，不会显示在通知栏。用户可以通过此字段来做一些定制需求，如特定的key传要指定跳转的页面（value）
  292. 294                                 //另一种方式： addExtra(key,value)
  293. 295                                 .addExtras(extrasparam)
  294. 296                                 .build())
  295. 297                         .addPlatformNotification(IosNotification.newBuilder()
  296. 298                                 .setAlert(iosAlert)//传一个IosAlert对象，指定apns title、body、subtitle等
  297. 299                                 .incrBadge(1)//此项是指定此推送的badge自动加1
  298. 300                                 //.setSound("sound.caf")//设置声音
  299. 301                                 //透传，不会显示在通知栏。用户可以通过此字段来做一些定制需求，如特定的key传要指定跳转的页面（value）
  300. 302                                 //另一种方式： addExtra(key,value)
  301. 303                                 .addExtras(extrasparam)
  302. 304                                 //.setContentAvailable(true)//是否可以在锁屏状态下接收
  303. 305                                 .build())    
  304. 306                     .build())
  305. 307                 //自定义消息
  306. 308                 .setMessage(Message.newBuilder()
  307. 309                         .setTitle(msg_title)//消息标题
  308. 310                         .setMsgContent(msg_content)//消息内容本身
  309. 311                         //.setContentType("json")//消息内容类型
  310. 312                         .addExtras(extrasparam)//json格式的可选参数
  311. 313                         .build())
  312. 314                 //可选参数
  313. 315                 .setOptions(Options.newBuilder()
  314. 316                         .setApnsProduction(true)//APNs是否为生产环境，false为开发环境
  315. 317                         .setSendno(1)//推送编号
  316. 318                         .setTimeToLive(86400)//指定本推送的离线保存时长(单位：秒)，如果不传此字段则默认保存一天，最多指定保留十天
  317. 319                         .build())
  318. 320                 .build();
  319. 321     }
  320. 322     /**
  321. 323      * 推送自定义消息：根据tag推给个人
  322. 324      * @param tag
  323. 325      * @param msg_title
  324. 326      * @param msg_content
  325. 327      * @param extrasparam
  326. 328      * @return
  327. 329      */
  328. 330     public static PushPayload buildPushObject_all_tags_message(String[] tag,String msg_title,String msg_content,Map<String, String> extrasparam ){
  329. 331         
  330. 332         return PushPayload.newBuilder()
  331. 333                 //推送平台
  332. 334                 .setPlatform(Platform.all())
  333. 335                 //推送目标：all、tag、tag_and、tag_not、alias、registration_id等
  334. 336                 .setAudience(Audience.tag(tag))
  335. 337                 //自定义消息
  336. 338                 .setMessage(Message.newBuilder()
  337. 339                         .setTitle(msg_title)//消息标题
  338. 340                         .setMsgContent(msg_content)//消息内容本身
  339.                        //.setContentType("json")//消息内容类型
  340.                       .addExtras(extrasparam)//json格式的可选参数
  341.                          .build())
  342.                 //可选参数
  343.                 .setOptions(Options.newBuilder()
  344.                        .setApnsProduction(true)//APNs是否为生产环境，false为开发环境
  345.                       .setSendno(1)//推送编号
  346.                        .setTimeToLive(86400)//指定本推送的离线保存时长(单位：秒)，如果不传此字段则默认保存一天，最多指定保留十天
  347.                          .build())
  348.                 .build();
  349.    }
  350.      
  351. }

3.三类

  1. #极光推送参数设定    yml
  2. jpush: 
  3.   appkey: 
  4.   masterSecret: 
  5.   #离线保存时间 7天 最长10天
  6.   liveTime: 604800
  7.   #推送开关
  8.   enable: true
  1. @Component  //配置类
  2. @ConfigurationProperties(prefix="jpush")
  3. public class JPushConfig {
  4.  
  5.     public static String APP_KEY;
  6.  
  7.     public static String MASTER_SECRET;
  8.  
  9.     public static long LIVE_TIME;
  10.  
  11.     /**
  12.      *  是否开启推送
  13.      */
  14.     public static Boolean ENABLE;
  15.  
  16.     public void setAppKey(String appKey) {
  17.         JPushConfig.APP_KEY = appKey;
  18.     }
  19.  
  20.     public void setMasterSecret(String masterSecret) {
  21.         JPushConfig.MASTER_SECRET = masterSecret;
  22.     }
  23.  
  24.     public void setLiveTime(long liveTime) {
  25.         JPushConfig.LIVE_TIME = liveTime;
  26.     }
  27.  
  28.     public void setEnable(Boolean enable) {
  29.         JPushConfig.ENABLE = enable;
  30.     }
  1. public class JPushUtil {
  2.  
  3.     private static final Logger logger = LoggerFactory.getLogger(JPushUtil.class);
  4.  
  5.     /**
  6.      * 消息自定义即时推送
  7.      * @param jPushMsgVO
  8.      * @return
  9.      */
  10.     public static PushLog messageCustomPush(JPushMsgVO jPushMsgVO) {
  11.         JPushClient jpushClient = buildJPushClient(jPushMsgVO.getLiveTime());
  12.         PushPayload payload = buildMessageCustomPushPayload(jPushMsgVO.getTitle(), jPushMsgVO.getContent(), jPushMsgVO.getExtrasMap(), jPushMsgVO.getPlatform(), jPushMsgVO.getPushType(), jPushMsgVO.getPushObject());
  13.         PushResult result = null;
  14.         PushLog pushLog = BeanUtils.copyResult(jPushMsgVO, PushLog::new);
  15.         pushLog.setCreateTime(new Date());
  16.         pushLog.setPushSort(PushSortEnum.MESSAGE.getCode());
  17.         try {
  18.             result = jpushClient.sendPush(payload);
  19.             pushLog.setMsgId(String.valueOf(result.msg_id));
  20.             logger.info("极光推送条件{},结果{}", payload,result);
  21.         } catch (APIConnectionException e) {
  22.             logger.error("极光推送连接错误，请稍后重试 ", e);
  23.             logger.error("SendNo: " + payload.getSendno());
  24.         } catch (APIRequestException e) {
  25.             logger.error("极光服务器响应出错，请修复！ ", e);
  26.             logger.info("HTTP Status: {}", e.getStatus());
  27.             logger.info("Error Code: {}", e.getErrorCode());
  28.             logger.info("Error Message: {}", e.getErrorMessage());
  29.             logger.error("SendNo: {}", payload.getSendno());
  30.             pushLog.setMsgId(String.valueOf(e.getMsgId()));
  31.             pushLog.setStatusCode(e.getErrorCode());
  32.             pushLog.setErrMsg(e.getErrorMessage());
  33.         } finally {
  34.             pushLog.setPayload(payload.toString());
  35.             pushLog.setSendNo(payload.getSendno());
  36.             pushLog.setPushTime(new Date());
  37.         }
  38.         return pushLog;
  39.     }
  40.  
  41.     /**
  42.      * 消息自定义定时推送
  43.      * @param jPushMsgVO
  44.      * @return
  45.      */
  46.     public static PushLog messageCustomSchedulePush(JPushMsgVO jPushMsgVO) {
  47.         JPushClient jpushClient = buildJPushClient(jPushMsgVO.getLiveTime());
  48.         PushPayload payload = buildMessageCustomPushPayload(jPushMsgVO.getTitle(), jPushMsgVO.getContent(), jPushMsgVO.getExtrasMap(), jPushMsgVO.getPlatform(), jPushMsgVO.getPushType(), jPushMsgVO.getPushObject());
  49.         ScheduleResult result = null;
  50.         PushLog pushLog = BeanUtils.copyResult(jPushMsgVO, PushLog::new);
  51.         pushLog.setCreateTime(new Date());
  52.         pushLog.setStatusCode(-1);
  53.         try {
  54.             result = jpushClient.createSingleSchedule("CustomScheduleJPush", jPushMsgVO.getPushTime().toString(), payload);
  55.             pushLog.setMsgId(result.getSchedule_id());
  56.             logger.info("极光推送条件{},结果{}", payload,result);
  57.         } catch (APIConnectionException e) {
  58.             logger.error("极光推送连接错误，请稍后重试 ", e);
  59.             logger.error("SendNo: " + payload.getSendno());
  60.         } catch (APIRequestException e) {
  61.             logger.error("极光服务器响应出错，请修复！ ", e);
  62.             logger.info("HTTP Status: {}", e.getStatus());
  63.             logger.info("Error Code: {}", e.getErrorCode());
  64.             logger.info("Error Message: {}", e.getErrorMessage());
  65.             logger.error("SendNo: {}", payload.getSendno());
  66.             pushLog.setStatusCode(e.getErrorCode());
  67.             pushLog.setErrMsg(e.getErrorMessage());
  68.         } finally {
  69.             pushLog.setPayload(payload.toString());
  70.             pushLog.setSendNo(payload.getSendno());
  71.             pushLog.setPushTime(new Date());
  72.         }
  73.         return pushLog;
  74.     }
  75.  
  76.     /**
  77.      * 通知自定义即时推送
  78.      * @param jPushMsgVO
  79.      * @return 推送记录
  80.      */
  81.     public static PushLog notifyCustomPush(JPushMsgVO jPushMsgVO) {
  82.         JPushClient jpushClient = buildJPushClient(jPushMsgVO.getLiveTime());
  83.         //构造推送条件
  84.         PushPayload payload = buildNotifyCustomPushPayload(jPushMsgVO.getTitle(), jPushMsgVO.getContent(), jPushMsgVO.getExtrasMap(), jPushMsgVO.getPlatform(), jPushMsgVO.getPushType(), jPushMsgVO.getPushObject());
  85.  
  86.         PushResult result = null;
  87.         PushLog pushLog = BeanUtils.copyResult(jPushMsgVO, PushLog::new);
  88.         pushLog.setCreateTime(new Date());
  89.         pushLog.setStatusCode(-1);
  90.  
  91.         try {
  92.             result = jpushClient.sendPush(payload);
  93.             pushLog.setMsgId(String.valueOf(result.msg_id));
  94.             pushLog.setPushMethod(PushMethodEnum.IMMEDIATE.getCode());
  95.             pushLog.setStatusCode(result.statusCode);
  96.             if(result.statusCode != 0){
  97.                 pushLog.setErrMsg(result.error.getMessage());
  98.             }
  99.             pushLog.setPayload(payload.toString());
  100.             pushLog.setSendNo(payload.getSendno());
  101.             logger.info("极光推送条件{},结果{}", payload,result);
  102.         } catch (APIConnectionException e) {
  103.             logger.error("极光推送连接错误，请稍后重试 ", e);
  104.             logger.error("SendNo: " + payload.getSendno());
  105.         } catch (APIRequestException e) {
  106.             logger.error("极光服务器响应出错，请修复！", e);
  107.             logger.info("HTTP Status: {}", e.getStatus());
  108.             logger.info("Error Code: {}", e.getErrorCode());
  109.             logger.info("Error Message: {}", e.getErrorMessage());
  110.             logger.error("SendNo: {}", payload.getSendno());
  111.         } finally {
  112.  
  113.             pushLog.setPushTime(new Date());
  114.         }
  115.         return pushLog;
  116.     }
  117.  
  118.     /**
  119.      * 通知自定义定时推送
  120.      * @param jPushMsgVO
  121.      * @return
  122.      */
  123.     public static PushLog notifyCustomSchedulePush(JPushMsgVO jPushMsgVO) {
  124.         JPushClient jpushClient = buildJPushClient(jPushMsgVO.getLiveTime());
  125.         PushPayload payload = buildNotifyCustomPushPayload(jPushMsgVO.getTitle(), jPushMsgVO.getContent(), jPushMsgVO.getExtrasMap(), jPushMsgVO.getPlatform(), jPushMsgVO.getPushType(), jPushMsgVO.getPushObject());
  126.         ScheduleResult result = null;
  127.         PushLog pushLog = new PushLog();
  128.         pushLog.setPushMethod(PushMethodEnum.TIMING.getCode());
  129.         pushLog.setCreateTime(new Date());
  130.         pushLog.setStatusCode(-1);
  131.         try {
  132.             result = jpushClient.createSingleSchedule("CustomScheduleJPush", jPushMsgVO.getPushTime().toString(), payload);
  133.             pushLog.setMsgId(result.getSchedule_id());
  134.             pushLog.setPayload(payload.toString());
  135.             pushLog.setSendNo(payload.getSendno());
  136.             logger.info("极光推送条件{},结果{}", payload,result);
  137.         } catch (APIConnectionException e) {
  138.             logger.error("极光推送连接错误，请稍后重试 ", e);
  139.             logger.error("SendNo: " + payload.getSendno());
  140.         } catch (APIRequestException e) {
  141.             logger.error("极光服务器响应出错，请修复！ ", e);
  142.             logger.info("HTTP Status: {}", e.getStatus());
  143.             logger.info("Error Code: {}", e.getErrorCode());
  144.             logger.info("Error Message: {}", e.getErrorMessage());
  145.             logger.error("SendNo: {}", payload.getSendno());
  146.             pushLog.setStatusCode(e.getErrorCode());
  147.             pushLog.setErrMsg(e.getErrorMessage());
  148.         } finally {
  149.             pushLog.setPushTime(new Date());
  150.         }
  151.         return pushLog;
  152.     }
  153.  
  154.     /**
  155.      * 取消定时推送
  156.      */
  157.     public static boolean deleteSchedule(String scheduleId) {
  158.         boolean result;
  159.         try {
  160.             JPushClient jPushClient = new JPushClient(JPushConfig.MASTER_SECRET, JPushConfig.APP_KEY);
  161.             jPushClient.deleteSchedule(scheduleId);
  162.             result = true;
  163.         } catch (APIConnectionException e) {
  164.             logger.error("Connection error. Should retry later. ", e);
  165.             result = false;
  166.         } catch (APIRequestException e) {
  167.             logger.error("Error response from JPush server. Should review and fix it. ", e);
  168.             logger.info("HTTP Status: {}", e.getStatus());
  169.             logger.info("Error Code: {}", e.getErrorCode());
  170.             logger.info("Error Message: {}", e.getErrorMessage());
  171.             result = false;
  172.         }
  173.         return result;
  174.     }
  175.  
  176.     /**
  177.      * 构建自定义消息的推送消息对象
  178.      *
  179.      * @param title       推送消息标题
  180.      * @param content     推送消息内容（为了单行显示全，尽量保持在22个汉字以下）
  181.      * @param extrasMap   额外推送信息（不会显示在通知栏，传递数据用）
  182.      * @param platform    推送的设备类型，默认全部类型
  183.      * @param pushTypeEnum    推送方式，默认广播推送
  184.      * @param pushObject PushTypeEnum为广播推送：此字段无意义；PushTypeEnum为别名推送：此字段为推送指定的别名；PushTypeEnum为标签推送：此字段为推送指定的标签
  185.      * @return 推送消息对象
  186.      */
  187.     private static PushPayload buildMessageCustomPushPayload(String title, String content, Map<String, String> extrasMap, PushPlatformEnum platform, PushTypeEnum pushTypeEnum, List<String> pushObject) {
  188.         // 批量删除数组中空元素
  189.         return PushPayload.newBuilder()
  190.                 // 设置推送的设备类型
  191.                 .setPlatform(null == platform ? Platform.all() : getPlatform(platform))
  192.                 // 设置推送的受众
  193.                 .setAudience(getAudience(pushTypeEnum, pushObject))
  194.                 // 设置推送标题、内容、额外信息
  195.                 .setMessage(Message.newBuilder().setTitle(title).setMsgContent(content).addExtras(null == extrasMap ? new HashMap<>() : extrasMap).build())
  196.                 .build();
  197.     }
  198.  
  199.     /**
  200.      * 构建自定义的通知推送对象
  201.      *
  202.      * @param title       推送通知标题
  203.      * @param content     推送通知内容（为了单行显示全，尽量保持在22个汉字以下）
  204.      * @param extrasMap   额外推送信息（不会显示在通知栏，传递数据用）
  205.      * @param platform    推送的设备类型，默认全部类型
  206.      * @param PushTypeEnum    推送方式，默认广播推送
  207.      * @param pushObject PushTypeEnum为广播推送：此字段无意义；PushTypeEnum为别名推送：此字段为推送指定的别名；PushTypeEnum为标签推送：此字段为推送指定的标签
  208.      * @return 推送通知对象
  209.      */
  210.     private static PushPayload buildNotifyCustomPushPayload(String title, String content, Map<String, String> extrasMap, PushPlatformEnum platform, PushTypeEnum PushTypeEnum, List<String> pushObject) {
  211.         extrasMap = extrasMap == null ? new HashMap<>() : extrasMap;
  212.         return PushPayload.newBuilder().setPlatform(null == platform ? Platform.all() : getPlatform(platform))
  213.                 .setAudience(getAudience(PushTypeEnum, pushObject))
  214.                 .setNotification(Notification.newBuilder().setAlert(content)
  215.                         .addPlatformNotification(AndroidNotification.newBuilder().setTitle(title).addExtras(extrasMap).build())
  216.                         .addPlatformNotification(IosNotification.newBuilder().incrBadge(1).addExtras(extrasMap).build())
  217.                         .build())
  218.                 .build();
  219.     }
  220.  
  221.     /**
  222.      * 构建推送客户端
  223.      */
  224.     private static JPushClient buildJPushClient(Long liveTime) {
  225.         ClientConfig clientConfig = ClientConfig.getInstance();
  226.         clientConfig.setTimeToLive(liveTime == null ? JPushConfig.LIVE_TIME : liveTime);
  227.         return new JPushClient(JPushConfig.MASTER_SECRET, JPushConfig.APP_KEY, null, clientConfig);
  228.     }
  229.  
  230.     /**
  231.      * 查询记录推送成功条数（暂未使用）
  232.      *
  233.      * @param msg_id 在推送返回结果PushResult中保存
  234.      */
  235.     public void countPush(String msg_id) {
  236.         JPushClient jpushClient = new JPushClient(JPushConfig.MASTER_SECRET, JPushConfig.APP_KEY);
  237.         try {
  238.             ReceivedsResult result = jpushClient.getReportReceiveds(msg_id);
  239.             ReceivedsResult.Received received = result.received_list.get(0);
  240.             logger.debug("Android接受信息:" + received.android_received + "\n IOS端接受信息:" + received.ios_apns_sent);
  241.             logger.debug("极光推送返回结果 - " + result);
  242.         } catch (APIConnectionException e) {
  243.             logger.error("极光推送连接错误，请稍后重试", e);
  244.         } catch (APIRequestException e) {
  245.             logger.error("检查错误，并修复推送请求", e);
  246.             logger.info("HTTP Status: " + e.getStatus());
  247.             logger.info("Error Code: " + e.getErrorCode());
  248.             logger.info("Error Message: " + e.getErrorMessage());
  249.         }
  250.     }
  251.  
  252.     /**
  253.      * 异步请求推送方式，使用NettyHttpClient,异步接口发送请求，通过回调函数可以获取推送成功与否情况
  254.      */
  255.     public void sendPushWithCallback(String title, String content, Map<String, String> extrasMap, PushPlatformEnum platform, PushTypeEnum PushTypeEnum, List<String> pushObject) {
  256.         ClientConfig clientConfig = ClientConfig.getInstance();
  257.         clientConfig.setTimeToLive(JPushConfig.LIVE_TIME);
  258.         String host = (String) clientConfig.get(ClientConfig.PUSH_HOST_NAME);
  259.         NettyHttpClient client = new NettyHttpClient(
  260.                 ServiceHelper.getBasicAuthorization(JPushConfig.APP_KEY, JPushConfig.MASTER_SECRET), null, clientConfig);
  261.         try {
  262.             URI uri = new URI(host + clientConfig.get(ClientConfig.PUSH_PATH));
  263.             PushPayload payload = buildNotifyCustomPushPayload(title, content, extrasMap, platform, PushTypeEnum, pushObject);
  264.             client.sendRequest(HttpMethod.POST, payload.toString(), uri, responseWrapper -> {
  265.                 if (200 == responseWrapper.responseCode) {
  266.                     logger.info("极光推送成功");
  267.                 } else {
  268.                     logger.info("极光推送失败，返回结果: " + responseWrapper.responseContent);
  269.                 }
  270.             });
  271.         } catch (URISyntaxException e) {
  272.             e.printStackTrace();
  273.         } finally {
  274.             // 需要手动关闭Netty请求进程,否则会一直保留
  275.             client.close();
  276.         }
  277.  
  278.     }
  279.  
  280.     /**
  281.      * 根据推送类型获取推送的受众
  282.      */
  283.     private static Audience getAudience(PushTypeEnum pushTypeEnum, List<String> pushObject) {
  284.         switch (pushTypeEnum){
  285.             // 别名推送
  286.             case ALIAS:
  287.                 return Audience.alias(filterEmptyAndRepeatElement(pushObject));
  288.             // 标签推送
  289.             case TAG:
  290.                 return Audience.tag(filterEmptyAndRepeatElement(pushObject));
  291.             //注册ID
  292.             case REGISTRATION_ID:
  293.                 return Audience.registrationId(filterEmptyAndRepeatElement(pushObject));
  294.             // 广播推送
  295.             default:
  296.                 return Audience.all();
  297.         }
  298.     }
  299.  
  300.     /**
  301.      * 过滤 空元素（需删除如：null,""," "）和重复的元素
  302.      */
  303.     private static List<String> filterEmptyAndRepeatElement(List<String> stringList) {
  304.         return stringList.stream().filter(item -> item != null && !"".equals(item)).distinct().collect(Collectors.toList());
  305.     }
  306.  
  307.     private static Platform getPlatform(PushPlatformEnum pushPlatformEnum){
  308.         switch (pushPlatformEnum){
  309.             case ALL:
  310.                 return Platform.all();
  311.             case ANDROID:
  312.                 return Platform.android();
  313.             case IOS:
  314.                 return Platform.ios();
  315.             default:
  316.                 return Platform.android_ios();
  317.         }
  318.     }
  319. }

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/空白诗007/article/detail/950303
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号