Okhttp3.0使用笔记

1.GitHub地址

　　https://github.com/square/okhttp

2.使用步骤

　　将下载的包导入

　　

       对包进行设置依赖：

　　

     最终的效果图：

　　

3.源码

public class MainActivity extends AppCompatActivity implements View.OnClickListener{

    private Button mButtonGetY;
    private Button mButtonGetA;
    private Button post;
    private Button fileDownload,fengzhuang;
    private TextView mTextView;
    private String result;
    
    private OkHttpClient client;
    private Request mRequest;


    /*
    *直接设置连接超时，初始化OkHttpClient
    */
    private void init(){
        client = new OkHttpClient();
        client.newBuilder().connectTimeout(10,TimeUnit.SECONDS);//连接超时
        client.newBuilder().readTimeout(10,TimeUnit.SECONDS);//读取超时
        client.newBuilder().writeTimeout(10,TimeUnit.SECONDS);//写入超时
    }
    /*
    *事件监听
    */
    private void initListener(){
        mButtonGetA.setOnClickListener(this);
        mButtonGetY.setOnClickListener(this);
        post.setOnClickListener(this);
        fileDownload.setOnClickListener(this);
    }

    /*
    *初始化布局控件
    */
    private void initialize(){
        mButtonGetA=(Button)findViewById(R.id.RequestA);
        mButtonGetY=(Button)findViewById(R.id.RequestY);
        post=(Button)findViewById(R.id.fromRequest);
        fileDownload=(Button)findViewById(R.id.fileDownLoad);
        mTextView=(TextView)findViewById(R.id.shortcut);
    }


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

    
    @Override
    public void onClick(Viewv){
    
        switch(v.getId()){
            caseR.id.RequestA:
                initAsyncGet();
                break;
            caseR.id.RequestY:
                initSyncData();
                break;
            caseR.id.fromRequest:
                initPost();
                break;
            caseR.id.fileDownLoad:
                downLoadFile();
                break;
        }
    }

    /*
    *get请求同步方法
    */
    private void initSyncData(){
          newThread(newRunnable(){
            @Override
            public void run(){
            try{
                mRequest = new Request.Builder().url("http://www.baidu.com").build();
                Response response = client.newCall(mRequest).execute();
                result=response.body().string();
                runOnUiThread(new Runnable(){
                    @Override
                    public void run(){
                    mTextView.setText(result);
                    Log.d("MainActivity","hello");
                }
            });
        }
            catch(Exceptione){
                e.printStackTrace();
              }
            }
        }).start();
    }
    

    /*
    *异步请求
    */
    private void initAsyncGet(){
        new Thread (new Runnable(){
            @Override
            public void run(){
            mRequest=newRequest.Builder().url("http://www.baidu.com").build();
            client.newCall(mRequest).enqueue(newCallback(){
            /**
            *Acallisarequestthathasbeenpreparedforexecution.Acallcanbecanceled.Asthisobject
            *representsasinglerequest/responsepair(stream),itcannotbeexecutedtwice.
            *
            *
            *@paramcall是一个接口，是一个准备好的可以执行的request
            *可以取消，对位一个请求对象，只能单个请求
            *@parame
            */
            @Override
            public void onFailure(Callcall,IOExceptione){
            Log.d("MainActivity","异步请求失败");
        }

    /**
    *
    *@paramcall
    *@paramresponse是一个响应请求
    *@throwsIOException
    */
    @Override
    public void onResponse (Call call,final Response response) throws IOException{
    /**
    *通过拿到response这个响应请求，然后通过body().string(),拿到请求到的数据
    *这里最好用string()而不要用toString（）
    *toString（）每个类都有的，是把对象转换为字符串
    *string（）是把流转为字符串
    */
        result=response.body().string();
        runOnUiThread(newRunnable(){
            @Override
            publicvoidrun(){
            mTextView.setText(result);
                }
            });
          }
         });
        }
        }).start();
    }

    /*
    *表单提交
    */
    private void initPost(){
    
    String url="http://112.124.22.238:8081/course_api/banner/query";
    
    FormBody formBody = new FormBody.Builder()
                             .add("type","1")
                             .build();
    mRequest=newRequest.Builder().url(url)
                   .post(formBody).build();
    new Thread(new Runnable(){
        @Override
        public void run(){
        client.newCall(mRequest).enqueue(newCallback(){
        @Override
        public void onFailure(Call call,IOException e){
        Log.d("MainActivity","表单请求失败");
    }
    
    @Override
    public void onResponse(Call call,Response response)throwsIOException{
    runOnUiThread(new Runnable(){
        @Override
        public void run(){
        mTextView.setText("提交成功");
         }
         });
        }
        });
        }
    }).start();
    }


    /*
    *文件下载地址
    */
    private void downLoadFile(){
    
    String url="http://ww2.sinaimg.cn/large/797ccd21gw1fa96zpf7ooj20dw0jtdh7.jpg";
    mRequest = newRequest.Builder().url(url).build();
    
    new Thread (new Runnable(){
    @Override
    public void run(){
    
    client.newCall(mRequest).enqueue(newCallback(){
    @Override
    public void onFailure(Callcall,IOExceptione){
        Log.d("MainActivity","下载失败");
    }
    
    @Override
    public void onResponse(Call call,Response response) throws IOException{
    
    //把请求成功的response转换为字节流
    InputStream inputStream=response.body().byteStream();
    /**
    *在这里要加上权限在mainfests文件中
    *<uses-permissionandroid:name="android.permission.INTERNET"/>
    *<uses-permissionandroid:name="android.permission.WRITE_EXTERNAL_STORAGE"/>
    */
    
    FileOutputStream fileOutputStream = new FileOutputStream(new File("/sdcard/girl.jpg"));
    ///定义一个字节流数组
    byte[] buffer = new byte[1024];
    int len = 0;
    while((len=inputStream.read(buffer))!=-1){
        fileOutputStream.write(buffer,0,len);
    }
    //关闭输出流
        fileOutputStream.flush();
            inputStream.close();
            Log.d("MainActivity","文件下载成功！");
            }
        });
        }
    }).start();
    
    }





}