websocket 如何投递消息到 http - V2EX
V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
v2li32
V2EX    WebSocket

websocket 如何投递消息到 http

  •  
  •   v2li32 2024-05-13 10:34:22 +08:00 1544 次点击
    这是一个创建于 564 天前的主题,其中的信息可能已经有所发展或是发生改变。

    我在构思微服务下如何通过 websocket 作为交互。

    运行流程

    client => http => server => ws/tcp => server2 到 => server2 通过 unixsocket 投递消息到 work 处理完成后 => 通过 ws 写消息回去 => server 的 ws 收到消息

    这个时候 如果正常处理 加工收到的消息, 写入消息到 client 的 fd,close 掉 client 连接 应该是可行的。

    平常业务代码

    client => server(伪代码)=> return

    <?php func add(){ $get= $_REQUEST_PARAMS; return success("code=>200,data=$get,msg=''"); } 

    如果换成上面通过 websocket 交互

    都不需要返回了, server 收到 server2 结果后 fwrite($client_fd,$data); close($client_fd);

    <?php func add(){ $get= $_REQUEST_PARAMS; (new Ws)->send($get); } 

    上面写好奇怪的样子。。 我想实现下面的写法有办法吗(代码直观看着舒服),比如

    <?php func add(){ $get= $_REQUEST_PARAMS; $res = (new Ws)->send($get); return success("code=>200,data=$res,msg=''"); } 

    如果想实现上面这样子,需要在加一个队列(起到 while true 阻塞效果?)。

    开辟 1 片内存 $arr[$client_fd] => $data; 数据回来后写入。然后 pop 消息。

    这样子就好像成 select 了。。 无时无刻在遍历,有数据在返回,性能问题很大。。

    然后好像为了解决问题又引入新的问题。

    大佬们给点思路呢

    7 条回复    2024-05-13 17:18:41 +08:00
    RedBeanIce
        1
    RedBeanIce  
       2024-05-13 10:49:26 +08:00
    请直接说,你在做什么,想实现什么目标。
    sentinelK
        2
    sentinelK  
       2024-05-13 10:55:02 +08:00
    需要楼主提炼一下问题。
    1 、问题只问核心就行了,不需要掺杂业务。
    2 、目前你遇到的问题是什么?
    3 、“写着舒服”是个什么概念?
    tool2dx
        3
    tool2dx  
       2024-05-13 11:04:48 +08:00
    我猜测一下,OP server1 要返回客户端的 http 请求,但是内容是来自于 server2 。

    而 server2 -> server1 是用 websocket 协议通讯。

    所以 OP 说,server1 就需要傻等 server2 返回的结果,用 whire true 卡住 CPU ,死等??
    v2li32
        4
    v2li32  
    OP
       2024-05-13 11:14:34 +08:00
    @tool2dx 是的。这个如何解决呢。while true 太不优雅了
    tool2dx
        5
    tool2dx  
       2024-05-13 11:20:04 +08:00
    @v2li32 JS 都是异步回调,php 没用过不太清楚。
    v2li32
        6
    v2li32  
    OP
       2024-05-13 11:33:50 +08:00
    @tool2dx js 的怎么个异步法呢,比如 node, server 回来的 ws 数据跟 客户的 client 他们没有桥梁。 所以才想到搞一个队列阻塞 被动查询是否有数据。
    julyclyde
        7
    julyclyde  
       2024-05-13 17:18:41 +08:00
    按说 HTTP upgrade 之后就不能再 downgrade 了吧?
    关于     帮助文档     自助推广系统     博客     API     FAQ     Solana     842 人在线   最高记录 6679       Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 24ms UTC 20:51 PVG 04:51 LAX 12:51 JFK 15:51
    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