UDP socket编程示例

devtools/2024/10/23 8:39:59/

服务端:

#include <iostream>
#include <cstring>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <unistd.h>const int BUFFER_SIZE = 1024;//TODO 使用多线程处理连接int main()
{int sockfd = socket(AF_INET, SOCK_DGRAM, 0);if (sockfd < 0){std::cerr << "Error opening socket" << std::endl;return 1;}struct sockaddr_in servaddr {};servaddr.sin_family = AF_INET;servaddr.sin_addr.s_addr = INADDR_ANY;servaddr.sin_port = htons(6868);if (bind(sockfd, (const struct sockaddr*)&servaddr, sizeof(servaddr)) < 0){std::cerr << "Error on binding" << std::endl;return 1;}std::cout << "UDP server up and running on port 6868" << std::endl;char buffer[BUFFER_SIZE];struct sockaddr_in clientaddr;socklen_t len = sizeof(clientaddr);while(true){ssize_t recvbytes = recvfrom(sockfd, buffer, BUFFER_SIZE, 0, (struct sockaddr*)&clientaddr, &len);if (recvbytes < 0){std::cerr << "Error receiving message" << std::endl;return 1;}buffer[recvbytes] = '\0';std::cout << "Received message:" << buffer << " from " << inet_ntoa(clientaddr.sin_addr) << std::endl;if (sendto(sockfd, buffer, recvbytes, 0, (const struct sockaddr * )&clientaddr, len) < 0){std::cerr << "Error sending message" << std::endl;return 1;}}close(sockfd);
}

客户端:

#include <iostream>
#include <string>
#include <sys/types.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <unistd.h>const int BUFFER_SIZE = 1024;int main() {// Create a UDP socketint sockfd = socket(AF_INET, SOCK_DGRAM, 0);if (sockfd < 0) {std::cerr << "Error opening socket" << std::endl;return 1;}// Set up the server address structurestruct sockaddr_in servaddr {};servaddr.sin_family = AF_INET; // IPv4servaddr.sin_addr.s_addr = inet_addr("127.0.0.1"); // Server IPservaddr.sin_port = htons(6868); // Port// Message to be sentstd::string message = "Hello, Server!";// Send the message to the serverif (sendto(sockfd, message.c_str(), message.size(), 0, (struct sockaddr *)&servaddr, sizeof(servaddr)) < 0) {std::cerr << "Error sending message" << std::endl;return 1;}std::cout << "Message sent to server." << std::endl;// Receive the message from the serverchar buffer[BUFFER_SIZE];struct sockaddr_in fromaddr;socklen_t fromlen = sizeof(fromaddr);ssize_t recvbytes = recvfrom(sockfd, buffer, BUFFER_SIZE, 0, (struct sockaddr *)&fromaddr, &fromlen);if (recvbytes < 0) {std::cerr << "Error receiving message" << std::endl;return 1;}// Null-terminate the bufferbuffer[recvbytes] = '\0';// Print the received messagestd::cout << "Received message: " << buffer << " from " << inet_ntoa(fromaddr.sin_addr) << std::endl;// Close the socketclose(sockfd);return 0;
}

区别:

  1. 绑定(Bind):

    • 服务端:通常需要调用bind()函数来绑定到一个特定的端口,这样它才能监听发往该端口的数据。在示例中,服务端绑定到端口8888。
    • 客户端:不需要绑定到一个端口,因为它是主动发起连接的一方。在示例中,客户端没有调用bind(),所以它会使用一个临时的源端口。
  2. 接收和发送数据:

    • 服务端:使用recvfrom()函数来接收客户端发送的消息,这个函数可以获取发送方的地址信息。
    • 客户端:使用sendto()发送消息,使用recvfrom()接收服务端的回显消息。
  3. 地址信息:

    • 服务端:需要一个服务器地址结构来存储其绑定的地址信息,包括IP地址和端口号。
    • 客户端:需要一个服务器地址结构来指定消息发送的目标地址和端口号。
  4. 网络编程模型:

    • 服务端:通常设计为可以持续运行,处理来自不同客户端的请求。
    • 客户端:可能设计为发送一次请求后关闭,或者根据需要发送多次请求。
  5. 并发处理:

    • 服务端:在实际应用中,可能需要处理多个客户端的并发连接,这可能涉及到多线程或多进程的使用。
    • 客户端:通常不需要处理并发,除非一个客户端需要同时与多个服务端通信。

