- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我正在研究 Tokio 和 Rust,举个例子,我正在尝试编写一个简单的 UDP 代理,它只接受一个套接字上的 UDP 数据包并将其发送到多个其他目的地。但是,我偶然发现需要将接收到的数据包发送到多个地址的情况,但我不确定如何以惯用的方式执行此操作。
到目前为止我的代码:
extern crate bytes;
extern crate futures;
use std::net::SocketAddr;
use tokio::codec::BytesCodec;
use tokio::net::{UdpFramed, UdpSocket};
use tokio::prelude::*;
fn main() {
let listen_address = "127.0.0.1:4711".parse::<SocketAddr>().unwrap();
let forwarder = {
let socket = UdpSocket::bind(&listen_address).unwrap();
let peers = vec![
"192.168.1.136:4711".parse::<SocketAddr>().unwrap(),
"192.168.1.136:4712".parse::<SocketAddr>().unwrap(),
];
UdpFramed::new(UdpSocket::bind(&listen_address).unwrap(), BytesCodec::new()).for_each(
move |(bytes, _from)| {
// These are the problematic lines
for peer in peers.iter() {
socket.send_dgram(&bytes, &peer);
}
Ok(())
},
)
};
tokio::run({
forwarder
.map_err(|err| println!("Error: {}", err))
.map(|_| ())
});
}
有问题的线路正在尝试使用新绑定(bind)的套接字将接收到的数据包发送到多个其他地址。
现有示例都将数据包转发到单个目的地,或者在内部使用 mpsc channel 在内部任务之间进行通信。我不认为这是必要的,而且不必为每个监听套接字生成多个任务就可以做到。
更新:感谢@Ömer-erden,我得到了这段有效的代码。
extern crate bytes;
extern crate futures;
use std::net::SocketAddr;
use tokio::codec::BytesCodec;
use tokio::net::{UdpFramed, UdpSocket};
use tokio::prelude::*;
fn main() -> Result<(), Box<dyn std::error::Error>> {
let listen_address = "0.0.0.0:4711".parse::<SocketAddr>()?;
let socket = UdpSocket::bind(&listen_address)?;
let peers: Vec<SocketAddr> = vec!["192.168.1.136:8080".parse()?, "192.168.1.136:8081".parse()?];
let (mut writer, reader) = UdpFramed::new(socket, BytesCodec::new()).split();
let forwarder = reader.for_each(move |(bytes, _from)| {
for peer in peers.iter() {
writer.start_send((bytes.clone().into(), peer.clone()))?;
}
writer.poll_complete()?;
Ok(())
});
tokio::run({
forwarder
.map_err(|err| println!("Error: {}", err))
.map(|_| ())
});
Ok(())
}
注意:
没有必要为每个start_send
调用poll_completion
:它只需要在所有start_send
被调度后调用.
由于某种原因,peer
的内容在调用之间被删除(但没有编译器错误),生成错误 22(这通常是因为给了一个错误的地址发送到(2)
).
在调试器中,很明显第二次,对等地址指向无效内存。我选择克隆 peer
。
我删除了对 unwrap()
的调用并改为向上传播 Result
。
最佳答案
您的代码有一个逻辑错误:您试图绑定(bind)同一个地址两次,分别作为发送者和接收者。相反,您可以使用流和接收器。 UdpFramed
具有提供该功能的功能,请参阅 Sink
:
A
Sink
is a value into which other values can be sent, asynchronously.
let listen_address = "127.0.0.1:4711".parse::<SocketAddr>().unwrap();
let forwarder = {
let (mut socket_sink, socket_stream) =
UdpFramed::new(UdpSocket::bind(&listen_address).unwrap(), BytesCodec::new()).split();
let peers = vec![
"192.168.1.136:4711".parse::<SocketAddr>().unwrap(),
"192.168.1.136:4712".parse::<SocketAddr>().unwrap(),
];
socket_stream.for_each(move |(bytes, _from)| {
for peer in peers.iter() {
socket_sink.start_send((bytes.clone().into(), *peer));
socket_sink.poll_complete();
}
Ok(())
})
};
tokio::run({
forwarder
.map_err(|err| println!("Error: {}", err))
.map(|_| ())
});
关于sockets - 使用 Tokio futures 的多播 UDP 数据包,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/56578876/
我是一名优秀的程序员,十分优秀!