极光推送_总结_01_Java实现极光推送-低调大师

极光推送_总结_01_Java实现极光推送

2017-11-28 701

一、代码实现

1.配置类—Env.java

package com.ray.jpush.config;

/**@desc  : 极光推送接入配置
 * 
 * @author: shirayner
 * @date  : 2017年9月27日 下午4:57:36
 */

public class Env {

    /**
     * 1.极光推送后台APPKEY,MASTER_SECRET
     */
    public static final String APP_KEY = "354fb5c3dd4249ec11bc545d";
    public static final String MASTER_SECRET = "8976605bf8a9ef9d8d97a8c2";
}

View Code

2.消息服务类—MessageService.java

package com.ray.jpush.service.message;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.ray.jpush.util.CommonUtil;
import com.ray.jpush.util.HttpHelper;

/**@desc  : 极光推送消息服务
 * 
 * @author: shirayner
 * @date  : 2017年11月29日 下午2:24:16
 */
public class MessageService {
    private static final Logger log= LogManager.getLogger(MessageServiceTest.class);

    //1.发送通知
    private static final String SEND_NOTIFICATION_URL="https://api.jpush.cn/v3/push";

    /**
     * @desc ： 1.调用极光API
     *  
     * @param url  接口url
     * @param registration_id  注册id
     * @param alert  通知内容
     * @param appKey   
     * @param masterSecret
     * @return 
     *   JSONObject
     */
    public static JSONObject sendNotification(String registration_id,String alert,String appKey,String masterSecret) {
        
        String base64_auth_string = CommonUtil.encryptBASE64(appKey + ":" + masterSecret);
        String authorization = "Basic " + base64_auth_string;
        
        String data=generateJson(registration_id,alert).toString();
       
        log.debug("authorization:"+authorization);
        log.debug("data:"+data);
       
        return HttpHelper.doPost(SEND_NOTIFICATION_URL, data, authorization);
    }
    
    
    /**
     * @desc ：  2.拼装请求json
     *   
     * @param registration_id     注册id
     * @param alert    通知内容
     * @return 
     *   JSONObject
     */
    private static JSONObject generateJson(String registration_id,String alert){
        JSONObject json = new JSONObject();
        
        JSONArray platform = new JSONArray();   //1.推送平台设置
        platform.add("android");
        platform.add("ios");
        
        JSONObject audience = new JSONObject();       //2.推送设备指定，即推送目标
        JSONArray registrationIdList = new JSONArray();
        registrationIdList.add(registration_id);
        audience.put("registration_id", registrationIdList);
        
        JSONObject notification = new JSONObject();         //3.通知内容
        JSONObject android = new JSONObject();             //3.1 android通知内容
        android.put("alert", alert);                      //设置通知内容
        android.put("builder_id", 1);
        JSONObject android_extras = new JSONObject();//android额外参数
        android_extras.put("type", "infomation");
        android.put("extras", android_extras);
        
        JSONObject ios = new JSONObject();//3.2 ios通知内容
        ios.put("alert", alert);
        ios.put("sound", "default");
        ios.put("badge", "+1");
        JSONObject ios_extras = new JSONObject();//ios额外参数
        ios_extras.put("type", "infomation");
        ios.put("extras", ios_extras);
        notification.put("android", android);
        notification.put("ios", ios);
        
        
        json.put("platform", platform);
        json.put("audience", audience);
        json.put("notification", notification);

        return json;
        
    }
    
}

View Code

3.HttpHelper工具类—HttpHelper.java

package com.ray.jpush.util;

import java.io.IOException;

import org.apache.http.HttpEntity;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.protocol.BasicHttpContext;
import org.apache.http.util.EntityUtils;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;

/**
 * HTTP请求工具类
 */
public class HttpHelper {


