作者:在路上的老兵 | 来源:互联网 | 2023-09-16 14:38
在TcpTransport中protectedvoiddoRun()throwsIOException{try{ObjectcommandreadCommand();doConsu
protected void doRun() throws IOException {
try {
Object command = readCommand();
doConsume(command);
} catch (SocketTimeoutException e) {
} catch (InterruptedIOException e) {
}
}
等待 message 并消费 message