Android - 客户端在接收回字符串之前关闭发送图像的连接

Question

我有一个Android应用程序，可以打开与服务器的套接字连接并将图像发送到 python 服务器。服务器接收该图像，并应发送回一个字符串以确认已收到图像。但是，在我结束输出流后套接字关闭，因此服务器接收图像，但客户端无法从服务器接收字符串，因为客户端关闭了连接。因此，我想做的是在套接字关闭之前返回一个字符串/文本，确认图像已到达用户客户端。

这是我的Python服务器，它在字节解码时接收图像并将其保存到一个目录，然后返回一条消息：

from socket import *
import datetime
import cv2
import PIL.Image as Image
from PIL import ImageFile, Image
import io
import base64
import numpy as np
import pickle
import uuid


date_string = datetime.datetime.now().strftime("%Y-%m-%d-%H:%M")

port = 9999
s = socket(AF_INET, SOCK_STREAM)
s.bind(('', port))
s.listen(1)

while True:
    conn, addr = s.accept()
    img_dir = '/home/Desktop/frames_saved/'
    img_format = '.png'
    try:
        print("Connected by the ",addr)
        #date_string = datetime.datetime.now().strftime("%Y-%m-%d-%H:%M")
        filename = str(uuid.uuid4())
        with open(img_dir+filename+img_format, 'wb') as file:
            while True:
                data = conn.recv(1024*8)
                if data:
                    print(data)
                    try:
                        file.write(data)
                    except:
                        s = socket(AF_INET, SOCK_STREAM)
                        s.bind(('', port))
                        s.listen(1)
                        conn.sendall(("Hello World"))
                        

                    
                else:
                    print("no data")
    
                    break
    finally:
        conn.close() 

我正在尝试做的是在我的 android 客户端中接收编码字符串并打印/显示吐司。

Android客户端代码：

 public class SendImageClient extends AsyncTask<byte[], Void, Void> {


        @Override
        protected Void doInBackground(byte[]... voids) {
            isSocketOpen = true;
            try {
                Socket socket = new Socket("192.168.0.14",9999);
                OutputStream out=socket.getOutputStream();
                DataOutputStream dataOutputStream = new DataOutputStream(out);
                BufferedReader input = new BufferedReader(new InputStreamReader(socket.getInputStream()));
                StringBuilder response = new StringBuilder();
                String line;

                while (isSocketOpen){
                    Log.d("IMAGETRACK", "Wrote to the socket[1]");
                    dataOutputStream.write(voids[0],0,voids[0].length);
                    while ((line = input.readLine()) != null)
                        Log.d("IMAGETRACK3", "Wrote to the socket[3]");
                    response.append(line);
                    Message clientmessage = Message.obtain();
                    clientmessage.obj = response.toString();
                    Log.d("[MESSAGE]", String.valueOf(clientmessage));
                    // Tries to receive a message from the server
                    out.close();
                    input.close();
                    if(isSocketOpen == false){
                        Log.d("CLOSED", "CLOSED CONNECTION");
                        socket.close();

                        break;
                    }
                }
                socket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }


            return null;
        }
    }

此外，我注意到执行out.close（;也会关闭流套接字。以下是服务器发送和接收映像后的日志：

D/IMAGETRACK: Wrote to the socket[1]
D/IMAGETRACK: Wrote to the socket[1]
W/System.err: java.net.SocketException: Socket closed
W/System.err:     at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:124)
        at java.net.SocketOutputStream.write(SocketOutputStream.java:161)
        at java.io.DataOutputStream.write(DataOutputStream.java:107)
        at MyApp.MainActivity$SendImageClient.doInBackground(MainActivity.java:2792)
        at MyApp.MainActivity$SendImageClient.doInBackground(MainActivity.java:2780)
        at android.os.AsyncTask$3.call(AsyncTask.java:394)
W/System.err:     at java.util.concurrent.FutureTask.run(FutureTask.java:266)
        at android.os.AsyncTask$SerialExecutor$1.run(AsyncTask.java:305)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1167)
W/System.err:     at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:641)
        at java.lang.Thread.run(Thread.java:923)

如果我尝试移动out.close（）；在同时循环之后，客户端将向服务器发送无限量的数据，当我关闭服务器以结束接收的无限数据时，我将有一个10MB或更多的图像，而不是70Kb的图像，这取决于我接收字节的日志方式。

从表面上看，我认为我需要以某种方式停止发送图像，而不关闭服务器来监听发送回来的图像。我怎样才能在不关闭套接字的情况下做到这一点？

Answer 1

套接字关闭的原因很简单。我以前有这样的示例程序。你有两种选择。您用于发送和接收文件的体系结构不完整且不正确。

一种选择是，您可以自己定义一个发送和接收的协议，这不是标准的。例如，您可以定义特殊字符，如##内飞##，并在您的图像之后发送，然后不要关闭套接字。服务器理解图像被接收，仅此而已。然后在客户端调用接收方法直到套接字结束，但之前，您必须发送数据字符串返回以确认图像已收到，客户端在收到此字符串时关闭套接字。记住明智地添加套接字超时，以防止无限套接字等待。

第二种解决方案是，您可以使用标准协议，如< code>HTTP或< code>FTP，但必须读取这些协议的标准，如标头和正文值，并且还必须以< code>multipart的形式发送和接收文件。