Struct ObserverServerBuilder 

pub struct ObserverServerBuilder { /* private fields */ }

观察者模式服务端构建器

提供基本功能实现，使用 ServerEventHandler trait 处理消息和事件。

设计原则

• 公共逻辑统一处理：基于 HybridServer，共享所有核心能力
• 自动消息路由：ServerMessageWrapper 自动将消息路由到 ServerEventHandler 的对应方法
• 自动 ACK 处理：如果 handler 返回 None，框架自动发送 ACK
• 错误处理：处理失败时自动发送错误 ACK，确保客户端能收到响应

使用方式

用户只需要实现 ServerEventHandler trait，框架会自动处理消息路由和 ACK。

Implementations

impl ObserverServerBuilder

pub fn new( bind_address: impl Into<String>, event_handler: Arc<dyn ServerEventHandler>, ) -> Self

创建新的观察者模式构建器

参数

• bind_address: 绑定地址
• event_handler: 事件处理器（必须），用户只需要实现 ServerEventHandler 的 handle_message 方法即可

pub fn with_authenticator(self, authenticator: Arc<dyn Authenticator>) -> Self

设置认证器（如果启用认证，必须提供）

如果设置了认证器，还需要在配置中启用认证：

.enable_auth()
.with_authenticator(authenticator)

pub fn enable_auth(self) -> Self

启用认证

pub fn with_auth_timeout(self, timeout: Duration) -> Self

设置认证超时时间

pub fn with_device_manager(self, device_manager: Arc<DeviceManager>) -> Self

设置设备管理器（用于设备冲突管理）

pub fn with_connection_manager(self, manager: Arc<ConnectionManager>) -> Self

设置连接管理器（可选，用于共享连接状态）

pub fn with_protocol(self, protocol: TransportProtocol) -> Self

设置传输协议

pub fn with_protocols(self, protocols: Vec<TransportProtocol>) -> Self

启用多协议监听

pub fn with_protocol_address( self, protocol: TransportProtocol, address: String, ) -> Self

为特定协议设置监听地址

pub fn with_max_connections(self, max: usize) -> Self

设置最大连接数

pub fn with_handshake_timeout(self, timeout: Duration) -> Self

设置握手超时时间

pub fn with_max_handshake_concurrency(self, max: usize) -> Self

设置最大并发握手数

pub fn with_write_timeout(self, timeout: Duration) -> Self

设置单次连接写入超时时间

pub fn with_fanout_concurrency(self, max: usize) -> Self

设置 fanout 发送最大并发度

pub fn with_heartbeat(self, heartbeat: HeartbeatConfig) -> Self

设置心跳配置

pub fn with_tls(self, tls: TlsConfig) -> Self

设置 TLS 配置

pub fn with_default_format(self, format: SerializationFormat) -> Self

设置默认序列化格式（用于协商，默认 Protobuf）

pub fn with_default_compression(self, compression: CompressionAlgorithm) -> Self

设置默认压缩算法（用于协商，默认 None）

pub fn build(self) -> Result<ObserverServer>

构建服务端

错误处理

• 如果配置无效（如启用了认证但未提供认证器），返回配置错误
• 如果服务器初始化失败，返回相应的错误

返回

• Ok(ObserverServer) - 成功构建的服务端实例
• Err(FlareError) - 构建失败的错误信息