我正在编写一个用于通信http服务器的应用程序。
我既有同步请求又有异步请求。我有一个单例，其中包含用于异步请求的Volley RequestQueue。现在，我想实现一个同步请求队列，例如：
Request i -> ... -> Response i -> Request i+1 -> ... -> Response i+1
但不是：
Request i -> Request i+1 -> ... -> Response i -> Response i+1
我已经阅读了以下主题：我可以用截击进行同步请求吗？
我想注入不同的Listener和ErrorListener（取决于请求类型）。所以我在RequestFuture类中添加了Listener和ErrorListener的新对象作为变量。
public class RequestFuture<T> implements Future<T>, Response.Listener<T>, Response.ErrorListener {
...
Response.Listener mListener;
Response.ErrorListener mErrorListener;
...
}
但是我真正想要做的是异步请求队列。我该如何用Volley做到这一点？
我想知道我是否继续使用Volley或HTTPRequestExecutor（已弃用）？
非常感谢任何反馈。
老实说，我不再使用这种方法。最好使用Callback而不是同步请求队列，这将使您的代码更易于更新，其他开发人员也更容易理解。请毫不犹豫地添加一个额外的回调参数，例如：在侦听器事件>>中，request_1（callback_1，...），callback_1调用request_2（callback_2，...）。
以下是旧答案：
我在这里发布我的解决方案（虽然不是很干净，但是到目前为止是我的工作）：
我的课：
public class SyncRequestLoader implements Response.ErrorListener, Response.Listener {
public final String TAG = "SyncRequestLoader";
private RequestQueue mRequestQueue;
private Response.Listener mListener;
private Response.ErrorListener mErrorListener;
private LinkedList<StringRequest> mSyncRequests;
private Handler.Callback mCallback;
public SyncRequestLoader(RequestQueue mRequestQueue) {
this.mRequestQueue = mRequestQueue;
mSyncRequests = new LinkedList<>();
}
synchronized public void add(StringRequest request) {
mSyncRequests.add(request);
if (size() == 1)
transceive();
}
@Override
synchronized public void onResponse(Object response) {
mListener.onResponse(response);
//do anything here if u want
removeCompletedRequest();
continueIfPossible();
}
@Override
synchronized public void onErrorResponse(VolleyError error) {
mErrorListener.onErrorResponse(error);
//do anything here if u want
removeCompletedRequest();
continueIfPossible();
}
synchronized private void transceive() {
StringRequest request = mSyncRequests.getFirst();
mListener = request.getListener();
mErrorListener = request.getErrorListener();
StringRequest new_request = new StringRequest(request.getUrl(), this, this);
mRequestQueue.add(new_request);
}
synchronized private void removeCompletedRequest() {
mSyncRequests.removeFirst();
}
synchronized private void continueIfPossible() {
if (size() > 0)
transceive();
else if (isOnCallback())
mCallback.handleMessage(Message.obtain(null, 1));
}
public boolean isOnCallback() {
return (mCallback != null);
}
public void setCallback(Handler.Callback callback) {
this.mCallback = callback;
}
}
我正在使用SyncRequestLoader mCallback通知Sync Request Queue已经完成。我将所有同步请求存储在Linkedlist中，然后将其一个接一个地添加到排球队列中。因为我们得到了先前请求的响应，所以每个请求都将被注入到Volley请求队列中。我在这里通过使用局部变量mListener和mErrorListener发出新请求来“欺骗”，您可以看到我解析了对“ true”侦听器的响应。
本文收集自互联网，转载请注明来源。
如有侵权，请联系 [email protected] 删除。
我来说两句