#fastcgi #fcgi #client #tokio #php

fastcgi-client

Fastcgi client implemented for Rust

13 releases (7 breaking)

0.8.0 Aug 29, 2022
0.7.0 Jun 21, 2021
0.6.1 Mar 1, 2021
0.5.0 Dec 8, 2019
0.3.0 Jul 12, 2019

#120 in Asynchronous

Download history 59/week @ 2022-10-15 91/week @ 2022-10-22 51/week @ 2022-10-29 54/week @ 2022-11-05 58/week @ 2022-11-12 322/week @ 2022-11-19 209/week @ 2022-11-26 237/week @ 2022-12-03 220/week @ 2022-12-10 209/week @ 2022-12-17 44/week @ 2022-12-24 63/week @ 2022-12-31 292/week @ 2023-01-07 106/week @ 2023-01-14 142/week @ 2023-01-21 159/week @ 2023-01-28

722 downloads per month
Used in phper-test

Apache-2.0

34KB
716 lines

fastcgi-client-rs

Rust Crate API

Fastcgi client implemented for Rust, power by tokio.

Installation

Add dependencies to your Cargo.toml by cargo add:

cargo add tokio --features full
cargo add fastcgi-client

Examples

Short connection mode:

use fastcgi_client::{Client, Params, Request};
use std::env;
use tokio::{io, net::TcpStream};

#[tokio::main]
async fn main() {
    let script_filename = env::current_dir()
        .unwrap()
        .join("tests")
        .join("php")
        .join("index.php");
    let script_filename = script_filename.to_str().unwrap();
    let script_name = "/index.php";

    // Connect to php-fpm default listening address.
    let stream = TcpStream::connect(("127.0.0.1", 9000)).await.unwrap();
    let mut client = Client::new(stream);

    // Fastcgi params, please reference to nginx-php-fpm config.
    let params = Params::default()
        .request_method("GET")
        .script_name(script_name)
        .script_filename(script_filename)
        .request_uri(script_name)
        .document_uri(script_name)
        .remote_addr("127.0.0.1")
        .remote_port(12345)
        .server_addr("127.0.0.1")
        .server_port(80)
        .server_name("jmjoy-pc")
        .content_type("")
        .content_length(0);

    // Fetch fastcgi server(php-fpm) response.
    let output = client.execute_once(Request::new(params, &mut io::empty())).await.unwrap();

    // "Content-type: text/html; charset=UTF-8\r\n\r\nhello"
    let stdout = String::from_utf8(output.stdout.unwrap()).unwrap();

    assert!(stdout.contains("Content-type: text/html; charset=UTF-8"));
    assert!(stdout.contains("hello"));
    assert_eq!(output.stderr, None);
}

Keep alive mode:

use fastcgi_client::{Client, Params, Request};
use std::env;
use tokio::{io, net::TcpStream};

#[tokio::main]
async fn main() {
    // Connect to php-fpm default listening address.
    let stream = TcpStream::connect(("127.0.0.1", 9000)).await.unwrap();
    let mut client = Client::new_keep_alive(stream);

    // Fastcgi params, please reference to nginx-php-fpm config.
    let params = Params::default();

    for _ in (0..3) {
        // Fetch fastcgi server(php-fpm) response.
        let output = client.execute(Request::new(params.clone(), &mut io::empty())).await.unwrap();

        // "Content-type: text/html; charset=UTF-8\r\n\r\nhello"
        let stdout = String::from_utf8(output.stdout.unwrap()).unwrap();

        assert!(stdout.contains("Content-type: text/html; charset=UTF-8"));
        assert!(stdout.contains("hello"));
        assert_eq!(output.stderr, None);
    }
}

License

Apache-2.0.

Dependencies

~2.6–7.5MB
~115K SLoC