org.springframework.web.client.RestTemplate.postForEntity()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(10.8k)|赞(0)|评价(0)|浏览(274)

本文整理了Java中org.springframework.web.client.RestTemplate.postForEntity方法的一些代码示例,展示了RestTemplate.postForEntity的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。RestTemplate.postForEntity方法的具体详情如下:
包路径:org.springframework.web.client.RestTemplate
类名称:RestTemplate
方法名:postForEntity

RestTemplate.postForEntity介绍

暂无

代码示例

代码示例来源:origin: macrozheng/mall

  1. @ApiOperation("postForEntity jsonBody")
  2. @RequestMapping(value = "/post", method = RequestMethod.POST)
  3. @ResponseBody
  4. public Object postForEntity(@RequestBody PmsBrand brand) {
  5. String url = HOST_MALL_ADMIN + "/brand/create";
  6. ResponseEntity<CommonResult> responseEntity = restTemplate.postForEntity(url, brand, CommonResult.class);
  7. return responseEntity.getBody();
  8. }

代码示例来源:origin: spring-cloud-incubator/spring-cloud-alibaba

  1. private void invokerAccountService(int orderMoney) {
  2. String url = "http://127.0.0.1:18084/account";
  3. HttpHeaders headers = new HttpHeaders();
  4. headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);
  5. MultiValueMap<String, String> map = new LinkedMultiValueMap<String, String>();
  6. map.add("userId", USER_ID);
  7. map.add("money", orderMoney + "");
  8. HttpEntity<MultiValueMap<String, String>> request = new HttpEntity<MultiValueMap<String, String>>(
  9. map, headers);
  10. ResponseEntity<String> response = restTemplate.postForEntity(url, request,
  11. String.class);
  12. }
  13. }

代码示例来源:origin: macrozheng/mall

  1. @ApiOperation("postForEntity form")
  2. @RequestMapping(value = "/post3", method = RequestMethod.POST)
  3. @ResponseBody
  4. public Object postForEntity3(@RequestParam String name) {
  5. String url = HOST_MALL_ADMIN + "/productAttribute/category/create";
  6. //设置头信息
  7. HttpHeaders headers = new HttpHeaders();
  8. headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);
  9. //构造表单参数
  10. MultiValueMap<String, String> params= new LinkedMultiValueMap<>();
  11. params.add("name", name);
  12. HttpEntity<MultiValueMap<String, String>> requestEntity = new HttpEntity<>(params, headers);
  13. ResponseEntity<CommonResult> responseEntity = restTemplate.postForEntity(url, requestEntity, CommonResult.class);
  14. return responseEntity.getBody();
  15. }
  16. }

代码示例来源:origin: codecentric/spring-boot-admin

  1. @Override
  2. protected Mono<Void> doNotify(InstanceEvent event, Instance instance) {
  3. return Mono.fromRunnable(
  4. () -> restTemplate.postForEntity(url, createPagerdutyEvent(event, instance), Void.class));
  5. }

代码示例来源:origin: codecentric/spring-boot-admin

  1. @Override
  2. protected Mono<Void> doNotify(InstanceEvent event, Instance instance) {
  3. if (webhookUrl == null) {
  4. return Mono.error(new IllegalStateException("'webhookUrl' must not be null."));
  5. }
  6. return Mono.fromRunnable(
  7. () -> restTemplate.postForEntity(webhookUrl, createMessage(event, instance), Void.class));
  8. }

代码示例来源:origin: codecentric/spring-boot-admin

  1. @Override
  2. protected Mono<Void> doNotify(InstanceEvent event, Instance instance) {
  3. if (webhookUrl == null) {
  4. return Mono.error(new IllegalStateException("'webhookUrl' must not be null."));
  5. }
  6. return Mono.fromRunnable(() -> restTemplate.postForEntity(
  7. webhookUrl,
  8. createDiscordNotification(event, instance),
  9. Void.class
  10. ));
  11. }

代码示例来源:origin: codecentric/spring-boot-admin

  1. @Override
  2. protected Mono<Void> doNotify(InstanceEvent event, Instance instance) {
  3. return Mono.fromRunnable(() -> restTemplate.postForEntity(buildUrl(),
  4. createHipChatNotification(event, instance),
  5. Void.class
  6. ));
  7. }

