天天看点
返回

使用第三方极光消息推送进行消息推送

极光推送：

因为公司项目需要进行消息的推送，所以参考了一些网上的资料和自己写了一些测试类，使用第三方极光推送进行推送消息。

一、导入依赖

cn.jpush.api

jpush-client

3.4.6

<dependency>
		<groupId>cn.jpush.api</groupId>
		<artifactId>jiguang-common</artifactId>
		<version>1.1.8</version>
	</dependency>

	<dependency>
		<groupId>io.netty</groupId>
		<artifactId>netty-all</artifactId>
		<version>4.1.6.Final</version>
		<scope>compile</scope>
	</dependency>
	<dependency>
		<groupId>com.google.code.gson</groupId>
		<artifactId>gson</artifactId>
		<version>2.3</version>
	</dependency>
	<!--极光推送end-->

二、写测试类：

package com.ls.common.push.jiguang;

import cn.jiguang.common.ClientConfig;

import cn.jiguang.common.resp.APIConnectionException;

import cn.jiguang.common.resp.APIRequestException;

import cn.jpush.api.JPushClient;

import cn.jpush.api.push.PushResult;

import cn.jpush.api.push.model.Options;

import cn.jpush.api.push.model.Platform;

import cn.jpush.api.push.model.PushPayload;

import cn.jpush.api.push.model.audience.Audience;

import cn.jpush.api.push.model.notification.AndroidNotification;

import cn.jpush.api.push.model.notification.IosNotification;

import cn.jpush.api.push.model.notification.Notification;

import com.alibaba.fastjson.JSONObject;

import com.ls.ibitpark.app.vo.PushVo;

import java.util.ArrayList;

import java.util.Date;

import java.util.List;

import lombok.extern.slf4j.Slf4j;

@Slf4j

public class JiGuangPush {

protected static final String APP_KEY = “xxxxxxxxx”;

protected static final String MASTER_SECRET = “xxxxxxxx”;

private final static Boolean ApnsProduction = true;//上线之后要改为true

public static void main(String[] args) {

//testSendToAliasList();

testSendToTagList();

sys();

vis();

}

public static void testSendToAliasList() {

List aliasList = new ArrayList<>();

//别名

aliasList.add(“flutter_bitpark”);

//消息内容

String msg_content = “我是测试的demo”;

//扩展字段

String extrasparam = “aaa”;

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

String extraKey = “bbb”;

//标题

String notification_title = “测试访客消息通知”;

sendToAliasList(aliasList, msg_content, extraKey, extrasparam, notification_title);

}

public static void testSendToTagList() {

List tagList = new ArrayList<>();

//tag 这个tag是需要客户端那边注册上去极光那边

tagList.add(“1305840456550944769”);

PushVo vo = new PushVo();

vo.setDepartName(“产品部”);

vo.setLocation(“一号测温机”);

vo.setHasMask(“1”);

vo.setHealthStatus(“1”);

vo.setUserName(“蔡旭东”);

vo.setSnapTime(new Date());

vo.setTemperature(“37.43℃”);

JSONObject json = (JSONObject) JSONObject.toJSON(vo);

//消息内容

JSONObject msg_content = json;

//扩展字段

String extrasparam = “3”;

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

String extraKey = “bbb”;

//标题

String notification_title = “防疫小助手”;

sendToTagList(tagList, msg_content, extraKey, extrasparam, notification_title);

}

//访客通知

public static void vis(){

List tagList = new ArrayList<>();

//tag

tagList.add(“1305840456550944769”);

//标题

String notification_title = “访客通知”;

PushVo vo = new PushVo();

vo.setUserName(“王昭君”);

vo.setIsVisit(“1”);

vo.setSnapTime(new Date());

JSONObject json = (JSONObject) JSONObject.toJSON(vo);

//消息内容

JSONObject msg_content = json;

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

String extraKey = “bbb”;

//扩展字段

String extrasparam = “1”;

sendToTagList(tagList, msg_content, extraKey, extrasparam, notification_title);

}

//系统通知

public static void sys(){

List tagList = new ArrayList<>();

//tag

tagList.add(“1305840456550944769”);

//标题

String notification_title = “系统通知”;

PushVo vo = new PushVo();

vo.setIsVisit(“1”);

vo.setSnapTime(new Date());

vo.setContent(“访客预约申请审核失败”);

JSONObject json = (JSONObject) JSONObject.toJSON(vo);

//消息内容

JSONObject msg_content = json;

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

String extraKey = “bbb”;

//扩展字段

String extrasparam = “2”;

sendToTagList(tagList, msg_content, extraKey, extrasparam, notification_title);

}

public static int sendToAliasList(List aliasList,

String msg_content, String extraKey, String extrasparam, String notification_title) {

int result = 0;

ClientConfig clientConfig = ClientConfig.getInstance();

final JPushClient jpushClient = new JPushClient(MASTER_SECRET, APP_KEY, null, clientConfig);

try {

PushPayload pushPayload = buildPushObject_all_aliasList_alertWithTitle(aliasList, msg_content,

extraKey, extrasparam, notification_title);

log.info(“推送给设备标识参数的用户” + pushPayload);

PushResult pushResult = jpushClient.sendPush(pushPayload);

log.info(“推送结果” + pushResult);

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

result = 1;

}

} catch (APIConnectionException e) {

e.printStackTrace();

} catch (APIRequestException e) {
  e.printStackTrace();
}

return result;

}

