OkHttp在安卓中的使用？

//創建Observable對象
Observable& observable= Observable.create(
new Observable.OnSubscribe&() {
@Override
public void call(Subscriber& subscriber) {
try {
User user =service.getUser("username","password")
subscriber.onNext(user);
subscriber.onCompleted();
} catch (Exception e) {
subscriber.onError(e);
}
}
});

import java.io.UnsupportedEncodingException;
import java.lang.reflect.Type;
import java.util.Map;

import me.zq.youjoin.utils.LogUtils;
import me.zq.youjoin.utils.StringUtils;

public class PostObjectRequest& extends Request& {

private ResponseListener listener;
private Gson gson;
private Type clazz;
private Map& params;

public PostObjectRequest(String url, Map& params, Type type,
ResponseListener listener){
super(Method.POST, url, listener);
this.listener = listener;
this.clazz = type;
this.params = params;
this.gson = new Gson();
}

@Override
protected Response& parseNetworkResponse(NetworkResponse response){
try{
T result;
String jsonString =
new String(response.data, HttpHeaderParser.parseCharset(response.headers));
LogUtils.d("hehe", jsonString);
result = gson.fromJson(StringUtils.FixJsonString(jsonString), clazz);
return Response.success(result,
HttpHeaderParser.parseCacheHeaders(response));
}catch (UnsupportedEncodingException e) {
return Response.error(new ParseError(e));
}
}

@Override
protected void deliverResponse(T response){
listener.onResponse(response);
}

@Override
protected Map& getParams() throws AuthFailureError{
return params;
}

import com.android.volley.AuthFailureError;
import com.android.volley.DefaultRetryPolicy;
import com.android.volley.NetworkResponse;
import com.android.volley.ParseError;
import com.android.volley.Request;
import com.android.volley.Response;
import com.android.volley.toolbox.HttpHeaderParser;
import com.google.gson.Gson;

import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.lang.reflect.Type;
import java.util.List;
import java.util.Map;

import me.zq.youjoin.model.ImageInfo;
import me.zq.youjoin.utils.StringUtils;

public class PostUploadRequest& extends Request& {

/**
* 正確數據的時候回掉用
*/
private ResponseListener mListener ;
/*請求 數據通過參數的形式傳入*/
private List& mListItem ;

private static final String BOUNDARY = "-----ZZQ----MZZ-----"; //數據分隔線
private static final String MULTIPART_FORM_DATA = "multipart/form-data";//使用表單數據方法提交
private static final String TAG = "hehe_upload_request";
private static final String PARAM = "uploadedfile";//圖片的參數，&為了上傳多張圖片，在下面的封裝中使用uploadedfile[index]格式作為圖片參數&

private Map& params;
private Gson gson;
private Type clazz;

public PostUploadRequest(String url, List& listItem,
Map& params,
Type type, ResponseListener listener) {
super(Method.POST, url, listener);
this.mListener = listener ;
this.params = params;
this.gson = new Gson();
this.clazz = type;
setShouldCache(false);
mListItem = listItem ;
//設置請求的響應事件，因為文件上傳需要較長的時間，所以在這裡加大了，設為5秒
setRetryPolicy(new DefaultRetryPolicy(5000,DefaultRetryPolicy.DEFAULT_MAX_RETRIES,DefaultRetryPolicy.DEFAULT_BACKOFF_MULT));
}

/**
* 這裡開始解析數據
* @param response Response from the network
* @return
*/
@Override
protected Response& parseNetworkResponse(NetworkResponse response) {
try {
String mString =
new String(response.data, HttpHeaderParser.parseCharset(response.headers));
Log.v(TAG, "mString = " + mString);
T result = gson.fromJson(StringUtils.FixJsonString(mString), clazz);
return Response.success(result,
HttpHeaderParser.parseCacheHeaders(response));
} catch (UnsupportedEncodingException e) {
return Response.error(new ParseError(e));
}
}

/**
* 回調正確的數據
* @param response The parsed response returned by
*/
@Override
protected void deliverResponse(T response) {

mListener.onResponse(response);
}
//重寫getBody()方法，封裝Post包
@Override
public byte[] getBody() throws AuthFailureError {
if (mListItem == null||mListItem.size() == 0){
return super.getBody() ;
}
ByteArrayOutputStream bos = new ByteArrayOutputStream() ;

if(!params.isEmpty()) {
StringBuilder sbParams = new StringBuilder();

for (Map.Entry& o : params.entrySet()) {
Map.Entry entry = (Map.Entry) o;

/*第一行*/
//`"--" + BOUNDARY + "
"`
sbParams.append("--" + BOUNDARY);
sbParams.append("
");
/*第二行*/
//Content-Disposition: form-data; name="參數的名稱"; + 參數 + "
"
sbParams.append("Content-Disposition: form-data;");
sbParams.append(" name="");
sbParams.append((String) entry.getKey());
sbParams.append(""");
sbParams.append("
");
sbParams.append("
");
sbParams.append((String) entry.getValue());
sbParams.append("
");
}
try {
bos.write(sbParams.toString().getBytes("utf-8"));
// bos.write("
".getBytes("utf-8"));
} catch (IOException e) {
e.printStackTrace();
}

}

public interface ResponseListener& extends Response.ErrorListener,Response.Listener& {

/**
* 網路介面相關常量
*/
public static final String USER_USERNAME = "user_name";
public static final String USER_PASSWORD = "user_password";
public static final String USER_EMAIL = "user_email";
public static final String USER_ID = "user_id";
public static final String USER_WORK = "user_work";
public static final String USER_BIRTH = "user_birth";
public static final String USER_SIGN = "user_sign";
public static final String USER_LOCATION = "user_location";
public static final String USER_SEX = "user_sex";

public static final String TWEETS_CONTNET = "tweets_content";

public static final String FRIEND_ID = "friend_id";

public static final String SEND_USERID = "send_userid";
public static final String RECEIVE_USERID = "receive_userid";
public static final String MESSAGE_CONTENT = "message_content";

/**
* 伺服器介面URL
*/
public static final String BASE_API_URL = "http://192.168.0.103:8088/youjoin-server/controllers/";
public static final String API_SIGN_IN = BASE_API_URL + "signin.php";
public static final String API_SIGN_UP = BASE_API_URL + "signup.php";
public static final String API_UPDATE_USERINFO = BASE_API_URL + "update_userinfo.php";
public static final String API_SEND_TWEET = BASE_API_URL + "send_tweet.php";
public static final String API_REQUEST_USERINFO = BASE_API_URL + "request_userinfo.php";
public static final String API_ADD_FRIEND = BASE_API_URL + "add_friend.php";
public static final String API_SEND_MESSAGE = BASE_API_URL + "send_message.php";
public static final String API_RECEIVE_MESSAGE = BASE_API_URL + "receive_message.php";
public static final String API_COMMENT_TWEET = BASE_API_URL + "comment_tweet.php";
public static final String API_UPVOTE_TWEET = BASE_API_URL + "upvote_tweet.php";

private static RequestQueue mRequestQueue ;

/**
* 發送動態介面
* @param listener ResponseListener
*/
public static void postSendTweet(String content, List& images,
ResponseListener listener){
Map& params = new HashMap&<&>();
params.put(USER_ID, YouJoinApplication.getCurrUser().getId());
params.put(TWEETS_CONTNET, content);
Request request = new PostUploadRequest(API_SEND_TWEET, images, params,
new TypeToken&(){}.getType(), listener);
NetworkManager.getRequestQueue().add(request);
}

/**
* 發送私信介面
* @param receiveUserId 接收方用戶id
* @param content 私信內容
* @param listener ResponseListener
*/
public static void postSendMessage(String receiveUserId, String content,
ResponseListener listener){
Map& params = new HashMap&<&>();
params.put(SEND_USERID, YouJoinApplication.getCurrUser().getId());
params.put(RECEIVE_USERID, receiveUserId);
params.put(MESSAGE_CONTENT, content);
Request request = new PostObjectRequest(
API_SEND_MESSAGE,
params, new TypeToken&(){}.getType(),
listener);
NetworkManager.getRequestQueue().add(request);
}

/**
* 添加好友介面
* @param friendUserId 要添加的好友id
* @param listener ResponseListener
*/
public static void postAddFriend(String friendUserId,
ResponseListener listener){
Map& params = new HashMap&<&>();
params.put(USER_ID, YouJoinApplication.getCurrUser().getId());
params.put(FRIEND_ID, friendUserId);
Request request = new PostObjectRequest(
API_ADD_FRIEND,
params, new TypeToken&(){}.getType(),
listener);
NetworkManager.getRequestQueue().add(request);
}

/**
* 個人資料請求（下載）介面
* @param userId 要獲取的用戶id
* @param listener ResponseListener
*/
public static void postRequestUserInfo(String userId, ResponseListener listener){
Map& params = new HashMap&<&>();
params.put(USER_ID, userId);
Request request = new PostObjectRequest(
API_REQUEST_USERINFO,
params,new TypeToken&(){}.getType(),
listener);
NetworkManager.getRequestQueue().add(request);
}

/**
* 個人資料更新（上傳）介面
* @param userInfo 用戶實體類
* @param picPath 頭像的本地路徑
* @param listener ResponseListener
*/
public static void postUpdateUserInfo(UserInfo userInfo, String picPath, ResponseListener listener){
if(userInfo.getId() == null) return;

List& imageList = new ArrayList&<&>();
imageList.add(new ImageInfo(picPath));
Map& params = new HashMap&<&>();
params.put(USER_ID, userInfo.getId());
params.put(USER_WORK, userInfo.getWork());
params.put(USER_LOCATION, userInfo.getLocation());
params.put(USER_SEX, userInfo.getSex());
params.put(USER_BIRTH, userInfo.getBirth());
params.put(USER_SIGN, userInfo.getUsersign());
Request request = new PostUploadRequest(API_UPDATE_USERINFO, imageList, params,
new TypeToken&(){}.getType(), listener);
NetworkManager.getRequestQueue().add(request);
}

/**
* 登陸介面
* @param username 登錄用戶名
* @param password 登陸密碼
* @param listener ResponseListener
*/
public static void postSignIn(String username, String password,
ResponseListener listener){
Map& param = new HashMap&<&>();
param.put(USER_USERNAME, username);
param.put(USER_PASSWORD, Md5Utils.getMd5(password));
Request request = new PostObjectRequest(
API_SIGN_IN,
param,
new TypeToken&(){}.getType(),
listener);
NetworkManager.getRequestQueue().add(request);
}

/**
* 註冊介面
* @param username 註冊用戶名
* @param password 註冊密碼
* @param email 註冊郵箱
* @param listener ResponseListener
*/
public static void postSignUp(String username, String password, String email,
ResponseListener listener){
Map& param = new HashMap&<&>();
param.put(USER_USERNAME, username);
param.put(USER_PASSWORD, Md5Utils.getMd5(password));
param.put(USER_EMAIL, email);
Request request = new PostObjectRequest(
API_SIGN_UP,
param,
new TypeToken&(){}.getType(),
listener);
NetworkManager.getRequestQueue().add(request);
}

/**初始化Volley 使用OkHttpStack
* @param context 用作初始化Volley RequestQueue
*/
public static synchronized void initialize(Context context){
if (mRequestQueue == null){
synchronized (NetworkManager.class){
if (mRequestQueue == null){
mRequestQueue =
Volley.newRequestQueue(context, new OkHttpStack(new OkHttpClient()));
}
}
}
mRequestQueue.start();
}

import me.zq.youjoin.model.UserInfo;
import me.zq.youjoin.network.NetworkManager;

public class YouJoinApplication extends Application {
public static float sScale;
public static int sHeightPix;

private static Context context;

private static UserInfo currUser;

@Override
public void onCreate(){
super.onCreate();
context = getApplicationContext();
NetworkManager.initialize(context);

sScale = getResources().getDisplayMetrics().density;
sHeightPix = getResources().getDisplayMetrics().heightPixels;
}

public static Context getAppContext(){
return context;
}

public static UserInfo getCurrUser() {
return currUser;
}