brew install opencv新建一个Rust项目:
cargo new rust-opencv在Cargo.toml文件中加入依赖项:
[dependencies] opencv = "0.84.5"如果出现找不到libclang.dylib的错误,参考下面的解决方法:
mdfind -name libclang.dylib sudo ln -s /usr/local/Cellar/llvm/16.0.6/lib/libclang.dylib /usr/local/lib下面让我们一步一步地分解实现:
use opencv::{ core::{Mat, Vector}, imgcodecs, prelude::*, videoio, }; use std::net::TcpListener; use std::io::Write;首先从OpenCV crate和标准Rust crate中导入必要的依赖项,OpenCV crate用于图像和视频处理。
fn main() { let listener = TcpListener::bind("127.0.0.1:8080").unwrap(); println!("服务器在端口8080上监听 ... "); }3,初始化摄像头
fn main() { ...... let mut cam = videoio::VideoCapture::new(0, videoio::CAP_ANY).expect("视频捕获失败"); let mut frame = Mat::default(); let mut buf = Vector::new(); loop{ // ... } }4,接受客户端连接
fn main() { ...... loop{ let (mut stream, _) = listener.accept().expect("无法接受连接"); } }上面的代码进入一个主循环,在这个主循环中,它不断地监听传入的客户端连接,并为它们提供实时视频帧。
fn main() { ..... loop{ let (mut stream, _) = listener.accept().expect("Failed to accept connection"); cam.read(&mut frame).expect("捕获帧失败"); buf.clear(); let _ = imgcodecs::imencode(".jpg", &frame, &mut buf, &Vector::new()); } }
fn main() { ...... loop{ ...... let response = format!( "HTTP/1.1 200 OK\r\nContent-Type: multipart/x-mixed-replace; boundary=frame\r\n\r\n" ); stream.write_all(response.as_bytes()).unwrap(); } }使用stream.write_all函数响应头被写入客户端的流,这通知客户端,服务器已准备好发送图像帧。
fn main() { ...... loop{ ...... loop { cam.read(&mut frame).expect("捕获帧失败"); buf.clear(); let _ = imgcodecs::imencode(".jpg", &frame, &mut buf, &Vector::new()); let image_data = format!( "--frame\r\nContent-Type: image/jpeg\r\nContent-Length: {}\r\n\r\n", buf.len() ); stream.write_all(image_data.as_bytes()).unwrap(); stream.write_all(buf.as_slice()).unwrap(); stream.write_all(b"\r\n").unwrap(); stream.flush().unwrap(); } } }在内部循环中,服务器再次捕获帧,对其进行编码,并将编码后的数据存储在buf向量中。然后,它为图像构造一个具有适当内容类型和内容长度的HTTP响应。使用stream.write_all函数将图像数据发送到客户端。
use opencv::{ core::{Mat, Vector}, imgcodecs, prelude::*, videoio, }; use std::net::TcpListener; use std::io::Write; fn main() { let listener = TcpListener::bind("127.0.0.1:8080").unwrap(); println!("服务器在端口8080上监听 ... "); let mut cam = videoio::VideoCapture::new(0, videoio::CAP_ANY).expect("视频捕获失败"); let mut frame = Mat::default(); let mut buf = Vector::new(); loop{ let (mut stream, _) = listener.accept().expect("无法接受连接"); cam.read(&mut frame).expect("捕获帧失败"); buf.clear(); let _ = imgcodecs::imencode(".jpg", &frame, &mut buf, &Vector::new()); let response = format!( "HTTP/1.1 200 OK\r\nContent-Type: multipart/x-mixed-replace; boundary=frame\r\n\r\n" ); stream.write_all(response.as_bytes()).unwrap(); loop { cam.read(&mut frame).expect("捕获帧失败"); buf.clear(); let _ = imgcodecs::imencode(".jpg", &frame, &mut buf, &Vector::new()); let image_data = format!( "--frame\r\nContent-Type: image/jpeg\r\nContent-Length: {}\r\n\r\n", buf.len() ); stream.write_all(image_data.as_bytes()).unwrap(); stream.write_all(buf.as_slice()).unwrap(); stream.write_all(b"\r\n").unwrap(); stream.flush().unwrap(); } } }运行
输入“cargo run”命令运行程序,然后打开浏览器,输入IP地址127.0.0.1:8080开始接收视频数据。