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

luckyelement

新问题在三楼

看了一下 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

如果把  17 (udp)  改成 6 (tcp) 提示错误.
socket: failed (Protocol not supported (WSAEPROTONOSUPPORT))

参考文档: http://cvs.haskell.org/Hugs/page ... ml#t%3ASocketStatus
http://cvs.haskell.org/Hugs/pages/libraries/network/Network.html

望指点一下. 谢谢.

[ 本帖最后由 luckyelement 于 2009-2-23 18:40 编辑 ]

luckyelement

谢谢了, 是我的问题.
之前懒省事用nc测试的.
刚刚自己写了一个小client, 做的测试, 没有问题了.

谢谢.

flw

原帖由 luckyelement 于 2009-2-26 17:26 发表
想实现
client_1 向server 发数据的时, server可以响应.
client_2 同时向server 发数据, 不需要等到处理完client_1的数据, server就可以响应,
client_3 同时向server 发数据, 不需要等到处理完client_1,cli ...

难道现在不是这样的？

luckyelement

想实现
client_1 向server 发数据的时, server可以响应.
client_2 同时向server 发数据, 不需要等到处理完client_1的数据, server就可以响应,
client_3 同时向server 发数据, 不需要等到处理完client_1,client_2的数据, server就可以响应,

flw

你想说明啥？你期望得到啥？

luckyelement

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的数据.

还是程序写的有问题?

flw

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

不是这样的，是并发的。

luckyelement

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

这种模式, 应该是阻塞方式, 多个client连接server, server处理完一个client发的数据,再处理下一个client发的数据.
在haskell 里面有没有非阻塞方式, 或者 同步, 异步? 消息模型, 找了一下, 没有找到.

flw

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 吧。

flw

Network.Socket 里的接口：

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

Network 里的接口：

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