极光推送消息——Alias别称方式（Andirod）

1、pom文件引入相关jar包

 <!--极光推送消息start-->
    <dependency>
      <groupId>net.sf.json-lib</groupId>
      <artifactId>json-lib</artifactId>
      <version>2.4</version>
      <classifier>jdk15</classifier>
    </dependency>


    <dependency>
      <groupId>cn.jpush.api</groupId>
      <artifactId>jpush-client</artifactId>
      <version>3.3.3</version>
      <exclusions>
        <exclusion>
          <groupId>org.slf4j</groupId>
          <artifactId>slf4j-api</artifactId>
        </exclusion>
      </exclusions>

    </dependency>

    <dependency>
      <groupId>cn.jpush.api</groupId>
      <artifactId>jiguang-common</artifactId>
      <version>1.1.1</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-->

2、提供相关包装好的类

（1）消息封装类

package com.test.entity.common;

import com.google.gson.JsonObject;

import java.util.List;
import java.util.Map;

/**
 * 极光推送消息类
 */
public class JPushDeviceBean {
  private String token;
  private String alias_value;//别名值
  private String registration_id;
  private List<String> username;//所有用户别名
  private String title;//标题
  private String fsmessagecontent;//内容
  private Integer count;//角标数
  private Map<String, String> extrasMap;
  private JsonObject extra;

  public JsonObject getExtra() {
    return extra;
  }

  public void setExtra(JsonObject extra) {
    this.extra = extra;
  }

  public Map<String, String> getExtrasMap() {
    return extrasMap;
  }

  public void setExtrasMap(Map<String, String> extrasMap) {
    this.extrasMap = extrasMap;
  }

  public String getToken() {
    return token;
  }

  public void setToken(String token) {
    this.token = token;
  }

  public String getAlias_value() {
    return alias_value;
  }

  public void setAlias_value(String alias_value) {
    this.alias_value = alias_value;
  }

  public String getRegistration_id() {
    return registration_id;
  }

  public void setRegistration_id(String registration_id) {
    this.registration_id = registration_id;
  }

  public List<String> getUsername() {
    return username;
  }

  public void setUsername(List<String> username) {
    this.username = username;
  }

  public String getTitle() {
    return title;
  }

  public void setTitle(String title) {
    this.title = title;
  }

  public String getFsmessagecontent() {
    return fsmessagecontent;
  }

  public void setFsmessagecontent(String fsmessagecontent) {
    this.fsmessagecontent = fsmessagecontent;
  }

  public Integer getCount() {
    return count;
  }

  public void setCount(Integer count) {
    this.count = count;
  }
}

（2）工具类

package com.test.util;

import cn.jpush.api.push.model.Message;
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.audience.AudienceTarget;
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.google.gson.JsonObject;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.Map;

public class JPushDevice {

    protected static final Logger LOG =LoggerFactory.getLogger(JPushDevice.class);

    private static final String URL="https://device.jpush.cn";//极光访问URL
    public static long timeToLive=60*60*24*10;//10天

    //privatestaticJPushClientjpushClient= newJPushClient(masterSecret,appKey,null,ClientConfig.getInstance());

    //  //对于推送，您所需要做的就是构建PushPayload对象。
    //  PushPayloadpayload=buildPushObject_ios_audienceMore_messageWithExtras();
    //  PushResultresult=jpushClient.sendPush(payload);

