안드로이드에서 구글앱엔진에 데이터 보내고 받기

안드로이드쪽 소스

RestClient.java

package com.newkie;

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStream;

import java.io.InputStreamReader;

import java.net.URLEncoder;

import java.util.ArrayList;

 

import org.apache.http.HttpEntity;

import org.apache.http.HttpResponse;

import org.apache.http.NameValuePair;

import org.apache.http.client.ClientProtocolException;

import org.apache.http.client.HttpClient;

import org.apache.http.client.entity.UrlEncodedFormEntity;

import org.apache.http.client.methods.HttpGet;

import org.apache.http.client.methods.HttpPost;

import org.apache.http.client.methods.HttpUriRequest;

import org.apache.http.impl.client.DefaultHttpClient;

import org.apache.http.message.BasicNameValuePair;

import org.apache.http.protocol.HTTP;

 

public class RestClient

{

    private ArrayList<NameValuePair> params;

    private ArrayList<NameValuePair> headers;

 

    private String url;

 

    private int responseCode;

    private String message;

 

    private String response;

 

    public String getResponse()

    {

        return response;

    }

 

    public String getErrorMessage()

    {

        return message;

    }

 

    public int getResponseCode()

    {

        return responseCode;

    }

 

    public RestClient(String url) {

        this.url = url;

        params = new ArrayList<NameValuePair>();

        headers = new ArrayList<NameValuePair>();

    }

 

    public void AddParam(String name, String value)

    {

        params.add(new BasicNameValuePair(name, value));

    }

 

    public void AddHeader(String name, String value)

    {

        headers.add(new BasicNameValuePair(name, value));

    }

 

    public void Execute(RequestMethod method) throws Exception

    {

        switch (method)

        {

        case GET:

        {

            // add parameters

            String combinedParams = "";

            if (!params.isEmpty())

            {

                combinedParams += "?";

                for (NameValuePair p : params)

                {

                    String paramString = p.getName() + "=" + URLEncoder.encode(p.getValue(),"UTF-8");

                    if (combinedParams.length() > 1)

                    {

                        combinedParams += "&" + paramString;

                    }

                    else

                    {

                        combinedParams += paramString;

                    }

                }

            }

 

            HttpGet request = new HttpGet(url + combinedParams);

 

            // add headers

            for (NameValuePair h : headers)

            {

                request.addHeader(h.getName(), h.getValue());

            }

 

            executeRequest(request, url);

            break;

        }

        case POST:

        {

            HttpPost request = new HttpPost(url);

 

            // add headers

            for (NameValuePair h : headers)

            {

                request.addHeader(h.getName(), h.getValue());

            }

 

            if (!params.isEmpty())

            {

                request.setEntity(new UrlEncodedFormEntity(params, HTTP.UTF_8));

            }

 

            executeRequest(request, url);

            break;

        }

        }

    }

 

    private void executeRequest(HttpUriRequest request, String url)

    {

        HttpClient client = new DefaultHttpClient();

 

        HttpResponse httpResponse;

 

        try

        {

            httpResponse = client.execute(request);

            responseCode = httpResponse.getStatusLine().getStatusCode();

            message = httpResponse.getStatusLine().getReasonPhrase();

 

            HttpEntity entity = httpResponse.getEntity();

 

            if (entity != null)

            {

 

                InputStream instream = entity.getContent();

                response = convertStreamToString(instream);

 

                // Closing the input stream will trigger connection release

                instream.close();

            }

 

        }

        catch (ClientProtocolException e)

        {

            client.getConnectionManager().shutdown();

            e.printStackTrace();

        }

        catch (IOException e)

        {

            client.getConnectionManager().shutdown();

            e.printStackTrace();

        }

    }

 

    private static String convertStreamToString(InputStream is)

    {

 

        BufferedReader reader = new BufferedReader(new InputStreamReader(is));

        StringBuilder sb = new StringBuilder();

 

        String line = null;

        try

        {

            while ((line = reader.readLine()) != null)

            {

                sb.append(line + "\n");

            }

        }

        catch (IOException e)

        {

            e.printStackTrace();

        }

        finally

        {

            try

            {

                is.close();

            }

            catch (IOException e)

            {

                e.printStackTrace();

            }

        }

        return sb.toString();

    }

}

RequestMethod.java

package com.newkie;

public enum RequestMethod

{

    GET,

    POST

}

위 두개를 써서 직접 통신하는 파일

AndroidHTTPClient.java

package com.newkie;

 

import android.accounts.Account;

import android.accounts.AccountManager;

import android.app.Activity;

import android.content.Context;

import android.os.Bundle;

import android.view.View;

import android.widget.Button;

import android.widget.TextView;

 

public class AndroidHTTPClient extends Activity

{

private Context mContext;

@Override

    public void onCreate(Bundle savedInstanceState)

    {

        super.onCreate(savedInstanceState);

        setContentView(R.layout.androidhttpclient);

        

        TextView textView = (TextView)findViewById(R.id.outputTextView);

        

        RestClient client = new RestClient("http://어플리케이션.appspot.com/지정한주소");

        client.AddParam("파라미터", "1");

//추가가능

 

        try

        {

            client.Execute(RequestMethod.GET);

        }

        catch (Exception e)

        {

            textView.setText(e.getMessage());

        }

 

        String response = client.getResponse();

        textView.setText(response);

        

     Button button1 = (Button)findViewById(R.id.cancel);

        button1.setOnClickListener(new View.OnClickListener() {

            public void onClick(View v) {

             finish();

            }

        });

        

    }

}

앱엔진쪽 소스

DataStore.java

package com.newkie;

import com.google.appengine.api.datastore.Key;

//import com.google.appengine.api.ids.String;

import javax.jdo.annotations.IdGeneratorStrategy;

import javax.jdo.annotations.PersistenceCapable;

import javax.jdo.annotations.Persistent;

import javax.jdo.annotations.PrimaryKey;

@PersistenceCapable

public class DataStore {

    @PrimaryKey

    @Persistent(valueStrategy = IdGeneratorStrategy.IDENTITY)

    private Key key;

    @Persistent

    private String id;

    @Persistent

    private String content;

//임의로 계속 추가가능

    public DataStore(String id, String content) {

        this.id = id;

        this.content = content;

    }

    public Key getKey() {

        return key;

    }

    public String getId() {

        return id;

    }

    public String getContent() {

        return content;

    }

    public void setId(String id) {

        this.id = id;

    }

    public void setContent(String content) {

        this.content = content;

    }

}

Gae2AndroidServlet.java

package com.newkie;

import java.io.IOException;

import java.util.List;

import javax.jdo.PersistenceManager;

import javax.servlet.http.*;

import com.newkie.DataStore;

import com.newkie.PMF;

 

@SuppressWarnings("serial")

public class Gae2AndroidServlet extends HttpServlet

{

    public void doGet(HttpServletRequest req, HttpServletResponse resp) throws IOException

    {

     String param= null;

     Boolean update = false;

        resp.setContentType("text/html; charset=UTF-8");

//각종 처리

//ex)if (req.getParameterMap().containsKey("파라미터"))

//         param = req.getParameter("파라미터");

//resp.getWriter().println(param + "데이터받음");

    }

}