- iOS/Objective-C 元类和类别
- objective-c - -1001 错误,当 NSURLSession 通过 httpproxy 和/etc/hosts
- java - 使用网络类获取 url 地址
- ios - 推送通知中不播放声音
这是对我之前的问题 here 的扩展,带有代码的“最小可行示例”。
我开发了一个 UDPClient 和 UDPServer 应用程序,如下所示。这些应用程序与 boost official udp client 和 boost official udp server 非常相似:
UDPClient.cpp
#include <iostream>
#include <algorithm>
#include <boost/asio.hpp>
using boost::asio::ip::udp;
struct Person {
char name[1024];
int age;
};
int main(int argc, char* argv[]) {
// Turn this variable TRUE on to send structs of "Person"
bool send_structs = false;
try {
if (argc != 2) {
std::cerr << "Usage: client <host>" << std::endl;
return 1;
}
boost::asio::io_service io_service;
udp::resolver resolver(io_service);
udp::resolver::query query(udp::v4(), argv[1], "7123");
udp::endpoint receiver_endpoint = *resolver.resolve(query);
udp::socket socket(io_service);
socket.open(udp::v4());
for (;;) {
if (send_structs == true) {
// Send structs
Person send_data = { "something_from_client", 123 };
boost::system::error_code ignored_error;
socket.send_to(boost::asio::buffer(&send_data, sizeof(send_data)), receiver_endpoint, 0, ignored_error);
udp::endpoint sender_endpoint;
Person receive_data;
std::size_t len = socket.receive_from(boost::asio::buffer(&receive_data, sizeof(receive_data)), sender_endpoint);
std::cout << "After receiving at client header is " << receive_data.name << std::endl;
std::cout << "After receiving at client version is " << receive_data.age << std::endl;
}
else {
// Send & receive char vectors
std::vector<unsigned char> send_data(1024);
std::string str = "Hello from Client";
std::copy (str.begin(),str.begin(), send_data.begin());
boost::system::error_code ignored_error;
std::cout << "Before sending vector length is " << send_data.size() << std::endl;
socket.send_to(boost::asio::buffer(send_data.data(), send_data.size()), receiver_endpoint, 0, ignored_error);
udp::endpoint sender_endpoint;
std::vector<unsigned char> receive_data;
receive_data.resize(1024);
std::size_t bytes_rec = socket.receive_from(boost::asio::buffer(receive_data), sender_endpoint);
std::cout << "After receiving at client vector size is " << receive_data.size() << std::endl;
std::cout << "Received bytes at client are " << bytes_rec << std::endl;
}
}
}
catch (std::exception& e) {
std::cerr << e.what() << std::endl;
}
return 0;
}
UDPServer.cpp
#include <iostream>
#include <algorithm>
#include <boost/asio.hpp>
using boost::asio::ip::udp;
struct Person {
char name[1024];
int age;
};
int main() {
// Turn this variable TRUE on to send structs of "Person"
bool send_structs = false;
try {
boost::asio::io_service io_service;
udp::socket socket(io_service, udp::endpoint(udp::v4(), 7123));
for (;;) {
udp::endpoint remote_endpoint;
if (send_structs == true) {
// Send structs
boost::system::error_code error;
Person receive_data;
size_t len = socket.receive_from(boost::asio::buffer(&receive_data, sizeof(receive_data)), remote_endpoint, 0, error);
std::cout << "After receiving at server header is " << receive_data.name << std::endl;
std::cout << "After receiving at server version is " << receive_data.age << std::endl;
if (error && error != boost::asio::error::message_size)
throw boost::system::system_error(error);
boost::system::error_code ignored_error;
Person send_data = { "something_from_server", 456 };
socket.send_to(boost::asio::buffer(&send_data, sizeof(send_data)), remote_endpoint, 0, ignored_error);
}
else {
// Send & receive char vectors
boost::system::error_code error;
std::vector<unsigned char> receive_data;
receive_data.resize(1024);
std::size_t bytes_rec = socket.receive_from(boost::asio::buffer(receive_data), remote_endpoint, 0, error);
std::cout << "Bytes received at server are " << bytes_rec << std::endl;
std::cout << "After receiving at server vector length is " << receive_data.size() << std::endl;
if (error && error != boost::asio::error::message_size)
throw boost::system::system_error(error);
boost::system::error_code ignored_error;
std::vector<unsigned char> send_data(1024);
std::string str = "Hello from Server";
std::copy (str.begin(),str.begin(), send_data.begin());
std::cout << "Before sending vector length is " << send_data.size() << std::endl;
std::size_t bytes_sent = socket.send_to(boost::asio::buffer(send_data.data(), send_data.size()), remote_endpoint, 0, ignored_error);
std::cout << "Bytes sent from server are " << bytes_sent << std::endl;
}
}
}
catch (std::exception& e) {
std::cerr << e.what() << std::endl;
}
return 0;
}
我正在使用以下编译命令在 clang OSX 上构建应用:
clang++ -std=c++14 -lboost_system UDPClient.cpp -o UDPClient
clang++ -std=c++14 -lboost_system UDPServer.cpp -o UDPServer
像这样在控制台上
运行 应用程序。在客户端启动之前先运行服务器:
./UDPServer
./UDPClient <host_ip>
问题是:
当我通过在两侧将 bool 标志 send_structs
设置为 true
来发送结构时,它可以很好地发送结构。但是,当我在两侧将 send_structs
设置为 false 并尝试使用相同的技术发送 std::vector<unsigned char>
时,奇怪的是它不起作用。
那么,如何使用 boost asio 通过 UDP 套接字发送 std::vector
的 unsigned char
?
服务器应用日志快照:
After receiving at server vector length is 0
Before sending vector length is 1024
Bytes sent from server are 1024
Bytes received at server are 0
After receiving at server vector length is 0
Before sending vector length is 1024
Bytes sent from server are 1024
Bytes received at server are 0
After receiving at server vector length is 0
客户端应用日志快照:
Before sending vector length is 1024
After receiving at client vector size is 0
Received bytes at client are 0
Before sending vector length is 1024
After receiving at client vector size is 0
可以看到,接收到 vector 后长度为零!!
PS:我还注意到,在发送结构时,当我首先启动服务器时,它会一直等到客户端打开套接字。 但是,当发送 vector 时,服务器只是盲目地循环发送。这是我的代码错误还是预期行为? (次要问题)
最佳答案
如果你想接收到一个 vector ,你将不得不调整缓冲区的大小以指示你想要接收多少。这正是这个答案中发生的事情:boost asio write/read vector
现在,这个:
std::vector<unsigned char> receive_data;
std::size_t bytes_rec = socket.receive_from(boost::asio::buffer(receive_data), sender_endpoint);
要求接收0字节(因为接收缓冲区的大小为0)。
您可能知道预期的数据报大小。否则,您可以简单地增加缓冲区的尺寸,因为接收到的 bytes_rec
会告诉您已接收到多少元素。
关于c++ - 如何使用 boost asio 通过 UDP 套接字发送 std::vector of unsigned char?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/43891849/
我刚刚了解了 udp 校验和计算。 但我很困惑算法是否检测到所有错误。 最佳答案 当然不是。没有校验和可以检测到所有错误。 关于udp - UDP 校验和是否检测到所有错误?,我们在Stack Ove
下面这个函数有什么问题?? 它应该抛出错误,因为我没有在本地主机上运行 UDP 服务器。 int openUdpSocket(int port) { int sock,sin_size;
我正在尝试修改这两个程序。我想让 udpclient.c 能够接收消息并让 udpserver.c 将消息回显给客户端。我还想在 udpclient 发送消息之前先获取它们的时间标记消息。收到的消息应
我有相当简单的 UDP 服务器写在 c 上。 有时我需要知道在套接字中排队的所有 udp 数据包(字节)的当前长度。 据我了解,getsockopt 没有得到这样的信息。 欢迎使用 Linux 和 F
除了直播音乐/视频外,谁能告诉在哪里使用 UDP 协议(protocol)? UDP 的默认用例是什么? 最佳答案 其他任何您需要性能但如果数据包在途中丢失时可以生存的东西。例如,多人游戏浮现在脑海中
与 TCP 的监视方法相反,UDP 是否会在所有数据包可用时立即发送它们? 谢谢。 最佳答案 TCP 有拥塞控制,UDP 没有,因为它是无连接的。 但是您的问题涉及多个问题:发送消息是否会导致立即发送
我知道 UDP 本质上是不可靠的,但是当连接到 localhost 时,我希望内核以不同的方式处理连接,因为一切都可以在内部处理。那么在这种特殊情况下,UDP 是否被认为是一种可靠的协议(protoc
我正在尝试使用 flash 和 rtmfp 协议(protocol)开发一个实时视频聊天应用程序,但我有疑问rtmfp 如何保证连接对等点,尤其是当对等点位于不同网络时。 最佳答案 RTMFP 依靠中
我发现所有使用 Netty 4.0 的 TCP 服务器实现都使用了 ServerBootstrap 实例。 The biggest and only difference between a serv
对于个人 MMO 游戏项目,我正在 java 中实现一个自制的可靠的基于 UDP 的协议(protocol)。鉴于我当前的设置,我相信窥探者劫持 session 相对简单,因此为了防止这种情况,我借此
我正在尝试手动计算各种 UDP 数据包的校验和,但与 Wireshark 中显示的结果相比,我总是得到错误的结果。下面是我如何做到这一点的示例: Source Address: 192.168.0.1
我正在尝试手动计算各种 UDP 数据包的校验和,但与 Wireshark 中显示的结果相比,我总是得到错误的结果。下面是我如何做到这一点的示例: Source Address: 192.168.0.1
我有一个奇怪的问题。我有一个成功运行的 C++ (boost asio) P2P 应用程序,它可以在大多数 NAT 上运行。问题是,当我将初始启动端口号指定为 1000 时,它会检查 1000 是否空
带有数据源的短 radio 链路,需要通过 IPv6 的 1280 Kbps 吞吐量,使用 UDP 停止和等待协议(protocol),该区域内没有其他客户端或明显的噪声源。我到底如何才能计算出最佳数
似乎可以在没有有效负载的情况下发送 UDP 数据包。 我能想到的唯一不需要有效载荷的就是用于 NAT 打洞。 这还能用来做什么? 这与我之前的问题有关Under Linux, can recv eve
我有一个客户端,我无法更改其代码 - 但我想(重新)使用 编写代码ZeroMQ socket 。 客户端同时使用原始 TCP 和原始 UDP socket 。 我知道我可以使用 ZMQ_ROUTER_
网络 4.0.24 我通过 UDP 传递 XML。收到 UPD 数据包时,数据包的长度始终为 2048,截断消息。尽管如此,我尝试将接收缓冲区大小设置为更大的值(4096、8192、65536),但它
我正在尝试编写一个有关 UDP 连接的简单程序来了解它们。我已经实现了一些基本的事情,但是当我尝试发送并取回我发送的内容时,我遇到了一些问题,例如, 当我这样做时;发送一个字符串 “asd”到服务器我
当我检查时,我在 UDP 客户端每 100 毫秒从服务器发送 UDP 数据包 接收频率不等于 100 毫秒,有时它要少得多,例如 3 毫秒…10 毫秒。 我知道UDP client server是异步
海友我是一个学习winsock2的新手。以下是我的udp服务器和客户端程序。 我这个程序客户端不知道服务器的IP地址,只知道端口。但是服务器会在整个网络中广播一条消息。 当客户端收到消息时,它会回溯服
我是一名优秀的程序员,十分优秀!