Lib.rs

Aurora Streams

Aurora Streams是一个使用Tokio消息传递通道管理发布/订阅通道的Rust库。

可选地，可以通过传递event-routing功能标志启用远程事件路由，使用redis，这允许发布/订阅消息在多个服务之间共享。

特性

• 简化发布/订阅交互
• 异步操作
• 重复消息处理
• 通道管理

入门指南

将依赖项添加到您的Cargo.toml中

[dependencies]
aurora-streams = "0.1.0"  # Replace with the actual version

在Rust代码中导入库

use aurora_streams::create_stream;

用法

创建AuroraStreams实例

let streams = create_stream()

如果启用了事件路由，则创建AuroraStreams实例

let streams = create_stream("redis://127.0.0.1:6387")

创建通道

streams.create_channel("test_channel".to_string()).await;

发布消息

streams.publish("test_channel".to_string(), "Hello World!".to_string()).await;

订阅通道

streams.subscribe("test_channel".to_string(), |message| {
    println!("Message received: {}", message);
}).await;

许可证

此库根据MIT许可证授权。

贡献

欢迎贡献！请参阅贡献指南以获取详细信息。