如何通过websocket实现服务器推送？

Question

我可以写这样的事情

let echo (ws: WebSocket) = 
    fun ctx -> socket { 
     let loop = ref true    
     while !loop do 
      let! message = Async.Choose (ws.read()) (inbox.Receive()) 
      match message with 
      | Choice1Of2 (wsMessage) -> 
       match wsMessage with 
       | Ping, _, _ -> do! ws.send Pong [||] true 
       | _ ->() 
      | Choice2Of2 pushMessage -> do! ws.send Text pushMessage true 
    } 

或者我需要2个独立的插座回路并发读 - 写？

Answer 1

Async.Choose没有正确的实现（至少对于这种情况），所以我们需要两个用于并发读写的异步循环;看到this更多细节

Answer 2

我想你可以解决这个使用Async.Choose（有很多实现 - 虽然我不知道哪里是最经典的）。

也就是说，你当然可以创建两个循环 - socket { .. }内的读取循环，以便您可以从网络套接字接收数据;写一个可以是普通的async { ... }块。

像这样的东西应该做的伎俩：

let echo (ws: WebSocket) = 
    // Loop that waits for the agent and writes to web socket 
    let notifyLoop = async { 
     while true do 
     let! msg = inbox.Receive() 
     do! ws.send Text msg } 

    // Start this using cancellation token, so that you can stop it later 
    let cts = new CancellationTokenSource() 
    Async.Start(notifyLoop, cts.Token) 

    // The loop that reads data from the web socket 
    fun ctx -> socket { 
     let loop = ref true    
     while !loop do 
      let! message = ws.read() 
      match message with 
      | Ping, _, _ -> do! ws.send Pong [||] true 
      | _ ->() }