極光推送經(jīng)驗之談-Java后臺服務器實現(xiàn)極光推送的兩種實現(xiàn)方式

原創(chuàng)作品频轿,可以轉(zhuǎn)載市咽,但是請標注出處地址http://www.reibang.com/p/c682cb8e50fd

Java后臺實現(xiàn)極光推送有兩種方式痊银,一種是使用極光推送官方提供的推送請求API:https://api.jpush.cn/v3/push,另一種則是使用官方提供的第三方Java SDK施绎,這里先進行第一種方式推送的實現(xiàn)代碼:

import org.apache.http.HttpResponse;
import org.apache.http.client.HttpClient;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.DefaultHttpClient;
import org.apache.http.util.EntityUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.alibaba.fastjson.JSONArray;
import net.sf.json.JSONObject;
import sun.misc.BASE64Encoder;

/**
 * java后臺極光推送方式一:使用Http API
 * 此種方式需要自定義http請求發(fā)送客戶端:HttpClient
 */
@SuppressWarnings({ "deprecation", "restriction" })
public class JiguangPush {
    private static final Logger log = LoggerFactory.getLogger(JiguangPush.class);
    private String masterSecret = "xxxxxxxxxxxxxxxxxxxx";
    private String appKey = "xxxxxxxxxxxxxxxxxxx";
    private String pushUrl = "https://api.jpush.cn/v3/push";    
    private boolean apns_production = true;    
    private int time_to_live = 86400;
    private static final String ALERT = "推送信息";    
    /**
     * 極光推送
     */
    public void jiguangPush(){
        String alias = "123456";//聲明別名
        try{
            String result = push(pushUrl,alias,ALERT,appKey,masterSecret,apns_production,time_to_live);
            JSONObject resData = JSONObject.fromObject(result);
                if(resData.containsKey("error")){
                    log.info("針對別名為" + alias + "的信息推送失斔莞铩!");
                    JSONObject error = JSONObject.fromObject(resData.get("error"));
                    log.info("錯誤信息為:" + error.get("message").toString());
                }
            log.info("針對別名為" + alias + "的信息推送成功谷醉!");
        }catch(Exception e){
            log.error("針對別名為" + alias + "的信息推送失斨孪 !",e);
        }
    }
    
    /**
     * 組裝極光推送專用json串
     * @param alias
     * @param alert
     * @return json
     */
    public static JSONObject generateJson(String alias,String alert,boolean apns_production,int time_to_live){
        JSONObject json = new JSONObject();
        JSONArray platform = new JSONArray();//平臺
        platform.add("android");
        platform.add("ios");
        
        JSONObject audience = new JSONObject();//推送目標
        JSONArray alias1 = new JSONArray();
        alias1.add(alias);
        audience.put("alias", alias1);
        
        JSONObject notification = new JSONObject();//通知內(nèi)容
        JSONObject android = new JSONObject();//android通知內(nèi)容
        android.put("alert", alert);
        android.put("builder_id", 1);
        JSONObject android_extras = new JSONObject();//android額外參數(shù)
        android_extras.put("type", "infomation");
        android.put("extras", android_extras);
        
        JSONObject ios = new JSONObject();//ios通知內(nèi)容
        ios.put("alert", alert);
        ios.put("sound", "default");
        ios.put("badge", "+1");
        JSONObject ios_extras = new JSONObject();//ios額外參數(shù)
        ios_extras.put("type", "infomation");
        ios.put("extras", ios_extras);
        notification.put("android", android);
        notification.put("ios", ios);
        
        JSONObject options = new JSONObject();//設置參數(shù)
        options.put("time_to_live", Integer.valueOf(time_to_live));
        options.put("apns_production", apns_production);
        
        json.put("platform", platform);
        json.put("audience", audience);
        json.put("notification", notification);
        json.put("options", options);
        return json;
        
    }
    
    /**
     * 推送方法-調(diào)用極光API
     * @param reqUrl
     * @param alias
     * @param alert
     * @return result
     */
    public static String push(String reqUrl,String alias,String alert,String appKey,String masterSecret,boolean apns_production,int time_to_live){
        String base64_auth_string = encryptBASE64(appKey + ":" + masterSecret);
        String authorization = "Basic " + base64_auth_string;
        return sendPostRequest(reqUrl,generateJson(alias,alert,apns_production,time_to_live).toString(),"UTF-8",authorization);
    }
    
    /**
     * 發(fā)送Post請求(json格式)
     * @param reqURL
     * @param data
     * @param encodeCharset
     * @param authorization
     * @return result
     */
    @SuppressWarnings({ "resource" })
    public static String sendPostRequest(String reqURL, String data, String encodeCharset,String authorization){
        HttpPost httpPost = new HttpPost(reqURL);
        HttpClient client = new DefaultHttpClient();
        HttpResponse response = null;
        String result = "";
        try {
             StringEntity entity = new StringEntity(data, encodeCharset);
             entity.setContentType("application/json");
             httpPost.setEntity(entity);
             httpPost.setHeader("Authorization",authorization.trim());
             response = client.execute(httpPost);
             result = EntityUtils.toString(response.getEntity(), encodeCharset);
        } catch (Exception e) {
            log.error("請求通信[" + reqURL + "]時偶遇異常,堆棧軌跡如下", e);  
        }finally{
            client.getConnectionManager().shutdown();
        }
        return result;
    }
     /**     * BASE64加密工具    */
     public static String encryptBASE64(String str) {
         byte[] key = str.getBytes();
       BASE64Encoder base64Encoder = new BASE64Encoder();
       String strs = base64Encoder.encodeBuffer(key);
         return strs;
     }
}

