Skip to content

Instantly share code, notes, and snippets.

@IPRIT

IPRIT/Example

Last active August 29, 2015 14:17
Show Gist options
  • Save IPRIT/83ec41c3215c5b752ba8 to your computer and use it in GitHub Desktop.
Save IPRIT/83ec41c3215c5b752ba8 to your computer and use it in GitHub Desktop.
Download ZIP
using AsyncTask and Uri.Builder
Raw
Example
import android.net.Uri;
import android.os.AsyncTask;
import android.util.Log;
import org.json.JSONException;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.net.MalformedURLException;
import java.net.URL;
import java.util.HashMap;
import java.util.Map;
import ru.twosphere.android.misisbooks.Edition;
import ru.twosphere.android.misisbooks.MisisBooksDataParser;
/**
* Created by Александр on 25.03.2015.
* Java examples (using AsyncTask and Uri.Builder)
*/
public class TestApiClass {
public void MainTestCase() {
HashMap<String, String> params = new HashMap<>();
params.put("q", "степанова");
params.put("access_token", "ACCESS_TOKEN");
HttpRequestBuilder builder = new HttpRequestBuilder();
builder.setParams(params);
builder.setUri("http://twosphere.ru/api/materials.search");
TestAsyncTask testTask = new TestAsyncTask();
testTask.setRequestMethod(TestAsyncTask.GET_REQUEST_NAME);
testTask.execute(builder.build().getUrl());
}
public class HttpRequestBuilder {
private final String LOG_TAG = HttpRequestBuilder.class.getSimpleName();
private String mReadyUrl;
private String mUri;
private HashMap<String, String> mRequestParams;
public HttpRequestBuilder() {}
public HttpRequestBuilder(HashMap<String, String> params) {
mRequestParams = params;
}
public void setParams(HashMap<String, String> params) {
mRequestParams = params;
}
public void setUri(String uri) {
mUri = uri;
}
public String generateStringUrl() {
try {
Uri.Builder builtUri = Uri.parse(mUri).buildUpon();
for (Map.Entry entry : mRequestParams.entrySet()) {
builtUri = builtUri.appendQueryParameter(entry.getKey().toString(),
entry.getValue().toString());
}
return builtUri.build().toString();
} catch (Exception err) {
Log.e(LOG_TAG, "Error occurred: " + err.getMessage());
return mUri != null ? mUri : "";
}
}
public HttpRequestBuilder build() {
mReadyUrl = generateStringUrl();
return HttpRequestBuilder.this;
}
public URL getUrl() {
try {
return new URL(mReadyUrl);
} catch (MalformedURLException err) {
Log.e(LOG_TAG, "Error occurred: " + err.getMessage());
return null;
}
}
}
public class TestAsyncTask extends AsyncTask<URL, Integer, Edition[]> {
/**
* <String, Void, Edition[]> — URL::String, Progress Report::Integer, Result::Edition[]
*/
private final String LOG_TAG = TestAsyncTask.class.getSimpleName();
public static final String POST_REQUEST_NAME = "POST";
public static final String GET_REQUEST_NAME = "GET";
public static final String HEAD_REQUEST_NAME = "HEAD";
private String mSelectedMethod = POST_REQUEST_NAME;
public void setRequestMethod(String selected) {
if (!selected.equals(POST_REQUEST_NAME) && !selected.equals(GET_REQUEST_NAME) &&
!selected.equals(HEAD_REQUEST_NAME)) {
return;
}
mSelectedMethod = selected;
}
@Override
protected void onPreExecute() {
// выполнение кода в UI потоке до запуска HTTP запроса
}
@Override
protected void onProgressUpdate(Integer... values) {
// Обновите индикатор хода выполнения, уведомления или другой
// элемент пользовательского интерфейса.
// Выполняется в UI потоке после каждого изменения
}
protected Edition[] doInBackground(URL... urls) {
// Выполняется не в UI потоке. Создается отдельный поток с помощью менеджера.
HttpURLConnection urlConnection = null;
BufferedReader reader = null;
String responseJsonStr = null;
try {
URL url = urls[0];
// Create the request to MISIS Books, and open the connection
urlConnection = (HttpURLConnection) url.openConnection();
urlConnection.setRequestMethod(mSelectedMethod);
urlConnection.connect();
// Read the input stream into a String
InputStream inputStream = urlConnection.getInputStream();
StringBuffer buffer = new StringBuffer();
if (inputStream == null) {
// Nothing to do.
return null;
}
reader = new BufferedReader(new InputStreamReader(inputStream));
String line;
while ((line = reader.readLine()) != null) {
buffer.append(line + "\n");
}
if (buffer.length() == 0) {
// Stream was empty. No point in parsing.
return null;
}
responseJsonStr = buffer.toString();
MisisBooksDataParser misisBooksDataParser = new MisisBooksDataParser();
return misisBooksDataParser.getEditionsFromResponse(responseJsonStr);
} catch (IOException e) {
Log.e(LOG_TAG, "Error ", e);
// If the code didn't successfully get the misis books data, there's no point in attempting
// to parse it.
return null;
} catch (final JSONException e) {
Log.e(LOG_TAG, "Error ", e);
// If the code didn't successfully get the misis books data, there's no point in attempting
// to parse it.
return null;
} finally {
if (urlConnection != null) {
urlConnection.disconnect();
}
if (reader != null) {
try {
reader.close();
} catch (final IOException e) {
Log.e(LOG_TAG, "Error closing stream", e);
}
}
}
}
@Override
protected void onPostExecute(Edition[] editions) {
Log.d(LOG_TAG, "[onPostExecute] Response has been received");
// Сюда приходит ответ после завершения HTTP запроса
// Выполняется в UI потоке
}
}
}
@IPRIT
Copy link
Author

