CodeBlanks Logo Icon CodeBlanks
Giriş Yap Kayıt Ol

Async web sunucusu

tokio ile paralel istemci işleyen mini bir sunucu yazarsın.

Bitirme görevi: web sunucusu

İleri seviyenin ilk bitirme görevi küçük bir HTTP sunucusu. Gerçek projede tokio::net::TcpListener ve her bağlantı için tokio::spawn kullanılır; alıştırmada aynı yapıyı std thread'leriyle kuruyoruz. HTTP/1.1 metin tabanlıdır: istek satırı, başlıklar, boş satır; yanıt da aynı biçimdedir:

GET / HTTP/1.1\r\n
Host: localhost\r\n
\r\n

HTTP/1.1 200 OK\r\n
Content-Length: 7\r\n
\r\n
merhaba

Sunucu istek satırından yolu okur, başlıkları boş satıra kadar tüketir ve yola göre yanıt verir.

İstek işleyici

İşleyici satır satır okur ve yanıtı tek seferde yazar:

fn istek_isle(akis: TcpStream) -> io::Result<()> {
    let mut okuyucu = BufReader::new(akis.try_clone()?);
    let mut ilk = String::new();
    okuyucu.read_line(&mut ilk)?;
    loop {
        let mut s = String::new();
        okuyucu.read_line(&mut s)?;
        if s == "\r\n" || s.is_empty() { break; }
    }
    let (durum, govde) = match ilk.split_whitespace().nth(1) {
        Some("/") => ("200 OK", "merhaba"),
        _ => ("404 NOT FOUND", "bulunamadı"),
    };
    let mut akis = akis;
    write!(akis, "HTTP/1.1 {durum}\r\nContent-Length: {}\r\n\r\n{govde}", govde.len())
}

Content-Length bayt cinsindendir: Türkçe karakterler iki bayt sayılır, bu yüzden len() kullanılır.

Uygulama HTTP sunucusu

Yukarıdaki istek_isle fonksiyonunu yaz. Sunucuyu bir thread'de incoming().take(2) ile çalıştır. Ana thread / ve /yok için sırayla istek göndersin, yanıtı read_to_string ile okusun; ilk yanıtın durum satırını ve gövdesini, ikincinin durum satırını ayrı satırlara yazdırsın.

Başlangıç kodu

main.rs
use std::io::{self, BufRead, BufReader, Read, Write};
use std::net::{SocketAddr, TcpListener, TcpStream};
use std::thread;

fn main() {
    // buraya yaz
}

Örnek çözüm

main.rs
use std::io::{self, BufRead, BufReader, Read, Write};
use std::net::{SocketAddr, TcpListener, TcpStream};
use std::thread;

fn istek_isle(akis: TcpStream) -> io::Result<()> {
    let mut okuyucu = BufReader::new(akis.try_clone()?);
    let mut ilk = String::new();
    okuyucu.read_line(&mut ilk)?;
    loop {
        let mut s = String::new();
        okuyucu.read_line(&mut s)?;
        if s == "\r\n" || s.is_empty() {
            break;
        }
    }
    let (durum, govde) = match ilk.split_whitespace().nth(1) {
        Some("/") => ("200 OK", "merhaba"),
        _ => ("404 NOT FOUND", "bulunamadı"),
    };
    let mut akis = akis;
    write!(akis, "HTTP/1.1 {durum}\r\nContent-Length: {}\r\n\r\n{govde}", govde.len())
}

fn iste(adres: SocketAddr, yol: &str) -> io::Result<(String, String)> {
    let mut akis = TcpStream::connect(adres)?;
    write!(akis, "GET {yol} HTTP/1.1\r\nHost: localhost\r\n\r\n")?;
    let mut yanit = String::new();
    akis.read_to_string(&mut yanit)?;
    let (bas, govde) = yanit.split_once("\r\n\r\n").unwrap_or((&yanit, ""));
    let durum = bas.lines().next().unwrap_or("").to_string();
    Ok((durum, govde.to_string()))
}

fn main() -> io::Result<()> {
    let dinleyici = TcpListener::bind("127.0.0.1:0")?;
    let adres = dinleyici.local_addr()?;
    thread::spawn(move || {
        for akis in dinleyici.incoming().take(2) {
            let akis = akis.unwrap();
            thread::spawn(move || istek_isle(akis));
        }
    });
    let (durum, govde) = iste(adres, "/")?;
    println!("{}", durum);
    println!("{}", govde);
    let (durum2, _) = iste(adres, "/yok")?;
    println!("{}", durum2);
    Ok(())
}

Beklenen çıktı

HTTP/1.1 200 OK
merhaba
HTTP/1.1 404 NOT FOUND

Soru ve cevaplar

Dersin sorularını cevaplarıyla birlikte inceleyebilirsin. Kendini denemek istersen dersi interaktif olarak çöz.

1 Sunucu başlıkları okumadan bağlantıyı kapatırsa ne olabilir?

  • Yanıt iki kez gider
  • Okunmamış veri yüzünden işletim sistemi bağlantıyı sıfırlayabilir (RST) ve istemci yanıtı alamayabilir Doğru cevap
  • Hiçbir şey
  • Derleme hatası

Açıklama: İsteği sonuna kadar tüketmek, bağlantının düzgün (FIN ile) kapanmasını sağlar.

2 Yolu oku

Soru 
let yol = ilk.split_whitespace().____(1);   // "GET / HTTP/1.1" → Some("/")
Cevap 
let yol = ilk.split_whitespace().nth(1);   // "GET / HTTP/1.1" → Some("/")

Açıklama: nth(1) istek satırının ikinci parçasını, yani yolu verir.

3 İstek ve yanıt

Kavram Anlamı
GET / 200 OK
GET /yok 404 NOT FOUND
Content-Length Bayt sayısı
\r\n\r\n Başlık sonu

İleri seviye bölümündeki tüm dersler

1 async/await

  1. async fn
  2. await
  3. Future traiti
  4. async block
  5. Pin
  6. Özet - async/await

2 Tokio

  1. Tokio runtime
  2. spawn
  3. tokio::sync
  4. tokio::fs
  5. select!
  6. Özet - Tokio

3 Eşzamanlılık

  1. thread::spawn
  2. Mutex<T>
  3. RwLock<T>
  4. Arc<T>
  5. Send ve Sync
  6. Özet - Eşzamanlılık

4 Kanallar

  1. mpsc kanalı
  2. send ve recv
  3. Birden çok üretici
  4. try_recv
  5. tokio::sync::mpsc
  6. Özet - Kanallar

5 Proje: Sohbet sunucusu

  1. TCP dinleyici
  2. İstemci iş parçacığı
  3. Kanal ile mesaj
  4. Broadcast
  5. Arc<Mutex> durumu

6 Unsafe Rust

  1. unsafe bloğu
  2. Ham işaretçiler
  3. unsafe fn
  4. static mut
  5. FFI çağrısı
  6. Özet - Unsafe Rust

7 FFI

  1. extern bloğu
  2. #[repr(C)]
  3. CString ve CStr
  4. Callback
  5. Drop ve cleanup
  6. Özet - FFI

8 Bildirimsel makrolar

  1. macro_rules!
  2. Tekrarlar
  3. Türler
  4. Makro hygieni
  5. println! incelemesi
  6. Özet - Bildirimsel makrolar

9 Prosedürel makrolar

  1. proc_macro cratei
  2. derive makrosu
  3. attribute makrosu
  4. syn ve quote
  5. TokenStream
  6. Özet - Prosedürel makrolar

10 Trait nesneleri

  1. dyn Trait
  2. Box<dyn Trait>
  3. Statik ve dinamik dağıtım
  4. Object safety
  5. &dyn Trait
  6. Özet - Trait nesneleri

11 İleri trait'ler

  1. Associated type
  2. Associated constant
  3. GAT
  4. Supertrait
  5. Newtype pattern
  6. Özet - İleri trait'ler

12 Const generics

  1. [T; N]
  2. const fn
  3. Const trait bound
  4. Min_const_generics
  5. Array ve slice
  6. Özet - Const generics

13 İleri kalıp eşleştirme

  1. Struct kalıpları
  2. Destructuring
  3. @ bağlama
  4. Guard
  5. Binding modları
  6. Özet - İleri kalıp eşleştirme

14 İleri seviye finali

  1. Async web sunucusu
  2. ThreadPool
  3. derive macro
  4. FFI wrapper