代码示例来源:origin: ctripcorp/apollo

  1. private <T> T doExecute(HttpMethod method, ServiceDTO service, String path, Object request,
  2. Class<T> responseType,
  3. Object... uriVariables) {
  4. T result = null;
  5. switch (method) {
  6. case GET:
  7. result = restTemplate.getForObject(parseHost(service) + path, responseType, uriVariables);
  8. break;
  9. case POST:
  10. result =
  11. restTemplate.postForEntity(parseHost(service) + path, request, responseType, uriVariables).getBody();
  12. break;
  13. case PUT:
  14. restTemplate.put(parseHost(service) + path, request, uriVariables);
  15. break;
  16. case DELETE:
  17. restTemplate.delete(parseHost(service) + path, uriVariables);
  18. break;
  19. default:
  20. throw new UnsupportedOperationException(String.format("unsupported http method(method=%s)", method));
  21. }
  22. return result;
  23. }

代码示例来源:origin: spring-projects/spring-framework

  1. @Test
  2. public void removeFailedPathVariablesAnd() {
  3. ResponseEntity<String> result =
  4. restTemplate.postForEntity("http://localhost:" + port + "/qux/quux", "", String.class);
  5. assertEquals(HttpStatus.OK, result.getStatusCode());
  6. assertEquals("{}", result.getBody());
  7. }

代码示例来源:origin: rampatra/jbot

  1. protected final ResponseEntity<String> reply(Event event) {
  2. sendTypingOffIndicator(event.getRecipient());
  3. logger.debug("Send message: {}", event.toString());
  4. try {
  5. return restTemplate.postForEntity(fbSendUrl, event, String.class);
  6. } catch (HttpClientErrorException e) {
  7. logger.error("Send message error: Response body: {} \nException: ", e.getResponseBodyAsString(), e);
  8. return new ResponseEntity<>(e.getResponseBodyAsString(), e.getStatusCode());
  9. }
  10. }

代码示例来源:origin: cloudfoundry/uaa

  1. private ResponseEntity<String> makePasswordGrantRequest(String userName, String password, String clientId, String clientSecret, String url) {
  2. HttpHeaders headers = new HttpHeaders();
  3. headers.setAccept(Arrays.asList(APPLICATION_JSON));
  4. headers.add("Authorization", testAccounts.getAuthorizationHeader(clientId, clientSecret));
  5. MultiValueMap<String, String> params = new LinkedMultiValueMap<>();
  6. params.add("grant_type", "password");
  7. params.add("username", userName);
  8. params.add("password", password);
  9. HttpEntity<MultiValueMap<String, String>> request = new HttpEntity<>(params, headers);
  10. RestTemplate template = getRestTemplate();
  11. return template.postForEntity(url, request, String.class);
  12. }

代码示例来源:origin: cloudfoundry/uaa

  1. public static void addMemberToGroup(RestTemplate client,
  2. String url,
  3. String userId,
  4. String groupId
  5. ) {
  6. ScimGroupMember groupMember = new ScimGroupMember(userId);
  7. ResponseEntity<String> response = client.postForEntity(url + "/Groups/{groupId}/members", groupMember, String.class, groupId);
  8. assertEquals(HttpStatus.CREATED, response.getStatusCode());
  9. }

代码示例来源:origin: cloudfoundry/uaa

  1. private ScimGroup createGroup(String name, ScimGroupMember... members) {
  2. ScimGroup g = new ScimGroup(null, name, IdentityZoneHolder.get().getId());
  3. List<ScimGroupMember> m = members != null ? Arrays.asList(members) : Collections.<ScimGroupMember>emptyList();
  4. g.setMembers(m);
  5. ScimGroup g1 = client.postForEntity(serverRunning.getUrl(groupEndpoint), g, ScimGroup.class).getBody();
  6. assertEquals(name, g1.getDisplayName());
  7. assertEquals(m.size(), g1.getMembers().size());
  8. groupIds.add(g1.getId());
  9. return g1;
  10. }

代码示例来源:origin: spring-projects/spring-framework

  1. @Test
  2. public void postForEntity() throws Exception {
  3. mockTextPlainHttpMessageConverter();
  4. HttpHeaders requestHeaders = new HttpHeaders();
  5. mockSentRequest(POST, "http://example.com", requestHeaders);
  6. mockResponseStatus(HttpStatus.OK);
  7. String expected = "42";
  8. mockResponseBody(expected, MediaType.TEXT_PLAIN);
  9. ResponseEntity<String> result = template.postForEntity("http://example.com", "Hello World", String.class);
  10. assertEquals("Invalid POST result", expected, result.getBody());
  11. assertEquals("Invalid Content-Type", MediaType.TEXT_PLAIN, result.getHeaders().getContentType());
  12. assertEquals("Invalid Accept header", MediaType.TEXT_PLAIN_VALUE, requestHeaders.getFirst("Accept"));
  13. assertEquals("Invalid status code", HttpStatus.OK, result.getStatusCode());
  14. verify(response).close();
  15. }

