0

パソコンで動くJavaアプリにソケット通信を使って画像を送るアンドロイドアプリを作っています。

何が起こっているか: デスクトップはサーバーの Java アプリケーションを実行しており、クライアントの Android アプリケーションはデバイスで実行されており、イメージをサーバーに転送すると、その部分はうまくいきます。その後、サーバー アプリはコンソールから行を取得し、それを Android アプリに渡します。そのメッセージがAndroidアプリによって受信されるまで、進行状況ダイアログボックスが表示されるはずで、そこで動かなくなります。Android アプリは、readLine() を使用してデスクトップ アプリから渡された文字列を読み取ることになっていますが、Android アプリのソケットを介して入力ストリームを開こうとすると、例外が発生します。

以下は、最初にデスクトップ サーバー用のコード、次に Android クライアント用のコードです。

java.net.ServerSocket をインポートします。java.net.Socket をインポートします。java.io.* をインポートします。

class ProjectServer
{
    ServerSocket serSock;
    Socket  sock;

    BufferedReader in;
    PrintWriter out;
    public static void main(String ar[])
    {
        try
        {
            ProjectServer cs=new ProjectServer();
            cs.startServer();
        }
        catch(Exception e)
        {

        }
    }

    public void startServer()
    {
        try
        {
            serSock=new ServerSocket(8070);
            System.out.println("Waiting for client...");
            sock=serSock.accept();


            System.out.println("Connections done");


            //Accept File
            System.out.println("Connected");
            System.out.println(sock.isConnected()+"1");

            //receive code

            int filesize=450660;
            int bytesRead;
            int current=0;
            // receive file
            byte [] mybytearray  = new byte [filesize];
            InputStream is = sock.getInputStream();
            FileOutputStream fos = new FileOutputStream("C:\\Project Server\\Capture.png");
            BufferedOutputStream bos = new BufferedOutputStream(fos);
            bytesRead = is.read(mybytearray,0,mybytearray.length);
            current = bytesRead;


            do {
               bytesRead =
                  is.read(mybytearray, current, (mybytearray.length-current));
               if(bytesRead >= 0) current += bytesRead;
            } while(bytesRead > -1);

            bos.write(mybytearray, 0 , current);
            bos.flush();
            System.out.println("end-start");
            bos.close();
            //sock.close();
            //receive code ends

            //System.out.println(br.readLine());


            //Matlab computation

            //Send result
            System.out.println(sock.isConnected()+"2");
            PrintWriter pr=new PrintWriter(sock.getOutputStream(),true);

            pr.println((new BufferedReader(new InputStreamReader(System.in))).readLine());
            System.out.println(sock.isConnected()+"3");
            (new BufferedReader(new InputStreamReader(System.in))).readLine();
            System.out.println(sock.isConnected()+"4");
        }
        catch(Exception e)
        {
            System.out.println(e);
            e.printStackTrace();
        }

    }
}

Android クライアント:

package com.site.custom;

import java.io.BufferedInputStream;
import java.io.BufferedReader;
import java.io.File;
import java.io.FileInputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.Socket;

import android.app.Activity;
import android.app.ProgressDialog;
import android.os.Bundle;
import android.util.Log;
import android.widget.TextView;


public class Act2 extends Activity
{
    private ProgressDialog pd;
    private String serverIP="58.146.100.187";
    private BufferedReader in;
    private PrintWriter out;
    private String path;
    private Socket cliSock;

    public void onCreate(Bundle onCreateInstance)
    {
        super.onCreate(onCreateInstance);
        setContentView(R.layout.act2);
        this.setTitle("This has started");
        path=getIntent().getStringExtra("path");

        //Establish Connection
        //pd=ProgressDialog.show(this, "Establishing connection", "Finding server",false,true);

        try
        {
            cliSock=new Socket(serverIP,8070);

            //pd.dismiss();
            //Log.v("MERA MSG","changing text");
            ((TextView)findViewById(R.id.tview)).setText(path);
        }
        catch(Exception e)
        {
            Log.v("MERA MSG",e.toString());
        }

        //Send file
        //Log.v("MERA MSG","changing text1");

        ProgressDialog pd=ProgressDialog.show(this, "Sending image", "Image chosen:"+path.substring(path.lastIndexOf("//")+1),false,true);
        //Log.v("MERA MSG","changing text2");

        try
        {


            File myFile = new File (path);
            System.out.println((int)myFile.length());
            byte[] mybytearray  = new byte[450560];
            FileInputStream fis = new FileInputStream(myFile);
            BufferedInputStream bis = new BufferedInputStream(fis);
            bis.read(mybytearray,0,mybytearray.length);
            OutputStream os = cliSock.getOutputStream();
            System.out.println("Sending...");
            os.write(mybytearray,0,mybytearray.length);
            os.flush();
            os.close();
            bis.close();
            //sock.close();
            //System.out.println("Completed");
            System.out.println(cliSock.isConnected()+"1");
            pd.dismiss();
            //System.out.println("Done");
            System.out.println(cliSock.isConnected()+"2");
            //Show dialog box till computation results arrive
            pd=ProgressDialog.show(this, "Recognizing...", "(waiting for server reply)",false,true);
            System.out.println(cliSock.isConnected()+"3");
            in=new BufferedReader(new InputStreamReader(cliSock.getInputStream()));
            System.out.println(in.readLine());
            pd.dismiss();

        }
        catch(Exception e)
        {
            Log.v("MERA MSG",e.toString());
            e.printStackTrace();
        }



    }
}

ところで、LogCat からのログは次のとおりです。 http://pastebin.com/atHMycTa 350 行目と 349 行目に true が表示されているため、ここでソケットがまだ接続されていることを確認できます。351 行目のエラーを確認してください。

4

1 に答える 1

2

isConnected() は、この Socket を接続したことがあるかどうかのみを通知するため、true を返します。接続状態を示すものではありません。

于 2012-04-15T22:44:58.517 に答える