Rust websocket 客户端实现

目前rust websocket文档较少，最近为了实现部分工作需要使用rust去做websocket链接网上找了不少，很多没有太多参考价值，websocket 在rust中要保持长连接，期间需要不停的去ping，不然会中断，但是使用线程在常规情况下闭包又无法在循环数据的时候持续的ping，所以引入了一下第三方包。

Cargo.toml

[dependencies]
tokio = { version = "1.19.2", features = ["rt", "rt-multi-thread", "macros"] }
websockets= "0.3.0"
futures = "0.3.21"

main.rs

use std::thread;
use std::time::Duration;
use websockets::{WebSocket, WebSocketWriteHalf};#[tokio::main]
async fn main() {// 建立websocket连接let mut ws = WebSocket::connect("wss://xxxxxxx").await.unwrap();let (mut r, mut w) = ws.split();let send_str = "你想提交的内容";w.send_text(send_str.to_string()).await.unwrap();// 定期推送ping，如果想改这里自己建立信息通讯mpsc::channel(0) 发送不同的数据;thread::spawn(move || {loop {// 这里因为是async自己包裹一下不然跑步起来tokio::runtime::Builder::new_multi_thread().enable_all().build().unwrap().block_on(async {// 睡眠定期推送数据thread::sleep(Duration::new(20, 0));w.send_text("ping".parse().unwrap()).await.unwrap();});}});// 循环打印数据loop {let s = r.receive().await.unwrap();let (ss, b, snake_case) = s.as_text().unwrap();println!("Got:{}", ss);}
}

Rust websocket 客户端实现相关推荐

netty websocket客户端_Websocket操作字节序之服务端
Websocket在JavaScript中操作字节序之客户端在上一篇文章中,把页面的websocket编码写好了,那么服务端又该如何实现呢?由于该文是在上上篇demo中修改的,所以不全的代码还请 ...
火币网行情获取的websocket客户端
从验证结果看应该是网络关闭了,不过程序写的不错,可以作为其它websocket客户端的测试程序 # !/usr/bin/env python # -*- coding: utf-8 -*- # aut ...
c++ websocket客户端_你要的websocket都在这，收好不谢~~~
此号已经沉寂多时,似乎已经忘了上一次更新是什么时候了!这一次重拾旧爱,希望能够一直保持下去,坚持写作,快乐你我他今天的主题是websocket,相信搞研发的兄弟对websocket并不陌生,都202 ...
webscoket绑定php uid,Think-Swoole之WebSocket客户端消息解析与使用SocketIO处理用户UID与fd关联...
WebSocket 客户端消息的解析前面我们演示了当客户端连接服务端,会触发连接事件,事件中我们要求返回当前客户端的 fd.当客户端发送消息给服务端,服务端会根据我们的规则将消息发送给指定 fd 的 ...
基于Boost::beast模块的异步WebSocket客户端
基于Boost::beast模块的异步WebSocket客户端实现功能 C++实现代码实现功能基于Boost::beast模块的异步WebSocket客户端 C++实现代码 #include & ...
基于Boost::beast模块的协程WebSocket客户端
基于Boost::beast模块的协程WebSocket客户端实现功能 C++实现代码实现功能基于Boost::beast模块的协程WebSocket客户端 C++实现代码 #include & ...
基于Boost::beast模块的同步WebSocket客户端
Boost:基于Boost::beast模块的同步WebSocket客户端实现功能 C++实现代码实现功能基于Boost::beast模块的同步WebSocket客户端 C++实现代码 #inc ...
netty系列之:使用netty搭建websocket客户端
文章目录简介浏览器客户端 netty对websocket客户端的支持 WebSocketClientHandshaker WebSocketClientCompressionHandler net ...
c++ websocket客户端_python测试开发django81.dwebsocket实现websocket
前言 HTTP 协议有一个缺陷:通信只能由客户端发起,做不到服务器主动向客户端推送信息. WebSocket 协议它的最大特点就是,服务器可以主动向客户端推送信息,客户端也可以主动向服务器发送信息,是 ...

Rust websocket 客户端实现

Rust websocket 客户端实现

Cargo.toml

Rust websocket 客户端实现相关推荐

最新文章

热门文章