生锈 – 使用铁框架,如何退出监听循环？

2019年8月6日 222次阅读

我有一个简单的休息类型的皮肤围绕一个大型文本文件,我需要交互式查询.它可能涉及繁重的计算,所以我使用了锈.我用铁做了一个简单的宁静皮肤.请注意,我没有做过很多生锈.这只是在localhost上运行.

pub fn query<'a>(parsed: &'a Parsed, context:&Context) -> {
  // parsed.keys is a hash containing config informtion
  // context is what I query
  let local_port = format!("{}:{}", "localhost", parsed.keys[AS_SERVER]);
  fn test_connect<'a>(r: &'a mut Request, c:&'a Context) -> IronResult<Response> {
    let url = r.url.to_string();
    let result = // some logic
    Ok(Response::with((status::Ok,  format!("requested=\"{}:{}\"\n", url, result))))
  } 
  let mut router = Router::new();
  router.get("*", move |r: &mut Request| test_connect(r, &context));
  let connection_status = Iron::new(router).http(&local_port[..]);
  connection_status.ok().expect("could not connect");
}

现在我的问题是我如何让控件退出监听循环

Iron::new(router).http(&local_port[..]);

我只想说curl http：// localhost / done

并有listen函数退出,所以一些日志记录和继续前进.这可能吗？我已经尝试过恐慌,但即使这样也不会退出监听循环？

我尝试返回像Err(IronError :: new(StringError(url),status :: ServiceUnavailable))

那个状态:: ServiceUnavailable只是随机的东西 – 它需要一些东西：我知道它在语义上不正确,不知道要使用什么.但是错误没有任何处理程序,因此它会默默地消失.

我想我会用aftermiddleware设置一些东西,但我不知道是什么？

最佳答案 一种方法是在处理程序和启动服务器的线程之间设置消息.发送消息时,主线程可以调用
Listening::close

在这个例子中,我使用了Condvar.我希望你也可以使用一个频道,但是无法快速复制和粘贴示例频道并使其正常工作…… ^ _ ^

extern crate iron;

use iron::prelude::*;
use iron::status;

use std::sync::{Arc, Mutex, Condvar};

fn main() {
    // Copied from docs
    let pair = Arc::new((Mutex::new(false), Condvar::new()));
    let pair2 = pair.clone();

    let handler = move |_: &mut Request| {
        // Copied from docs
        let &(ref lock, ref cvar) = &*pair2;
        let mut should_exit = lock.lock().unwrap();
        *should_exit = true;
        cvar.notify_one();

        Ok(Response::with((status::Ok, "Hello World!")))
    };

    // Hold onto the listener
    let mut serv = Iron::new(handler).http("localhost:3210").unwrap();

    println!("Now listening...");

    // Copied from docs
    let &(ref lock, ref cvar) = &*pair;
    let mut should_exit = lock.lock().unwrap();
    while !*should_exit {
        should_exit = cvar.wait(should_exit).unwrap();
    }

    serv.close().unwrap();

    println!("Exiting...");
}
点赞