[GH-ISSUE #2364] Please need more examples. How to properly enable resolver in my tokio project? #971

New issue

Open

opened 2026-03-16 01:08:17 +03:00 by kerem · 1 comment

kerem commented

2026-03-16 01:08:17 +03:00

Owner

Originally created by @Cergoo on GitHub (Aug 20, 2024).
Original GitHub issue: https://github.com/hickory-dns/hickory-dns/issues/2364

Hi,

fn main() -> Result<()>{
    let mut rt = tokio::runtime::Runtime::new().unwrap();
    let _guard = rt.enter();

    rt.block_on(async {
        let resolver = TokioAsyncResolver::tokio(ResolverConfig::default(), ResolverOpts::default());    
        let addr = SocketAddr::from(([127, 0, 0, 1], 8080));
        let listener = TcpListener::bind(addr).await.unwrap();
        println!("sever start");

        loop {
            let (socket, _) = listener.accept().await.unwrap();
            let addr = socket.peer_addr().unwrap();
            rt.spawn(async move {
                let _ = process(socket).await.or_else(|x| {
                    println!("err {:?}", x);
                    Err(x)
                });
            });
            println!("socket close: {:?}", addr);
        }

    })
}


async fn process(mut socket: TcpStream) -> Result<()> {
    let mut buffer = BytesMut::with_capacity(4096);
    if 0 == socket.read_buf(&mut buffer).await? {
        if buffer.is_empty() {
            return Ok(());
        } else {
            return Err("connection reset by peer".into());
        }
    }
    
    let addr = parse_http_head(buffer.borrow())?;
 
   <-      get dns resolv her  ?  ______________________________________________
    
    Ok(())
}

Originally created by @Cergoo on GitHub (Aug 20, 2024). Original GitHub issue: https://github.com/hickory-dns/hickory-dns/issues/2364 Hi, ```rust fn main() -> Result<()>{ let mut rt = tokio::runtime::Runtime::new().unwrap(); let _guard = rt.enter(); rt.block_on(async { let resolver = TokioAsyncResolver::tokio(ResolverConfig::default(), ResolverOpts::default()); let addr = SocketAddr::from(([127, 0, 0, 1], 8080)); let listener = TcpListener::bind(addr).await.unwrap(); println!("sever start"); loop { let (socket, _) = listener.accept().await.unwrap(); let addr = socket.peer_addr().unwrap(); rt.spawn(async move { let _ = process(socket).await.or_else(|x| { println!("err {:?}", x); Err(x) }); }); println!("socket close: {:?}", addr); } }) } async fn process(mut socket: TcpStream) -> Result<()> { let mut buffer = BytesMut::with_capacity(4096); if 0 == socket.read_buf(&mut buffer).await? { if buffer.is_empty() { return Ok(()); } else { return Err("connection reset by peer".into()); } } let addr = parse_http_head(buffer.borrow())?; <- get dns resolv her ? ______________________________________________ Ok(()) } ```

kerem added the

docs

label

2026-03-16 01:08:17 +03:00

kerem commented

2026-03-16 01:08:28 +03:00

Author

Owner

@djc commented on GitHub (Aug 20, 2024):

Well, if you want to use the TokioAsyncResolver from process() you'll at least have to pass a reference to it. Then, I'm guessing you'll want to call lookup_ip() on it.

@djc commented on GitHub (Aug 20, 2024): Well, if you want to use the `TokioAsyncResolver` from `process()` you'll at least have to pass a reference to it. Then, I'm guessing you'll want to call `lookup_ip()` on it.

kerem referenced this issue

2026-03-16 02:27:47 +03:00

[PR #973] [MERGED] add examples to test case in Resolver #1827