Haskell IO with Websockets

Question

以以下方式使用websockets库

{-# LANGUAGE OverloadedStrings #-}
module Main where
import System.IO
import System.IO.Unsafe
import Network.Socket hiding (recv)
import Network.WebSockets
import Network.Socket.ByteString
import qualified Data.ByteString.Char8 as B
import Debug.Trace
import Control.Applicative
fetch :: IO B.ByteString
fetch = do
  B.putStrLn "connected"
  [v4] <- getAddrInfo Nothing (Just "127.0.0.1") (Just "3000")
  c <- socket (addrFamily  v4) Stream 0x6
  c `connect` (addrAddress v4)
  recv c 512000
proxy :: TextProtocol p => WebSockets p ()
proxy = sendTextData . unsafePerformIO $! fetch
app :: Request -> WebSockets Hybi00 ()
app r = acceptRequest r >> r `traceShow` proxy
main :: IO ()
main = withSocketsDo $! runServer "0.0.0.0" 4000 app

导致CCD_ 2仅发生一次并且所有websocket客户端都接收到相同的非新鲜数据。

• 如何使用websockets执行任意IO
• 如何使上面的示例与新的fetches一起工作

我很乐意听到任何建议或完整的解决方案。如果能在不接触iteratee的情况下进行操作，我们将不胜感激。

Answer 1

WebSockets monad是MonadIO类型类的一个实例，因此您可以使用liftIO函数执行任意IO操作。

在这种情况下，我猜你想做

proxy = liftIO fetch >>= sendTextData

您还需要添加导入

import Control.Monad.IO.Class