Haskell服务器不回复客户端

Question

我尝试按照这个关于Haskell的网络管道库的教程构建一个简单的客户端-服务器程序。

这是客户端，它同时向服务器发送文件并接收答案：

{-# LANGUAGE OverloadedStrings #-}
import Control.Concurrent.Async (concurrently)
import Data.Functor (void)
import Conduit
import Data.Conduit.Network
main = runTCPClient (clientSettings 4000 "localhost") $ server ->
void $ concurrently
(runConduitRes $ sourceFile "input.txt" .| appSink server)
(runConduit $ appSource server .| stdoutC)

这是服务器，它计算每个单词的出现次数并将结果发送回客户端：

{-# LANGUAGE OverloadedStrings #-}
import Data.ByteString.Char8 (pack)
import Data.Foldable (toList)
import Data.HashMap.Lazy (empty, insertWith)
import Data.Word8 (isAlphaNum)
import Conduit
import Data.Conduit.Network
import qualified Data.Conduit.Combinators as CC
main = runTCPServer (serverSettings 4000 "*") $ appData -> do
hashMap <- runConduit $ appSource appData 
.| CC.splitOnUnboundedE (not . isAlphaNum)
.| foldMC insertInHashMap empty
runConduit $ yield (pack $ show $ toList hashMap)
.| iterMC print
.| appSink appData
insertInHashMap x v = do
return (insertWith (+) v 1 x)

问题是服务器在我手动关闭客户端之前不会达到收益阶段，因此永远不会回答它。我注意到从客户端中删除并发性并仅保留将数据发送到服务器的部分，一切正常。

那么，如何在不中断流的情况下保留客户端的接收部分呢？

Answer 1

您有一个死锁：客户端在关闭连接之前正在等待服务器响应，但服务器不知道客户端已完成发送数据并正在等待更多数据。这基本上是 https://cr.yp.to/tcpip/twofd.html 中描述的问题：

当generate-data程序完成时，相同的 fd 仍然在consume-data程序中打开，因此内核不知道它应该发送 FIN。

在您的情况下，修复需要在客户端进行。一旦conduit完成发送输入的内容，您需要在套接字上调用带有ShutdownSendshutdown.txt。

这是一种方法(我不确定是否有更好的方法)：

{-# LANGUAGE OverloadedStrings #-}
import Control.Concurrent.Async (concurrently)
import Data.Functor (void)
import Data.Foldable (traverse_)
import Conduit
import Data.Conduit.Network
import Data.Streaming.Network (appRawSocket)
import Network.Socket (shutdown, ShutdownCmd(..))
main = runTCPClient (clientSettings 4000 "localhost") $ server ->
void $ concurrently
((runConduitRes $ sourceFile "input.txt" .| appSink server) >> doneWriting server)
(runConduit $ appSource server .| stdoutC)
doneWriting = traverse_ (`shutdown` ShutdownSend) . appRawSocket

旁注：在这种情况下，客户端中实际上并不需要并发性，因为在完成对服务器的写入之前，永远不会有任何内容可以从服务器读取。您可以在写入和关闭后进行读取。