TCP Acceptor类更多...

#include <tcp_acceptor.hpp>

类 tcp_acceptor 继承关系图:

Public 成员函数
	tcp_acceptor ()=default
	默认构造函数
void	open (const ip_address &endpoint, int backlog=SOMAXCONN)
	打开并开始监听
NEFORCE_NODISCARD tcp_socket	accept ()
	接受客户端连接（阻塞模式）
NEFORCE_NODISCARD optional< tcp_socket >	accept_nonblock ()
	接受客户端连接（非阻塞模式）
Public 成员函数继承自 ip_socket
	ip_socket ()=default
	默认构造函数
	ip_socket (const native_handle_type fd) noexcept
	从原生句柄构造
	~ip_socket () override=default
	析构函数
NEFORCE_NODISCARD int	address_family () const noexcept
	获取地址族
NEFORCE_NODISCARD bool	is_ipv4 () const noexcept
	检查是否为IPv4 socket
NEFORCE_NODISCARD bool	is_ipv6 () const noexcept
	检查是否为IPv6 socket
virtual void	connect (const ip_address &endpoint)
	连接到远程端点（TCP客户端）
bool	close () noexcept override
	关闭socket
Public 成员函数继承自 socket_base
	socket_base ()
	默认构造函数
	socket_base (const native_handle_type fd) noexcept
	从原生句柄构造
	socket_base (socket_base &&other) noexcept
	移动构造函数
socket_base &	operator= (socket_base &&other) noexcept
	移动赋值运算符
virtual	~socket_base ()
	析构函数
NEFORCE_NODISCARD native_handle_type	native_handle () const noexcept
	获取原生句柄
NEFORCE_NODISCARD bool	is_open () const noexcept
	检查socket是否已打开
	operator bool () const noexcept
	布尔转换运算符
void	open (int family, int type, int protocol)
	打开socket
bool	try_open (int family, int type, int protocol) noexcept
	尝试打开socket（不抛出异常）
bool	set_nonblocking (bool enable) noexcept
	设置非阻塞模式
bool	shutdown_send () noexcept
	关闭发送方向
bool	shutdown_receive () noexcept
	关闭接收方向
bool	shutdown_both () noexcept
	关闭双向通信
bool	set_option (int level, int optname, const void *value, ::socklen_t len) noexcept
	设置socket选项
bool	get_option (int level, int optname, void optval, ::socklen_t optlen) const noexcept
	获取socket选项
bool	set_reuse_address (bool enable=true) noexcept
	设置地址重用（SO_REUSEADDR）
bool	set_reuse_port (bool enable=true) noexcept
	设置端口重用（SO_REUSEPORT）
bool	set_keep_alive (bool enable=true) noexcept
	设置TCP KeepAlive
bool	set_tcp_nodelay (bool enable=true) noexcept
	设置TCP_NODELAY（禁用Nagle算法）
bool	set_receive_buffer_size (int size) noexcept
	设置接收缓冲区大小
bool	set_send_buffer_size (int size) noexcept
	设置发送缓冲区大小
bool	set_send_timeout (milliseconds timeout) noexcept
	设置发送超时时间
bool	set_receive_timeout (milliseconds timeout) noexcept
	设置接收超时时间
NEFORCE_NODISCARD optional< ip_address >	local_endpoint () const
	获取本地端点地址
NEFORCE_NODISCARD optional< ip_address >	remote_endpoint () const
	获取远程端点地址
void	bind (const ip_address &endpoint)
	绑定socket到本地地址
void	listen (int backlog)
	开始监听连接（TCP）
NEFORCE_NODISCARD native_handle_type	release () noexcept
	释放socket所有权

额外继承的成员函数
Public 类型继承自 socket_base
using	native_handle_type
	平台原生句柄类型
静态 Public 属性继承自 socket_base
static constexpr native_handle_type	invalid_handle
	无效句柄常量
Protected 属性继承自 ip_socket
int	family_ = AF_UNSPEC
	地址族
Protected 属性继承自 socket_base
native_handle_type	fd_ = invalid_handle
	Socket句柄

详细描述

TCP Acceptor类

实现TCP服务器的连接接受功能，负责监听端口并接受客户端连接。继承自ip_socket，提供专门用于服务器端的操作。

主要功能：

绑定到本地端点
开始监听连接
接受客户端连接

使用示例：

// TCP服务器示例
tcp_acceptor acceptor;
 
// 绑定并监听端口
auto endpoint = ip_address::any(ports(8080));
acceptor.open(endpoint, 128);
acceptor.set_nonblocking(true);
 
println("Server listening on ", endpoint);
 
while (true) {
    try {
        // 接受客户端连接
        auto client = acceptor.accept_nonblock();
        if (client) {
            // 获取客户端地址
            auto client_addr = client.remote_endpoint();
            if (client_addr) {
                println("New connection from ", client_addr);
            }
 
            // 处理客户端请求
            char buffer[1024];
            ssize_t received = client.receive({buffer, sizeof(buffer)});
            if (received > 0) {
                client.send_all({"Hello from server!"});
            }
        }
    } catch (const exception& e) {
        println("Accept error: ", e.what());
    }
}

注解: 默认启用地址重用选项，允许在关闭后立即重用端口。

在文件 tcp_acceptor.hpp 第 75 行定义.

成员函数说明

◆ accept()

NEFORCE_NODISCARD tcp_socket tcp_acceptor::accept ( )

接受客户端连接（阻塞模式）

返回: 新的TCP socket对象

异常

socket_exception	接受失败时抛出
value_exception	acceptor未打开时抛出

阻塞等待直到有新连接到达，然后返回代表该连接的socket。返回的socket可用于与客户端通信。

◆ accept_nonblock()

NEFORCE_NODISCARD optional< tcp_socket > tcp_acceptor::accept_nonblock ( )

接受客户端连接（非阻塞模式）

返回: 有新连接返回socket对象，无连接返回none

异常

socket_exception 发生错误时抛出

非阻塞地尝试接受新连接。如果没有待处理的连接，立即返回none。需要先设置socket为非阻塞模式。

◆ open()

void tcp_acceptor::open	(	const ip_address &	endpoint,
		int	backlog = SOMAXCONN )

打开并开始监听

参数

endpoint	要绑定的本地端点地址
backlog	连接队列大小（默认SOMAXCONN）

异常

socket_exception	绑定或监听失败时抛出
value_exception	端点无效时抛出

该类的文档由以下文件生成:

tcp_acceptor.hpp

Public 成员函数

额外继承的成员函数

详细描述

成员函数说明

◆ accept()

◆ accept_nonblock()

◆ open()