message io下载 - message io源码下载

message io

其他类别

1.0.0

下载

消息io

message-io是一个快速且易于使用的事件驱动网络库。该库在内部处理操作系统套接字，并向用户提供简单的事件消息 API。它还允许您遵循一些规则为您自己的传输协议创建适配器，将繁琐的异步和线程管理委托给库。

如果您在使用该库时发现问题或者您有改进它的想法，请随时提出问题。欢迎任何贡献！请记住：咖啡因越多，工作效率越高！

动机

管理套接字很困难，因为您需要应对线程、并发、全双工、编码、来自操作系统的 IO 错误（在某些情况下确实很难理解）等。如果您使用非阻塞套接字，它增加了新的复杂性：同步来自操作系统的异步事件。

message-io提供了一种简单的方法来处理所有上述问题，使它们对您（想要创建具有自己的问题的应用程序）的程序员来说是透明的。为此，该库为您提供了一个简单的 API，其中包含两个需要理解的概念：消息（您发送和接收的数据）和端点（该数据的接收者）。这种抽象还提供了独立于所使用的传输协议而使用相同 API 的可能性。您可以在一行中更改应用程序的传输。

特征

高度可扩展：非阻塞套接字，允许管理数千个活动连接。
多平台：请参阅 mio 平台支持。
多种传输协议（文档）：
- TCP ：流和帧模式（处理消息而不是流）
- UDP ，具有多播选项
- WebSocket ：普通和~~安全的~~#102 使用 tungstenite-rs 的选项（不支持wasm但已计划）。
具有计时器和优先级的自定义 FIFO 事件。
简单、直观且一致的 API：
- 遵循 KISS 原则。
- 从传输层抽象：不要考虑套接字，而要考虑消息和端点。
- 仅使用两个主要实体：
  - 一个NodeHandler来管理所有连接（连接、监听、删除、发送）和信号（计时器、优先级）。
  - NodeListener用于处理来自网络的所有信号和事件。
- 忘记并发问题：从一个线程处理所有连接和侦听器：“一个线程统治它们”。
- 简单的错误处理：从网络发送/接收时不处理黑暗的内部std::io::Error 。
高性能（参见基准）：
- 使用零拷贝写入/读取消息。您可以直接从内部操作系统套接字缓冲区写入和读取，而无需库在中间进行任何复制。
- 全双工：在同一个内部操作系统套接字上同时进行读/写操作。
可定制： message-io没有您需要的传输？轻松添加适配器。

文档

API文档
基本概念
基准测试
示例：
- Ping Pong（一个简单的客户端/服务器示例）
- 组播
- 具有发现服务器的分布式网络
- 文件传输
开源应用程序

入门

添加到您的Cargo.toml （默认情况下包含所有运输）：

[ dependencies ]
message-io = " 0.18 "

如果您只想使用可用传输电池的子集，则可以通过其关联功能tcp 、 udp和websocket来选择它们。例如，为了仅包含TCP和UDP ，请添加到您的Cargo.toml ：

[ dependencies ]
message-io = { version = " 0.18 " , default-features = false , features = [ " tcp " , " udp " ] }

多合一：TCP、UDP 和 WebSocket 回显服务器

以下示例是最简单的服务器，它从客户端读取消息并使用相同的消息响应它们。它能够同时为3种不同的协议提供“服务”。

 use message_io :: node :: { self } ;
use message_io :: network :: { NetEvent , Transport } ;

fn main ( ) {
    // Create a node, the main message-io entity. It is divided in 2 parts:
    // The 'handler', used to make actions (connect, send messages, signals, stop the node...)
    // The 'listener', used to read events from the network or signals.
    let ( handler , listener ) = node :: split :: < ( ) > ( ) ;

    // Listen for TCP, UDP and WebSocket messages at the same time.
    handler . network ( ) . listen ( Transport :: FramedTcp , "0.0.0.0:3042" ) . unwrap ( ) ;
    handler . network ( ) . listen ( Transport :: Udp , "0.0.0.0:3043" ) . unwrap ( ) ;
    handler . network ( ) . listen ( Transport :: Ws , "0.0.0.0:3044" ) . unwrap ( ) ;

    // Read incoming network events.
    listener . for_each ( move |event| match event . network ( ) {
        NetEvent :: Connected ( _ , _ ) => unreachable ! ( ) , // Used for explicit connections.
        NetEvent :: Accepted ( _endpoint , _listener ) => println ! ( "Client connected" ) , // Tcp or Ws
        NetEvent :: Message ( endpoint , data ) => {
            println ! ( "Received: {}" , String :: from_utf8_lossy ( data ) ) ;
            handler . network ( ) . send ( endpoint , data ) ;
        } ,
        NetEvent :: Disconnected ( _endpoint ) => println ! ( "Client disconnected" ) , //Tcp or Ws
    } ) ;
}

