是这样的,我在Iohandler中的messageReceived中监听请求,收到了请求按分页去查询,我会返回一百页数据,类似于
messageReceived (IoSession session, Object message) {
for(int i=0;i<100;i++){
p = findbyPage(pageNo,pageSize);
for(Object obj : p.list()){
session.write(obj); ---------------1
}
}
system.out.println("over") ------------------2
}
我发现执行1后对方还没有收到发送的数据,执行到2仍没有,只有当messageReceived方法执行完毕了返回了数据才会发送至另外一方,不是异步IO吗为什么没有即刻刷写出去呢,采用的自定义的编码器,编码器里面调用
void encode(IoSession session, Object message, ProtocolEncoderOutput out) {
......
.....
out.write(buf);
out.flush();
}
这个flush也没法立刻刷写
想问下是哪儿可以配置立刻刷写吗?数据都在内存里面,因为我查询一百页花费的时间会比较长,不能等到messageReceived结束再发送的,求大神帮忙。刚用mina不懂的较多。
mina 编码 写出,延时,flush
- 写回答
- 好问题 0 提建议
- 追加酬金
- 关注问题
- 邀请回答
-
0条回答 默认 最新
悬赏问题
- ¥15 python天天向上类似问题,但没有清零
- ¥30 3天&7天&&15天&销量如何统计同一行
- ¥30 帮我写一段可以读取LD2450数据并计算距离的Arduino代码
- ¥15 C#调用python代码(python带有库)
- ¥15 矩阵加法的规则是两个矩阵中对应位置的数的绝对值进行加和
- ¥15 活动选择题。最多可以参加几个项目?
- ¥15 飞机曲面部件如机翼,壁板等具体的孔位模型
- ¥15 vs2019中数据导出问题
- ¥20 云服务Linux系统TCP-MSS值修改?
- ¥20 关于#单片机#的问题:项目:使用模拟iic与ov2640通讯环境:F407问题:读取的ID号总是0xff,自己调了调发现在读从机数据时,SDA线上并未有信号变化(语言-c语言)