当前位置: 首页 > news >正文

使用udp进行通信

UDP chat

头文件

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <time.h>
#include <signal.h>
#include <pthread.h>

服务端server

typedef struct sockaddr *(SA);
int main(int argc,char *argv[])
{int sockfd = socket(AF_INET,SOCK_DGRAM,0);if(-1 == sockfd){perror("socket");return 1;}struct sockaddr_in server,client;bzero(&server,sizeof(server));bzero(&client,sizeof(client));server.sin_family = AF_INET;server.sin_port = htons(50000);server.sin_addr.s_addr = 0;int ret = bind(sockfd,(SA)&server,sizeof(server));if(-1 == ret){perror("bind");exit(1);}char buf[512] = {0};socklen_t len = sizeof(client);recvfrom(sockfd,buf,sizeof(buf),0,(SA)&client,&len);printf("cli addr:%s port:%s\n",inet_ntoa(client.sin_addr),ntohs(client.sin_port));pid_t pid = fork();if(pid>0){while(1){bzero(buf,sizeof(buf));recvfrom(sockfd,buf,sizeof(buf),0,(SA)&client,&len);if(0==strcmp(buf,"#quit\n")){kill(pid,2);exit(1);}    printf("from cli:%s\n",buf);fflush(stdout);}}else if(0 == pid){while(1){bzero(buf,sizeof(buf));printf("to cli:");fgets(buf,sizeof(buf),stdin);sendto(sockfd,buf,strlen(buf),0,(SA)&client,sizeof(client));if(0 == strcmp(buf,"#quit\n")){kill(getppid(),2);exit(1);}}}else{perror("fork");exit(1);}return 0;}

客户端client

typedef struct sockaddr * (SA);struct sockaddr_in server;
void* th1(void* arg)
{int sockfd  = *(int*)arg;while(1){char buf[512]={0};recvfrom(sockfd,buf,sizeof(buf),0,NULL,NULL);if(0 == strcmp(buf,"#quit\n")){exit(0);}printf("from ser:%s\n",buf);}return NULL;
}
void* th2(void* arg)
{int sockfd  = *(int*)arg;while(1){char buf[512]={0};printf("to ser:");fgets(buf,sizeof(buf),stdin);sendto(sockfd,buf,strlen(buf),0,(SA)&server,sizeof(server));if(0 == strcmp("#quit\n",buf)){exit(0);}}return NULL;
}int main(int argc, char *argv[])
{int sockfd  =socket(AF_INET,SOCK_DGRAM ,0);if(-1 == sockfd){perror("socket");return 1;}//set ip port  man 7 ip bzero(&server,sizeof(server));server.sin_family  = AF_INET;server.sin_port  = htons(50000);// >50000 host to net short server.sin_addr.s_addr =0;char buf[512]="@_@";sendto(sockfd,buf,strlen(buf),0,(SA)&server,sizeof(server));pthread_t tid1,tid2;pthread_create(&tid1,NULL,th1,&sockfd);pthread_create(&tid2,NULL,th2,&sockfd);pthread_join(tid1,NULL);pthread_join(tid2,NULL);return 0;
}

函数

socket

int socket(int domain, int type, int protocol);
  • domain: 指定通信协议族,这里使用的是AF_INET,表示使用IPv4协议。
  • type: 指定套接字类型,SOCK_DGRAM表示使用数据报套接字,也就是UDP协议。
  • protocol: 通常为0,表示选择默认协议,对于SOCK_DGRAM来说,默认的协议就是UDP。

创建udp套接字  int sockfd = socket(AF_INET, SOCK_DGRAM, 0)

sockfd = socket(int socket_family, int socket_type, int protocol);

bzero

bzero 是一个用于将指定内存区域清零的函数,通常用于初始化数据结构,以确保它们不包含任何未初始化的数据。

void bzero(void *s, size_t n);
  • s: 指向需要清零的内存区域的指针。
  • n: 要清零的字节数。

bzero 将从指针 s 所指向的内存区域开始的 n 个字节全部设置为零。

struct sockaddr_in server;
bzero(&server, sizeof(server));

bzero 在网络编程中初始化 sockaddr_in 结构体:

bzeroserver 结构体的所有字节都设置为零,确保其中的每个字段都被正确初始化。使用 bzero 比逐个字段手动初始化要简单得多。

sendto

sendto 是一个用于发送数据到指定目标地址的函数,常用于UDP(数据报套接字)的网络编程。与TCP不同,UDP是无连接的协议,使用sendto函数可以在不建立连接的情况下发送数据。

