基于Actix Web的Rust REST API能否同时处理HTTP与原始TCP请求？

完全可以实现，不需要依赖外部中转脚本。Actix Web基于Actix Runtime，而Actix生态提供的actix-net库可处理原始TCP连接，两者能共享同一个异步运行时，在同一个二进制文件里同时启动HTTP服务和TCP服务。

实现步骤 #

1. 调整依赖

在Cargo.toml中添加必要的依赖：

[dependencies]
actix-web = "4"
actix-net = "0.10"
bytes = "1"
futures-util = "0.3"

2. 编写TCP服务逻辑

实现TCP监听服务，处理GPS追踪器的连接和数据上报：

use actix_net::TcpListener;
use bytes::BytesMut;
use futures_util::{SinkExt, StreamExt};
use std::io;

// 处理单个TCP连接的业务逻辑
async fn handle_tcp_connection(stream: actix_net::TcpStream) -> io::Result<()> {
    let mut stream = stream.into_split();

    loop {
        let mut buf = BytesMut::with_capacity(1024);
        // 按换行读取追踪器发送的文本数据（可根据实际协议调整分隔符）
        match stream.reader.read_until(b'\n', &mut buf).await {
            Ok(0) => break, // 连接关闭
            Ok(_) => {
                // 解析并处理GPS数据（替换为你的实际业务逻辑）
                let gps_data = String::from_utf8_lossy(&buf).trim().to_string();
                println!("收到GPS数据: {}", gps_data);

                // 可选：向追踪器发送响应（如ACK确认）
                stream.writer.write_all(b"ACK\r\n").await?;
                stream.writer.flush().await?;
            }
            Err(e) => {
                eprintln!("TCP连接错误: {}", e);
                break;
            }
        }
    }

    Ok(())
}

// 启动TCP监听服务
async fn run_tcp_server() -> io::Result<()> {
    let listener = TcpListener::bind("0.0.0.0:8081").await?;
    println!("TCP服务监听端口 8081");

    while let Ok((stream, addr)) = listener.accept().await {
        println!("新的TCP连接: {}", addr);
        // 为每个连接启动独立异步任务，避免阻塞其他连接或HTTP服务
        actix_rt::spawn(async move {
            if let Err(e) = handle_tcp_connection(stream).await {
                eprintln!("TCP连接处理失败: {}", e);
            }
        });
    }

    Ok(())
}

3. 整合HTTP与TCP服务

在同一个main函数中同时启动Actix Web的HTTP服务和TCP服务：

use actix_web::{get, App, HttpResponse, HttpServer, Responder};

// 示例HTTP接口
#[get("/")]
async fn hello() -> impl Responder {
    HttpResponse::Ok().body("HTTP API服务运行中")
}

#[actix_web::main]
async fn main() -> io::Result<()> {
    // 启动TCP服务的异步任务
    let tcp_server = run_tcp_server();
    // 启动HTTP服务
    let http_server = HttpServer::new(|| {
        App::new()
            .service(hello)
            // 添加你的其他HTTP路由和中间件
    })
    .bind(("0.0.0.0", 8080))?
    .run();

    // 等待两个服务同时运行，任意一个退出则终止程序
    futures_util::future::join(tcp_server, http_server).await.0
}

关键说明 #

• 两者共享Actix Runtime，无需额外线程或进程切换，性能远高于外部中转方案。
• TCP连接的处理逻辑可直接访问HTTP服务的共享资源（如数据库连接池），通过Arc或Actix的Data机制实现，避免跨进程通信开销。
• 可根据GPS追踪器的实际协议调整数据读取逻辑（比如部分设备使用固定长度报文，而非换行分隔）。

内容的提问来源于stack exchange，提问作者Guerreiro