diff options
| author | Weicao-CatilGrass <1992414357@qq.com> | 2025-04-21 03:45:51 +0800 |
|---|---|---|
| committer | Weicao-CatilGrass <1992414357@qq.com> | 2025-04-21 03:45:51 +0800 |
| commit | d72d700c84794ca420035ceb9c294563f3f9c048 (patch) | |
| tree | 0681ae2710d39229d0a583a74410b5d36dab67ed /core/src/pads_server.rs | |
| parent | f582dc68040ac96e9cea611c0e1b5b6fb740b311 (diff) | |
.
Diffstat (limited to 'core/src/pads_server.rs')
| -rw-r--r-- | core/src/pads_server.rs | 21 |
1 files changed, 20 insertions, 1 deletions
diff --git a/core/src/pads_server.rs b/core/src/pads_server.rs index a9f3acb..d10a88b 100644 --- a/core/src/pads_server.rs +++ b/core/src/pads_server.rs @@ -1,4 +1,6 @@ +use std::net::{SocketAddr, UdpSocket}; use std::time::Duration; +use bincode::Encode; use crate::pads_player::{PlayerInfo, PlayerMessage}; /// # 监听服务器 @@ -27,7 +29,24 @@ impl PadServer { /// self : 服务器 /// event : 事件 pub fn start_listening(&self, event : impl PadServerEvent) { - + let socket_addr = SocketAddr::from(([127, 0, 0, 1], self.port)); + match UdpSocket::bind(socket_addr) { + Ok(socket) => { + let mut buf = vec![0u8; 1024]; + + loop { + // 接收连接请求 + match socket.recv_from(&mut buf) { + Ok((size, src)) => { + + } + Err(_) => {} + } + } + } + + Err(_) => {} + } } /// # 停止监听服务器 |
