| | |
|---|
| | | System.err.println(jsonObject1.getString("msg")); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | public void pushChangeServer(Integer id, Integer type){ |
|---|
| | | Map<String, Object> map = new HashMap<>(); |
|---|
| | | JSONObject msg = new JSONObject(); |
|---|
| | | msg.put("code", 200); |
|---|
| | | msg.put("msg", "SUCCESS"); |
|---|
| | | msg.put("method", "CHANGE_SERVER"); |
|---|
| | | msg.put("data", map); |
|---|
| | | |
|---|
| | | //调用推送 |
|---|
| | | HttpHeaders headers = new HttpHeaders(); |
|---|
| | | // 以表单的方式提交 |
|---|
| | | headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED); |
|---|
| | | //将请求头部和参数合成一个请求 |
|---|
| | | MultiValueMap<String, Object> params = new LinkedMultiValueMap<>(); |
|---|
| | | params.add("msg", msg.toJSONString()); |
|---|
| | | params.add("id", id.toString()); |
|---|
| | | params.add("type", type.toString()); |
|---|
| | | HttpEntity<MultiValueMap<String, Object>> requestEntity = new HttpEntity<>(params, headers); |
|---|
| | | String s = internalRestTemplate.postForObject("http://zuul-gateway/netty/sendMsgToClient",requestEntity , String.class); |
|---|
| | | JSONObject jsonObject1 = JSON.parseObject(s, JSONObject.class); |
|---|
| | | if(jsonObject1.getIntValue("code") != 200){ |
|---|
| | | logger.debug(jsonObject1.getString("msg")); |
|---|
| | | System.err.println(jsonObject1.getString("msg")); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
