是否可以使用ResteasyClient（代理框架）进行自定义方法处理？

Question

是否可以像在服务器端所做的那样，向ResteasyClient（代理框架）注册DynamicFeature？

所以类似这样的东西：

final ResteasyClient client = new ResteasyClientBuilder().build();
client.register(new MyDynamicFeature());

其中MyDynamicFeature实现

@POST
@Path("some/path/user")
@ExpectedHttpStatus(201) // <- this would have to be passed on somehow as expectedStatus
User createUser(User request);

@Override
public void filter(ClientRequestContext requestContext, ClientResponseContext responseContext) throws IOException {
    if (responseContext.getStatus() != expectedStatus) {
        // explode
    }
}

下面的一些文章似乎解释了一些非常相似的事情，但这似乎不适用于ClientResponseFilter/ResteAsyClient：

• 通过Resteasy上的NameBinding匹配特定方法的筛选器
• Resteasy 3.x PreprocessInterceptor的正确替换是什么？

Answer 1

首先，我真的不能把解决方案归功于我，但我要把答案粘贴在这里。

你也可以问我们为什么要这么做？因为我们需要/希望测试服务返回正确的http状态，但不幸的是，我们测试的服务并不总是为相同的http方法返回相同的http状态。

例如。在下面的示例中，post返回HttpStatus.OK，同一服务的另一个post方法可以返回HttpStatus.Created。

import java.io.IOException;
import java.util.UUID;

import javax.ws.rs.client.ClientRequestContext;
import javax.ws.rs.client.ClientResponseContext;
import javax.ws.rs.client.ClientResponseFilter;

/**
 * {@link ClientResponseFilter} which will handle setting the HTTP StatusCode property for use with
 * {@link HttpStatusResponseInterceptor}
 */
public class HttpStatusResponseFilter implements ClientResponseFilter {

    public static final String STATUS_CODE = "StatusCode-" + UUID.randomUUID();

    @Override
    public void filter(ClientRequestContext requestContext, ClientResponseContext responseContext) throws IOException {
        requestContext.setProperty(STATUS_CODE, responseContext.getStatusInfo());
    }
}

import java.io.IOException;
import java.lang.annotation.Annotation;

import javax.ws.rs.ServerErrorException;
import javax.ws.rs.core.Response.Status;
import javax.ws.rs.ext.ReaderInterceptor;
import javax.ws.rs.ext.ReaderInterceptorContext;

/**
 * {@link ReaderInterceptor} which will verify the success HTTP status code returned from the server against the
 * expected successful HTTP status code {@link SuccessStatus}
 *
 * @see HttpStatusResponseFilter
 */
public class HttpStatusResponseInterceptor implements ReaderInterceptor {

    @Override
    public Object aroundReadFrom(ReaderInterceptorContext interceptorContext) throws ServerErrorException, IOException {
        Status actualStatus = (Status) interceptorContext.getProperty(HttpStatusResponseFilter.STATUS_CODE);
        if (actualStatus == null) {
            throw new IllegalStateException("Property " + HttpStatusResponseFilter.STATUS_CODE + " does not exist!");
        }

        Status expectedStatus = null;
        for (Annotation annotation : interceptorContext.getAnnotations()) {
            if (annotation.annotationType() == SuccessStatus.class) {
                expectedStatus = ((SuccessStatus) annotation).value();
                break;
            }
        }

        if (expectedStatus != null && expectedStatus != actualStatus) {
            throw new ServerErrorException(String.format("Invalid status code returned. Expected %d, but got %d.",
                    expectedStatus.getStatusCode(), actualStatus.getStatusCode()), actualStatus);
        }

        return interceptorContext.proceed();
    }
}

    final ResteasyClient client = new ResteasyClientBuilder().disableTrustManager().build();
    client.register(new HttpStatusResponseFilter());
    client.register(new HttpStatusResponseInterceptor());

@POST
@Path("some/foobar")
@Consumes(MediaType.APPLICATION_JSON)
@Produces(MediaType.APPLICATION_JSON)
@SuccessStatus(Status.OK)
Foobar createFoobar(Foobar foobar);