UnixSocket编程双工通信例子

Arduino极客

客户端发送66(int32),服务端判断是奇偶并返回Boolean

1. use std::{io::{Read, Write}, os::unix::net::{UnixListener, UnixStream}};
   
2. 
   
3. #[derive(serde::Serialize, serde::Deserialize, Debug)]
   
4. enum Message {
   
5.     I32(i32),
   
6.     Bool(bool)
   
7. }
   
8. 
   
9. const UNIX_SOCK_ADDR: &str = "/home/w/temp/my_sock.sock11";
   
10. 
    
11. #[test]
    
12. fn unix_socket_server() -> Result<(), Box<dyn std::error::Error>> {
    
13.     let listener = UnixListener::bind(UNIX_SOCK_ADDR)?;
    
14.     for mut stream in listener.incoming().flatten() {
    
15.         //stream.recv_vectored_with_ancillary(bufs, ancillary);
    
16.         let mut read_buffer = Vec::new();
    
17.         stream.read_to_end(&mut read_buffer)?;
    
18.         let request: Message = bincode::deserialize(&read_buffer[..])?;
    
19.         println!("Server Incomming Request: {:?}", request);
    
20.         let response = match request {
    
21.             Message::I32(int) => Message::Bool(int % 2 == 1),
    
22.             _ => panic!("unsupported message type")
    
23.         };
    
24.         println!("Server Preprare Reponse: {:?}", response);
    
25.         // stream.write(&bincode::serialize(&response)?)?;
    
26.         // stream.flush()?;
    
27.         stream.shutdown(std::net::Shutdown::Both);
    
28.     }
    
29.     Ok(())
    
30. }
    
31. 
    
32. #[test]
    
33. fn unix_socket_client() -> Result<(), Box<dyn std::error::Error>> {
    
34.     let mut stream = UnixStream::connect(UNIX_SOCK_ADDR)?;
    
35.     let request = Message::I32(66);
    
36.     stream.write(&bincode::serialize(&request)?)?;
    
37.     stream.flush()?;
    
38.     Ok(())
    
39. }

复制代码