День добрый. Понемногу переношу свои питоновские скрипты на Rust, один из них вывод ликвидаций монет из веб сокета. Проблема скорее всего несущественная, однако не понимаю как решить. Код в принципе работает(При условии если в течении 2х минут сокет отдаст порцию данных), однако если будет тишина, а это нормально, ликвидации позиций трейдеров не каждую секунду происходят, то скрипт через 2 минуты разрывает соединение.
use serde_json;
use tungstenite::connect;
use url::Url;
static BINANCE_WS: &str = "wss://fstream.binance.com/ws/btcusdt";
fn main() {
let api_request = ["@forceOrder"];
let binance_url = format!("{}{}", BINANCE_WS, api_request[0]);
let (mut socket, response) =
connect(Url::parse(&binance_url).unwrap()).expect("Can't connect...");
println!("Connected to binance stream.");
println!("HTTP status code: {}", response.status());
println!("Response headers:");
for (ref header, ref header_value) in response.headers() {
println!("- {}: {:?}", header, header_value);
}
loop {
let msg = socket.read_message().expect("Error reading message...");
let msg = match msg {
tungstenite::Message::Text(s) => s,
_ => {
panic!("Error getting text...");
}
};
let parsed: serde_json::Value = serde_json::from_str(&msg).expect("Unable to parse msg...");
println!(
"Coin[{}] == Side[{}] == Price[{}] == Count[{}] ",
parsed["o"]["s"], parsed["o"]["S"], parsed["o"]["p"], parsed["o"]["q"]
);
}
}
Вывод:
Connected to binance stream.
HTTP status code: 101 Switching Protocols
Response headers:
- date: "Sat, 05 Nov 2022 10:31:46 GMT"
- connection: "upgrade"
- upgrade: "websocket"
- sec-websocket-accept: "NFDEuqtSsdgP56Rh0jIqNkGkfxk="
thread 'main' panicked at 'Error getting text...', src/main.rs:42:17
note: run with `RUST_BACKTRACE=1` environment variable to display a backtrace
В общем удалось понять из-за чего падает коннект, между json ответами сервер шлет Ping([],) Правда я не могу сообразить как это в приделах match обработать, в tungstenite есть tungstenite::Message::Ping\Pong но что-то мне это не сильно помогает ))
match msg
, т.е. в msg пришёл какой-то другой вариант, а неText
. Вам нужно посмотреть, что приходит и как-то обработать без panic.