Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- use std::env;
- use std::net::{SocketAddrV4, TcpStream};
- use std::fs::File;
- use std::io::{Read, Write};
- use std::time::Duration;
- use std::thread::sleep;
- fn main() {
- let usage = "usgae: multi_client ip:port file multi_nums \nex: ./multi_client 10.0.0.68:5555 /dev/shm/idea 100\n";
- let args:Vec<String> = env::args().collect();
- if args.len() != 4 {
- panic!(usage);
- }
- let server_addr:SocketAddrV4 = args[1].parse().unwrap();
- let file_path = &args[2];
- let multi_nums = &args[3].clone();
- let mut connects:Vec<TcpStream> = Vec::new();
- let mut file = File::open(file_path).unwrap();
- let mut file_buf:[u8; 1024] = [0; 1024];
- for _i in 0..multi_nums.parse::<u32>().unwrap(){
- connects.push(TcpStream::connect(server_addr).unwrap());
- }
- sleep(Duration::new(60, 0));
- while file.read(&mut file_buf).unwrap() != 0{
- for mut connect in &connects {
- connect.write(&file_buf).unwrap();
- }
- }
- }
Add Comment
Please, Sign In to add comment