    public static PushPayload buildPushObject_android_tag_alertWithTitle(String username){
      return PushPayload.newBuilder()
        .setPlatform(Platform.all())
        .setAudience(Audience.alias(username))
        .setNotification(Notification.alert("ALERT"))
        .build();
    }
    //弹框
   public static PushPayload buildPushObject_ios_audienceMore_messageWithExtras(String username){
      return PushPayload.newBuilder()
        .setPlatform(Platform.all())
        .setAudience(Audience.alias(username))
        .setMessage(Message.newBuilder()
            .setMsgContent("您有一条回复内容。。")
            .addExtra("from","JPush")
          .build())
        .build();
    }
    //推送全部平台（一个用户）（无角标）
  public static PushPayload oneName(String username, String title, String fsmessagecontent,
                                    Map<String, String> extrasMap, JsonObject extra){
      return PushPayload.newBuilder()
        .setPlatform(Platform.all())//推送全部平台
      .setAudience(Audience.newBuilder()//推送目标：别名、标签、注册ID、分群、广播等。
        .addAudienceTarget(AudienceTarget.alias(username))
        .build())
        .setMessage(Message.newBuilder()
          .setMsgContent(fsmessagecontent)//消息内容
       //     .setTitle(count.toString())//当做安卓的角标数
            .addExtra("from","JPush")//应用内消息通道
            .build())
        .setNotification(Notification.newBuilder()//notification：通知内容体。是被推送到客户端的内容
        .addPlatformNotification(IosNotification.newBuilder()//iOS
        .setAlert(title)//弹框显示标题
       // .setBadge(count)//角标
        .build())
            .addPlatformNotification(AndroidNotification.newBuilder()//安卓
            .setAlert(fsmessagecontent)//弹框显示内容
            .setTitle(title)//弹框显示标题
              .addExtras(extrasMap)
              .addExtra("extra",extra)
            .build())
            .build())
        .build();
    }
      //推送全部平台（传多个别名用户）（有角标）
      public static PushPayload AllName(String[] username,String title,String fsmessagecontent,Integer count){
        return PushPayload.newBuilder()
          .setPlatform(Platform.all())//推送全部平台
          .setAudience(Audience.newBuilder()//推送目标：别名、标签、注册ID、分群、广播等。
          .addAudienceTarget(AudienceTarget.alias(username))//别名可以是数组为并集，一次只能存1000个
          .build())
          .setMessage(Message.newBuilder()
              .setMsgContent(fsmessagecontent)//消息内容
              .setTitle(count.toString())//当做安卓的角标数
              .addExtra("from","JPush")//应用内消息通道
              .build())
          .setNotification(Notification.newBuilder()//notification：通知
          .addPlatformNotification(IosNotification.newBuilder()//iOS
          .setAlert(title)//弹框显示标题
          .setBadge(count)//角标
          .build())
              .addPlatformNotification(AndroidNotification.newBuilder()//安卓
              .setAlert(fsmessagecontent)//弹框显示内容
              .setTitle(title)//弹框显示标题
              .build())
              .build())
          .build();
    }
}

(3)实现类

package com.test.controller.common;

import static com.yjl.util.UploadUtil.getErrorMsg;
import static com.yjl.util.UploadUtil.getYjlResponseModel;
import static com.yjl.util.UploadUtil.isSuccess;
import static com.yjl.util.UploadUtil.setErrorMsg;
import static com.yjl.util.UploadUtil.setSuccess;
import static com.yjl.util.UploadUtil.setYjlResponseModel;

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.PushPayload;
import com.google.gson.Gson;
import com.yjl.entity.common.JPushDeviceBean;
import com.yjl.entity.common.YJLResponseModel;
import com.yjl.util.HttpClientUtil;
import com.yjl.util.JPushDevice;
import java.io.UnsupportedEncodingException;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import net.sf.json.JSONObject;
import org.apache.commons.codec.binary.Base64;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.ResponseBody;

@Controller
@RequestMapping("/JPushDevice")
public class JPushDeviceController{

  private static Logger logger = LoggerFactory.getLogger(JPushDeviceController.class);

  //极光访问URL
  private static final String URL = "https://device.jpush.cn";
  //极光用户名
  private static final String APPKEY ="极光平台生成的app的appkey";
  //极光密码
  private static final String MASTERSECRET ="极光平台生成的app的mastersecret";