ssize_t sendto(int sockfd, const void *buf, size_t len, int flags,const struct sockaddr *dest_addr, socklen_t addrlen);
  • sockfd: 套接字文件描述符,表示通过哪个套接字发送数据。
  • buf: 指向要发送的数据的指针。
  • len: 要发送的数据的长度(字节数)。
  • flags: 一般设置为 0,除非需要设置特殊的发送选项。
  • dest_addr: 指向目的地址的指针,即目标主机的地址和端口信息。这个地址通常使用 sockaddr_in 结构体表示。
  • addrlen: dest_addr 结构体的大小,通常使用 sizeof(struct sockaddr_in)

recvfrom

ssize_t recvfrom(int sockfd, void *buf, size_t len, int flags,struct sockaddr *src_addr, socklen_t *addrlen);
  • sockfd: 套接字文件描述符,指定从哪个套接字接收数据。
  • buf: 指向接收数据的缓冲区指针。
  • len: 缓冲区的大小(字节数),即可以接收的最大数据量。
  • flags: 通常设置为 0,除非需要特殊的接收行为(如非阻塞模式)。
  • src_addr: 用于存储发送方的地址信息的结构体指针(通常是 sockaddr_in 类型)。如果不关心发送方地址,可以设置为 NULL
  • addrlen: 一个指向 socklen_t 类型变量的指针,用于存储发送方地址的长度。如果 src_addrNULL,这个参数可以忽略。

bind

bind 函数在网络编程中用于将一个套接字(socket)绑定到一个特定的IP地址和端口号上。通常在服务器端程序中使用,以指定该服务器在某个IP地址和端口上监听客户端的连接或数据。

int bind(int sockfd, const struct sockaddr *addr, socklen_t addrlen);
  • sockfd: 套接字文件描述符,指示要绑定的套接字。
  • addr: 指向包含IP地址和端口信息的 sockaddr 结构体的指针。对于IPv4,通常使用 sockaddr_in 结构体来表示。
  • addrlen: addr 结构体的大小,通常使用 sizeof(struct sockaddr_in)
  • 服务器端bind 是服务器端程序中必须的步骤之一,它将服务器的套接字绑定到一个特定的IP地址和端口上,以便客户端能够通过这个地址和端口与服务器通信。
  • 客户端:对于客户端程序,通常不需要手动调用 bind,因为系统会自动为客户端分配一个临时端口。然而,如果客户端希望指定特定的源IP地址或端口,也可以使用 bind

相关文章:

使用udp进行通信

UDP chat 头文件 #include <stdio.h> #include <stdlib.h> #include <unistd.h> #include <string.h> #include <sys/types.h> #include <sys/socket.h> #include <netinet/in.h> #include <arpa/inet.h> #include <time…...

C#上位机使用Microsoft.Office.Interop.Excel和EPPlus库对Excel或WPS表格进行写操作

C#上位机使用Microsoft.Office.Interop.Excel和EPPlus库对Excel或WPS表格进行写操作 一、使用Microsoft.Office.Interop.Excel库 1、通过NuGet包管理器添加引用 按照下图中红框所示进行操作。 需要安装Microsoft.Office.Interop.Excel包 添加Microsoft Office 16.0 Object …...

java重点学习-redis

一.redis 穿透无中生有key&#xff0c;布隆过滤nul隔离 锁与非期解难题。缓存击穿过期key&#xff0c; 雪崩大量过期key&#xff0c;过期时间要随机。 面试必考三兄弟&#xff0c;可用限流来保底。 1.1 Redis的使用场景 根据自己简历上的业务进行回答 缓存穿透、击穿、雪崩、双…...

每日刷题(图论)

P1119 灾后重建 P1119 灾后重建 - 洛谷 | 计算机科学教育新生态 (luogu.com.cn) 思路 看数据范围知道需要用到Floyd算法&#xff0c;但是道路是不能直接用的&#xff0c;需要等到连接道路的两个村庄重建好才可以使用&#xff0c;所以这需要按照时间依次加入中转点&#xff0c…...

Requestium - 将Requests和Selenium合并在一起的自动化测试工具

Requests 是 Python 的第三方库&#xff0c;主要用于发送 http 请求&#xff0c;常用于接口自动化测试等。 Selenium 是一个用于 Web 应用程序的自动化测试工具。Selenium 测试直接运行在浏览器中&#xff0c;就像真正的用户在操作一样。 本篇介绍一款将 Requests 和 Seleniu…...

mysql和pg等数据库之间的数据迁移实战分享

mysql和pg等数据库之间的数据迁移是常见的问题&#xff1a;比如一开始使用Oracle&#xff0c;后来想使用mysql&#xff0c;而且需要把Oracle数据库的数据迁移到mysql里面&#xff1b;后期有想使用pg数据库&#xff0c;同时需要把Mysql数据库的数据迁移到pgl里面&#xff0c;等等…...

消息中间件都有哪些

