javax.ws.rs.core.Response类的使用及代码示例

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

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

Response介绍

[英]Defines the contract between a returned instance and the runtime when an application needs to provide meta-data to the runtime.

An application class should not extend this class directly. Response class is reserved for an extension by a JAX-RS implementation providers. An application should use one of the static methods to create a Response instance using a ResponseBuilder.

Several methods have parameters of type URI, UriBuilder provides convenient methods to create such values as does URI#create(java.lang.String).
[中]当应用程序需要向运行时提供元数据时，定义返回实例和运行时之间的约定。
应用程序类不应直接扩展此类。响应类是JAX-RS实现提供者为扩展保留的。应用程序应该使用其中一种静态方法来使用ResponseBuilder创建响应实例。
有几种方法具有URI类型的参数，UriBuilder提供了方便的方法来创建URI#create（java.lang.String）等值。

代码示例

代码示例来源：origin: prestodb/presto

@GET
  @Path("coordinator")
  @Produces(TEXT_PLAIN)
  public Response getServerCoordinator()
  {
    if (coordinator) {
      return Response.ok().build();
    }
    // return 404 to allow load balancers to only send traffic to the coordinator
    return Response.status(Response.Status.NOT_FOUND).build();
  }
}

代码示例来源：origin: dropwizard/dropwizard

private Response createResponse(final WebApplicationException exception) {
    final ErrorMessage errorMessage = new ErrorMessage(exception.getResponse().getStatus(),
      exception.getLocalizedMessage());
    return Response.status(errorMessage.getCode())
      .type(APPLICATION_JSON_TYPE)
      .entity(errorMessage)
      .build();
  }
}

代码示例来源：origin: apache/incubator-druid

@GET
@Produces({MediaType.APPLICATION_JSON, SmileMediaTypes.APPLICATION_JACKSON_SMILE})
public Response getAll()
{
 try {
  return handler.handleGETAll();
 }
 catch (Exception e) {
  LOG.error(e, "Exception in handling GETAll request");
  return Response.serverError().entity(ServletResourceUtils.sanitizeException(e)).build();
 }
}

代码示例来源：origin: prestodb/presto

@DELETE
@Path("{queryId}/{token}")
@Produces(MediaType.APPLICATION_JSON)
public Response cancelQuery(@PathParam("queryId") QueryId queryId,
    @PathParam("token") long token)
{
  Query query = queries.get(queryId);
  if (query == null) {
    return Response.status(Status.NOT_FOUND).build();
  }
  query.cancel();
  return Response.noContent().build();
}

代码示例来源：origin: apache/incubator-druid

@POST
@Path("/assignTask")
@Consumes({MediaType.APPLICATION_JSON, SmileMediaTypes.APPLICATION_JACKSON_SMILE})
public Response assignTask(Task task)
{
 try {
  workerTaskMonitor.assignTask(task);
  return Response.ok().build();
 }
 catch (RuntimeException ex) {
  return Response.serverError().entity(ex.getMessage()).build();
 }
}

代码示例来源：origin: prestodb/presto

@DELETE
@Path("/v1/proxy")
@Produces(APPLICATION_JSON)
public void cancelQuery(
    @QueryParam("uri") String uri,
    @QueryParam("hmac") String hash,
    @Context HttpServletRequest servletRequest,
    @Suspended AsyncResponse asyncResponse)
{
  if (!hmac.hashString(uri, UTF_8).equals(HashCode.fromString(hash))) {
    throw badRequest(FORBIDDEN, "Failed to validate HMAC of URI");
  }
  Request.Builder request = prepareDelete().setUri(URI.create(uri));
  performRequest(servletRequest, asyncResponse, request, response -> responseWithHeaders(noContent(), response));
}

代码示例来源：origin: apache/incubator-druid

@SuppressWarnings({"ConstantConditions"})
private int getNumSubTasks(Function<SinglePhaseParallelIndexingProgress, Integer> func)
{
 final Response response = task.getProgress(newRequest());
 Assert.assertEquals(200, response.getStatus());
 return func.apply((SinglePhaseParallelIndexingProgress) response.getEntity());
}

代码示例来源：origin: apache/incubator-druid

@Override
public final Response handleGET(String id)
{
 try {
  final Object returnObj = get(id);
  if (returnObj == null) {
   return Response.status(Response.Status.NOT_FOUND).build();
  } else {
   return Response.ok(returnObj).build();
  }
 }
 catch (Exception e) {
  LOG.error(e, "Error handling get request for [%s]", id);
  return Response.serverError().entity(ServletResourceUtils.sanitizeException(e)).build();
 }
}

代码示例来源：origin: Graylog2/graylog2-server

@PUT
@RequiresPermissions(value = {RestPermissions.LDAPGROUPS_EDIT, RestPermissions.LDAP_EDIT}, logical = OR)
@ApiOperation(value = "Update the LDAP group to Graylog role mapping", notes = "Corresponds directly to the output of GET /system/ldap/settings/groups")
@Path("/settings/groups")
@Consumes(MediaType.APPLICATION_JSON)
@AuditEvent(type = AuditEventTypes.LDAP_GROUP_MAPPING_UPDATE)
public Response updateGroupMappingSettings(@ApiParam(name = "JSON body", required = true, value = "A hash in which the keys are the LDAP group names and values is the Graylog role name.")
                @NotNull Map<String, String> groupMapping) throws ValidationException {
  final LdapSettings ldapSettings = firstNonNull(ldapSettingsService.load(), ldapSettingsFactory.createEmpty());
  ldapSettings.setGroupMapping(groupMapping);
  ldapSettingsService.save(ldapSettings);
  return Response.noContent().build();
}

代码示例来源：origin: apache/incubator-dubbo

