小白不懂就问, Java InputStream 如何在接收数据时收到事件通知 - V2EX
V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
teliang
V2EX    Java

小白不懂就问, Java InputStream 如何在接收数据时收到事件通知

  •  
  •   teliang 2021 年 8 月 27 日 2208 次点击
    这是一个创建于 1700 天前的主题,其中的信息可能已经有所发展或是发生改变。
    各位大佬,现在有个场景是这样的:
    我本地建立一个 Socket 连接到服务器,OutputStream.write 和 flush 给服务器发送数据,等待服务响应然后读取数据。

    问题:
    我 flush 后直接 InputStream.available()返回 0,需要 sleep 零点几秒才能拿到数据,并发请求的时候都 sleep 感觉不太好

    请问:
    InputStream 有没有事件通知呢,比如服务器返回数据后有个事件通知,我用线程池处理数据

    跪求各位大佬指教
    第 1 条附言    2021 年 8 月 27 日
    5 楼说的对,我直接 read 就行,是我傻了,nio 我还不太会用,等我看看书再试试
    9 条回复    2021-08-28 14:07:36 +08:00
    AoEiuV020
        1
    AoEiuV020  
       2021 年 8 月 27 日
    你需要的可能是 nio,
    Ariver
        2
    Ariver  
       2021 年 8 月 27 日 via iPhone
    2021 年了,用 netty 写吧。
    如果不用的话就是写一个死循环
    AoEiuV020
        3
    AoEiuV020  
       2021 年 8 月 27 日 via Android   1
    不过你都提到线程池了,bio 正常做法就是单独一个线程循环读数据,读到了再处理,没读到就一直等着,这也不需要什么通知,
    teliang
        4
    teliang  
    OP
       2021 年 8 月 27 日
    @AoEiuV020 有道理,我试试 nio
    kaneg
        5
    kaneg  
       2021 年 8 月 27 日 via iPhone   1
    直接调 read ()方法啊,它会自己阻塞直到有数据才返回。
    darkengine
        6
    darkengine  
       2021 年 8 月 27 日
    用 netty 吧
    lululau
        7
    lululau  
       2021 年 8 月 27 日
    nio 是要你去 polling 的吧,楼主要的应该是 aio 吧
    Cbdy
        8
    Cbdy  
       2021 年 8 月 27 日   1
    这点小需求有必要上框架吗?

    您点的单线程读,多线程处理
    https://gist.github.com/cbdyzj/5a9612a00db7fdcf1b9fc314b3c58c70
    gBurnX
        9
    gBurnX  
       2021 年 8 月 28 日
    什么年代了还自己写 socket...

    直接 pb + gprc 一步到位不好嘛?
    关于     帮助文档     自助推广系统     博客     API     FAQ &nbs;   Solana     3591 人在线   最高记录 6679       Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 54ms UTC 05:02 PVG 13:02 LAX 22:02 JFK 01:02
    Do have faith in what you're doing.
    ubao msn snddm index pchome yahoo rakuten mypaper meadowduck bidyahoo youbao zxmzxm asda bnvcg cvbfg dfscv mmhjk xxddc yybgb zznbn ccubao uaitu acv GXCV ET GDG YH FG BCVB FJFH CBRE CBC GDG ET54 WRWR RWER WREW WRWER RWER SDG EW SF DSFSF fbbs ubao fhd dfg ewr dg df ewwr ewwr et ruyut utut dfg fgd gdfgt etg dfgt dfgd ert4 gd fgg wr 235 wer3 we vsdf sdf gdf ert xcv sdf rwer hfd dfg cvb rwf afb dfh jgh bmn lgh rty gfds cxv xcv xcs vdas fdf fgd cv sdf tert sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf shasha9178 shasha9178 shasha9178 shasha9178 shasha9178 liflif2 liflif2 liflif2 liflif2 liflif2 liblib3 liblib3 liblib3 liblib3 liblib3 zhazha444 zhazha444 zhazha444 zhazha444 zhazha444 dende5 dende denden denden2 denden21 fenfen9 fenf619 fen619 fenfe9 fe619 sdf sdf sdf sdf sdf zhazh90 zhazh0 zhaa50 zha90 zh590 zho zhoz zhozh zhozho zhozho2 lislis lls95 lili95 lils5 liss9 sdf0ty987 sdft876 sdft9876 sdf09876 sd0t9876 sdf0ty98 sdf0976 sdf0ty986 sdf0ty96 sdf0t76 sdf0876 df0ty98 sf0t876 sd0ty76 sdy76 sdf76 sdf0t76 sdf0ty9 sdf0ty98 sdf0ty987 sdf0ty98 sdf6676 sdf876 sd876 sd876 sdf6 sdf6 sdf9876 sdf0t sdf06 sdf0ty9776 sdf0ty9776 sdf0ty76 sdf8876 sdf0t sd6 sdf06 s688876 sd688 sdf86