public static int sendToAll(String msg_content, String extraKey,

String extrasparam, String notification_title) {

ClientConfig clientConfig = ClientConfig.getInstance();

final JPushClient jpushClient = new JPushClient(MASTER_SECRET, APP_KEY, null, clientConfig);

int result = 0;

try {

PushPayload pushPayload = buildPushObject_android_and_ios(msg_content, extraKey, extrasparam,

notification_title);

log.info("" + pushPayload);

PushResult pushResult = jpushClient.sendPush(pushPayload);

log.info("" + pushResult);

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

result = 1;

}

} catch (Exception e) {

e.printStackTrace();

}

return result;

}

public static int sendToTagList(List tagsList,

JSONObject msg_content, String extra, String extrasparam, String notification_title) {

ClientConfig clientConfig = ClientConfig.getInstance();

final JPushClient jpushClient = new JPushClient(MASTER_SECRET, APP_KEY, null, clientConfig);

int result = 0;

try {

PushPayload pushPayload = buildPushObject_all_tagList_alertWithTitle(tagsList, msg_content,

extra, extrasparam, notification_title);

log.info("" + pushPayload);

PushResult pushResult = jpushClient.sendPush(pushPayload);

log.info("" + pushResult);

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

result = 1;

}

} catch (APIConnectionException e) {

e.printStackTrace();

} catch (APIRequestException e) {
  e.printStackTrace();
}

return result;

}

public static int sendToAllAndroid(String notification_title,

String msg_content, String extraKey, String extrasparam) {

ClientConfig clientConfig = ClientConfig.getInstance();

final JPushClient jpushClient = new JPushClient(MASTER_SECRET, APP_KEY, null, clientConfig);

int result = 0;

try {

PushPayload pushPayload = buildPushObject_android_all_alertWithTitle(notification_title,

msg_content, extraKey, extrasparam);

log.info("" + pushPayload);

PushResult pushResult = jpushClient.sendPush(pushPayload);

log.info("" + pushResult);

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

result = 1;

}

} catch (Exception e) {

e.printStackTrace();

}

return result;

}

public static int sendToAllIos(String msg_content, String extraKey,

String extrasparam) {

ClientConfig clientConfig = ClientConfig.getInstance();

final JPushClient jpushClient = new JPushClient(MASTER_SECRET, APP_KEY, null, clientConfig);

int result = 0;

try {

PushPayload pushPayload = buildPushObject_ios_all_alertWithTitle(msg_content, extraKey,

extrasparam);

log.info("" + pushPayload);

PushResult pushResult = jpushClient.sendPush(pushPayload);

log.info("" + pushResult);

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

result = 1;

}

} catch (Exception e) {

e.printStackTrace();

}

return result;

}