代码示例来源:origin: spring-projects/spring-framework

  1. @Test // SPR-16132
  2. public void followUpRequestAfterFailure() {
  3. MockRestServiceServer server = MockRestServiceServer.bindTo(this.restTemplate).build();
  4. server.expect(requestTo("/some-service/some-endpoint"))
  5. .andRespond(request -> { throw new SocketException("pseudo network error"); });
  6. server.expect(requestTo("/reporting-service/report-error"))
  7. .andExpect(method(POST)).andRespond(withSuccess());
  8. try {
  9. this.restTemplate.getForEntity("/some-service/some-endpoint", String.class);
  10. }
  11. catch (Exception ex) {
  12. this.restTemplate.postForEntity("/reporting-service/report-error", ex.toString(), String.class);
  13. }
  14. server.verify();
  15. }

代码示例来源:origin: cloudfoundry/uaa

  1. private ScimUser createUser(String username, String password) {
  2. ScimUser user = new ScimUser();
  3. user.setUserName(username);
  4. user.setName(new ScimUser.Name(username, username));
  5. user.addEmail(username);
  6. user.setVerified(true);
  7. user.setPassword(password);
  8. ResponseEntity<ScimUser> result = client.postForEntity(serverRunning.getUrl(userEndpoint), user, ScimUser.class);
  9. assertEquals(HttpStatus.CREATED, result.getStatusCode());
  10. return result.getBody();
  11. }

代码示例来源:origin: spring-projects/spring-framework

  1. @Test
  2. public void postForEntityNull() throws Exception {
  3. mockTextPlainHttpMessageConverter();
  4. HttpHeaders requestHeaders = new HttpHeaders();
  5. mockSentRequest(POST, "http://example.com", requestHeaders);
  6. mockResponseStatus(HttpStatus.OK);
  7. HttpHeaders responseHeaders = new HttpHeaders();
  8. responseHeaders.setContentType(MediaType.TEXT_PLAIN);
  9. responseHeaders.setContentLength(10);
  10. given(response.getHeaders()).willReturn(responseHeaders);
  11. given(response.getBody()).willReturn(StreamUtils.emptyInput());
  12. given(converter.read(String.class, response)).willReturn(null);
  13. ResponseEntity<String> result = template.postForEntity("http://example.com", null, String.class);
  14. assertFalse("Invalid POST result", result.hasBody());
  15. assertEquals("Invalid Content-Type", MediaType.TEXT_PLAIN, result.getHeaders().getContentType());
  16. assertEquals("Invalid content length", 0, requestHeaders.getContentLength());
  17. assertEquals("Invalid status code", HttpStatus.OK, result.getStatusCode());
  18. verify(response).close();
  19. }

代码示例来源:origin: cloudfoundry/uaa

  1. private ResponseEntity<ScimUser> createUser(String username, String firstName, String lastName, String email) {
  2. ScimUser user = new ScimUser();
  3. user.setUserName(username);
  4. user.setPassword("password");
  5. user.setName(new ScimUser.Name(firstName, lastName));
  6. user.addEmail(email);
  7. return client.postForEntity(serverRunning.getUrl(userEndpoint), user, ScimUser.class);
  8. }

代码示例来源:origin: cloudfoundry/uaa

  1. private ResponseEntity<ScimUser> createUser(String username, String firstName, String lastName,
  2. String email, boolean verified) {
  3. ScimUser user = new ScimUser();
  4. user.setPassword("password");
  5. user.setUserName(username);
  6. user.setName(new ScimUser.Name(firstName, lastName));
  7. user.addEmail(email);
  8. user.setVerified(verified);
  9. return client.postForEntity(serverRunning.getUrl(userEndpoint), user, ScimUser.class);
  10. }

代码示例来源:origin: cloudfoundry/uaa

  1. private ResponseEntity<ScimUser> createUser(String username, String firstName, String lastName,
  2. String email, boolean verified) {
  3. ScimUser user = new ScimUser();
  4. user.setUserName(username);
  5. user.setName(new ScimUser.Name(firstName, lastName));
  6. user.addEmail(email);
  7. user.setVerified(verified);
  8. user.setActive(true);
  9. user.setPassword("s3Cret");
  10. return client.postForEntity(serverRunning.getUrl(userEndpoint), user, ScimUser.class);
  11. }

相关文章