"
public void run() {
try { final ObjectInputStream ois = new ObjectInputStream(mClient.getInputStream()); while (true) { final LoggingEvent event = (LoggingEvent) ois.readObject(); mModel.addEvent(new EventDetails(event)); } // 这里为什么对输入流 循环读取object,mClient是Scoket } catch (EOFException e) { LOG.info("Reached EOF, closing connection"); }
try {
mClient.close();
} catch (IOException e) {
LOG.warn("Error closing connection", e);
}
}
"
这不是很正常么. 一个(或者N个)线程网络线程获取到对象, push到消息队列里面去, 让主循环去消费处理.
![image.png](https://ucc.alicdn.com/pic/developer-ecology/d85b5865fe3f4305a164e00af2e78f1d.png)版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。