Recon

在tokio-rs上进行的异步消息传递

描述

Tokio提供低级构建块以使用futures-rs的mio。相关的crate tokio-service和tokio-proto是围绕同步客户端/服务器应用程序设计的。

该项目旨在提供节点之间实现异步消息算法的构建块。

组件

recon-link

这是一个位于TcpStream之上的抽象。它将持久连接并重新连接到SocketAddr以保持一个工作的开放连接。

消息通过本地和远程的Stream和Sink对发送和接收。带有框架的TcpStream与远程端配合工作。

消息传递不保证：在TCP会话中，消息流的任何后缀都可能被丢弃。

在单个TCP会话中，消息将按照Tcp的消息排序保证按顺序到达。

重新连接时，将向本地端发送一个控制消息，其中包含递增的会话ID。发送到本地端的消息将带有会话ID的标记。