將 極光推送 放到mq隊(duì)列中网严，mq有幾個(gè)注解  都是配合使用的 最簡(jiǎn)單的兩個(gè)
@RabbitListener(queues = “   ”,containerFactory="rabbitListenerContainerFactory")

@RabbitHandler

在方法中一定要有異常捕捉 ，要不然會(huì)陷入死循環(huán)，通過(guò)異常來(lái)跳出隊(duì)列發(fā)送

調(diào)用極光的方法

@Component

@RabbitListener(queues = JPushServer.JPUSH_MQ_NAME,containerFactory="rabbitListenerContainerFactory")

public class JPushServer {

public static final StringJPUSH_MQ_NAME ="JPUSH_MQ_NAME";

  public static final String APPKEY ="appKey";

  public static final String MASTERSECRET =" MASTERSECRET ";

  public static JPushClientjpushClient =null;

  @RabbitHandler

  void getJPush(JPushModel jPushModel){

try {

//推送目標(biāo) 為空時(shí)全部推送

        if(jPushModel.getObject() ==null){

sendPush(jPushModel.getContent(),jPushModel.getTitle(),jPushModel.getParams());

        }else{

//推送目標(biāo) String類型時(shí)單體推送

            if(jPushModel.getObject().getClass().isArray()){

sendByAlias(jPushModel.getContent(),jPushModel.getTitle(),jPushModel.getParams(),(String) jPushModel.getObject());

            }else if(jPushModel.getObject()instanceof String){//推送目標(biāo)  List類型時(shí)選擇性推送

              sendByAliasList(jPushModel.getContent(),jPushModel.getTitle(),jPushModel.getParams(),(List) jPushModel.getObject());

            }

}

Thread.sleep(5000);

        jpushClient.close();

      }catch (InterruptedException e) {

e.printStackTrace();

      }

}

/**

    * 功能描述:

    * 〈全平臺(tái)推送〉

    * @Param: [msg, title, params]

    * @Return: void

    * @Author:  

    * @Date: 2019/8/14 14:10

*/

  public static void sendPush(String msg,String title, Map params) {

jpushClient =new JPushClient(MASTERSECRET, APPKEY);

      PushPayload payload =buildPushObjectByMessage(msg,title,params);

      try {

PushResult result =jpushClient.sendPush(payload);

      }catch (Exception e) {

e.printStackTrace();

      }

}

public static PushPayloadbuildPushObjectByMessage(String content,String title, Map params) {

PushPayload.Builder builder = PushPayload.newBuilder();

      builder.setPlatform(Platform.all())// 設(shè)置接受的平臺(tái)

            .setAudience(Audience.all());// Audience設(shè)置為all昭躺，說(shuō)明采用廣播方式推送炕淮，所有用戶都可以接收到

      Notification.Builder notificationBuilder = Notification.newBuilder();

      JPushServer.notificationBuilder(notificationBuilder,content,title,params);

      builder.setNotification(notificationBuilder.build());

      return builder.build();

  }

/**

    * 功能描述:

    * 〈根據(jù)別名推送〉

    * @Param: [content, title, params, userId]

    * @Return: void

    * @Author:  

    * @Date: 2019/8/14 14:17

*/

  public static void sendByAlias(String content,String title, Map params, String userId) {

ClientConfig clientConfig = ClientConfig.getInstance();

      JPushClient jpushClient =new JPushClient(MASTERSECRET, APPKEY, null, clientConfig);

      List users =new ArrayList();

      users.add(userId);

      PushPayload payload =buildPushObjectByAlias(content,title, params, users);

      try {

PushResult result = jpushClient.sendPush(payload);

      }catch (APIConnectionException e) {

}catch (APIRequestException e) {

}

}

/**

    * 功能描述:

    * 〈根據(jù)別名集合發(fā)送〉

    * @Param: [content, title, params, users]

    * @Return: void

    * @Author:  

    * @Date: 2019/8/14 14:18

*/

  public static void sendByAliasList(String content,String title, Map params,List users) {

ClientConfig clientConfig = ClientConfig.getInstance();

      JPushClient jpushClient =new JPushClient(MASTERSECRET, APPKEY, null, clientConfig);

      PushPayload payload =buildPushObjectByAlias(content, title,params, users);

      try {

PushResult result = jpushClient.sendPush(payload);

      }catch (APIConnectionException e) {

}catch (APIRequestException e) {

}

}

private static PushPayloadbuildPushObjectByAlias(String content,String title, Map params, List userIds) {

PushPayload.Builder builder = PushPayload.newBuilder();

      builder.setPlatform(Platform.all());

      builder.setAudience(Audience.alias(userIds));

      Notification.Builder notificationBuilder = Notification.newBuilder();

      JPushServer.notificationBuilder(notificationBuilder,content,title,params);

      builder.setNotification(notificationBuilder.build());

      return builder.build();

  }

public static void notificationBuilder(Notification.Builder notificationBuilder,String content,String title, Map params){

notificationBuilder.setAlert(content);

      notificationBuilder.addPlatformNotification(IosNotification.newBuilder().setAlert(content).setSound("happy").addExtras(params).build());

      notificationBuilder.addPlatformNotification(AndroidNotification.newBuilder().setTitle(title).setAlert(content).addExtras(params).build());

  }

public static void main(String[] args) {

Map params =new HashMap();

      //map里面可以放一些你需要展示的或者你需要傳遞的數(shù)據(jù)

      params.put("type", "1");

      sendByAlias("(即將作業(yè))您的作業(yè)將于2小時(shí)后開(kāi)始","測(cè)試標(biāo)題", params,"1" );

  }

}

調(diào)用推送

/**

* 功能描述:

* 〈您好，您申請(qǐng)的巴拿馬籍雜貨船“豪興1號(hào)”離金海碼頭6號(hào)泊位的引航申請(qǐng)呐矾，主引XXX變更為XXX悼沈，負(fù)責(zé)本次引航任務(wù)∪兀〉

* @Param: [jPushRequest]

* @Return: void

* @Author:  

* @Date: 2019/8/14 16:35

*/

public void agentChangePilot(JPushRequest jPushRequest){

String content ="您好抬探，您申請(qǐng)的"+jPushRequest.getNationality()+"籍"+jPushRequest.getShipType()+

"“"+jPushRequest.getShipName()+

"”"+jPushRequest.getJobType()+jPushRequest.getAimName()+"{4}的引航申請(qǐng)，主引{5}變更為{6}帆赢，負(fù)責(zé)本次引航任務(wù)小压。";

    getData(content,new JPushModel(),jPushRequest);

}

public void getData(String content,JPushModel jPushModel,JPushRequest jPushRequest){

jPushModel.setContent(content);

    jPushModel.setParams(jPushRequest.getParams());

    jPushModel.setObject(jPushRequest.getObject());

    jPushModel.setTitle(jPushRequest.getTitle());

    rabbitTemplate.convertAndSend(JPushServer.JPUSH_MQ_NAME,jPushModel);

}