1

我有一个关于异步套接字的问题。在过去的几个月里，这一直困扰着我，我认为我应该明智地从这里的专业人士那里得到事实。

我有一个来自客户端的传入流，我想接收数据。此传入流需要通过字符串进行初始设置，然后才能开始发送数据。

我听说过像 node.js 这样的异步 tcp 服务器的强大可扩展性。我的问题是我是否可以使用 node.js 或任何其他异步 tcp 服务器与此客户端握手并接收传入流。

您可以将传入数据视为给定时间点的库存数据或用电量流。本质上，数据将连续流入。

请让我知道我需要分享哪些其他信息来帮助我了解异步套接字以及如何使用它。

4

1 回答 1

3

是的，在异步套接字之上实现握手是完全正常的。

考虑伪代码：

socket = accept() # or connect()
// now socket is connected
socket.write(logon_request)
logon_response = socket.read()
assert(logon_response ok)
// now socket is logged in
socket.write(more_handshake);
handshake_response = socket.read()
assert(handshake_response ok)
// now socket is ready to go

while data = socket.read()
{    process data ... }

您可以将其建模为状态机，然后很容易与异步套接字一起使用。看看下面的代码如何与上面的代码相似，但分解为多个回调：

# state Idle -> LoggingOn
handle_connection_event(socket)
    state = LoggingOn
    socket.write(logon_request)

# state LoggingOn -> Handshaking
handle_login_response(socket)
    logon_response = socket.read()
    assert(logon_response ok)
    state = Handshaking
    socket.write(more_handshake);

# state Handshaking -> Ready
handle_handshake_response(socket)
    handshake_response = socket.read()
    assert(handshake_response ok)
    state = Ready

并且所有读取都进入这里，并根据状态机进行调度

handle_read(socket)
    switch(state) {
    case LoggingOn: handle_logon_response(socket)
    case Handshaking: handle_handshake_response(socket)
    case Ready: process(socket.read())
    }

PS。由于某种原因，我在这里遇到了严重的格式化失败，希望它是可读的

于 2012-05-03T14:36:50.433 回答