详解在spring boot中消息推送系统设计与实现

<!-- 信鸽推送客户端 -->
<dependency>
  <groupId>com.github.xingePush</groupId>
  <artifactId>xinge</artifactId>
  <version>1.2.1</version>
</dependency>

Map<String, Object> messagePayload = new HashMap<String, Object>(1);
messagePayload.put("user_id", 1);
messagePayload.put("msg_title", "消息标题");
messagePayload.put("msg_content", "消息内容");
messagePayload.put("msg_type", 1);
messagePayload.put("data", Lists.newHashMap("order_id", 1));

XingeApp xinge = new XingeApp(androidAccessId, androidSecretKey);
MessageAndroid message = new MessageAndroid();
ClickAction action = new ClickAction();
action.setActionType(ClickAction.TYPE_ACTIVITY);
message.setAction(action);
message.setContent(JsonUtil.toJsonString(messagePayload));
message.setType(MessageAndroid.TYPE_MESSAGE);
message.setExpireTime(86400);
message.setCustom(new HashMap<String, Object>(1));
JSONObject response = xinge.pushSingleDevice("用户的PushToken", message);
if (response.getInt(RET_CODE) != 0) {
  // 推送异常了，进行日志记录等
}

<!-- IOS推送客户端 -->
<dependency>
  <groupId>com.turo</groupId>
  <artifactId>pushy</artifactId>
  <version>0.13.3</version>
</dependency>

Map<String, Object> aps = new HashMap<String, Object>(1);
aps.put("alert", "推送内容");
aps.put("sound", "default");
aps.put("badge", 1);

Map<String, Object> data = new HashMap<String, Object>(1);
data.put("msgTitle", "推送标题");
data.put("msgContent", "推送内容");
data.put("msgType", "1");
data.put("userId", "13288888888");
data.put("data", Lists.newHashMap("order_id", 1));

Map<String, Object> messagePayload = new HashMap<String, Object>(1);
messagePayload.put("aps", aps);
messagePayload.put("data", data);

ApnsClient apnsClient = new ApnsClientBuilder()
    .setApnsServer(ApnsClientBuilder.PRODUCTION_APNS_HOST)
    .setClientCredentials(this.getClass().getClassLoader().getResourceAsStream("推送证书相对resources目录的路径"), "")
    .build();

String payload = JsonUtil.toJsonString(messagePayload);
String token = TokenUtil.sanitizeTokenString("app用户的pushToken");

SimpleApnsPushNotification pushNotification = new SimpleApnsPushNotification(token, "com.suxiaolin.app1", payload);

PushNotificationFuture<SimpleApnsPushNotification, PushNotificationResponse<SimpleApnsPushNotification>>
    sendNotificationFuture = apnsClient.sendNotification(pushNotification);

final PushNotificationResponse<SimpleApnsPushNotification> pushNotificationResponse =
    sendNotificationFuture.get();

if (pushNotificationResponse.isAccepted()) {
  System.out.println("Push notification accepted by APNs gateway.");
} else {
  System.out.println("Notification rejected by the APNs gateway: " +
      pushNotificationResponse.getRejectionReason());

  if (pushNotificationResponse.getTokenInvalidationTimestamp() != null) {
    System.out.println("\t…and the token is invalid as of " +
        pushNotificationResponse.getTokenInvalidationTimestamp());
  }
}

JSONObject messagePayload = new JSONObject();
Map<String, Object> custom = new HashMap<String, Object>();

messagePayload.put("title", "推送标题");
messagePayload.put("body", "推送内容");

messagePayload.put("user_id", 1);
messagePayload.put("msg_type", 1);
messagePayload.put("data", Lists.newArrayList("orderId", 1));

XingeApp xinge = new XingeApp(iosAccessId, iosSecretKey);
MessageIOS message = new MessageIOS();
message.setType(MessageIOS.TYPE_APNS_NOTIFICATION);
message.setExpireTime(86400);
message.setAlert(content);
message.setBadge(1);
message.setCategory("INVITE_CATEGORY");
message.setCustom(messagePayload);

response = xinge.pushSingleDevice("app用户的pushToken", message, XingeApp.IOSENV_PROD);
if (response.getInt(RET_CODE) != 0) {
  // 推送异常了
}

public static boolean send(String content, String title, Set<String> receivers) {
  try {
    HttpUtil.ResponseWrap result = HttpUtil.postWrap(ddUrl,
        "{\n"
            + "   \"msgtype\": \"text\",\n"
            + "   \"text\": {\"content\":\"" + title + "\r\n" + content + "\n|"
            + receivers.stream().map(r -> "@" + r).collect(Collectors.joining(" ")) + "\"},\n"
            + "  \"at\": {\n"
            + "    \"atMobiles\": [" + receivers.stream().map(r -> "\"" + r + "\"").collect(Collectors.joining(",")) + "], \n"
            + "    \"isAtAll\": false\n"
            + "  }\n"
            + " }");
    return result.getStatusCode() == 200;
  } catch (Exception e) {
    return false;
  }
}

<dependency>
  <groupId>javax.mail</groupId>
  <artifactId>mail</artifactId>
  <version>1.4.7</version>
</dependency>