Wiki Index

Day 3 코드 command.rs use crate::{Config, Db, ValueEntry}; use tokio::io::AsyncWriteExt; use tokio::net::TcpStream; pub enum Command { PING, ECHO(String), GET(String), SET { key: String, value: String, px: Option<u64>, ex: Option<u64> }, CONFIG(ConfigCommand), } pub enum ConfigCommand { GET(String), } impl Command { pub fn parse_message(message: &str) -> Result<Command, String> { let mut lines = message.lines(); let first_line = lines.next().ok_or("Argument Error : Empty message")?; if first_line.starts_with('*') { let num_args: usize = first_line[1..].parse().map_err(|_| "Invalid array size")?...

About Part 2 저장소와 데이터 검색에 여러 장비가 관여한다면 어떻게 될까? 이번 장에서는 분산 데이터에 대해 다룬다. 여러 장비가 필요한 이유 확장성 : 부하를 분산시킬수 있다. 내결함성/고가용성 : 장애가 발생해도 시스템이 계속 동작할 수 있다. 지연시간 : 사용자 가까이 데이터를 분산시킬 수 있다. 공유 메모리 아키텍처, 공유 디스크 아키텍처 많은 CPU, 메모리, 디스크를 하나의 운영체제로 합친다. 단순한 구조에 어느정도 내결함성을 가진다. 선형적이지 않은 비용증가, 제한적인 내결함성이 단점이다. 비공유 아키텍처 각 장비를 노드로 분류하고, 각각의 컴퓨팅 자원을 독립적으로 사용한다....

1. Code use regex::Regex; use std::collections::HashMap; use std::sync::Arc; use tokio::io::{AsyncReadExt, AsyncWriteExt}; use tokio::net::{TcpListener, TcpStream}; use tokio::sync::RwLock; use tokio::task; type Db = Arc<RwLock<HashMap<String, String>>>; enum Command { PING, ECHO(String), GET(String), SET(String, String), } impl Command { fn parse_message(message: &str) -> Result<Command, String> { let re_ping = Regex::new(r"^\*1\r\n\$4\r\nPING\r\n$").unwrap(); let re_echo = Regex::new(r"^\*2\r\n\$4\r\nECHO\r\n\$(\d+)\r\n(.+)\r\n$").unwrap(); let re_get = Regex::new(r"^\*2\r\n\$3\r\nGET\r\n\$(\d+)\r\n(.+)\r\n$").unwrap(); let re_set = Regex::new(r"^\*3\r\n\$3\r\nSET\r\n\$(\d+)\r\n(.+)\r\n\$(\d+)\r\n(.+)\r\n$").unwrap(); if re_ping.is_match(message) { Ok(Command::PING) } else if let Some(captures) = re_echo.captures(message) { let length: usize = captures[1]....

0. PreRequisite 해당 문서의 참고입니다! https://app.codecrafters.io/concepts/rust-tcp-server std::net 모듈은 TCP 서버를 만들기 위한 모듈이다. 그리고 아래의 다섯가지 메셔드를 주요하게 이용한다. TcpListener::bind : pub fn bind<A: ToSocketAddrs>(addr: A) -> Result<TcpListener> - 주어진 주소에 바인딩된 새로운 TcpListener 인스턴스를 반환한다 TcpListener::incoming : pub fn incoming(&self) -> Incoming - 이 리스너로 들어오는 coneection에 대한 iterator를 반환한다. TcpStream::connect : pub fn connect<A: ToSocketAddrs>(addr: A) -> Result<TcpStream> - 주어진 주소로 연결된 새로운 TcpStream 인스턴스를 반환한다. TcpStream::read : pub fn read(&mut self, buf: &mut [u8]) -> Result<usize> - 스트림에서 데이터를 읽어서 주어진 버퍼에 저장한다....

Build Redis With Rust 🦀 이건 코드크래프터스 에서 진행하는 프로젝트를 따라하면서 작성한 문서입니다. 전적으로 제가 작성한 코드와 저의 생각만 포스팅을 할 예정입니다. 주요한 가이드는 직접 위 사이트에서 확인해주세요. Github-Repo Redis-Protocol [[Rust-Redis-D1]] [[Rust-Redis-D2]] [[Rust-Redis-D3]] [[Rust-Redis-D4]] Trouble Shootings [[Redis-Handshake-For-Replicas]] : 레플리카(슬레이브) 등록을 위한 HandShake중 클라이언트를 식별하는 이슈 [[Redis-Stream-Issue]]

4장 부호화와 발전 어플리케이션의 변경과 변화에 대응하는 방법을 소개하는 장. 일단 먼저 대규모 어플리케이션 변화에 있어 장애물이 되는 부분은 크게 아래와같다. 데이터타입이나 스키마가 변경되는 경우 서버측에서는 순회식 업그레이드를 진행한다. 클라이언트측 어플리케이션은 사용자에 전적으로 좌우된다. 어떤 사용자는 한동안 업그레이드를 하지 않을 수도 있다. 즉 예전버전의 코드와 새로운 버전의 코드, 이전의 데이터타입과 새로운 데이터타입 이 시스템에 공존 할 수 있다는 것이다. 그래서 시스템에는 양방향의 호환성이 필요하다. 하위 호환성 : 새로운 코드는 이전 코드가 기록한 데이터를 읽을 수 있어야 한다....

러스트 관련 모든 문서의 Index 🗂️

저장소와 검색 데이터베이스의 가장 중요한 두가지 추상화는 쓰기/읽기이다. 그리고 이 두가지 성능은 항상 Trade-off 관계에 있다. 그 Trade-off 관계를 이해하는 것과, 가장 대표적인 저장소 엔진인 로그구조(Log-Structured) 저장소 엔진과 B-트리 같은 페이지지향(page-oriented) 저장소 엔진을 비교하는 것이 이 장의 목표이다. 데이터베이스를 강력하게 만드는 데이터 구조 #!/bin/bash db_set () { echo "$1,$2" >> database } db_get () { grep "^$1," database | sed -e "s/^$1,//" | tail -n 1 // 특정 키에 대한 마지막 값을 가져온다....

13.0.0 Functional Languages Features: Iterators and Closures Rust의 디자인과 기능은 함수형 프로그래밍에서 영감을 받았습니다. 함수형 스타일로 프로그래밍하는 것은 종종 함수를 값으로 사용하여 인수로 전달하거나, 다른 함수에서 반환하거나, 나중에 실행하기 위해 변수에 할당하는 등의 작업을 포함합니다. 이 장에서는 함수형 프로그래밍이 무엇인지 아닌지에 대해 논쟁하지 않고, 대신 함수형이라고 불리는 많은 언어의 기능과 유사한 Rust의 일부 기능에 대해 논의할 것입니다. 요약하자면 러스트의 디자인과 기능은 함수형 프로그래밍에서도 영감을 받았다. 하지만 뭐가 함수형인지 논의하는것보다는 많은 언어들에서 함수형 언어로 일컫어지는 기능들이 러스트에서 어떻게 사용할 수 있는지 알아본다고 한다....

공통 종작은 타입 시스템으로 표현하라