  //1.推送一个人
  @RequestMapping(value = "getOneJPushDevice", method = RequestMethod.POST)
  @ResponseBody
  public PushResult getOneJPushDevice(@RequestBody JPushDeviceBean j) {
    String aliases = getAliases(j.getAlias_value());
    //一个别名
    PushResult pResult = new PushResult();
    //别名;
    if(StringUtils.isNotBlank(aliases)){
      //极光推送
      JPushClient jpushClient = new JPushClient(MASTERSECRET,APPKEY,null,ClientConfig.getInstance());
      PushPayload payload = JPushDevice.oneName(aliases, j.getTitle(), j.getFsmessagecontent(),j.getExtrasMap(),j.getExtra());
      try {
        pResult = jpushClient.sendPush(payload);
        System.out.println("Got result 推送一个人 - 3" + pResult );
        Thread.sleep(5000);
        // 请求结束后，调用 NettyHttpClient 中的 close 方法，否则进程不会退出。
        jpushClient.close();
      }
      catch (APIConnectionException e) {
        e.printStackTrace();
      }
      catch (APIRequestException e) {
        e.printStackTrace();
      }
      catch (InterruptedException e) {
        e.printStackTrace();
      }
    }
    return pResult;
  }
  //2.推送多人//先循环判断别名
  @RequestMapping(value = "getAllJPushDevice", method = RequestMethod.POST)
  @ResponseBody
  public YJLResponseModel getAllJPushDevice(@RequestBody JPushDeviceBean j) {
    setYjlResponseModel(new YJLResponseModel());
    setErrorMsg("");
    setSuccess(false);
    List<String> ulist = j.getUsername();
    //判断过得别名数组
    if(null!=ulist && !ulist.isEmpty()){
      String[] username = ulist.toArray(new String[ulist.size()]);
      //转化为数组
      //极光推送
      JPushClient jpushClient = new JPushClient(MASTERSECRET,APPKEY,null, ClientConfig.getInstance());
      PushPayload payload = JPushDevice.AllName(username, j.getTitle(), j.getFsmessagecontent(), j.getCount());
      //用户别名数组1000个一次，标题，内容，角标数
      PushResult pResult;
      try {
        pResult = jpushClient.sendPush(payload);
        setSuccess(true);
        System.out.println("Got result - " + new Gson().toJson(pResult) );
        try {
          Thread.sleep(5000);
        }
        catch (InterruptedException e) {
          e.printStackTrace();
        }
        // 请求结束后，调用 NettyHttpClient 中的 close 方法，否则进程不会退出。
        jpushClient.close();
      }
      catch (APIConnectionException e) {
        e.printStackTrace();
      }
      catch (APIRequestException e) {
        e.printStackTrace();
      }
      finally {
        getYjlResponseModel().setErrorMsg(getErrorMsg());
        getYjlResponseModel().setSuccess(isSuccess());
      }
    }
    return getYjlResponseModel();
  }
  //查询别名是否存在
  public static String getAliases(String aliases){
    String alia ="";
    JPushDeviceBean j = new JPushDeviceBean();
    j.setAlias_value(aliases);
    YJLResponseModel map = getJPushDeviceAliases(j);
    //查询是否含有别名
    Map<String, Object> ma = (Map<String, Object>)map.getData();
    if(ma.containsKey("registration_ids")){
      List<String> list = (List<String>)ma.get("registration_ids");
      //查询registration_ids的值不为空则含有该别名
      if(null!=list && !list.isEmpty()){
        System.out.println("查询别名----"+new Gson().toJson(list));
        //在此内可调用极光的推送方法
        alia = aliases;
        //如果存在就给返回该别名
      }
    }
    return alia;
  }
  //--------------------查询别名的方法-------------------------------------------
  //查询别名(找不到统计项就是 null，否则为统计项的值。)
  @RequestMapping(value = "getJPushDeviceAliases", method = RequestMethod.POST)
  @ResponseBody
  public static YJLResponseModel getJPushDeviceAliases(@RequestBody JPushDeviceBean ht) {
    setYjlResponseModel(new YJLResponseModel());
    setErrorMsg("");
    setSuccess(false);
    JSONObject response = null;
    try {
      StringBuilder url = new StringBuilder(URL).append("/v3/aliases/"+ht.getAlias_value());
      String authorValue = getBase64();
      Map<String, String> para = new HashMap<>();
      response = HttpClientUtil.doGet(url.toString(), authorValue, para);
      if (StringUtils.isNotEmpty((String)response.get("error"))) {
        logger.info("getAliases:url+params----" + url + para);
        throw new Exception();
      }
      setSuccess(true);
    }
    catch (Exception e) {
      e.printStackTrace();
      logger.error("getAliases:url+params----" + e);
    }finally {
      getYjlResponseModel().setErrorMsg(getErrorMsg());
      getYjlResponseModel().setSuccess(isSuccess());
      getYjlResponseModel().setData(response);
    }
    return getYjlResponseModel();
  }

  //String转base64
  public static String getBase64(){
    Base64 base64 = new Base64();
    String base64Sign ="";
    String string = APPKEY+":"+MASTERSECRET;
    try {
      base64Sign = base64.encodeToString(string.getBytes("UTF-8"));
    }
    catch (UnsupportedEncodingException e) {
      e.printStackTrace();
    }
    return " Basic "+base64Sign;
  }

  //测试一下
  public static void main(String[] args) {
    JPushDeviceController JPushDeviceController = new JPushDeviceController();
    JPushDeviceBean jd = new JPushDeviceBean();
    jd.setAlias_value("40");//此处为待推送的用户id
    jd.setTitle("推送消息");
    jd.setFsmessagecontent("测试一下服务器端");
    PushResult pushResult = JPushDeviceController.getOneJPushDevice(jd);
    System.out.println(pushResult);

  }
}

3.测试一下

 //测试一下
  public static void main(String[] args) {
    JPushDeviceController JPushDeviceController = new JPushDeviceController();
    JPushDeviceBean jd = new JPushDeviceBean();
    jd.setAlias_value("18037471792");
    jd.setTitle("推送消息");
    jd.setFsmessagecontent("测试一下服务器端");
    Map<String,String> extrasParam = new HashMap<>();
      extrasParam.put("额外参数1","额外参数内容1");
      jd.setExtrasMap(extrasParam);
    PushResult pushResult = JPushDeviceController.getOneJPushDevice(jd);
    System.out.println(pushResult);

  }