5

能够Network.WebSockets从 snaplet 内部使用模块会很好，但我不知道如何实际做到这一点。

使用它的runWebSocketsSnap :: MonadSnap m => ServerApp -> m ()功能Network.WebSockets.Snap很容易在我的应用程序中包含一个简单的无状态 websocket 服务器：

routes :: [(ByteString, Handler App App ())]
routes = [ ("/ws", runWebSocketsSnap wsApp) ]

wsApp :: PendingConnection -> IO () -- this is the ServerApp type
wsApp pending = do
    conn <- acceptRequest pending
    forever $ do
        msg <- receiveData conn
        sendTextData conn ("Echo " `mappend` msg :: Text)

但我的目标是维护 webscket 服务器的状态（例如，已连接客户端的列表，如http://jaspervdj.be/websockets/example.html）。或者，访问 snaplet 的酸性状态存储会很好。

我的第一个想法是liftIO将 websocket 操作放入Handler App Appmonad，并编写一个像这样的应用程序：

wsApp :: PendingConnection -> Handler App App ()
wsApp pending = do
    conn <- liftIO $ acceptRequest pending
    forever $ do
        msg <- liftIO $ receiveData conn
        update (SetLastMsg msg)
        liftIO $ sendTextData conn ("Stored msg in datastore.")

但是没有一个版本runWebSocketsSnap采用上述形式的应用程序，我不知道如何修改现有的应用程序（hackage 上的源代码）。在我看来，需要一个替代方案来代替forkIO在 monad 中采取行动Handler App App，但我对 Haskell 的理解，尤其是 Snap 中的并发性到此结束......

4

1 回答 1

4

runWebSocketsSnap 函数要求其参数类型为PendingConnection -> IO ()。这意味着您无法直接访问该函数内部的 App 数据结构。您需要做的是将信息作为参数传递给函数，就像这样。

routes = [ ("/ws", webSocketsDriver) ]

webSocketsDriver :: Handler App App ()
webSocketsDriver = do
    appState <- get
    runWebSocketsSnap (wsApp appState)

wsApp :: App -> PendingConnection -> IO ()
wsApp app pending = do
    ...
于 2014-03-25T14:38:46.733 回答