个人中心
文章发布
退出
作者热门文章
- html - 出于某种原因，IE8 对我的 Sass 文件中继承的 html5 CSS 不友好？
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景？
25
4
我正在尝试重写代理 example的 Asynchronous Programming in Rust通过迁移到预订:
futures-preview = { version = "0.3.0-alpha.19", features = ["async-await"]}`
hyper = "0.13.0-alpha.4"`
来自:
futures-preview = { version = "=0.3.0-alpha.17", features = ["compat"] }`
hyper = "0.12.9"
当前示例转换返回的 Future来自futures 0.3进入 futures 0.1 ，因为 hyper = "0.12.9"与 futures 0.3 不兼容的异步/等待。
我的代码:
use {
futures::future::{FutureExt, TryFutureExt},
hyper::{
rt::run,
service::{make_service_fn, service_fn},
Body, Client, Error, Request, Response, Server, Uri,
},
std::net::SocketAddr,
std::str::FromStr,
};
fn forward_uri<B>(forward_url: &'static str, req: &Request<B>) -> Uri {
let forward_uri = match req.uri().query() {
Some(query) => format!("{}{}?{}", forward_url, req.uri().path(), query),
None => format!("{}{}", forward_url, req.uri().path()),
};
Uri::from_str(forward_uri.as_str()).unwrap()
}
async fn call(
forward_url: &'static str,
mut _req: Request<Body>,
) -> Result<Response<Body>, hyper::Error> {
*_req.uri_mut() = forward_uri(forward_url, &_req);
let url_str = forward_uri(forward_url, &_req);
let res = Client::new().get(url_str).await;
res
}
async fn run_server(forward_url: &'static str, addr: SocketAddr) {
let forwarded_url = forward_url;
let serve_future = service_fn(move |req| call(forwarded_url, req).boxed());
let server = Server::bind(&addr).serve(serve_future);
if let Err(err) = server.await {
eprintln!("server error: {}", err);
}
}
fn main() {
// Set the address to run our socket on.
let addr = SocketAddr::from(([127, 0, 0, 1], 3000));
let url = "http://127.0.0.1:9061";
let futures_03_future = run_server(url, addr);
run(futures_03_future);
}
首先，我收到 server 的错误在run_server功能:
the trait
tower_service::Service<&'ais not implemented for
hyper::server::tcp::addr_stream::AddrStream>hyper::service::service::ServiceFn<[closure@src/main.rs:35:35: 35:78
forwarded_url:_], hyper::body::body::Body>
此外，我不能使用 hyper::rt::run因为它可能在 hyper = 0.13.0-alpha.4 中以不同的方式实现.
如果您能告诉我您的修复方法，我将不胜感激。
最佳答案
通过这个issue , 为每个需要创建的连接创建一个新服务 MakeService在 hyper = "0.13.0-alpha.4" 中。您可以使用 make_service_fn 创建带有闭包的 MakeService。
Also, I cannot use
hyper::rt::runbecause it might have been implemented differently inhyper = 0.13.0-alpha.4.
正确，hyper::rt::run 正在调用 tokio::run，它已从 api 中删除，但目前我不知道原因。您可以通过自己调用 tokio::run 或使用 #[tokio::main] 注释来运行您的 future 。为此，您需要将 tokio 添加到您的 cargo 中:
#this is the version of tokio inside hyper "0.13.0-alpha.4"
tokio = "=0.2.0-alpha.6"
然后像这样更改您的 run_server:
async fn run_server(forward_url: &'static str, addr: SocketAddr) {
let server = Server::bind(&addr).serve(make_service_fn(move |_| {
async move { Ok::<_, Error>(service_fn(move |req| call(forward_url, req))) }
}));
if let Err(err) = server.await {
eprintln!("server error: {}", err);
}
}
和主要:
#[tokio::main]
async fn main() -> () {
// Set the address to run our socket on.
let addr = SocketAddr::from(([127, 0, 0, 1], 3000));
let url = "http://www.google.com:80"; // i have tested with google
run_server(url, addr).await
}
关于asynchronous - 如何使用 futures "0.3"和 hyper "0.13.0-alpha.4"编写一个简单的 Rust 异步代理？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/58505000/
25
4
0
来自 Akka 文档，Pipelining and Parallelism Akka Streams processing stages (be it simple operators on Flow
我正在开发一个提取元数据的 chrome 扩展程序。解析元数据的代码包含在内容脚本中。 background.js 和 content.js 通过 sendMessage 请求和响应进行通信。我遇到了
我正在使用 Python 3.7.4 和这段代码(MWE): import asyncio async def foo(x): await asyncio.sleep(1) retur
嘿，我对 Dart Futures 很陌生，我有以下情况。 每当用户在 UI 中键入一个字母时，addressChanged()我的 ui_component 中的方法被调用。该方法调用方法getPr
我在尝试将异步函数转换为同步函数时遇到问题。 这是类中的一个方法: doPost: function(call, data) { var uri = 'http://localhost/api
在很多关于 C# 的 async/await 的讨论中，我看到人们提到了“自然异步”或“纯异步”的术语。这些术语到底是什么意思？ “自然异步”操作的一些示例是什么？为什么这样调用它？ “非自然异步”操
现在我正在使用 Gevent，我想问两个问题: 有没有办法执行特定的任务，这将 从不异步执行 (而不是在每个任务中使用锁) 有没有办法到优先在 Gevent 中生成任务？就像一组将以低优先级生成的任务
在 document , 如果方法也用@gen.coroutine 修饰，则不需要@web.asynchronous。像这样 @web.asynchronous @gen.coroutine def
已在 Google Analytics(分析)帮助论坛中发布此内容，但无人能提供帮助。希望我在这里有更多的运气......: 我对我的网页使用 Google Anlaytics 异步跟踪。像个魔法一样
我正在尝试从 Controller 异步发送电子邮件并收到以下错误: 我不想等待电子邮件发送完成操作。 An asynchronous module or handler completed whil
在使用 SendMailAsync 时出现以下错误: An asynchronous module or handler completed while an asynchronous operati
我有一个非常简单的 ASP.NET MVC 4 Controller : public class HomeController : Controller { private const st
我正在编写一个使用 ASP.NET Web API 代理一些 HTTP 请求的应用程序，我正在努力识别间歇性错误的来源。这似乎是一个竞争条件...但我不完全确定。 在详细介绍之前，先介绍应用程序的一般
Cancel CancellationTokenSource 的成员对象“传达取消请求”，我认为这意味着它是触发并忘记并且不会等到取消完成(例如，所有异常处理程序都已运行)。这很好，但我需要等到一个未
在 D 中异步调用其他进程的首选方法是什么？我的用例正在调用 svn status检查退出状态，并解析其标准输出和错误。 最佳答案 我想 std.stdio.popen是你想要的: void pope
我一直听说使用异步编程模式会使我的代码运行得更快。为什么这是真的？无论是现在运行还是稍后运行，都不是必须以任何一种方式运行完全相同的代码吗？ 最佳答案 它不是更快，它只是不浪费时间。 同步代码在等待
我有点困惑为什么同步调用与异步调用不同，因为从来没有“立即”响应，它仍然需要几纳秒或几毫秒？ 最佳答案 同步调用在完成其工作(或达到超时)后返回其调用者。异步调用在启动其他事件后立即返回。 这意味着，
我正在尝试使用 MSDN 上描述的 OVERLAPPED 结构异步调用 DeviceIO 函数。 我正在使用 FSCTL_ENUM_USN_DATA 控制代码来枚举 NTFS 驱动器的 MFT，但我无
我一直在尝试创建一个服务器进程，以异步方式从客户端进程接收输入文件路径和输出路径。服务器进行了一些与数据库有关的转换，但是为了简单起见，我们假设它只是将所有内容都转换为大写。这是服务器的一个玩具示例:
我正在编写一个异步方法，它应该异步查询一个端口，直到找到一个，或者在 5 分钟后超时； member this.GetPort(): Async = this._GetPort(DateTim
我是一名优秀的程序员,十分优秀！