MockWebServer与回调重组

Question

我想用MockWebServer来模拟网络通信。不可修改的回调永远不会被调用。我的代码：

    MockWebServer server = new MockWebServer();
    server.enqueue(new MockResponse().setResponseCode(200).setBody("{}"));
    server.play();

    RestAdapter restAdapter = new RestAdapter.Builder().setConverter(new MyGsonConverter(new Gson()))
            .setEndpoint(server.getUrl("/").toString()).build();

    restAdapter.create(SearchService.class).getCount(StringUtils.EMPTY,
            new Callback<CountContainer>() {

                @Override
                public void success(CountContainer countContainer, Response response) {
                    System.out.println("success");
                }

                @Override
                public void failure(RetrofitError error) {
                    System.out.println("error");
                }
            });

    server.shutdown();

当我使用不需要回调的改装时，它可以工作。

Answer 1

通过拥有一个Callback，您将告诉Retrofit调用请求并异步调用回调。这意味着在发生任何事情之前，您的测试就会退出。

有两种方法可以让它发挥作用：

• 在测试结束时使用一个锁，直到调用其中一个回调方法。
• 将同步Executor的一个实例(一个直接调用.run()的实例)传递给RestAdapter.Builder上的setExecutors，以便后台调用和回调调用同步进行。

Answer 2

关于改进2，请参见这里的答案：https://github.com/square/retrofit/issues/1259，您可以将同步执行器提供给OkHttpClient (通过它的dispatcher)，并将这个客户机设置为Retrofit.Builder。还可以将相同的执行器设置为callbackExecutor。

例如：

CurrentThreadExecutor currentThreadExecutor = new CurrentThreadExecutor();
okhttp3.Dispatcher dispatcher = new okhttp3.Dispatcher(currentThreadExecutor);
OkHttpClient okHttpClient = new 
OkHttpClient.Builder().dispatcher(dispatcher).build();

new Retrofit.Builder()
        .client(okHttpClient)
        .baseUrl(httpUrl)
        .addConverterFactory(JacksonConverterFactory.create())
        .callbackExecutor(currentThreadExecutor)
        .build();

CurrentThreadExecutor实现示例：https://gist.github.com/vladimir-bukhtoyarov/38d6b4b277d0a0cfb3af

Answer 3

或者，您可以在MockWebServer中使用Mockinizer：

OkHttpClient.Builder()
        .addInterceptor(loggingInterceptor)
        .mockinize(mocks) // <-- just add this line
        .build()

以及您想要模拟的请求/响应，可以在mocks值中定义。在你的例子中，它看起来是这样的：

package com.appham.mockinizer.demo

import com.appham.mockinizer.RequestFilter
import okhttp3.mockwebserver.MockResponse

val mocks: Map<RequestFilter, MockResponse> = mapOf(

    RequestFilter("/") to MockResponse().apply {
        setResponseCode(200)
        setBody("""{}""")
    }

)

请参阅https://github.com/donfuxx/Mockinizer