3

我正在编写一个 android 应用程序，它将图像发送到运行 java 应用程序的服务器，它以一种非常奇怪的方式工作！

这是我所做的

  1. 在桌面上编译并运行 Java 应用程序，接收部分充当服务器
  2. 编译、部署并运行必须将图像发送到服务器的 android 部分。android 应用程序完成执行，但 java 应用程序没有
  3. 运行具有再次发送图像的代码的 android 应用程序活动，这一次，android 应用程序进度对话框卡住了，但是，java 应用程序完成执行并且图像被成功传输...

以下是 Java 应用程序的 RECEIVE 部分的代码：

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");

            //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");    
        }
        catch(Exception e)
        {
            System.out.println(e);
            e.printStackTrace();
        }

    }
}

以下是 Android 应用上 SEND 部分的代码：

package com.site.custom;
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
        try
        {
            cliSock=new Socket(serverIP,8070);
            in=new BufferedReader(new InputStreamReader(cliSock.getInputStream()));

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

        //Send file
        ProgressDialog pd=ProgressDialog.show(this, "Sending image", "Image chosen:"+path.substring(path.lastIndexOf("//")+1),false,true);

        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();
            System.out.println("Completed");

            pd.dismiss();
            System.out.println("Done");
        }
        catch(Exception e)
        {
            Log.v("MERA MSG",e.toString());
        }

    }
}
4

1 回答 1

1

您没有关闭任何连接。您的服务器可能正在等待连接关闭，然后才知道数据已完成发送。当您的客户端第二次运行时，第一个连接可能会被 Android 自动关闭，这允许您的服务器处理图像。但是，如果您的服务器处理图像的速度不够快，则您的客户端可能会在第二次运行时“卡住”，因为它正在等待与服务器的成功端口连接但服务器正忙。

长话短说，close()完成后尝试连接客户端怎么样。调用flush()并没有真正告诉服务器数据已经发送完毕。

如果您希望套接字在关闭时仍保持打开状态OutputStream，则可以编写一个Socket仅覆盖该close()方法的自定义，如下所示...

public class MySocket extends Socket {

    public MySocket(String ipAddress, int port){
        super(ipAddress,port);
    }

    public void close(){
        // do nothing
    }

    public void reallyClose(){
        super.close();
    }
}

在您的代码中，更改cliSock=new Socket(serverIP,8070);为cliSock=new MySocket(serverIP,8070);

当您调用 时OutputStream.close()，它会调用close()，MySocket但正如您所见，它实际上并没有做任何事情。完成后Socket，您可以调用MySocket.reallyClose();它，它会正确关闭它。

于 2012-04-15T11:01:46.603 回答