保存cookie
import android.content.Context;
import android.content.SharedPreferences;
import android.text.TextUtils;
import android.util.Log;
import com.zhy.http.okhttp.cookie.store.CookieStore;
import com.zhy.http.okhttp.cookie.store.SerializableHttpCookie;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.util.ArrayList;
import java.util.Collection;
import java.util.HashMap;
import java.util.List;
import java.util.Locale;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import okhttp3.Cookie;
import okhttp3.HttpUrl;
public class OKhttpCookieChange implements CookieStore {
private static final String LOG_TAG = "PersistentCookieStore";
private static final String COOKIE_PREFS = "CookiePrefsFile";
private static final String COOKIE_NAME_PREFIX = "cookie_";
private final HashMap<String, ConcurrentHashMap<String, Cookie>> cookies;
private final SharedPreferences cookiePrefs;
/**
* Construct a persistent cookie store.
*
* @param context Context to attach cookie store to
*/
public OKhttpCookieChange(Context context) {
cookiePrefs = context.getSharedPreferences(COOKIE_PREFS, 0);
cookies = new HashMap<>();
// Load any previously stored cookies into the store
Map<String, ?> prefsMap = cookiePrefs.getAll();
for (Map.Entry<String, ?> entry : prefsMap.entrySet()) {
if (((String) entry.getValue()) != null && !((String) entry.getValue()).startsWith(COOKIE_NAME_PREFIX)) {
String[] cookieNames = TextUtils.split((String) entry.getValue(), ",");
for (String name : cookieNames) {
String encodedCookie = cookiePrefs.getString(COOKIE_NAME_PREFIX + name, null);
if (encodedCookie != null) {
Cookie decodedCookie = decodeCookie(encodedCookie);
if (decodedCookie != null) {
if (!cookies.containsKey(entry.getKey()))
cookies.put(entry.getKey(), new ConcurrentHashMap<String, Cookie>());
cookies.get(entry.getKey()).put(name, decodedCookie);
}
}
}
}
}
}
protected void add(HttpUrl uri, Cookie cookie) {
String name = getCookieToken(cookie);
if (cookie.persistent()) {
if (!cookies.containsKey(uri.host())) {
cookies.put(uri.host(), new ConcurrentHashMap<String, Cookie>());
}
cookies.get(uri.host()).put(name, cookie);
}/* else
{
if (cookies.containsKey(uri.host()))
{
cookies.get(uri.host()).remove(name);
}else
{
return ;
}
}*/
// Save cookie into persistent store
SharedPreferences.Editor prefsWriter = cookiePrefs.edit();
prefsWriter.putString(uri.host(), TextUtils.join(",", cookies.get(uri.host()).keySet()));
prefsWriter.putString(COOKIE_NAME_PREFIX + name, encodeCookie(new SerializableHttpCookie(cookie)));
prefsWriter.apply();
}
protected String getCookieToken(Cookie cookie) {
return cookie.name() + cookie.domain();
}
@Override
public void add(HttpUrl uri, List<Cookie> cookies) {
for (Cookie cookie : cookies) {
add(uri, cookie);
}
}
@Override
public List<Cookie> get(HttpUrl uri) {
ArrayList<Cookie> ret = new ArrayList<Cookie>();
if (cookies.containsKey(uri.host())) {
Collection<Cookie> cookies = this.cookies.get(uri.host()).values();
for (Cookie cookie : cookies) {
if (isCookieExpired(cookie)) {
remove(uri, cookie);
} else {
ret.add(cookie);
}
}
}
return ret;
}
private static boolean isCookieExpired(Cookie cookie) {
return cookie.expiresAt() < System.currentTimeMillis();
}
@Override
public boolean removeAll() {
SharedPreferences.Editor prefsWriter = cookiePrefs.edit();
prefsWriter.clear();
prefsWriter.apply();
cookies.clear();
return true;
}
@Override
public boolean remove(HttpUrl uri, Cookie cookie) {
String name = getCookieToken(cookie);
if (cookies.containsKey(uri.host()) && cookies.get(uri.host()).containsKey(name)) {
cookies.get(uri.host()).remove(name);
SharedPreferences.Editor prefsWriter = cookiePrefs.edit();
if (cookiePrefs.contains(COOKIE_NAME_PREFIX + name)) {
prefsWriter.remove(COOKIE_NAME_PREFIX + name);
}
prefsWriter.putString(uri.host(), TextUtils.join(",", cookies.get(uri.host()).keySet()));
prefsWriter.apply();
return true;
} else {
return false;
}
}
@Override
public List<Cookie> getCookies() {
ArrayList<Cookie> ret = new ArrayList<Cookie>();
for (String key : cookies.keySet())
ret.addAll(cookies.get(key).values());
return ret;
}
protected String encodeCookie(SerializableHttpCookie cookie) {
if (cookie == null)
return null;
ByteArrayOutputStream os = new ByteArrayOutputStream();
try {
ObjectOutputStream outputStream = new ObjectOutputStream(os);
outputStream.writeObject(cookie);
} catch (IOException e) {
Log.d(LOG_TAG, "IOException in encodeCookie", e);
return null;
}
return byteArrayToHexString(os.toByteArray());
}
protected Cookie decodeCookie(String cookieString) {
byte[] bytes = hexStringToByteArray(cookieString);
ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(bytes);
Cookie cookie = null;
try {
ObjectInputStream objectInputStream = new ObjectInputStream(byteArrayInputStream);
cookie = ((SerializableHttpCookie) objectInputStream.readObject()).getCookie();
} catch (IOException e) {
Log.d(LOG_TAG, "IOException in decodeCookie", e);
} catch (ClassNotFoundException e) {
Log.d(LOG_TAG, "ClassNotFoundException in decodeCookie", e);
}
return cookie;
}
/**
* Using some super basic byte array <-> hex conversions so we don't have to rely on any
* large Base64 libraries. Can be overridden if you like!
*
* @param bytes byte array to be converted
* @return string containing hex values
*/
protected String byteArrayToHexString(byte[] bytes) {
StringBuilder sb = new StringBuilder(bytes.length * 2);
for (byte element : bytes) {
int v = element & 0xff;
if (v < 16) {
sb.append('0');
}
sb.append(Integer.toHexString(v));
}
return sb.toString().toUpperCase(Locale.US);
}
/**
* Converts hex values from strings to byte arra
*
* @param hexString string of hex-encoded values
* @return decoded byte array
*/
protected byte[] hexStringToByteArray(String hexString) {
int len = hexString.length();
byte[] data = new byte[len / 2];
for (int i = 0; i < len; i += 2) {
data[i / 2] = (byte) ((Character.digit(hexString.charAt(i), 16) << 4) + Character.digit(hexString.charAt(i + 1), 16));
}
return data;
}
}
普通使用
package com.zhy.sample_okhttp;
import android.app.Activity;
import android.graphics.Bitmap;
import android.os.Bundle;
import android.os.Environment;
import android.util.Log;
import android.view.View;
import android.widget.ImageView;
import android.widget.ProgressBar;
import android.widget.TextView;
import android.widget.Toast;
import com.google.gson.Gson;
import com.zhy.http.okhttp.OkHttpUtils;
import com.zhy.http.okhttp.callback.BitmapCallback;
import com.zhy.http.okhttp.callback.FileCallBack;
import com.zhy.http.okhttp.callback.StringCallback;
import java.io.File;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import okhttp3.Call;
import okhttp3.MediaType;
import okhttp3.Request;
public class MainActivity extends Activity {
private static final String TAG = "MainActivity";
private TextView mTv;
private ImageView mImageView;
private ProgressBar mProgressBar;
public class MyStringCallback extends StringCallback {
@Override
public void onBefore(Request request) {
super.onBefore(request);
setTitle("loading...");
}
@Override
public void onAfter() {
super.onAfter();
setTitle("Sample-okHttp");
}
@Override
public void onError(Call call, Exception e) {
e.printStackTrace();
mTv.setText("onError:" + e.getMessage());
}
//响应的结果太长了，这里截断显示
@Override
public void onResponse(String response) {
mTv.setText("onResponse:" + response.substring(0, 300));
}
@Override
public void inProgress(float progress) {
Log.e(TAG, "inProgress:" + progress);
mProgressBar.setProgress((int) (100 * progress));
}
}
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
mTv = (TextView) findViewById(R.id.id_textview);
mImageView = (ImageView) findViewById(R.id.id_imageview);
mProgressBar = (ProgressBar) findViewById(R.id.id_progress);
mProgressBar.setMax(100);
String url ="http://www.baidu.com";
getHtml(url);
String img_url = "http://p0.so.qhimg.com/sdr/720_1080_/t01b59359f15a85528f.jpg";
getImage(img_url);
}
/**
* 获得html信息
* @param url
*/
public void getHtml(String url) {
OkHttpUtils
.get()
.url(url)
.addHeader("Accept-Encoding", "utf-8")
.build()
.execute(new MyStringCallback());
}
/**
* 上传一个json字符串
* @param view
*/
public void postString(String url) {
String json = new Gson().toJson(new User("zhy", "123"));
OkHttpUtils.postString()
.url(url)
.mediaType(MediaType.parse("application/json; charset=utf-8"))
.content(json)
.build()
.execute(new MyStringCallback());
}
public abstract class UserCallback extends Callback<User>
{
@Override
public User parseNetworkResponse(Response response) throws IOException
{
String string = response.body().string();
User user = new Gson().fromJson(string, User.class);
return user;
}
}
/**
* 登陆
* @param url
*/
public void getUser(String url) {
OkHttpUtils.post()//
.url(url)//
.addParams("username", "hyman")//
.addParams("password", "123")//
.build()//
.execute(new UserCallback() {
@Override
public void onError(Call call, Exception e) {
//mTv.setText("onError:" + e.getMessage());
}
@Override
public void onResponse(User response) {
//mTv.setText("onResponse:" + response.username);
}
});
}
/**
* 下载图片
* @param mImageView
*/
public void getImage(String url) {
OkHttpUtils.get()
.url(url)
.tag(this)
.build()
.connTimeOut(20000)
.readTimeOut(20000)
.writeTimeOut(20000)
.execute(new BitmapCallback() {
@Override
public void onError(Call call, Exception e) {
//
}
@Override
public void onResponse(Bitmap bitmap) {
mImageView.setImageBitmap(bitmap);
}
});
}
/**
* 上传单个文件
* @param url
*/
public void uploadFile(String url ) {
File file = new File(Environment.getExternalStorageDirectory(),"messenger_01.png");
if (!file.exists()) {
Toast.makeText(MainActivity.this, "文件不存在，请修改文件路径",Toast.LENGTH_SHORT).show();
return;
}
Map<String, String> params = new HashMap<>();
params.put("username", "张鸿洋");
params.put("password", "123");
Map<String, String> headers = new HashMap<>();
headers.put("APP-Key", "APP-Secret222");
headers.put("APP-Secret", "APP-Secret111");
OkHttpUtils.post()//
.addFile("mFile", "messenger_01.png", file)//
.url(url)//
.params(params)//
.headers(headers)//
.build()//
.execute(new MyStringCallback());
}
/**
* 上传多个文件+params
* @param url
*/
public void multiFileUpload(String url) {
File file = new File(Environment.getExternalStorageDirectory(),"messenger_01.png");
File file2 = new File(Environment.getExternalStorageDirectory(),"test1.txt");
if (!file.exists()) {
Toast.makeText(MainActivity.this, "文件不存在，请修改文件路径",Toast.LENGTH_SHORT).show();
return;
}
if(!file2.exists()){
Toast.makeText(MainActivity.this, "文件不存在，请修改文件路径",Toast.LENGTH_SHORT).show();
return;
}
Map<String, String> params = new HashMap<>();
params.put("username", "张鸿洋");
params.put("password", "123");
OkHttpUtils.post()//
.addFile("mFile", "messenger_01.png", file)//
.addFile("mFile", "test1.txt", file2)//
.url(url)
.params(params)//
.build()//
.execute(new MyStringCallback());
}
/**
* 文件下载
* @param view
*/
public void downloadFile() {
String url = "https://github.com/hongyangAndroid/okhttp-utils/blob/master/gson-2.2.1.jar?raw=true";
String fileDir = Environment.getExternalStorageDirectory().getAbsolutePath();
String fileName = "gson-2.2.1.jar";
OkHttpUtils//
.get()//
.url(url)//
.build()
.execute(
new FileCallBack(fileDir, fileName) {
@Override
public void onBefore(Request request) {
super.onBefore(request);
}
@Override
public void inProgress(float progress, long total) {
mProgressBar.setProgress((int) (100 * progress));
}
@Override
public void onError(Call call, Exception e) {
Log.e(TAG, "onError :" + e.getMessage());
}
@Override
public void onResponse(File file) {
Log.e(TAG,"onResponse :" + file.getAbsolutePath());
}
});
}
/**
* 清除缓存信息
*
* @param view
*/
public void clearSession(View view) {
OkHttpUtils.getInstance().getCookieStore().removeAll();
}
/**
* 取消某个请求
*/
@Override
protected void onDestroy() {
super.onDestroy();
OkHttpUtils.getInstance().cancelTag(this);
}
}
上面的实例中有很多封装好的方法， 可以直接使用。
在实际使用过程中，一些全局性的配置可以在Application中去设置。如https请求，需要加载签名证书。
package com.zhy.sample_okhttp;
import android.app.Application;
import com.zhy.http.okhttp.OkHttpUtils;
import java.io.InputStream;
import java.util.concurrent.TimeUnit;
import okhttp3.OkHttpClient;
import okio.Buffer;
/**
* 注意：如果https网站为权威机构颁发的证书，不需要以上设置。自签名的证书才需要。
*/
public class MyApplication extends Application{
//12306签名证书
private String CER_12306 = "-----BEGIN CERTIFICATE-----\n" +
"MIICmjCCAgOgAwIBAgIIbyZr5/jKH6QwDQYJKoZIhvcNAQEFBQAwRzELMAkGA1UEBhMCQ04xKTAn\n" +
"BgNVBAoTIFNpbm9yYWlsIENlcnRpZmljYXRpb24gQXV0aG9yaXR5MQ0wCwYDVQQDEwRTUkNBMB4X\n" +
"DTA5MDUyNTA2NTYwMFoXDTI5MDUyMDA2NTYwMFowRzELMAkGA1UEBhMCQ04xKTAnBgNVBAoTIFNp\n" +
"bm9yYWlsIENlcnRpZmljYXRpb24gQXV0aG9yaXR5MQ0wCwYDVQQDEwRTUkNBMIGfMA0GCSqGSIb3\n" +
"DQEBAQUAA4GNADCBiQKBgQDMpbNeb34p0GvLkZ6t72/OOba4mX2K/eZRWFfnuk8e5jKDH+9BgCb2\n" +
"9bSotqPqTbxXWPxIOz8EjyUO3bfR5pQ8ovNTOlks2rS5BdMhoi4sUjCKi5ELiqtyww/XgY5iFqv6\n" +
"D4Pw9QvOUcdRVSbPWo1DwMmH75It6pk/rARIFHEjWwIDAQABo4GOMIGLMB8GA1UdIwQYMBaAFHle\n" +
"tne34lKDQ+3HUYhMY4UsAENYMAwGA1UdEwQFMAMBAf8wLgYDVR0fBCcwJTAjoCGgH4YdaHR0cDov\n" +
"LzE5Mi4xNjguOS4xNDkvY3JsMS5jcmwwCwYDVR0PBAQDAgH+MB0GA1UdDgQWBBR5XrZ3t+JSg0Pt\n" +
"x1GITGOFLABDWDANBgkqhkiG9w0BAQUFAAOBgQDGrAm2U/of1LbOnG2bnnQtgcVaBXiVJF8LKPaV\n" +
"23XQ96HU8xfgSZMJS6U00WHAI7zp0q208RSUft9wDq9ee///VOhzR6Tebg9QfyPSohkBrhXQenvQ\n" +
"og555S+C3eJAAVeNCTeMS3N/M5hzBRJAoffn3qoYdAO1Q8bTguOi+2849A==\n" +
"-----END CERTIFICATE-----";
@Override
public void onCreate(){
super.onCreate();
//这里可以设置自签名证书
//OkHttpUtils.getInstance().setCertificates(new InputStream[] { new Buffer().writeUtf8(CER_12306).inputStream()});
//设置超时时间
//OkHttpUtils.getInstance().debug("OkHttpUtils").setConnectTimeout(100000, TimeUnit.MILLISECONDS);
//使用https，但是默认信任全部证书
// OkHttpUtils.getInstance().setCertificates();
//使用https，加载证书。将证书放在assets目录：
// try {
// InputStream is1 = getAssets().open("aaa.cer");
// InputStream is2 = getAssets().open("server.cer");
// OkHttpUtils.getInstance().setCertificates(is1,is2);
// } catch (Exception e) {
// }
// 使用这种方式，设置多个OkHttpClient参数
// OkHttpUtils.getInstance(new OkHttpClient.Builder().build());
//OkHttpClient client = OkHttpUtils.getInstance().getOkHttpClient();
}
}