RabbitMQ&#xff1a;这可是一个开源的消息代理软件&#xff0c;也叫消息中间件。它支持多种消息传递协议&#xff0c;可以轻松地在分布式系统中进行可靠的消息传递。 Kafka&#xff1a;Apache Kafka是一个分布式流处理平台&#xff0c;它主要用于处理实时数据流。Kafka的设计初…...

数据结构(3)内核链表

一、内核链表 内核链表是一种在操作系统内核中使用的数据结构&#xff0c;主要用于管理和组织内核对象。它是有头双向链表的一种实现。 内核链表的特点 双向链表: 内核链表的每个节点都包含指向前一个节点和后一个节点的指针&#xff0c;这使得在链表中进行插入和删除操作时更…...

Linux 硬件学习 s3c2440 arm920t蜂鸣器

1.查找手册时钟图&#xff0c;输入12m想要通过pll得到400m的信号 2.对比pll值&#xff0c;找到最近的为405&#xff0c;得到pll中mdiv为127&#xff0c;pdiv为2&#xff0c;sdiv为1 3.想要得到fclk400&#xff0c;hclk100&#xff0c;pclk50&#xff0c;对比分频比例&#xff0…...

提交保存,要做重复请求拦截,避免出现重复保存的问题

**问题&#xff1a;**前端ajax提交数据的时候&#xff0c;当频繁点击的时候&#xff0c;或者两个账号以相同数据创建的时候&#xff0c;会出现问题。 **处理办法&#xff1a;**前端拦截&#xff0c;防止重复提交数据&#xff0c;在上一次请求返回结果之后才允许提交第二次&…...

华为 HCIP-Datacom H12-821 题库 (3)

有需要题库的可以看主页置顶​​​​​​​ 1.运行 OSPF 协议的路由器在交互 DD 报文时&#xff0c;会使用以下哪一个参数选举主从关系&#xff1f; A、接口的 IP 地址 B、接口的 DR 优先级 C、Area ID D、Router ID 答案&#xff1a;D 解析&#xff1a; Router-ID 大的为主&a…...

spring-boot 事件

事件触发时机常用监听器描述ApplicationStartingEvent应用启动时LoggingApplicationListener&#xff1a;决定加载哪个日志系统ApplicationEnvironmentPreparedEvent创建Environment之后BootstrapApplicationListener&#xff1a;加载spring-cloud bootstrap配置文件&#xff1…...

合碳智能 × Milvus:探索化学合成新境界——逆合成路线设计

合碳智能&#xff08;C12.ai&#xff09;成立于2022年&#xff0c;致力于运用AI和具身智能技术&#xff0c;为药物研发实验室提供新一代智能化解决方案&#xff0c;推动实验室从自动化迈向智能化&#xff0c;突破传统实验模式与人员的依赖&#xff0c;解决效率和成本的瓶颈&…...

二分查找 | 二分模板 | 二分题目解析

1.二分查找 二分查找的一个前提就是要保证数组是有序的&#xff08;不准确&#xff09;&#xff01;利用二段性&#xff01; 1.朴素二分模板 朴素二分法的查找中间的值和目标值比较 while(left < right) // 注意是要&#xff1a; < {int mid left (right -left) / 2;…...

uni-app应用更新(Android端)

关于app更新&#xff0c;uni-app官方推荐的是 uni-upgrade-center&#xff0c;看了下比较繁琐&#xff0c;因此这里自己实现检查更新并下载安装的逻辑。 1.界面效果 界面中的弹框和 进度条采用了uView 提供的组件 2.检查更新并下载安装 一、版本信息配置在服务端&#xff0c…...

JavaEE(2):前后端项目之间的交互

现在&#xff0c;在网页中通过超链接&#xff0c;表单就可以向后端发送请求&#xff0c;后端也可以正常响应内容。 以前通过表单访问后端的请求方式称为同步请求 同步请求 当网页与后端交互时&#xff0c;前端不能再进行其他操作 服务器端响应回来的内容&#xff0c;会把整个浏…...

(已开源-CVPR 2024)YOLO-World: Real-Time Open-Vocabulary Object Detection

169期《YOLO-World Real-Time Open-Vocabulary Object Detection》 You Only Look Once (YOLO) 系列检测模型是目前最常用的检测模型之一。然而&#xff0c;它们通常是在预先定义好的目标类别上进行训练&#xff0c;很大程度上限制了它们在开放场景中的可用性。为了解决这一限制…...

Spring6梳理4——SpringIoC容器

以上笔记来源&#xff1a; 尚硅谷Spring零基础入门到进阶&#xff0c;一套搞定spring6全套视频教程&#xff08;源码级讲解&#xff09;https://www.bilibili.com/video/BV1kR4y1b7Qc 目录 4.1 前言 4.2 IoC容器 4.2.1 控制反转(IoC) 4.2.2 依赖注入 4.2.3 IoC容器在Spri…...

