一、使用步驟

目錄

1.引入架包

2.創建推送的對象類

3.創建Util類，運行main測試完成

---

?1.引入架包

代碼如下（示例）：

<!-- 極光推送 begin --><dependency><groupId>cn.jpush.api</groupId><artifactId>jpush-client</artifactId><version>3.5.1</version></dependency><dependency><groupId>cn.jpush.api</groupId><artifactId>jiguang-common</artifactId><version>1.1.10</version></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><scope>test</scope></dependency><!-- 極光推送 end -->

---

2.創建推送的對象類

代碼如下（示例）：

package com.example.demo2.util.jpush;import lombok.Data;import java.util.List;@Data public class PushStudent {/** 發送目標類型 **/private Integer audienceType;/** 接收消息的用戶別名 **/private String aliasName;/** 標題 **/private String title;/** 內容 **/private String content;/** 跳轉類型 0:原生 1:網頁 **/private Integer goType;/** 跳轉 pageKey **/private String pageKey;/** 推送類型id **/private Long pushTypeId;/** 跳轉 url **/private String url;/** 學生編號 **/private String studentCode;/** 發送學生消息id **/private Long pushStudentId;/** 發送目標 **/public enum AudienceTypeEnum {/** 所有用戶 **/all(0, "所有用戶"),/** 標簽用戶 **/tags(1, "標簽用戶"),/** 別名用戶 **/alias(2, "別名用戶"),/** 自定義id用戶 **/registrationId(3, "自定義id用戶");private int value;private String desc;public int getValue() {return value;}public String getDesc() {return desc;}AudienceTypeEnum(int value, String desc) {this.value = value;this.desc = desc;}public static AudienceTypeEnum getTypeByValue(Integer valueKey) {if (null==valueKey) {return null;}for (AudienceTypeEnum enums : AudienceTypeEnum.values()) {if (enums.getValue() == valueKey) {return enums;}}return null;}} }

?3.創建Util類，運行main測試完成

代碼如下（示例）：