相同点:

  1. 关闭连接(Close):

    • 服务端和客户端:在完成数据传输后,都会调用close()函数来关闭socket。
  2. 错误处理:

    • 服务端和客户端:都需要对可能发生的错误进行处理,如socket创建失败、绑定失败、发送/接收失败等。

http://www.ppmy.cn/devtools/39347.html

相关文章

如何创建git并上传

Git的配置和上传主要涉及以下步骤&#xff1a; 一、Git的配置 安装Git&#xff1a;首先&#xff0c;你需要在你的计算机上安装Git。这通常可以通过访问Git的官方网站并按照其提供的安装指南来完成。 注册GitHub账户&#xff08;如果你还没有的话&#xff09;&#xff1a;在Gi…

结合创新!通道注意力+UNet,实现高精度分割

在U-Net网络中加入通道注意力机制能显著提升模型的性能&#xff01; 具体点说是在U-Net的卷积层之后添加一个通道注意力模块&#xff0c;这样这个模块可以学习不同通道之间的权重&#xff0c;并根据这些权重对通道进行加权&#xff0c;从而增强重要通道的特征表示。 这种结合…

迅为RK3568开发板资料说明4750+页专属文档专为3568编写

iTOP-3568开发板采用瑞芯微RK3568处理器&#xff0c;内部集成了四核64位Cortex-A55处理器。主频高达2.0Ghz&#xff0c;RK809动态调频。集成了双核心架构GPU&#xff0c;ARM G52 2EE、支持OpenGLES1.1/2.0/3.2、OpenCL2.0、Vulkan1.1、内嵌高性能2D加速硬件。 内置独立NPU,算力…

深入浅出JavaScript继承机制:解密原型、原型链与面向对象实战攻略

&#x1f525; 个人主页&#xff1a;空白诗 文章目录 &#x1f525; 引言&#x1f9f1; 原型基础⛓️ 原型链的形成&#x1f504; 修改原型的影响&#x1f3c1; 原型链的尽头为什么null标志着结束&#xff1f;实际意义 &#x1f310; &#x1f504; 继承的实现方式1. 原型链继承…

UDP广播

1、UDP广播 1.1、广播的概念 广播&#xff1a;由一台主机向该主机所在子网内的所有主机发送数据的方式 例如 &#xff1a;192.168.3.103主机发送广播信息&#xff0c;则192.168.3.1~192.168.3.254所有主机都可以接收到数据 广播只能用UDP或原始IP实现&#xff0c;不能用TCP…

【Qt元对象系统解析】

提示&#xff1a;文章写完后&#xff0c;目录可以自动生成&#xff0c;如何生成可参考右边的帮助文档 文章目录 概述一、元对象系统二、信号与槽1.connect()函数的不同参数形式2. 使用 sender()获得信号发射者3. 自定义信号及其使用 概述 Qt实质上是一个跨平台的C开发类库&…

windows连接CentOS数据库或Tomcat报错,IP通的,端口正常监听

错误信息 数据库错误&#xff1a; ERROR 2003 (HY000): Cant connect to MySQL server on x.x.x.x (10060) Tomcat访问错误&#xff1a; 响应时间过长 ERR_CONNECTION_TIMED_OUT 基础排查工作 【以下以3306端口为例&#xff0c;对于8080端口来说操作是一样的&#xff0c;只需…

编译适配纯鸿蒙系统的ijkplayer中的ffmpeg库

目前bilibili官方的ijkplayer播放器&#xff0c;是只适配Android和IOS系统的。而华为接下来即将发布纯harmony系统&#xff0c;是否有基于harmony系统的ijkplayer可以使用呢&#xff1f; 鸿蒙版ijkplayer播放器是哪个&#xff0c;如何使用&#xff0c;这个问题&#xff0c;大家…