IPRIT commented Mar 25, 2015 

import android.net.Uri;
import android.os.AsyncTask;
import android.util.Log;

import org.json.JSONException;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.net.MalformedURLException;
import java.net.URL;
import java.util.HashMap;
import java.util.Map;

import ru.twosphere.android.misisbooks.Edition;
import ru.twosphere.android.misisbooks.MisisBooksDataParser;

/**
 * Created by Александр on 25.03.2015.
 * Java examples (using AsyncTask and Uri.Builder)
 */
public class TestApiClass {

    public void MainTestCase() {
        HashMap<String, String> params = new HashMap<>();
        params.put("q", "степанова");
        params.put("access_token", "ACCESS_TOKEN");

        HttpRequestBuilder builder = new HttpRequestBuilder();
        builder.setParams(params);
        builder.setUri("http://twosphere.ru/api/materials.search");

        TestAsyncTask testTask = new TestAsyncTask();
        testTask.setRequestMethod(TestAsyncTask.GET_REQUEST_NAME);
        testTask.execute(builder.build().getUrl());
    }

    public class HttpRequestBuilder {
        private final String LOG_TAG = HttpRequestBuilder.class.getSimpleName();

        private String mReadyUrl;
        private String mUri;
        private HashMap<String, String> mRequestParams;

        public HttpRequestBuilder() {}

        public HttpRequestBuilder(HashMap<String, String> params) {
            mRequestParams = params;
        }

        public void setParams(HashMap<String, String> params) {
            mRequestParams = params;
        }

        public void setUri(String uri) {
            mUri = uri;
        }

        public String generateStringUrl() {
            try {
                Uri.Builder builtUri = Uri.parse(mUri).buildUpon();
                for (Map.Entry entry : mRequestParams.entrySet()) {
                    builtUri = builtUri.appendQueryParameter(entry.getKey().toString(),
                            entry.getValue().toString());
                }
                return builtUri.build().toString();

            } catch (Exception err) {
                Log.e(LOG_TAG, "Error occurred: " + err.getMessage());
                return mUri != null ? mUri : "";
            }
        }

        public HttpRequestBuilder build() {
            mReadyUrl = generateStringUrl();
            return HttpRequestBuilder.this;
        }

        public URL getUrl() {
            try {
                return new URL(mReadyUrl);
            } catch (MalformedURLException err) {
                Log.e(LOG_TAG, "Error occurred: " + err.getMessage());
                return null;
            }
        }
    }

    public class TestAsyncTask extends AsyncTask<URL, Integer, Edition[]> {

        /**
         * <String, Void, Edition[]> — URL::String, Progress Report::Integer, Result::Edition[]
         */

        private final String LOG_TAG = TestAsyncTask.class.getSimpleName();

        public static final String POST_REQUEST_NAME = "POST";
        public static final String GET_REQUEST_NAME = "GET";
        public static final String HEAD_REQUEST_NAME = "HEAD";

        private String mSelectedMethod = POST_REQUEST_NAME;

        public void setRequestMethod(String selected) {
            if (!selected.equals(POST_REQUEST_NAME) && !selected.equals(GET_REQUEST_NAME) &&
                    !selected.equals(HEAD_REQUEST_NAME)) {
                return;
            }
            mSelectedMethod = selected;
        }

        @Override
        protected void onPreExecute() {
            // выполнение кода в UI потоке до запуска HTTP запроса
        }

        @Override
        protected void onProgressUpdate(Integer... values) {
            // Обновите индикатор хода выполнения, уведомления или другой
            // элемент пользовательского интерфейса.

            // Выполняется в UI потоке после каждого изменения
        }

        protected Edition[] doInBackground(URL... urls) {
            // Выполняется не в UI потоке. Создается отдельный поток с помощью менеджера.

            HttpURLConnection urlConnection = null;
            BufferedReader reader = null;
            String responseJsonStr = null;

            try {
                URL url = urls[0];

                // Create the request to MISIS Books, and open the connection
                urlConnection = (HttpURLConnection) url.openConnection();
                urlConnection.setRequestMethod(mSelectedMethod);
                urlConnection.connect();

                // Read the input stream into a String
                InputStream inputStream = urlConnection.getInputStream();
                StringBuffer buffer = new StringBuffer();
                if (inputStream == null) {
                    // Nothing to do.
                    return null;
                }
                reader = new BufferedReader(new InputStreamReader(inputStream));

                String line;
                while ((line = reader.readLine()) != null) {
                    buffer.append(line + "\n");
                }

                if (buffer.length() == 0) {
                    // Stream was empty. No point in parsing.
                    return null;
                }

                responseJsonStr = buffer.toString();
                MisisBooksDataParser misisBooksDataParser = new MisisBooksDataParser();
                return misisBooksDataParser.getEditionsFromResponse(responseJsonStr);

            } catch (IOException e) {
                Log.e(LOG_TAG, "Error ", e);
                // If the code didn't successfully get the misis books data, there's no point in attempting
                // to parse it.
                return null;
            } catch (final JSONException e) {
                Log.e(LOG_TAG, "Error ", e);
                // If the code didn't successfully get the misis books data, there's no point in attempting
                // to parse it.
                return null;
            } finally {
                if (urlConnection != null) {
                    urlConnection.disconnect();
                }
                if (reader != null) {
                    try {
                        reader.close();
                    } catch (final IOException e) {
                        Log.e(LOG_TAG, "Error closing stream", e);
                    }
                }
            }
        }

        @Override
        protected void onPostExecute(Edition[] editions) {
            Log.d(LOG_TAG, "[onPostExecute] Response has been received");
            // Сюда приходит ответ после завершения HTTP запроса
            // Выполняется в UI потоке
        }
    }
}

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment