main函数代码如下：
#[tokio::main]async fn main() {websocket_client("ws://127.0.0.1:3030/subscribe/newtopic").await;}测试执行如下命令运行消息代理服务器：
cargo run --bin real-ime-message执行结果：
Broker server running at http://127.0.0.1:3030然后打开一个新的命令行，执行如下命令运行WebSocket客户端：
cargo run --bin ws_cli执行结果：
WebSocket client connected向http://127.0.0.1:3030/produce/newtopic接口发送post请求，如图：
文章插图
图片
客户端接收到消息：
WebSocket client connectedReceived message: This is a new event总结我们已经探索了在Rust中创建一个简单的消息代理，并使用WebSocket客户端对其进行测试 。这个例子突出了Rust在构建高效、并发的网络应用程序方面的能力 。【异步Rust：构建实时消息代理服务器】
推荐阅读
- 如何使用Python、Apache Kafka和云平台构建健壮的实时数据管道
- 构建 Web API 的两种流行选择：REST vs GraphQL
- 在 Rust 编程中使用泛型
- 什么是Rust语言 ，特点是什么，跟其它语言对比有什么优势
- 在 Rust 编程中使用多线程
- JavaScript开发者转向Rust的原因？
- 为什么要学一学 Rust？
- 风扇用电容运转异步电动机接线图
- 构建Flask 数据可视化大屏
- Go 语言使用 Echo 构建高性能 Web 应用