如何使用unbounded_channel接收消息后往web前端推消息(web eventsource)
💡
原文中文,约1300字,阅读约需3分钟。
📝
内容提要
这段代码使用Axum框架创建了一个简单的服务器应用,定义了两个路由:SSE请求处理和根路径请求处理。SSE请求处理函数使用无限通道向前端推送消息,每隔3秒发送一次消息和每隔1秒发送一次保活消息。最后,绑定到本地地址并运行服务器。
🎯
关键要点
- 使用Axum框架创建一个简单的服务器应用。
- 定义了两个路由:SSE请求处理和根路径请求处理。
- SSE请求处理函数使用无限通道向前端推送消息。
- 每隔3秒发送一次消息,每隔1秒发送一次保活消息。
- 服务器绑定到本地地址127.0.0.1:3000并运行。
➡️