Android Volley同步请求不工作

Question

我试图使用RequestFuture向服务器发出同步请求，但它不起作用。使用异步完成相同的请求时效果良好。

这是我的代码：

 public void fetchModules(){
   JSONObject response = null;
    RequestQueue requestQueue = Volley.newRequestQueue(getContext());

    RequestFuture<JSONObject> future = RequestFuture.newFuture();
    JsonObjectRequest request = new JsonObjectRequest(Url.ALL_MODULES_URL,null,future,future);
    requestQueue.add(request);


    try {
         response = future.get(3, TimeUnit.SECONDS); // Blocks for at most 10 seconds.
    } catch (InterruptedException e) {
             Log.d(TAG,"interupted");
     } catch (ExecutionException e) {
        Log.d(TAG,"execution");
    } catch (TimeoutException e) {
        e.printStackTrace();
    }

    Log.d(TAG,response.toString());
}

我得到一个nullpointerexception：

Java语言lang.NullPointerException：尝试调用虚拟方法的java。lang.String组织。json。J主题。com上的null对象引用上的toString（）。数学应用程序。所有模块。在com上获取模块（AllModules.java:85）。数学应用程序。所有模块。android上的onCreateView（AllModules.java:51）。支持v4.app。碎片android上的performCreateView（Fragment.java:2080）。支持v4.app。碎片管理。android上的moveToState（FragmentManager.java:1108）。支持v4.app。碎片管理。android上的moveToState（FragmentManager.java:1290）。支持v4.app。回溯记录。在android上运行（backbackrecord.java:801）。支持v4.app。碎片管理。android上的ExependingActions（FragmentManager.java:1677）。支持v4.app。FragmentManagerImpl 1美元。在android上运行（FragmentManager.java:536）。操作系统。处理程序。android上的handleCallback（Handler.java:746）。操作系统。处理程序。android上的dispatchMessage（Handler.java:95）。操作系统。活套。android上的loop（Looper.java:148）。应用程序。活动线程。java上的main（ActivityThread.java:5443）。郎。反思。方法在com上调用（本机方法）。Android内部的操作系统。ZygoteInit$MethodandArgscaler。在com上运行（ZygoteInit.java:728）。Android内部的操作系统。合子岩。main（ZygoteInit.java:618）

它返回一个空响应。我该如何解决这个问题？

Answer 1

在我自己研究了这个问题之后，你不能（在写作的时候）在主线中这样做

我希望截击在主线程中完成，因为我需要阻止截击，直到截击得到响应。这是不可能的，截取上的同步请求必须在异步线程中，而不是在主线程中。

我所做的工作是，在凌空请求的onResponse方法中执行后续代码

Answer 2

我们可以使用RxJava。

假设fetchModules方法返回JSONObject

Observable<JSONObject> moduleObservable = Observable.defer(new Callable<ObservableSource<? extends JSONObject>>() {
        @Override
        public ObservableSource<? extends JSONObject> call() throws Exception {
            return Observable.just(fetchModules());
        }
    });

在主活动

moduleObservable
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(new io.reactivex.Observer<JSONObject>() {
                @Override
                public void onSubscribe(Disposable d) {

                }

                @Override
                public void onNext(JSONObject response) {
                    // Your response is here
                }

                @Override
                public void onError(Throwable e) {
                     showAlert(context, e.getMessage());
                }

                @Override
                public void onComplete() {

                }
            });

Answer 3

你被试抓欺骗了

说明：因为Request estFuture.get（）可能在UI线程上运行，所以您实际上在幕后得到了java.util.concurrent.TimeoutException。这是调用在主线程上执行时的默认行为。

try catch阻止应用程序崩溃，但响应仍然是一个空引用，当您尝试Log结果时会使应用程序崩溃。如果您评论以下行，您将看到应用程序不再崩溃（那里）。

日志d（TAG，response.toString（））；

修复：在另一个线程上进行RequestFuture网络调用！

一种方法是：

    public class TestVolley {

    private String TAG = "SO_TEST";
    private String url = "http://pokeapi.co/api/v2/pokemon-form/1/";


    public JSONObject fetchModules(Context ctx){
        JSONObject response = null;
        RequestQueue requestQueue = Volley.newRequestQueue(ctx);


        RequestFuture<JSONObject> future = RequestFuture.newFuture();
        JsonObjectRequest request = new JsonObjectRequest(url,null,future,future);
        requestQueue.add(request);


        try {
            response = future.get(3, TimeUnit.SECONDS); // Blocks for at most 10 seconds.
        } catch (InterruptedException e) {
            Log.d(TAG,"interrupted");
        } catch (ExecutionException e) {
            Log.d(TAG,"execution");
        } catch (TimeoutException e) {
            e.printStackTrace();
        }

        Log.d(TAG,response.toString());

        return response;
    }
}

将进行网络调用的异步任务：

public class MyVolleyAsyncTask extends AsyncTask<String,String, JSONObject> {

    private Context ctx;

    public MyVolleyAsyncTask(Context hostContext)
    {
        ctx = hostContext;
    }

    @Override
    protected JSONObject doInBackground(String... params) {

        // Method runs on a separate thread, make all the network calls you need
        TestVolley tester = new TestVolley();

        return tester.fetchModules(ctx);
    }


    @Override
    protected void onPostExecute(JSONObject result)
    {
       // runs on the UI thread
       // do something with the result
    }
}

主要活动：

public class MainActivity extends AppCompatActivity {

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        // this is your old code which will crash the app
        //TestVolley tester = new TestVolley();
        //tester.fetchModules(this);

        // Works!
        new MyVolleyAsyncTask(this).execute();
    }
}

结果：

com.so.henriquems.testvolleyfuture D/SO_TEST: {"id":1,"pokemon":{"url":"http:\/\/pokeapi.co\/api\/v2\/pokemon\/1\/","name":"bulbasaur"},[...]

希望这有帮助

干杯