使用铁框架，如何退出监听循环？

Question

我在一个需要交互查询的大型文本文件周围有一个简单的休息类皮肤。它可能涉及繁重的计算，所以我使用了 rust。我已经用铁制作了一个简单的宁静皮肤。请注意，我没有对生锈做太多事情。这只是在本地主机上运行。

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

并让监听函数退出，然后进行一些日志记录，然后继续。这有可能做到这一点吗？我尝试过恐慌，但即使这样也不会退出监听循环？

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

status::ServiceUnavailable 只是随机的 - 它需要一些东西：我知道它在语义上不正确，不知道该使用什么。但是该错误上没有任何处理程序，因此它会默默消失。

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

Answer 1

一种方法是在处理程序和启动服务器的线程之间设置消息。消息发送时，主线程可以调用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...");
}

Answer 2

如果所有其他方法都失败了，并且没有人可以给您更好的答案（换句话说：这应该是最后的选择）：std::process::exit 应该以一种或另一种方式解决问题。请记住，这只是立即退出进程，因此根本没有进行任何清理。