Struct Connection

pub struct Connection { /* private fields */ }

TCP连接管理器

Implementations

impl Connection

pub async fn reconnect(&self) -> Result<()>

重新建立连接

pub async fn new<A: ToSocketAddrs + Display>( addr: A, identify_config: Option<IdentifyConfig>, auth_secret: Option<String>, read_timeout: Duration, write_timeout: Duration, ) -> Result<Self>

创建新的连接

pub async fn connect_with_retry( addr: &str, timeout_duration: Duration, _read_timeout: Duration, _write_timeout: Duration, ) -> Result<TcpStream>

使用重试机制连接到NSQ服务器

pub async fn send_command(&self, command: Command) -> Result<()>

发送命令到NSQ服务器

pub async fn read_frame(&self) -> Result<Frame>

读取下一个NSQ帧

pub async fn handle_heartbeat(&self) -> Result<()>

处理心跳帧

pub async fn ping(&self, timeout_duration: Option<Duration>) -> Result<()>

发送 ping 命令并等待响应，用于检测连接是否活跃

使用 NOP 命令实现，并添加超时机制

参数

• timeout_duration - 超时时间，默认为 5 秒

返回

• Ok(()) - 如果连接正常
• Err(Error) - 如果连接异常或超时

pub async fn read_message(&self) -> Result<Option<Message>>

读取消息 - 参考Go客户端中的readLoop实现

pub fn addr(&self) -> &str

获取连接的地址

pub async fn write_all(&self, buf: &[u8]) -> Result<()>

pub async fn read_exact(&self, buf: &mut [u8]) -> Result<()>

pub async fn write_command( &self, name: &str, body: Option<&[u8]>, params: &[&str], ) -> Result<()>

pub async fn close(&self) -> Result<()>

Trait Implementations

impl Debug for Connection

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Drop for Connection

fn drop(&mut self)

Executes the destructor for this type.