private static PushPayload buildPushObject_all_aliasList_alertWithTitle(List aliasList,

String msg_content, String extraKey, String extrasparam, String notification_title) {

log.info("----------向所有平台单个或多个指定别名用户推送消息中......");
//创建一个IosAlert对象，可指定APNs的alert、title等字段
//IosAlert iosAlert =  IosAlert.newBuilder().setTitleAndBody("title", "alert body").build();

return PushPayload.newBuilder()
    //指定要推送的平台，all代表当前应用配置了的所有平台，也可以传android等具体平台
    .setPlatform(Platform.all())
    //指定推送的接收对象，all代表所有人，也可以指定已经设置成功的tag或alias或该应应用客户端调用接口获取到的registration id
    .setAudience(Audience.alias(aliasList))
    //jpush的通知，android的由jpush直接下发，iOS的由apns服务器下发，Winphone的由mpns下发
    .setNotification(Notification.newBuilder()
        //指定当前推送的android通知
        .addPlatformNotification(AndroidNotification.newBuilder()

            .setAlert(msg_content)
            .setTitle(notification_title)
            //此字段为透传字段，不会显示在通知栏。用户可以通过此字段来做一些定制需求，如特定的key传要指定跳转的页面（value）
            .addExtra(extraKey, 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("default")
            //此字段为透传字段，不会显示在通知栏。用户可以通过此字段来做一些定制需求，如特定的key传要指定跳转的页面（value）
            .addExtra(extraKey, 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("message extras key",extrasparam)

            .build())*/

    .setOptions(Options.newBuilder()
        //此字段的值是用来指定本推送要推送的apns环境，false表示开发，true表示生产；对android和自定义消息无意义
        .setApnsProduction(ApnsProduction)
        //此字段是给开发者自己给推送编号，方便推送者分辨推送记录
        .setSendno(1)
        //此字段的值是用来指定本推送的离线保存时长，如果不传此字段则默认保存一天，最多指定保留十天；
        .setTimeToLive(86400)

        .build())

    .build();

}

public static PushPayload buildPushObject_android_and_ios(String msg_content, String extraKey,

String extrasparam, String notification_title) {

log.info("----------向所有平台所有用户推送消息中…");

return PushPayload.newBuilder()

.setPlatform(Platform.android_ios())

.setAudience(Audience.all())

.setNotification(Notification.newBuilder()

.setAlert(msg_content)

.addPlatformNotification(AndroidNotification.newBuilder()

.setTitle(notification_title)

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

.addExtra(extraKey, extrasparam)

.build()

)

.addPlatformNotification(IosNotification.newBuilder()

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

// .setAlert(notification_title)

//直接传alert

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

.incrBadge(1)

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

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

.setSound(“default”)

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

.addExtra(extraKey, extrasparam)

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

// .setContentAvailable(true)

.build()
       )
       .build()

)

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

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

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

/.setMessage(Message.newBuilder()

.setMsgContent(msg_content)

.setTitle(msg_title)

.addExtra(“message extras key”,extrasparam)

.build())/

.setOptions(Options.newBuilder()

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

.setApnsProduction(ApnsProduction)

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

.setSendno(1)

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

.setTimeToLive(86400)

.build()

)

.build();

}

private static PushPayload buildPushObject_all_tagList_alertWithTitle(List tagsList,

JSONObject msg_content, String extraKey, String extrasparam, String notification_title) {

log.info("----------向所有平台单个或多个指定Tag用户推送消息中.......");
//创建一个IosAlert对象，可指定APNs的alert、title等字段
//IosAlert iosAlert =  IosAlert.newBuilder().setTitleAndBody("title", "alert body").build();

return PushPayload.newBuilder()
    //指定要推送的平台，all代表当前应用配置了的所有平台，也可以传android等具体平台
    .setPlatform(Platform.all())
    //指定推送的接收对象，all代表所有人，也可以指定已经设置成功的tag或alias或该应应用客户端调用接口获取到的registration id
    .setAudience(Audience.tag(tagsList))
    //jpush的通知，android的由jpush直接下发，iOS的由apns服务器下发，Winphone的由mpns下发
    .setNotification(Notification.newBuilder()
        //指定当前推送的android通知
        .addPlatformNotification(AndroidNotification.newBuilder()

            .setAlert(msg_content)
            .setTitle(notification_title)
            //此字段为透传字段，不会显示在通知栏。用户可以通过此字段来做一些定制需求，如特定的key传要指定跳转的页面（value）
            .addExtra(extraKey, 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("default")
            //此字段为透传字段，不会显示在通知栏。用户可以通过此字段来做一些定制需求，如特定的key传要指定跳转的页面（value）
            .addExtra(extraKey, 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("message extras key",extrasparam)

            .build())*/

    .setOptions(Options.newBuilder()
        //此字段的值是用来指定本推送要推送的apns环境，false表示开发，true表示生产；对android和自定义消息无意义
        .setApnsProduction(ApnsProduction)
        //此字段是给开发者自己给推送编号，方便推送者分辨推送记录
        .setSendno(1)
        //此字段的值是用来指定本推送的离线保存时长，如果不传此字段则默认保存一天，最多指定保留十天；
        .setTimeToLive(86400)

        .build())

    .build();

}

.setOptions(Options.newBuilder()

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

.setApnsProduction(ApnsProduction)

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

.setSendno(1)

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

.setTimeToLive(86400)

.build())

.build();

}

private static PushPayload buildPushObject_ios_all_alertWithTitle(String msg_content,

String extraKey, String extrasparam) {

log.info("----------向ios平台所有用户推送消息中…");

return PushPayload.newBuilder()

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

.setPlatform(Platform.ios())

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

.setAudience(Audience.all())

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

.setNotification(Notification.newBuilder()

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

.addPlatformNotification(IosNotification.newBuilder()

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

.setAlert(msg_content)

//直接传alert

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

.incrBadge(1)

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

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

.setSound(“default”)

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

.addExtra(extraKey, extrasparam)

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

// .setContentAvailable(true)

.build())
   .build()

)

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

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

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

/.setMessage(Message.newBuilder()

.setMsgContent(msg_content)

.setTitle(msg_title)

.addExtra(“message extras key”,extrasparam)

.build())/

.setOptions(Options.newBuilder()

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

.setApnsProduction(ApnsProduction)

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

.setSendno(1)

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

.setTimeToLive(86400)

.build())

.build();

}

}

上一篇: Javascript继承的最佳实践
下一篇: Spring循环依赖源码解析（下）Bean的创建循环依赖问题解决Spring不能解决的循环依赖