    /**
     * @desc ：1.发送POST请求-极光推送
     *  
     * @param url   接口url
     * @param data  请求包体
     * @param authorization  验证字段，Authorization: Basic base64_auth_string
     *                       其中 base64_auth_string 的生成算法为：base64(appKey:masterSecret)
     *                       即，对 appKey 加上冒号，加上 masterSecret 拼装起来的字符串，再做 base64 转换。
     * @return
     * @throws Exception 
     *   JSONObject
     */
    public static JSONObject doPost(String url, String data ,String authorization) {
        //1.生成一个请求
        HttpPost httpPost = new HttpPost(url);

        //2.配置请求属性
        //2.1 设置请求超时时间
        RequestConfig requestConfig = RequestConfig.custom().setSocketTimeout(100000).setConnectTimeout(100000).build();
        httpPost.setConfig(requestConfig);
        //2.2 设置数据传输格式-json
        httpPost.addHeader("Content-Type", "application/json");
        //2.3 设置Authorization
        httpPost.addHeader("Authorization", authorization.trim());
        
        //2.3 设置请求实体，封装了请求参数
        StringEntity requestEntity = new StringEntity(data, "utf-8");
        httpPost.setEntity(requestEntity);

        //3.发起请求，获取响应信息    
        //3.1 创建httpClient 
        CloseableHttpClient httpClient = HttpClients.createDefault();
        CloseableHttpResponse response = null;

        try {
            //3.3 发起请求，获取响应
            response = httpClient.execute(httpPost, new BasicHttpContext());

            if (response.getStatusLine().getStatusCode() != 200) {

                System.out.println("request url failed, http code=" + response.getStatusLine().getStatusCode()
                        + ", url=" + url);
                return null;
            }

            //获取响应内容
            HttpEntity entity = response.getEntity();
            if (entity != null) {
                String resultStr = EntityUtils.toString(entity, "utf-8");
                System.out.println("POST请求结果："+resultStr);

                //解析响应内容
                JSONObject result = JSON.parseObject(resultStr);

                //请求失败
                if (result.getInteger("errcode")!=null && 0 != result.getInteger("errcode")) {  

                    System.out.println("request url=" + url + ",return value=");
                    System.out.println(resultStr);
                    int errCode = result.getInteger("errcode");
                    String errMsg = result.getString("errmsg");
                    
                    try {
                        throw new Exception("error code:"+errCode+", error message:"+errMsg);
                    } catch (Exception e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    } 
    
                    //请求成功
                } else {
                    return result;
                } 
                
            
            }
        } catch (IOException e) {
            System.out.println("request url=" + url + ", exception, msg=" + e.getMessage());
            e.printStackTrace();
        } finally {
            if (response != null) try {
                response.close();              //释放资源

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

        return null;
    }

}

View Code

4.通用工具类—CommonUtil.java

package com.ray.jpush.util;

import sun.misc.BASE64Encoder;

/**@desc  : 
 * 
 * @author: shirayner
 * @date  : 2017年11月29日 下午3:11:33
 */
public class CommonUtil {


    /**
     * @desc ：BASE64加密工具
     *  
     * @param str  待加密字符串
     * @return 
     *   String
     */
    public static String encryptBASE64(String str) {
        byte[] key = str.getBytes();
        BASE64Encoder base64Encoder = new BASE64Encoder();
        String strs = base64Encoder.encodeBuffer(key);
        return strs;
    }
}

View Code

5.消息服务测试类—MessageServiceTest.java

package com.ray.jpush.service.message;

import org.junit.Test;

import com.ray.jpush.config.Env;

/**@desc  : 极光推送测试类
 * 
 * @author: shirayner
 * @date  : 2017年11月29日 下午3:54:42
 */
public class MessageServiceTest {

    /**
     * @desc :1.发送通知
     *   
     *   void
     */
    @Test
    public void testSendNotification() {
        String registration_id="121c83f760211fa5944";
        //String alert="hello,my honey!";
        String alert="您好:\\n 于岩军在2017-11-15提出了一张金额为5的费用报销单 BX10017110076 ,需要审批! \\n\\n\\n===================================================================\\n\\n秒针费用管理系统\\n\\n本邮件由系统自动发送,请勿回复。";
        String appKey=Env.APP_KEY;
        String masterSecret=Env.MASTER_SECRET;
        
        MessageService.sendNotification(registration_id, alert, appKey, masterSecret);
    }
}

View Code

二、参考资料

1.极光推送经验之谈-Java后台服务器实现极光推送的两种实现方式

微信关注我们

原文链接：https://yq.aliyun.com/articles/621444

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

安装CentOS7（文）

步骤： “虚拟机设置”》“cd/dvd“的选择“使用ios映像” 开启虚拟机。选择第一项安装。选择语言下拉“中文”“简体中文”，继续系统选择安装位置、其他存储选项分区，选择“我要配置分区”完成。下拉列表中选择“标准分区”，在选择“+”》挂载点“boot”容量“200M”、“swap”“内存的2倍（大于等于4G，分8G就可以）”其他的分根分区。完成》接受改变。开始安装。设置用户密码（弱密码两下回车）本文转自虾米的春天 51CTO博客，原文链接：http://blog.51cto.com/lsxme/1972627，如需转载请自行联系原作者

2017-11-28

643

Ubuntu上adb使用及问题解决 Adb包是从解压版eclipse解压而来（adb可脱离eclipse或sdk独立使用，直接将包拷走即可）然后做了个到/sbin/下的软链接（员工电脑已做），$sudo ln –s /home/IT/sdk/platform-tools/adb /sbin/，可执行which命令进行查看：$ which adb Adb版本：1.0.31（android 4.4.2要求adb版本为1.0.29以上，如果adb版本较低可进行下替换） Adb执行kill后再start会生成.android目录（命令执行时前要加sudo） $ sudo adb kill-server $ sudo adb start-server $ sudo ls/root/.android/ (adbkey和adbkey.pub) 然后在/root/android/下新建adb_usb.ini文件，文件里写上手机usb id （可通过lsusb进行查看，如：0x1773）如果员工Ubuntu无法连接手机可首先查看该文件（adb_usb.ini）是否存在，或文件内容（0x1773）是否...

2017-11-28

789

资源下载

更多资源

Mario

马里奥是站在游戏界顶峰的超人气多面角色。马里奥靠吃蘑菇成长，特征是大鼻子、头戴帽子、身穿背带裤，还留着胡子。与他的双胞胎兄弟路易基一起，长年担任任天堂的招牌角色。

腾讯云软件源

为解决软件依赖安装时官方源访问速度慢的问题，腾讯云为一些软件搭建了缓存服务。您可以通过使用腾讯云软件源站来提升依赖包的安装速度。为了方便用户自由搭建服务架构，目前腾讯云软件源站支持公网访问和内网访问。

Spring

Spring框架（Spring Framework）是由Rod Johnson于2002年提出的开源Java企业级应用框架，旨在通过使用JavaBean替代传统EJB实现方式降低企业级编程开发的复杂性。该框架基于简单性、可测试性和松耦合性设计理念，提供核心容器、应用上下文、数据访问集成等模块，支持整合Hibernate、Struts等第三方框架，其适用范围不仅限于服务器端开发，绝大多数Java应用均可从中受益。

Rocky Linux

Rocky Linux（中文名：洛基）是由Gregory Kurtzer于2020年12月发起的企业级Linux发行版，作为CentOS稳定版停止维护后与RHEL（Red Hat Enterprise Linux）完全兼容的开源替代方案，由社区拥有并管理，支持x86_64、aarch64等架构。其通过重新编译RHEL源代码提供长期稳定性，采用模块化包装和SELinux安全架构，默认包含GNOME桌面环境及XFS文件系统，支持十年生命周期更新。