建立XmppMessageUtil類

    static Logger logger = LoggerFactory.getLogger(XmppMessageUtil.class);

    private static XmppMessageUtil xmppMessageUtil;

    @Resource(name = "loadBalanced")
    private RestTemplate loadBalanced;

public static void sendXmppMessage(String userFromId, String password, String userId, XmppMessageBody body) {
        try {
            body.setTimeSend(new Date());
            Map<String, Object> mapPara = new HashMap<String, Object>();
            mapPara.put("userId", userId);
            mapPara.put("body", JSON.toJSONString(body));
            mapPara.put("userFromId", userFromId);
            mapPara.put("password", password);
            HttpHeaders headers = new HttpHeaders();
            headers.setContentType(MediaType.APPLICATION_JSON_UTF8);
            HttpEntity<String> httpEntity = new HttpEntity<String>(headers);
            com.yhyt.health.spring.AppResult result = xmppMessageUtil.loadBalanced
 
.postForObject("http://dialog/dialog/sendMessage?userId={userId}&body={body}", httpEntity, com.yhyt.health.spring.AppResult.class, mapPara);
            if (null != result && "200".equals(result.getStatus().getCode())) {
                logger.info("推送下線成功");
            }
        } catch (Exception e) {
            logger.error("傳送xmpp失敗，使用者id"+userId,e);
        }
    }