0

Androidソケットについて質問したいです。wifly モジュールにデータを送信するサンプルアプリを作成します。しかし、モジュールからデータを受信すると、ソケットタイムアウト例外が発生します。setSoTimeoutアプリフリーズなしでinputStream.read。これが私のコードです：

    package com.socket.wiflysocket;

import android.net.ConnectivityManager;
import android.net.NetworkInfo;
import android.os.Bundle;
import android.app.Activity;
import android.content.Context;
import android.view.Menu;
import android.view.View;
import android.widget.Button;
import android.widget.EditText;
import android.widget.TextView;

public class MainActivity extends Activity {

    protected static final String TAG = "WIflySocket";

    EditText textOut;
    TextView textIn;

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

         textOut = (EditText)findViewById(R.id.textout);
         Button buttonSend = (Button)findViewById(R.id.send);
         textIn = (TextView)findViewById(R.id.textin);
         buttonSend.setOnClickListener(buttonSendOnClickListener);
    }

    @Override
    public boolean onCreateOptionsMenu(Menu menu) {
        // Inflate the menu; this adds items to the action bar if it is present.
        getMenuInflater().inflate(R.menu.main, menu);
        return true;
    }

    Button.OnClickListener buttonSendOnClickListener
        = new Button.OnClickListener(){

            @Override
            public void onClick(View arg0) {

                ConnectivityManager connMgr = (ConnectivityManager) 
                    getSystemService(Context.CONNECTIVITY_SERVICE);
                NetworkInfo networkInfo = connMgr.getActiveNetworkInfo();
                if (networkInfo == null || networkInfo.isConnected() == false) {
                   try {
                       throw new Exception("Network is not connected");
                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                }
                else {
                    new SocketThread(textOut.getText().toString()).execute();

                    textOut.setText("");
                }
            }};
}

および asyncTask:

package com.socket.wiflysocket;


import java.io.BufferedReader;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;

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

public class SocketThread extends AsyncTask<String, Void, String>{

    private static final String TAG = "SocketAsyncTask";

    private static final int BUFFER_SIZE = 8;

    private String textViewIn;

    private String output;

    private Socket socket = null;

    private PrintWriter outputStream;

    private InputStreamReader inputStream;

    public SocketThread(String paramTextViewIn)
    {
        this.textViewIn = paramTextViewIn;
    }

    @Override
    protected String doInBackground(String ...views) {
        Log.d(TAG, "Execute");

        DataOutputStream dataOutputStream = null;
        DataInputStream dataInputStream = null;

         try {
            socket = new Socket("1.2.3.4", 2000);
            socket.setSoTimeout(2000);

            outputStream = new PrintWriter(new OutputStreamWriter(socket.getOutputStream()));
            inputStream = new InputStreamReader(socket.getInputStream());

            if(socket.isConnected()) {

                this.sendDataWithString(textViewIn);

                output = this.receiveDataFromServer();
            }

            this.closeSocket();

         } catch (UnknownHostException e) {
             e.printStackTrace();
         } catch (IOException e) {
             e.printStackTrace();
         }
         finally{
            if (socket != null){
                try {
                    socket.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }

            if (dataOutputStream != null){
                try {
                    dataOutputStream.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }

            if (dataInputStream != null){
                try {
                    dataInputStream.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
         }

         return output;
    }
    /*
    // onPostExecute displays the results of the AsyncTask.
    @Override
    protected void onPostExecute(String result) {
        return textViewOut;
   }
    */

    private void closeSocket() {
        if (socket != null) {
            if (socket.isConnected()) {
                try {
                    inputStream.close();
                    outputStream.close();
                    socket.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }

    private void sendDataWithString(String message) {
        if (message != null) {
            outputStream.write(message);
            outputStream.flush();
        }
    }

    private String receiveDataFromServer() {
        String message = "";
        try {
            int charsRead = 0;
            char[] buffer = new char[BUFFER_SIZE];

            while ((charsRead = inputStream.read(buffer)) != -1) {
                message += new String(buffer).substring(0, charsRead);
            }

            closeSocket();
            return message;
        } catch (IOException e) {

            //TODO work around
            return message;
            //return "Error receiving response:  " + e.getMessage();
        }
    }

}

私が追加する権限は次のとおりです。

android.permission.INTERNET; android.permission.ACCESS_NETWORK_STATE

何が間違っているのか、この問題を解決する方法を教えてください。ありがとう

4

2 に答える 2

0

SocketFactory はソケットを作成します

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;

import javax.net.SocketFactory;

...

private Socket socket = null;
public Reader reader = null;
public Writer writer = null;

protected void init(String host, int port) throws ClientException {
    try {
        socket = SocketFactory.getDefault().createSocket(host, port);
    } catch (UnknownHostException e) {
            throw new ClientException(e);
    } catch (IOException e) {
        throw new ClientException(e);
    }
    initDataManagers();
}
protected void initDataManagers() throws ClientException {
        try {
            reader = new BufferedReader(new InputStreamReader(socket.getInputStream(), "UTF-8"));
            writer = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream(), "UTF-8"));
        } catch (UnsupportedEncodingException e) {
            throw new ClientException(e);
        } catch (IOException e) {
            throw new ClientException(e);
        }   
}
于 2013-05-28T06:46:59.900 に答える