redis-event
用于监听Redis的写入操作,据此可以实现数据复制,监控等相关的应用。
[dependencies]
redis-event = "1.2.1"
原理
此crate实现了Redis Replication协议,在运行时,程序将以replica的身份连接到Redis,相当于Redis的一个副本。
所以,在程序连接上某个Redis之后,Redis会将它当前的所有数据以RDB的格式dump一份,dump完毕之后便发送过来,这个RDB中的每一条数据就对应一个Event::RDB
事件。
在这之后,Redis接收到来自客户端的写入操作(即Redis命令)后,也会将这个写入操作传播给它的replica,每一个写入操作就对应一个Event::AOF
事件。
示例
use std::net::{IpAddr, SocketAddr};
use std::sync::atomic::AtomicBool;
use std::sync::Arc;
use std::str::FromStr;
use std::rc::Rc;
use std::cell::RefCell;
use std::io;
use redis_event::listener;
use redis_event::config::Config;
use redis_event::{NoOpEventHandler, RedisListener};
fn main() -> io::Result<()> {
let host = String::from("127.0.0.1");
let port = 6379;
let conf = Config {
is_discard_rdb: false, is_aof: false, host,
port,
username: String::new(), password: String::new(), repl_id: String::from("?"), repl_offset: -1, read_timeout: None, write_timeout: None, is_tls_enabled: false, is_tls_insecure: false, identity: None, identity_passwd: None };
let running = Arc::new(AtomicBool::new(true));
let mut builder = listener::Builder::new();
builder.with_config(conf);
builder.with_control_flag(running);
builder.with_event_handler(Rc::new(RefCell::new(NoOpEventHandler{})));
let mut redis_listener = builder.build();
redis_listener.start()?;
Ok(())
}