UDP socket编程示例

服务端:

#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.mzph.cn/bicheng/9859.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

鸿蒙开发接口Ability框架:【@ohos.application.Want (Want)】

Want Want模块提供系统的基本通信组件的能力。 说明&#xff1a; 本模块首批接口从API version 8 开始支持。后续版本的新增接口&#xff0c;采用上角标单独标记接口的起始版本。 导入模块 import Want from ohos.application.Want; 开发前请熟悉鸿蒙开发指导文档&#xff1…

nginx--rewrite

功能 Nginx服务器利用ngx_http_rewrite_module 模块解析和处理理rewrite请求&#xff0c;此功能依靠PCRE(Perl Compatible Regular Expressions)&#xff0c;因此编译之前要安装PCRE库&#xff0c;rewrite是nginx服务器的重要功能之一&#xff0c;用于实现URL的重写&#xff0…

力扣:300. 最长递增子序列(Java,动态规划)

目录 题目描述&#xff1a;示例 1&#xff1a;示例 2&#xff1a;代码实现&#xff1a; 题目描述&#xff1a; 给你一个整数数组 nums &#xff0c;找到其中最长严格递增子序列的长度。 子序列 是由数组派生而来的序列&#xff0c;删除&#xff08;或不删除&#xff09;数组中…

《Video Mamba Suite》论文笔记(4)Mamba在时空建模中的作用

原文翻译 4.4 Mamba for Spatial-Temporal Modeling Tasks and datasets.最后&#xff0c;我们评估了 Mamba 的时空建模能力。与之前的小节类似&#xff0c;我们在 Epic-Kitchens-100 数据集 [13] 上评估模型在zero-shot多实例检索中的性能。 Baseline and competitor.ViViT…

【网络编程】UDP协议和TCP协议1

UDP协议格式 UDP 报文分为 UDP 报头和 UDP 数据区两部分。报头由 4 个 16 位长&#xff08;2字节&#xff09;字段组成&#xff0c;分别说明该报文的源端口、目的端口、报文长度和校验值。 UDP协议如何将报头和有效载荷分离 UDP报头是一种定长报头&#xff0c;长度为8个字节。…

QCC3071/QCC3081/QCC3083/QCC3084/QCC5171/QCC5181/QCC3091/QCC3095平台LDAC解码

QCC3071/QCC3081/QCC3083/QCC3084/QCC5171/QCC5181/QCC3091/QCC3095平台LDAC解码 LDAC Decoder Evaluation Kit for QCC5181 and QCC5171 (The 5181 Kit) 随着Qualcomm DSP向下开放&#xff0c;QCC3071/QCC3081/QCC3083/QCC3084目前可以可以实现LDAC Decoder。 QCC3071/QCC3…

【Shell脚本】Shell编程之循环语句

目录 一.循环语句 1.for语句的结构 1.1.格式 1.2.实操案例 案例1. 案例2. 案例3. 案例4. 2.while语句的结构 2.1.格式 2.2.实操案例 案例1. 案例2. 案例3. 案例4. 3.until循环命令 3.1.格式 3.2.实操案例 案例1. 二.补充 1.常用转义符 一.循环语句 1.for…

56 关于 linux 的 oom killer 机制

前言 这里主要讲的是 linux 的 oom killer 机制 在系统可用内存较少的情况下&#xff0c;内核为保证系统还能够继续运行下去&#xff0c;会选择杀掉一些进程释放掉一些内存。 通常oom_killer的触发流程是&#xff1a;进程A想要分配物理内存&#xff08;通常是读写内存&#…

笨方法自学python(九)-读写文件

读取文件 前面已经学过了 input 和 argv&#xff0c;这些是你开始学习读取文件的必备基础。你可能需要多多实验才能明白它的工作原理&#xff0c;这节练习涉及到写两个文件。一个正常的 ex15.py 文件&#xff0c;另外一个是 ex15_sample.txt&#xff0c;第二个文件并不是脚本&…

如何从yaml取值,如何处理编码,使用BeautifulSoup解析网页获取数据

import requests from bs4 import BeautifulSoup import yaml import chardet #从doctor.yaml里面引入网址 with open(doctor.yaml, r, encodingutf-8) as file:urls_data yaml.safe_load(file) #把查出的数据写入doctor_info.txt中 with open(doctor_info.txt, w, encodingut…