以上代碼中使用的是第一種方式實現(xiàn)推送俱尼,下面介紹第二種方式:使用java SDK

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


/**
 * java后臺極光推送方式二:使用Java SDK
 */
@SuppressWarnings({ "deprecation", "restriction" })
public class JiguangPush {
    private static final Logger log = LoggerFactory.getLogger(JiguangPush.class);
    private static String masterSecret = "xxxxxxxxxxxxxxxxx";
    private static String appKey = "xxxxxxxxxxxxxxxx";
    private static final String ALERT = "推送信息";    
    /**
     * 極光推送
     */
    public void jiguangPush(){
        String alias = "123456";//聲明別名
        log.info("對別名" + alias + "的用戶推送信息");
        PushResult result = push(String.valueOf(alias),ALERT);
        if(result != null && result.isResultOK()){
            log.info("針對別名" + alias + "的信息推送成功抖单!");
        }else{
            log.info("針對別名" + alias + "的信息推送失敗遇八!");
        }
    }
    
    /**
     * 生成極光推送對象PushPayload(采用java SDK)
     * @param alias
     * @param alert
     * @return PushPayload
     */
    public static PushPayload buildPushObject_android_ios_alias_alert(String alias,String alert){
        return PushPayload.newBuilder()
                .setPlatform(Platform.android_ios())
                .setAudience(Audience.alias(alias))
                .setNotification(Notification.newBuilder()
                        .addPlatformNotification(AndroidNotification.newBuilder()
                                .addExtra("type", "infomation")
                                .setAlert(alert)
                                .build())
                        .addPlatformNotification(IosNotification.newBuilder()
                                .addExtra("type", "infomation")
                                .setAlert(alert)
                                .build())
                        .build())
                .setOptions(Options.newBuilder()
                        .setApnsProduction(false)//true-推送生產(chǎn)環(huán)境 false-推送開發(fā)環(huán)境(測試使用參數(shù))
                        .setTimeToLive(90)//消息在JPush服務器的失效時間(測試使用參數(shù))
                        .build())
                .build();
    }
    /**
     * 極光推送方法(采用java SDK)
     * @param alias
     * @param alert
     * @return PushResult
     */
    public static PushResult push(String alias,String alert){
        ClientConfig clientConfig = ClientConfig.getInstance();
        JPushClient jpushClient = new JPushClient(masterSecret, appKey, null, clientConfig);
        PushPayload payload = buildPushObject_android_ios_alias_alert(alias,alert);
        try {
            return jpushClient.sendPush(payload);
        } catch (APIConnectionException e) {
            log.error("Connection error. Should retry later. ", e);
            return null;
        } catch (APIRequestException e) {
            log.error("Error response from JPush server. Should review and fix it. ", e);
            log.info("HTTP Status: " + e.getStatus());
            log.info("Error Code: " + e.getErrorCode());
            log.info("Error Message: " + e.getErrorMessage());
            log.info("Msg ID: " + e.getMsgId());
            return null;
        }    
    }
}

可以看出使用Java SDK實現(xiàn)推送的方式很簡單矛绘,代碼量也少,理解起來也不難刃永,官方提供的SDK中將很多內(nèi)容都實現(xiàn)了货矮,我們只是需要配置一下信息,然后發(fā)起推送即可揽碘。需要注意的是使用第二種方式次屠,需要導入極光官網(wǎng)提供的jar包。

直接在maven中的pom文件中加入:

<dependency>
    <groupId>cn.jpush.api</groupId>
    <artifactId>jpush-client</artifactId>
    <version>3.2.15</version>
</dependency>

注意:在這里極有可能會出現(xiàn)jar包沖突:具體哪個包我也忘記了雳刺,好像是個日志包劫灶,找到后刪除即可,我曾經(jīng)記錄過這個jar包沖突問題掖桦,詳見jar包沖突解決本昏。

原本我們項目中也是采用第二種方式實現(xiàn)的,但是最后在提交代碼時發(fā)現(xiàn)一個問題枪汪,那就是雖然我們只是帶導入了官網(wǎng)提供的那個jar包涌穆,但是最后一統(tǒng)計,竟然無緣無故增多了80+個jar包雀久,如此多的jar包提交過于臃腫宿稀,而且不現(xiàn)實,所以才臨時改變方案赖捌,采用第一種方式進行編碼祝沸。