回显客户端

以下示例显示了可以连接到先前服务器的客户端。它每秒向服务器发送一条消息并监听其回显响应。将Transport::FramedTcp更改为Udp或Ws将更改使用的底层传输。

 use message_io :: node :: { self , NodeEvent } ;
use message_io :: network :: { NetEvent , Transport } ;
use std :: time :: Duration ;

enum Signal {
    Greet ,
    // Any other app event here.
}

fn main ( ) {
    let ( handler , listener ) = node :: split ( ) ;

    // You can change the transport to Udp or Ws (WebSocket).
    let ( server , _ ) = handler . network ( ) . connect ( Transport :: FramedTcp , "127.0.0.1:3042" ) . unwrap ( ) ;

    listener . for_each ( move |event| match event {
        NodeEvent :: Network ( net_event ) => match net_event {
            NetEvent :: Connected ( _endpoint , _ok ) => handler . signals ( ) . send ( Signal :: Greet ) ,
            NetEvent :: Accepted ( _ , _ ) => unreachable ! ( ) , // Only generated by listening
            NetEvent :: Message ( _endpoint , data ) => {
                println ! ( "Received: {}" , String :: from_utf8_lossy ( data ) ) ;
            } ,
            NetEvent :: Disconnected ( _endpoint ) => ( ) ,
        }
        NodeEvent :: Signal ( signal ) => match signal {
            Signal :: Greet => { // computed every second
                handler . network ( ) . send ( server , "Hello server!" . as_bytes ( ) ) ;
                handler . signals ( ) . send_with_timer ( Signal :: Greet , Duration :: from_secs ( 1 ) ) ;
            }
        }
    } ) ;
}

自己测试一下！

克隆存储库并测试Ping Pong示例（类似于README示例，但更丰富）。

运行服务器：

cargo run --example ping-pong server tcp 3456

运行客户端：

cargo run --example ping-pong client tcp 127.0.0.1:3456

您可以通过更改传输、运行多个客户端、断开它们的连接等来使用它。请在此处查看更多信息。

您是否需要`message-io`没有的传输协议？添加适配器！

message-io提供两种API。作为库用户与message-io本身进行对话的用户 API ，以及那些想要将其协议适配器添加到库中的内部适配器 API 。

如果可以在mio之上构建传输协议（大多数现有协议库都可以），那么您可以非常轻松地将其添加到message-io中：

在src/adapters/<my-transport-protocol>.rs中添加适配器文件，以实现您在此处找到的特征。它只包含 8 个需要实现的强制函数（参见模板），并且需要大约 150 行代码来实现一个适配器。
在 src/network/transport.rs 中的Transport枚举中添加一个新字段来注册您的新适配器。

就这样。您可以像其他传输一样将新传输与message-io API 一起使用。

哎呀！又一步：发出Pull 请求，以便每个人都可以使用它:)

使用`message-io`开源项目

Termchat 终端通过 LAN 进行视频流和文件传输聊天。
Egregoria 沉思社会模拟。
项目-Midas 基于分布式网络的并行计算系统。
AsciiArena 终端多人死亡竞赛游戏（alpha）。
LanChat LanChat flutter + rust 演示。

您的出色项目使用message-io吗？发出拉取请求并将其添加到列表中！

message-io 适合我吗？

message-io主要目标是让事情变得简单。这很好，但有时这种观点可能会使本来就复杂的事情变得更加复杂。

例如， message-io允许在不使用async/await模式的情况下处理异步网络事件。它降低了处理来自网络的收入消息的复杂性，这很棒。然而，读取异步消息的应用程序也倾向于对这些事件执行异步任务。这种异步继承可以轻松地传播到整个应用程序，如果没有异步/等待模式，则很难维护或扩展。在这种情况下，也许tokio可能是更好的选择。您需要处理更多低级网络内容，但您会在组织和线程/资源管理方面有所收获。

关于message-io的节点使用，可能会发生类似的问题。由于节点可以独立用作客户端/服务器或两者，因此您可以轻松地开始制作对等应用程序。其实这也是message-io的意图之一。然而，如果您的目标规模较大，就会出现与此模式相关的问题需要处理，而libp2p等库附带了大量工具来帮助实现该目标。

当然，这并不是对库使用的免责声明（我使用它！），更多的是诚实地了解其功能，并根据您的需求引导您使用正确的工具。

总结一下：