package com.example.demo2.util.jpush;import cn.jiguang.common.resp.APIConnectionException; import cn.jiguang.common.resp.APIRequestException; import cn.jpush.api.JPushClient; import cn.jpush.api.push.CIDResult; 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.IosAlert; import cn.jpush.api.push.model.notification.IosNotification; import cn.jpush.api.push.model.notification.Notification; import com.google.gson.JsonObject; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Component;import java.util.Arrays; import java.util.HashMap; import java.util.List; import java.util.Map;/*** 極光推送客戶端** @author lhc* @since 2021-06-01*/ @Component @Slf4j public class MyJPushClientsUtil {//@Value("${jpush.appKey}")private String appKey = "";//@Value("${jpush.masterSecret}")private String masterSecret = "";// 此字段的值是用來指定本推送要推送的apns環境，false表示開發，true表示生產；對android和自定義消息無意義@Value("${jpush.apnsProduction}")private String apnsProduction;private static JPushClient jPushClient = null;public JPushClient getJPushClient() {if (jPushClient == null) {jPushClient = new JPushClient(masterSecret, appKey);}return jPushClient;}/** 極光返回的狀態碼 **/private static Map<Integer, String> codeMap = new HashMap(12){private static final long serialVersionUID = 1L;{put(200,"OK Success!");put(400, "錯誤的請求 該請求是無效的。相應的描述信息會說明原因。");put(401, "未驗證 沒有驗證信息或者驗證失敗");put(403, "被拒絕 理解該請求，但不被接受。相應的描述信息會說明原因。");put(404, "無法找到 資源不存在，請求的用戶的不存在，請求的格式不被支持。");put(405, "請求方法不合適 該接口不支持該方法的請求。");put(410, "已下線 請求的資源已下線。請參考相關公告。");put(429, "過多的請求 請求超出了頻率限制。相應的描述信息會解釋具體的原因。");put(500, "內部服務錯誤 服務器內部出錯了。請聯系我們盡快解決問題。");put(502, "無效代理 業務服務器下線了或者正在升級。請稍后重試。");put(503, "服務暫時失效 服務器無法響應請求。請稍后重試。");put(504, "代理超時");}};public static String getCodeStr(int code){return (codeMap.get(code)==null || "".equals(codeMap.get(code)))?"無對應狀態碼值":codeMap.get(code);}/** 獲取 cid，避免同一個通知被調用多次 **/private String getCid(JPushClient jPushClient) {String value = null;try {CIDResult cidResult = jPushClient.getCidList(1, "push");value = cidResult.cidlist.get(0);} catch (APIConnectionException | APIRequestException e) {log.error("獲取極光cid失敗 ", e);}return value;}// 擴展消息private Map<String, String> getAppExtra(PushStudent pushMessage){Map<String, String> extra = new HashMap<>(6);extra.put("third_url_encode","false");extra.put("pageKey",pushMessage.getPageKey());extra.put("url",pushMessage.getUrl());extra.put("studentCode",pushMessage.getStudentCode());extra.put("goType",""+pushMessage.getGoType());extra.put("pushTypeId",""+pushMessage.getPushTypeId());return extra;}private PushResult sendPush(PushPayload pushPayload) {log.info("pushPayload={}", pushPayload);PushResult pushResult = null;try {JPushClient jPushClient = this.getJPushClient();pushResult = jPushClient.sendPush(pushPayload);log.info("" + pushResult);if (pushResult.getResponseCode() == 200) {log.info("push successful, pushPayload={}", pushPayload);System.out.println(pushPayload);}} catch (APIConnectionException e) {log.error("push failed: pushPayload={}, exception={}", pushPayload, e);throw new RuntimeException(e.getMessage());} catch (APIRequestException e) {log.error("push failed: pushPayload={}, exception={}", pushPayload, e);throw new RuntimeException(e.getMessage());}finally {jPushClient.close();}return pushResult;}private AndroidNotification getAndroidNotification(PushStudent pushMessage){return AndroidNotification.newBuilder()//消息體.setTitle(pushMessage.getTitle()).setAlert(pushMessage.getContent()).addExtras(getAppExtra(pushMessage)).setBadgeAddNum(1).setBadgeClass("com.skyedu.communal.ui.splash.SplashActivity").setUriAction("com.skyedu.push.StudentOpenClickActivity").setUriActivity("com.skyedu.push.StudentOpenClickActivity").build();}private IosNotification getIosNotification(PushStudent pushMessage){IosAlert alert = IosAlert.newBuilder().setTitleAndBody(pushMessage.getTitle(), "", pushMessage.getContent()).build();return IosNotification.newBuilder()//消息體.setAlert(alert)// 通知提示聲音或警告通知//.setSound(pushMessage.getSound())// 應用角標.incrBadge(1).addExtras(getAppExtra(pushMessage)).setMutableContent(true).build();}/** 發送極光消息 **/public PushResult buildPush(PushStudent mesVo){Audience audience;PushStudent.AudienceTypeEnum audienceTypeEnum = PushStudent.AudienceTypeEnum.getTypeByValue(mesVo.getAudienceType());switch (audienceTypeEnum) {case all:audience = Audience.all();break;case tags:audience = Audience.tag(mesVo.getAliasName());break;case alias:audience = Audience.alias(mesVo.getAliasName());break;case registrationId:audience = Audience.registrationId(mesVo.getAliasName());break;default:log.error("不支持該類型: audience:{} ", mesVo.getAudienceType());throw new RuntimeException("不支持該類型!");}PushPayload.Builder builder = PushPayload.newBuilder();builder.setPlatform(Platform.android_ios());builder.setAudience(audience);// 設置發送設備Notification.Builder notBuilder = Notification.newBuilder();notBuilder.addPlatformNotification(getAndroidNotification(mesVo));notBuilder.addPlatformNotification(getIosNotification(mesVo));builder.setNotification(notBuilder.build());// 其他builder.setCid(getCid(this.getJPushClient()));builder.setOptions(Options.newBuilder().setApnsProduction(apnsProduction!=null && apnsProduction.equals("true")).setThirdPartyChannelV2(getThirdPartyChannel()).build());PushResult pushResult = this.sendPush(builder.build());return pushResult;}public Map getThirdPartyChannel(){Map<String, JsonObject> thirdPartyChannel = new HashMap<>();JsonObject json = new JsonObject();json.addProperty("distribution","secondary_push");thirdPartyChannel.put("xiaomi",json);thirdPartyChannel.put("huawei",json);thirdPartyChannel.put("meizu",json);thirdPartyChannel.put("fcm",json);thirdPartyChannel.put("oppo",json);thirdPartyChannel.put("vivo",json);return thirdPartyChannel;}public static void main(String[] args) throws APIConnectionException {MyJPushClientsUtil jPushUtil = new MyJPushClientsUtil();PushStudent mesVo = new PushStudent();mesVo.setAudienceType(PushStudent.AudienceTypeEnum.alias.getValue());List<String> aliasList = Arrays.asList();mesVo.setAliasName("你的別名");mesVo.setTitle("消息標題");mesVo.setContent("消息內容消息內容消息內容");mesVo.setPageKey("pagekey");mesVo.setUrl("https://fanyi.baidu.com/?aldtype=16047#auto/zh");mesVo.setStudentCode("NO110");PushResult pushResult = jPushUtil.buildPush(mesVo);System.out.println(pushResult.getOriginalContent());}}

總結

以上是生活随笔為你收集整理的Java极光推送工具类的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。