SpringBoot2:请求处理原理分析-FORM表单请求接口

一、RESTFUL简介 Rest风格支持&#xff08;使用HTTP请求方式&#xff0c;动词来表示对资源的操作&#xff09; 以前&#xff1a;/getUser 获取用户 /deleteUser 删除用户 /editUser 修改用户 /saveUser 保存用户 现在&#xff1a; /user GET-获取用户 DELETE-删除用户 PUT-修改…...

Monkey日志ANR、CRASH、空指针异常及其他异常数据分析

引言 在Android开发过程中&#xff0c;monkey测试是一种常用的随机测试手段&#xff0c;用于模拟用户的各种操作来发现应用中的稳定性问题。通过monkey测试生成的日志文件包含了丰富的信息&#xff0c;包括应用程序崩溃&#xff08;Crash&#xff09;、无响应&#xff08;ANR&…...

Leetcode 3576. Transform Array to All Equal Elements

Leetcode 3576. Transform Array to All Equal Elements 1. 解题思路2. 代码实现 题目链接&#xff1a;3576. Transform Array to All Equal Elements 1. 解题思路 这一题思路上就是分别考察一下是否能将其转化为全1或者全-1数组即可。 至于每一种情况是否可以达到&#xf…...

树莓派超全系列教程文档--(62)使用rpicam-app通过网络流式传输视频

使用rpicam-app通过网络流式传输视频 使用 rpicam-app 通过网络流式传输视频UDPTCPRTSPlibavGStreamerRTPlibcamerasrc GStreamer 元素 文章来源&#xff1a; http://raspberry.dns8844.cn/documentation 原文网址 使用 rpicam-app 通过网络流式传输视频 本节介绍来自 rpica…...

在 Nginx Stream 层“改写”MQTT ngx_stream_mqtt_filter_module

1、为什么要修改 CONNECT 报文&#xff1f; 多租户隔离&#xff1a;自动为接入设备追加租户前缀&#xff0c;后端按 ClientID 拆分队列。零代码鉴权&#xff1a;将入站用户名替换为 OAuth Access-Token&#xff0c;后端 Broker 统一校验。灰度发布&#xff1a;根据 IP/地理位写…...

【AI学习】三、AI算法中的向量

在人工智能&#xff08;AI&#xff09;算法中&#xff0c;向量&#xff08;Vector&#xff09;是一种将现实世界中的数据&#xff08;如图像、文本、音频等&#xff09;转化为计算机可处理的数值型特征表示的工具。它是连接人类认知&#xff08;如语义、视觉特征&#xff09;与…...

04-初识css

一、css样式引入 1.1.内部样式 <div style"width: 100px;"></div>1.2.外部样式 1.2.1.外部样式1 <style>.aa {width: 100px;} </style> <div class"aa"></div>1.2.2.外部样式2 <!-- rel内表面引入的是style样…...

PL0语法,分析器实现!

简介 PL/0 是一种简单的编程语言,通常用于教学编译原理。它的语法结构清晰,功能包括常量定义、变量声明、过程(子程序)定义以及基本的控制结构(如条件语句和循环语句)。 PL/0 语法规范 PL/0 是一种教学用的小型编程语言,由 Niklaus Wirth 设计,用于展示编译原理的核…...

大模型多显卡多服务器并行计算方法与实践指南

一、分布式训练概述 大规模语言模型的训练通常需要分布式计算技术,以解决单机资源不足的问题。分布式训练主要分为两种模式: 数据并行:将数据分片到不同设备,每个设备拥有完整的模型副本 模型并行:将模型分割到不同设备,每个设备处理部分模型计算 现代大模型训练通常结合…...

数据库分批入库

今天在工作中&#xff0c;遇到一个问题&#xff0c;就是分批查询的时候&#xff0c;由于批次过大导致出现了一些问题&#xff0c;一下是问题描述和解决方案&#xff1a; 示例&#xff1a; // 假设已有数据列表 dataList 和 PreparedStatement pstmt int batchSize 1000; // …...

关于 WASM:1. WASM 基础原理

一、WASM 简介 1.1 WebAssembly 是什么&#xff1f; WebAssembly&#xff08;WASM&#xff09; 是一种能在现代浏览器中高效运行的二进制指令格式&#xff0c;它不是传统的编程语言&#xff0c;而是一种 低级字节码格式&#xff0c;可由高级语言&#xff08;如 C、C、Rust&am…...

HDFS分布式存储 zookeeper

hadoop介绍 狭义上hadoop是指apache的一款开源软件 用java语言实现开源框架&#xff0c;允许使用简单的变成模型跨计算机对大型集群进行分布式处理&#xff08;1.海量的数据存储 2.海量数据的计算&#xff09;Hadoop核心组件 hdfs&#xff08;分布式文件存储系统&#xff09;&a…...