代碼中采用的是別名方式進行推送,需要在在手機APP端進行別名設置越庇,最好就是在用戶登錄之后就設置好罩锐,這樣只要用戶登錄一次,它的綁定別名就可以保存到極光服務器卤唉,而我們推送時涩惑,指定這個別名,就能將信息推送到對應用戶的手機上桑驱。

其實我們發(fā)起推送請求竭恬,只是將信息發(fā)送到了極光服務器之上,這個信息有一個保存時限熬的,默認一天萍聊,只要用戶使用手機APP登錄系統(tǒng),極光服務器就會將信息自動推送到對應別名的手機上悦析,由此可見寿桨,信息并非由我們后臺直接推送到手機,而是通過極光服務器這個中轉(zhuǎn)站强戴,而這正式極光的工作亭螟。

注意:這里告知一個技巧,這個別名設置的時候骑歹,其實直接將用戶ID設置為別名即可预烙,既方便,又安全道媚,不用再去想辦法生成一個唯一的串來進行標識扁掸,甚至需要在后臺數(shù)據(jù)庫中用戶表中新增字段翘县。

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末,一起剝皮案震驚了整個濱河市谴分,隨后出現(xiàn)的幾起案子锈麸,更是在濱河造成了極大的恐慌,老刑警劉巖牺蹄,帶你破解...
    沈念sama閱讀 206,214評論 6 481
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件忘伞,死亡現(xiàn)場離奇詭異,居然都是意外死亡沙兰,警方通過查閱死者的電腦和手機氓奈,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 88,307評論 2 382
  • 文/潘曉璐 我一進店門,熙熙樓的掌柜王于貴愁眉苦臉地迎上來鼎天,“玉大人舀奶,你說我怎么就攤上這事≌洌” “怎么了伪节?”我有些...
    開封第一講書人閱讀 152,543評論 0 341
  • 文/不壞的土叔 我叫張陵,是天一觀的道長绩鸣。 經(jīng)常有香客問我怀大,道長,這世上最難降的妖魔是什么呀闻? 我笑而不...
    開封第一講書人閱讀 55,221評論 1 279
  • 正文 為了忘掉前任化借,我火速辦了婚禮,結(jié)果婚禮上捡多,老公的妹妹穿的比我還像新娘蓖康。我一直安慰自己,他們只是感情好垒手,可當我...
    茶點故事閱讀 64,224評論 5 371
  • 文/花漫 我一把揭開白布蒜焊。 她就那樣靜靜地躺著,像睡著了一般科贬。 火紅的嫁衣襯著肌膚如雪泳梆。 梳的紋絲不亂的頭發(fā)上,一...
    開封第一講書人閱讀 49,007評論 1 284
  • 那天榜掌,我揣著相機與錄音优妙,去河邊找鬼。 笑死憎账,一個胖子當著我的面吹牛套硼,可吹牛的內(nèi)容都是我干的垄开。 我是一名探鬼主播劈狐,決...
    沈念sama閱讀 38,313評論 3 399
  • 文/蒼蘭香墨 我猛地睜開眼,長吁一口氣:“原來是場噩夢啊……” “哼辖众!你這毒婦竟也來了辩块?” 一聲冷哼從身側(cè)響起欣舵,我...
    開封第一講書人閱讀 36,956評論 0 259
  • 序言:老撾萬榮一對情侶失蹤葱轩,失蹤者是張志新(化名)和其女友劉穎征峦,沒想到半個月后,有當?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體呆贿,經(jīng)...
    沈念sama閱讀 43,441評論 1 300
  • 正文 獨居荒郊野嶺守林人離奇死亡,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 35,925評論 2 323
  • 正文 我和宋清朗相戀三年森渐,在試婚紗的時候發(fā)現(xiàn)自己被綠了做入。 大學時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點故事閱讀 38,018評論 1 333
  • 序言:一個原本活蹦亂跳的男人離奇死亡同衣,死狀恐怖竟块,靈堂內(nèi)的尸體忽然破棺而出,到底是詐尸還是另有隱情耐齐,我是刑警寧澤浪秘,帶...
    沈念sama閱讀 33,685評論 4 322
  • 正文 年R本政府宣布,位于F島的核電站埠况,受9級特大地震影響耸携,放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜辕翰,卻給世界環(huán)境...
    茶點故事閱讀 39,234評論 3 307
  • 文/蒙蒙 一夺衍、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧喜命,春花似錦沟沙、人聲如沸。這莊子的主人今日做“春日...
    開封第一講書人閱讀 30,240評論 0 19
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽。三九已至牌里,卻和暖如春颊咬,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背牡辽。 一陣腳步聲響...
    開封第一講書人閱讀 31,464評論 1 261
  • 我被黑心中介騙來泰國打工贪染, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留,地道東北人催享。 一個月前我還...
    沈念sama閱讀 45,467評論 2 352
  • 正文 我出身青樓杭隙,卻偏偏與公主長得像,于是被迫代替她去往敵國和親因妙。 傳聞我的和親對象是個殘疾皇子痰憎,可洞房花燭夜當晚...
    茶點故事閱讀 42,762評論 2 345