protected Response handleConstraintViolationException(ConstraintViolationException cve) {
    ViolationReport report = new ViolationReport();
    for (ConstraintViolation cv : cve.getConstraintViolations()) {
      report.addConstraintViolation(new RestConstraintViolation(
          cv.getPropertyPath().toString(),
          cv.getMessage(),
          cv.getInvalidValue() == null ? "null" : cv.getInvalidValue().toString()));
    }
    // TODO for now just do xml output
    return Response.status(Response.Status.INTERNAL_SERVER_ERROR).entity(report).type(ContentType.TEXT_XML_UTF_8).build();
  }
}

代码示例来源：origin: confluentinc/ksql

private <T> RestResponse<T> getRequest(final String path, final Class<T> type) {
 try (Response response = client.target(serverAddress)
   .path(path)
   .request(MediaType.APPLICATION_JSON_TYPE)
   .get()) {
  return response.getStatus() == Response.Status.OK.getStatusCode()
    ? RestResponse.successful(response.readEntity(type))
    : createErrorResponse(path, response);
 } catch (final Exception e) {
  throw new KsqlRestClientException("Error issuing GET to KSQL server. path:" + path, e);
 }
}

代码示例来源：origin: Netflix/eureka

@Override
public EurekaHttpResponse<ReplicationListResponse> submitBatchUpdates(ReplicationList replicationList) {
  Response response = null;
  try {
    response = jerseyClient.target(serviceUrl)
        .path(PeerEurekaNode.BATCH_URL_PATH)
        .request(MediaType.APPLICATION_JSON_TYPE)
        .post(Entity.json(replicationList));
    if (!isSuccess(response.getStatus())) {
      return anEurekaHttpResponse(response.getStatus(), ReplicationListResponse.class).build();
    }
    ReplicationListResponse batchResponse = response.readEntity(ReplicationListResponse.class);
    return anEurekaHttpResponse(response.getStatus(), batchResponse).type(MediaType.APPLICATION_JSON_TYPE).build();
  } finally {
    if (response != null) {
      response.close();
    }
  }
}

代码示例来源：origin: apache/incubator-druid

@Test
public void testMissingProducerSequence() throws IOException
{
 setUpRequestExpectations("producer", null);
 final InputStream inputStream = IOUtils.toInputStream(inputRow, StandardCharsets.UTF_8);
 final Response response = firehose.addAll(inputStream, req);
 Assert.assertEquals(Response.Status.BAD_REQUEST.getStatusCode(), response.getStatus());
 inputStream.close();
 EasyMock.verify(req);
 firehose.close();
}

代码示例来源：origin: apache/incubator-druid

@Test
public void testGetTasksNegativeState()
{
 EasyMock.replay(taskRunner, taskMaster, taskStorageQueryAdapter, indexerMetadataStorageAdapter, req);
 Object responseObject = overlordResource
   .getTasks("blah", "ds_test", null, null, null, req)
   .getEntity();
 Assert.assertEquals(
   "Invalid state : blah, valid values are: [pending, waiting, running, complete]",
   responseObject.toString()
 );
}

代码示例来源：origin: dropwizard/dropwizard

@Override
public Response toResponse(WebApplicationException exception) {
  LOGGER.error("Template Error", exception);
  return Response.serverError()
      .type(MediaType.TEXT_HTML_TYPE)
      .entity(TEMPLATE_ERROR_MSG)
      .build();
}

代码示例来源：origin: confluentinc/ksql

public RestResponse<KsqlEntityList> makeKsqlRequest(final String ksql) {
 final KsqlRequest jsonRequest = new KsqlRequest(ksql, localProperties.toMap(), null);
 return postRequest("ksql", jsonRequest, Optional.empty(), true,
   r -> r.readEntity(KsqlEntityList.class));
}

代码示例来源：origin: dropwizard/dropwizard

@Override
  public Response toResponse(EmptyOptionalException exception) {
    return Response.noContent().build();
  }
}

代码示例来源：origin: apache/incubator-druid

@Test
public void testExceptionalHandleAll()
{
 shouldFail.set(true);
 final Response response = abstractListenerHandler.handleGETAll();
 Assert.assertEquals(500, response.getStatus());
 Assert.assertEquals(ImmutableMap.of("error", error_message), response.getEntity());
}

代码示例来源：origin: apache/incubator-dubbo

protected Response handleConstraintViolationException(ConstraintViolationException cve) {
    ViolationReport report = new ViolationReport();
    for (ConstraintViolation cv : cve.getConstraintViolations()) {
      report.addConstraintViolation(new RestConstraintViolation(
          cv.getPropertyPath().toString(),
          cv.getMessage(),
          cv.getInvalidValue() == null ? "null" : cv.getInvalidValue().toString()));
    }
    // TODO for now just do xml output
    return Response.status(Response.Status.INTERNAL_SERVER_ERROR).entity(report).type(ContentType.TEXT_XML_UTF_8).build();
  }
}

代码示例来源：origin: jersey/jersey

public String start() {
  final Response response = addProperties(client.target(requestTokenUri).request())
      .post(null);
  if (response.getStatus() != 200) {
    throw new RuntimeException(LocalizationMessages.ERROR_REQUEST_REQUEST_TOKEN(response.getStatus()));
  }
  final MultivaluedMap<String, String> formParams = response.readEntity(Form.class).asMap();
  parameters.token(formParams.getFirst(OAuth1Parameters.TOKEN));
  secrets.tokenSecret(formParams.getFirst(OAuth1Parameters.TOKEN_SECRET));
  return UriBuilder.fromUri(authorizationUri).queryParam(OAuth1Parameters.TOKEN, parameters.getToken())
      .build().toString();
}

内容来源于网络，如有侵权，请联系作者删除！

response

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com