tornado.tcpserver.TCPServer

`tornado.tcpserver.TCPServer` 是 Tornado 框架中的一个类，用于实现 TCP 服务器的功能。它继承自 `tornado.netutil.TCPServer` 类，提供了对 TCP 连接的监听、接收和处理等功能。

`TCPServer` 的初始化方法如下：

class tornado.tcpserver.TCPServer(io_loop=None, ssl_options=None, max_buffer_size=None, read_chunk_size=None, max_idle_time=None, connect_timeout=None, max_body_size=None)

其中，参数含义如下：

- `io_loop`: 事件循环对象，用于处理 TCP 连接的事件和回调。如果不指定，将使用默认的事件循环对象。
- `ssl_options`: SSL/TLS 配置选项，用于开启加密传输。默认为 `None`，表示不开启 SSL/TLS 加密传输。
- `max_buffer_size`: 读取数据时的最大缓冲区大小，默认为 `None`，表示不限制缓冲区大小。
- `read_chunk_size`: 读取数据时的缓冲区大小，默认为 64KB。
- `max_idle_time`: 连接的最大空闲时间，超过该时间未收到数据，则关闭连接，默认为 `None`，表示不限制空闲时间。
- `connect_timeout`: 连接的最大超时时间，默认为 `None`，表示不限制超时时间。
- `max_body_size`: 读取消息体的最大大小，默认为 `None`，表示不限制消息体大小。

`TCPServer` 类还提供了以下常用方法：

- `listen`: 监听指定的端口，并启动服务器。
- `stop`: 停止服务器，关闭所有连接。
- `handle_stream`: 处理新的 TCP 连接。

例如，下面的示例代码实现了一个简单的 TCP 服务器：

import tornado.ioloop
import tornado.tcpserver
import tornado.gen

class MyTCPServer(tornado.tcpserver.TCPServer):
    async def handle_stream(self, stream, address):
        print(f"New connection from {address}")
        while True:
            try:
                data = await stream.read_until(b"\n")
                print(f"Received {data.decode().strip()} from {address}")
                await stream.write(data.upper())
            except Exception as e:
                print(f"Error: {e}")
                break

if __name__ == "__main__":
    server = MyTCPServer()
    server.listen(8888)
    tornado.ioloop.IOLoop.current().start()

在上面的代码中，我们定义了一个 `MyTCPServer` 类，继承自 `tornado.tcpserver.TCPServer`。在 `handle_stream` 方法中，我们处理了新的 TCP 连接，并循环读取客户端发送的数据，并将其转换为大写后发送回客户端。最后，我们通过 `server.listen(8888)` 启动了 TCP 服务器，监听 8888 端口，并通过 `tornado.ioloop.IOLoop.current().start()` 运行了事件循环。

需要注意的是，在 `handle_stream` 方法中，我们使用了 `await` 关键字来等待客户端发送的数据，并异步地处理数据。这样可以避免在处理 TCP 连接时阻塞事件循环，提高服务器的并发性能。