图像锐化——非锐化掩膜USM和锐化掩膜SM(附代码)

非锐化掩膜 (USM) 和锐化掩膜 (SM) 都是常用的图像锐化技术。它们都可以通过增强图像的边缘信息来提高图像的清晰度。 目录 一、非锐化掩膜USM1.1 USM原理1.2 USM实现步骤1.3 优点1.4 代码 二、锐化掩膜SM2.1 SM原理2.2 SM实现步骤2.3 优点2.4 代码 三、锐化效果四、总结4.1 效…

Jupyter集成AI环境搭建@miniconda@FreeBSD

首先安装jupyter pip install jupyter启动jupyter notebook jupyter notebook然后会自动打开网页&#xff1a;http://localhost:8888/tree 开始干活&#xff01; 启动jupyter lab jupyter lab自动打开网页&#xff1a;http://localhost:8888/lab 开工&#xff0c;干活&am…

Qt三方库:QuaZIP介绍、编译和使用

前言 Qt使用一些压缩解压功能&#xff0c;探讨过libzip库&#xff0c;zlib库&#xff0c;libzip库比较原始&#xff0c;还有其他库&#xff0c;都比较基础&#xff0c;而在基础库之上&#xff0c;又有高级封装库&#xff0c;Qt中的QuaZIP是一个很好的选择。Quazip是一个用于压缩…

5.11学习记录

20长安杯部分 检材 1 的操作系统版本 CentOS Linux 7.6.1810 (Core) 检材 1 中&#xff0c;操作系统的内核版本是 3.10.0-957.el7.x86_64 检材 1 中磁盘包含一个 LVM 逻辑卷&#xff0c;该 LVM 开始的逻辑区块地址&#xff08;LBA&#xff09;是 2099200 物理卷&#xff…

20240510每日后端---聊聊文件预览,doc,image,ppt转PDF预览

一、引入依赖 <dependency><groupId>com.aspose</groupId><artifactId>aspose-words</artifactId><version>15.8</version></dependency><dependency><groupId>com.aspose</groupId><artifactId>crac…

(Mac)RocketMQ的本地安装测试(详细图示)

目录 部署服务 namesrv / broker下载解压缩运行 namesrvnohup ./bin/mqnamesrv & 启动命令详解运行 broker 测试收发消息运行自带的生产者测试类运行自带的消费者测试类 部署 Dashboard 可视化下载打包运行访问 部署服务 namesrv / broker 下载解压缩 官网下载 https://r…

mac苹果电脑卡顿反应慢如何解决?2024最新免费方法教程

苹果电脑以其稳定的性能、出色的设计和高效的操作系统&#xff0c;赢得了广大用户的喜爱。然而&#xff0c;随着时间的推移&#xff0c;一些用户会发现自己的苹果电脑开始出现卡顿、反应慢等问题。这不仅影响使用体验&#xff0c;还会影响工作效率。那么&#xff0c;面对这些问…

FPGA -手写异步FIFO

一&#xff0c;FIFO原理 FIFO&#xff08;First In First Out&#xff09;是一种先进先出的数据缓存器&#xff0c;没有外部读写地址线&#xff0c;使用起来非常简单&#xff0c;只能顺序写入数据&#xff0c;顺序的读出数据&#xff0c;其数据地址由内部读写指针自动加1完成&a…

指针(4)有点难

指针&#xff08;4&#xff09; 来做个简单的回顾&#xff1a; 指针数组&#xff1a; 1.是数组 2.是存放指针的数组 char* arr1[5]; int*arr2[3]; 数组指针&#xff1a; 1 .是指针 2 .指向数组的指针 字符指针&#xff1a;char*pc; 整型指针&#xff1a;int*pi; int …

win10无法被远程桌面连接,Win10系统无法被远程桌面连接的原因有哪些

win10无法被远程桌面连接&#xff0c;Win10系统无法被远程桌面连接的原因有哪些&#xff1f; 先&#xff0c;我们需要明确Win10系统无法被远程桌面连接的可能原因。其中&#xff0c;最常见的原因包括&#xff1a;远程桌面功能未启用、网络连接问题、防火墙或安全软件设置不当、…