Плохая производительность сети haskell

Ответ 1

Строка медленная. Действительно, действительно, очень медленно. Это односвязный список cons-ячеек, каждый из которых содержит один символ Unicode. Запись одного в сокет требует преобразования каждого символа в байты, копирования этих байтов в массив и передачи этого массива в системный вызов. Какая часть этого звучит так, как вы хотите?:)

Вы хотите использовать только ByteString. Функции IO ByteString фактически используют OO с нулевой копией, где это возможно. Особенно посмотрите на network-bytestring пакет для взлома. Он содержит версии всех сетевых библиотек, оптимизированных для эффективной работы с ByteString.

Ответ 2

Карл прав в отношении ваших первых двух вопросов. О своем последнем, рассмотрите строгий пакет concurrency.

Ответ 3

Ниже приведены две примерные программы: клиент и сервер. Используя GHC 7.0.1 и network-2.3, я получил более 7500 Мбит/с по шлейфу, на моем довольно новом двухъядерном ноутбуке (~ 90% общего использования ЦП). Я не знаю, сколько накладных UDP вводит, но, тем не менее, это довольно много.

--------------------
-- Client program --
--------------------
module Main where

import qualified Data.ByteString as C
import Network.Socket hiding (recv)
import Network.Socket.ByteString (recv)

import System.IO
import Control.Monad

main :: IO ()
main = withSocketsDo $
    do devNull <- openFile "/dev/null" WriteMode
       addrinfos <- getAddrInfo Nothing (Just "localhost") (Just "3000")
       let serveraddr = head addrinfos
       sock <- socket (addrFamily serveraddr) Stream defaultProtocol
       connect sock (addrAddress serveraddr)
       forever $ do
         msg <- recv sock (256 * 1024) -- tuning recv size is important!
         C.hPutStr devNull msg
       sClose sock


--------------------
-- Server program --
--------------------
module Main where

-- import Control.Monad (unless)
import Network.Socket hiding (recv)
import qualified Data.ByteString.Lazy as S
import Network.Socket.ByteString.Lazy (
                                       --recv, 
                                       sendAll)

main :: IO ()
main = withSocketsDo $
       do addrinfos <- getAddrInfo
                        (Just (defaultHints {addrFlags = [AI_PASSIVE]}))
                        Nothing (Just "3000")
          let serveraddr = head addrinfos
          sock <- socket (addrFamily serveraddr) Stream defaultProtocol
          bindSocket sock (addrAddress serveraddr)
          listen sock 1
          (conn, _) <- accept sock
          talk conn
          sClose conn
          sClose sock

     where
       talk :: Socket -> IO ()
       talk conn = sendAll conn $ S.repeat 7