3

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

导致fetch只发生一次，并且所有 websocket 客户端都会收到相同的非新鲜数据。

  • 如何使用 IO 进行任意 IO websockets？
  • 我怎样才能让上面的例子与新鲜的fetches 一起工作？

我很想听听任何建议或完整的解决方案。一种不接触的方式iteratee将不胜感激。

4

1 回答 1

3

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

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

proxy = liftIO fetch >>= sendTextData

您还需要添加导入

import Control.Monad.IO.Class
于 2012-07-20T17:46:04.593 回答