鱼C论坛

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

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

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

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

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

x
客户端发送66(int32),服务端判断是奇偶并返回Boolean
use std::{io::{Read, Write}, os::unix::net::{UnixListener, UnixStream}};

#[derive(serde::Serialize, serde::Deserialize, Debug)]
enum Message {
    I32(i32),
    Bool(bool)
}

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

#[test]
fn unix_socket_server() -> Result<(), Box<dyn std::error::Error>> {
    let listener = UnixListener::bind(UNIX_SOCK_ADDR)?;
    for mut stream in listener.incoming().flatten() {
        //stream.recv_vectored_with_ancillary(bufs, ancillary);
        let mut read_buffer = Vec::new();
        stream.read_to_end(&mut read_buffer)?;
        let request: Message = bincode::deserialize(&read_buffer[..])?;
        println!("Server Incomming Request: {:?}", request);
        let response = match request {
            Message::I32(int) => Message::Bool(int % 2 == 1),
            _ => panic!("unsupported message type")
        };
        println!("Server Preprare Reponse: {:?}", response);
        // stream.write(&bincode::serialize(&response)?)?;
        // stream.flush()?;
        stream.shutdown(std::net::Shutdown::Both);
    }
    Ok(())
}

#[test]
fn unix_socket_client() -> Result<(), Box<dyn std::error::Error>> {
    let mut stream = UnixStream::connect(UNIX_SOCK_ADDR)?;
    let request = Message::I32(66);
    stream.write(&bincode::serialize(&request)?)?;
    stream.flush()?;
    Ok(())
}
想知道小甲鱼最近在做啥?请访问 -> ilovefishc.com
回复

使用道具 举报

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

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

GMT+8, 2024-11-22 09:42

Powered by Discuz! X3.4

© 2001-2023 Discuz! Team.

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