我的希望是客户端发送信息后,再读取从服务器返回的信息。
但是有时会出错,发现Object o = readFuture.getMessage();这个object的类型与我预想的不一致,我怀疑是几个线程一起在发送信息时,读取的信息顺序有问题。例有3个发送线程,如AReq,BReq,CReq。正常的话AReq发送信息后,应该得到AResp,但现在读取的却是CResp。请问这样的情况该怎么处理。
public AbstractResponse send(AbstractRequest request) {
if (session != null) {
session.write(request);
AbstractResponse resp = null;
// 接收
ReadFuture readFuture = session.read();
if (readFuture.awaitUninterruptibly(30000, TimeUnit.SECONDS)) {
Object o = readFuture.getMessage();
ResponseObject respObj = (ResponseObject) o;
AbstractResponse resp = decoder(respObj);
return resp;
}
}
return null;
}