鱼C论坛

 找回密码
 立即注册
查看: 54|回复: 0

[学习笔记] UnixSocket编程双工通信例子

[复制链接]
发表于 2021-6-11 11:04:03 | 显示全部楼层 |阅读模式

马上注册,结交更多好友,享用更多功能^_^

您需要 登录 才可以下载或查看,没有帐号?立即注册

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

  1. use std::{io::{Read, Write}, os::unix::net::{UnixListener, UnixStream}};

  2. #[derive(serde::Serialize, serde::Deserialize, Debug)]
  3. enum Message {
  4.     I32(i32),
  5.     Bool(bool)
  6. }

  7. const UNIX_SOCK_ADDR: &str = "/home/w/temp/my_sock.sock11";

  8. #[test]
  9. fn unix_socket_server() -> Result<(), Box<dyn std::error::Error>> {
  10.     let listener = UnixListener::bind(UNIX_SOCK_ADDR)?;
  11.     for mut stream in listener.incoming().flatten() {
  12.         //stream.recv_vectored_with_ancillary(bufs, ancillary);
  13.         let mut read_buffer = Vec::new();
  14.         stream.read_to_end(&mut read_buffer)?;
  15.         let request: Message = bincode::deserialize(&read_buffer[..])?;
  16.         println!("Server Incomming Request: {:?}", request);
  17.         let response = match request {
  18.             Message::I32(int) => Message::Bool(int % 2 == 1),
  19.             _ => panic!("unsupported message type")
  20.         };
  21.         println!("Server Preprare Reponse: {:?}", response);
  22.         // stream.write(&bincode::serialize(&response)?)?;
  23.         // stream.flush()?;
  24.         stream.shutdown(std::net::Shutdown::Both);
  25.     }
  26.     Ok(())
  27. }

  28. #[test]
  29. fn unix_socket_client() -> Result<(), Box<dyn std::error::Error>> {
  30.     let mut stream = UnixStream::connect(UNIX_SOCK_ADDR)?;
  31.     let request = Message::I32(66);
  32.     stream.write(&bincode::serialize(&request)?)?;
  33.     stream.flush()?;
  34.     Ok(())
  35. }
复制代码
想知道小甲鱼最近在做啥?请访问 -> ilovefishc.com
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

小黑屋|手机版|Archiver|鱼C工作室 ( 粤ICP备18085999号-1

GMT+8, 2021-6-24 19:21

Powered by Discuz! X3.4

Copyright © 2001-2021, Tencent Cloud.

快速回复 返回顶部 返回列表