新问题:haskell Network.Socket 监听TCP 如何持续接收数据?

Question

新问题在三楼

看了一下 Network 和 Network.Socket
如果用Network 里面的ListenOn 可以监听TCP 端口.

用Network.Socket 不知道如何监听TCP 端口 .
监听UDP端口的实例如下:

import Network.Socket import IO main = withSocketsDo $ do         s <- socket AF_INET Datagram 17         addr <- inet_addr "127.0.0.1"         bindSocket s (SockAddrInet 30000 addr)         putStrLn "Listening port 30000 ..."         (m,l,f) <- recvFrom s 1024         putStrLn $ "msg from " ++ (show f) ++ "length " ++ (show l)         putStrLn m

Answer 1

8楼的代码是可以编译的. 可以测试一下.

运行server.exe, 监听端口30000
client_1 : nc -vv 127.0.0.1 30000
client_2 : nc -vv 127.0.0.1 30000
两个连接建立成功.

client_1 给server发送数据
client_2 给server发送数据

server 返回的结果, 处理(显示)完client_1的数据, 再处理(显示)client_2的数据.

还是程序写的有问题?

Answer 2

> 处理完一个client发的数据,再处理下一个client发的数据.

不是这样的，是并发的。

Answer 3

main = do         putStrLn "Start Server!"         mainserver mainserver = withSocketsDo $ do         sock <- socket AF_INET Stream 6         bindSocket sock (SockAddrInet 30000 iNADDR_ANY)         listen sock 10         putStrLn "Server Listening port 30000 ..."         loopserver sock loopserver sock = do         (s,c) <- accept sock         forkIO $ clientloop s c         loopserver sock clientloop s c = do         msg <- recvFrom s 1024         print msg         sendTo s "I'm Servern" c         clientloop s c

Answer 4

loopserver sock = do
        (s,c) <- accept sock
        forkIO $ perClientLoop s
        loopserver sock

perClientLoop s = do
        msg <- recvFrom s 1024
        print msg
        send msg "I'm Server"
        perClientLoop s

看了一下，Network.Socket 这套接口太底层了，还是用 Network 吧。

Answer 5

Network.Socket 里的接口：

listen :: Socket -> Int -> IO ()

Network 里的接口：

listenOn
:: PortID        Port Identifier
-> IO Socket        Connected Socket

Answer 6

给你一个简单例子，server把收到的内容原样发给client

2. import Network
3. import System.IO
5. main = listenOn (PortNumber 30000) >>=
6.           sock -> accept sock >>= talk >> sClose sock
7.     where talk (h, name, port) = do
8.                 hSetBuffering h LineBuffering
9.                 hGetContents h >>= hPutStr h >> hClose h

复制代码

Answer 7

这一步过去,下一步就可以做数据处理了, 结果又K啦.

Answer 8

module Main where import Network.Socket import IO main = do           putStrLn "Server start ... "           mainserver mainserver = withSocketsDo $ do         s <- socket AF_INET Stream 6         s_addr <- inet_addr "127.0.0.1"         bindSocket s (SockAddrInet 30000 s_addr)         putStrLn $ "Listening port 30000 ......"         listen s 10         loopserver s loopserver sock = do         (s,c) <- accept sock         msg <- recvFrom s 1024         print msg         send msg "I'm Server"         loopserver sock

Answer 9

tcp难道不需要listen吗？ 还有accept
可参考一下http://book.realworldhaskell.org/read/sockets-and-syslog.html