使用单个 AsyncTask 发送和接收数据 to/from Python 服务器
Using single AsyncTask to both send and then receive data to/from Python server
我想发送 40x40px 的 blob 到我的 Python 服务器,然后在那里处理它并发回一个带有代表图像 class 的 id 的回复(它是一个图像 classification 任务).我使用 AsyncTask,但出现了问题 - blob 已发送到服务器,但在我的 Android 代码中未到达负责接收回复的部分。
我想知道在一个AsyncTask中同时发送和接收数据是否正确。我已经读过,对于这个解决方案来说,大约需要 <10 秒的任务就可以了,所以理论上我的情况应该没有问题。
这里附上我的代码,给客户:
public class ServerConnectAsyncTask extends AsyncTask<Void, Void, Integer> {
private AsyncTaskResultListener asyncTaskResultListener;
private Socket socket;
private Mat img;
ServerConnectAsyncTask(Mat blob, Context c) throws IOException {
img = blob;
asyncTaskResultListener = (AsyncTaskResultListener) c;
}
@Override
protected Integer doInBackground(Void... voids) {
MatOfByte buf = new MatOfByte();
Imgcodecs.imencode(".jpg", img, buf);
byte[] imgBytes = buf.toArray();
try {
socket = new Socket("192.168.0.109",8888);
DataOutputStream dout = new DataOutputStream(socket.getOutputStream());
DataInputStream din = new DataInputStream(socket.getInputStream());
dout.write(imgBytes);
dout.flush();
String str = din.readUTF(); // it seems that it doesn't reach this line
dout.close();
din.close();
socket.close();
return Integer.valueOf(str);
} catch (IOException e) {
e.printStackTrace();
return 99;
}
}
@Override
protected void onPostExecute(Integer imgClass) {
asyncTaskResultListener.giveImgClass(imgClass);
}
}
对于 python 服务器:
HOST = "192.168.0.109"
PORT = 8888
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.bind((HOST, PORT))
s.listen(10)
while True:
conn, addr = s.accept()
print("Got connection from", addr)
msg = conn.recv(4096)
buf = np.frombuffer(msg, dtype=np.uint8).reshape(-1, 1)
img = cv2.imdecode(buf, 0)
cv2.imwrite("output.jpg", img) # here I save my blob correctly
if msg:
message_to_send = "0".encode("UTF-8") # then I send my "predicted" image class
conn.send(message_to_send)
else:
print("no message")
同样重要的是,我在我的 onCameraFrame()
方法中调用了 AsyncTask.execute()
- 偶尔一次(不是在每一帧中,只有当我的 blob 足够 "stable" 时,这很少发生)。
显然它卡在了 readUTF()
部分。现在有效了:
DataInputStream din = new DataInputStream(socket.getInputStream());
int str = din.read();
char sign = (char) str;
dout.close();
din.close();
socket.close();
return Character.getNumericValue(sign);
现在当我从 python 服务器发送“0”时它是 returns 0,所以它对我来说工作正常。
我想发送 40x40px 的 blob 到我的 Python 服务器,然后在那里处理它并发回一个带有代表图像 class 的 id 的回复(它是一个图像 classification 任务).我使用 AsyncTask,但出现了问题 - blob 已发送到服务器,但在我的 Android 代码中未到达负责接收回复的部分。
我想知道在一个AsyncTask中同时发送和接收数据是否正确。我已经读过,对于这个解决方案来说,大约需要 <10 秒的任务就可以了,所以理论上我的情况应该没有问题。
这里附上我的代码,给客户:
public class ServerConnectAsyncTask extends AsyncTask<Void, Void, Integer> {
private AsyncTaskResultListener asyncTaskResultListener;
private Socket socket;
private Mat img;
ServerConnectAsyncTask(Mat blob, Context c) throws IOException {
img = blob;
asyncTaskResultListener = (AsyncTaskResultListener) c;
}
@Override
protected Integer doInBackground(Void... voids) {
MatOfByte buf = new MatOfByte();
Imgcodecs.imencode(".jpg", img, buf);
byte[] imgBytes = buf.toArray();
try {
socket = new Socket("192.168.0.109",8888);
DataOutputStream dout = new DataOutputStream(socket.getOutputStream());
DataInputStream din = new DataInputStream(socket.getInputStream());
dout.write(imgBytes);
dout.flush();
String str = din.readUTF(); // it seems that it doesn't reach this line
dout.close();
din.close();
socket.close();
return Integer.valueOf(str);
} catch (IOException e) {
e.printStackTrace();
return 99;
}
}
@Override
protected void onPostExecute(Integer imgClass) {
asyncTaskResultListener.giveImgClass(imgClass);
}
}
对于 python 服务器:
HOST = "192.168.0.109"
PORT = 8888
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.bind((HOST, PORT))
s.listen(10)
while True:
conn, addr = s.accept()
print("Got connection from", addr)
msg = conn.recv(4096)
buf = np.frombuffer(msg, dtype=np.uint8).reshape(-1, 1)
img = cv2.imdecode(buf, 0)
cv2.imwrite("output.jpg", img) # here I save my blob correctly
if msg:
message_to_send = "0".encode("UTF-8") # then I send my "predicted" image class
conn.send(message_to_send)
else:
print("no message")
同样重要的是,我在我的 onCameraFrame()
方法中调用了 AsyncTask.execute()
- 偶尔一次(不是在每一帧中,只有当我的 blob 足够 "stable" 时,这很少发生)。
显然它卡在了 readUTF()
部分。现在有效了:
DataInputStream din = new DataInputStream(socket.getInputStream());
int str = din.read();
char sign = (char) str;
dout.close();
din.close();
socket.close();
return Character.getNumericValue(sign);
现在当我从 python 服务器发送“0”时它是 returns 0,所以它对我来说工作正常。