以线程完成并发的UDP服务端

网络(九)并发的UDP服务端 以线程完成功能

客户端

// todo UDP发送端
#include <stdio.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <sys/types.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>#define LOGIN_SUCCESS 1
#define LOGIN_FAIL 0
//?发送数据
//?@param fd 套接字描述符
//?@param addr 目标地址
//?@param addrlen 地址长度
void send_data(int fd, struct sockaddr_in * addr , socklen_t addrlen);void login(int fd, struct sockaddr_in * addr ,struct sockaddr_in * new_addr , socklen_t new_addrlen);//命令行参数 ip port
int main(int argc, char *argv[] ){
//    if(argc!= 3){
//        printf("Usage: %s ip port\n", argv[0]);
//        exit(EXIT_FAILURE);
//    }//!通过socket函数创建套接字//!@param domain 协议族，AF_INET表示IPv4协议族//!@param type 套接字类型，SOCK_DGRAM表示UDP套接字//!@param protocol 协议，一般为0 让系统⾃动识别//!@return 成功返回套接字描述符，失败返回-1int fd = socket(AF_INET, SOCK_DGRAM, 0);if(fd == -1){    //创建套接字失败perror("socket err");exit(EXIT_FAILURE);}//准备接收消息的地址/*      struct sockaddr_in {short int sin_family; // 地址族 AF_INETunsigned short int sin_port; // 端口号struct in_addr sin_addr;// IP地址unsigned char sin_zero[8]; // 填充字节 为了对齐sockaddr};*/struct sockaddr_in addr;memset(&addr, 0, sizeof(addr));addr.sin_family=AF_INET;addr.sin_port=htons(8083);//htons函数将主机字节序转换为网络字节序//addr.sin_addr.s_addr=inet_addr("192.168.74.1");//inet_addr()将点分十进制IP地址转换为网络字节序IP地址//inet_aton()将点分十进制IP地址转换为网络字节序IP地址//@param ip 字符串形式的IP地址//@param in_addr 结构体变量，用于存储IP地址int ret=inet_aton("172.17.140.183", &addr.sin_addr); // 成功返回⾮0,失败返回0if(ret == 0){perror("inet_aton err");exit(EXIT_FAILURE);}printf("ip == %d\n",addr.sin_addr.s_addr);//inet_ntoa()将网络字节序IP地址转换为点分十进制IP地址//char *ip=inet_ntoa(addr.sin_addr); // 成功返回⾮0,失败返回0//printf("ip == %s\n",ip);//获取  和服务端的新建的子进程通信struct sockaddr_in new_addr;login(fd, &addr, &new_addr, sizeof(new_addr));//与新的子进程通信send_data(fd, &new_addr, sizeof(new_addr));return 0;
}//!发送数据
//!@param fd 套接字描述符
//!@param addr 目标地址
//!@param addrlen 地址长度
void send_data(int fd, struct sockaddr_in * addr , socklen_t addrlen){while (1){int n = 0;//返回发送的字节数char buf[1024] = {0};printf("请输入要发送的消息：");fgets(buf, 1024, stdin);//!发送数据//!@param fd 套接字描述符//!@param buf 发送缓冲区//!@param len 发送缓冲区长度//!@param flags 发送标志  0 表示默认操作//!@param addr 目标地址//!@param addrlen 地址长度//!@return 成功返回发送的字节数，失败返回-1n= sendto(fd, buf, strlen(buf), 0, (struct sockaddr *)addr, addrlen);if(n == -1){perror("sendto err");exit(EXIT_FAILURE);}if(strncmp(buf, "exit",4) == 0){break;}}}void login(int fd, struct sockaddr_in * addr ,struct sockaddr_in * new_addr , socklen_t addrlen){char login_status=LITTLE_ENDIAN;while (1){int n = 0;//返回发送的字节数char buf[1024] = {0};printf("请输入要发送的消息：");fgets(buf, 1024, stdin);n= sendto(fd, buf, strlen(buf), 0, (struct sockaddr *)addr, addrlen);if(n == -1){perror("sendto err");exit(EXIT_FAILURE);}//接收消息服务器的响应n= recvfrom(fd, &login_status, sizeof(login_status), 0, (struct sockaddr *)new_addr, &addrlen);if(n == -1){perror("recvfrom err");exit(EXIT_FAILURE);}if(login_status == LOGIN_SUCCESS){printf("登录成功\n");printf("新的子进程的地址为：%s:%d\n",inet_ntoa(new_addr->sin_addr),ntohs(new_addr->sin_port));break;}else if(login_status == LOGIN_FAIL){printf("登录失败\n");continue;}if(strncmp(buf, "exit",4) == 0){break;}}}

服务端

服务端创建主线程,接收客户端的请求,创建新的子线程,
子线程完成后续交互,子线程中创建新的套接字,返回给客户端,后续交互将在新的套接字中完成.
将子线程分离,线程运行结束将由系统回收资源

// todo UDP服务器端程序
#include <stdio.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <sys/types.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <signal.h>
#include <sys/wait.h>
#include <pthread.h>
#define LOGIN_SUCCESS 1
#define LOGIN_FAIL 0//接收数据
void recv_data(int sockfd);
void *pthread_todo(void *arg);//初始化套接字
int  init_socket(char *ip, char* port);int TheLogin(char *ip, char * port);//定义结构体为子线程传递参数
struct thread_arg {char *ip;unsigned char login_status;struct sockaddr_in thread_addr;//客户端的地址
}thread_arg;int main(int argc, char *argv[]){//验证int new_sockfd = TheLogin("172.17.140.183", "8083");//接收数据//由子线程完成//关闭套接字close(new_sockfd);return 0;
}//接收数据
void recv_data(int sockfd) {struct sockaddr_in client_addr;//客户端的地址int client_addr_len = sizeof(client_addr);while(1) {char recv_buf[1024]={0};//接收数据//*@param sockfd 套接字描述符//*@param buf 接收缓冲区//*@param len 接收缓冲区长度//*@param flags 接收标志//*@param src_addr 发送方地址//*@param addrlen 发送方地址长度//*@return 成功返回接收到的字节数，失败返回-1int ret = recvfrom(sockfd, recv_buf, sizeof(recv_buf), 0, (struct sockaddr *) &client_addr, &client_addr_len);if (ret == -1) {perror("recvfrom err");exit(EXIT_FAILURE);}//打印接收到的信息char *ip_str = inet_ntoa(client_addr.sin_addr);//将网络字节序IP地址转换为点分十进制IP地址int port = ntohs(client_addr.sin_port); //将网络字节序端口号转换为主机字节序端口号printf("接收到来自%s:%d的数据：%s\n", ip_str, port, recv_buf);if(strncmp(recv_buf, "exit", 4) == 0){//退出程序break;}}close(sockfd);return;
}int  init_socket(char *ip,char *port){//!通过socket函数创建套接字//!@param domain 协议族，AF_INET表示IPv4协议族//!@param type 套接字类型，SOCK_DGRAM表示UDP套接字//!@param protocol 协议，一般为0 让系统⾃动识别//!@return 成功返回套接字描述符，失败返回-1int fd = socket(AF_INET, SOCK_DGRAM, 0);if(fd == -1){    //创建套接字失败perror("socket err");exit(EXIT_FAILURE);}//准备服务器地址/*      struct sockaddr_in {short int sin_family; // 地址族 AF_INETunsigned short int sin_port; // 端口号struct in_addr sin_addr;// IP地址unsigned char sin_zero[8]; // 填充字节 为了对齐sockaddr};*/struct sockaddr_in addr;memset(&addr, 0, sizeof(addr));addr.sin_family=AF_INET;addr.sin_port=htons(atoi(port));//htons函数将主机字节序转换为网络字节序//inet_aton()将点分十进制IP地址转换为网络字节序IP地址//*@param ip 字符串形式的IP地址//*@param in_addr 结构体变量，用于存储IP地址int ret=inet_aton(ip, &addr.sin_addr); // 成功返回⾮0,失败返回0if(ret == 0){perror("inet_aton err");exit(EXIT_FAILURE);}//!绑定套接字到服务器地址//!@param sockfd 套接字描述符//!@param addr 服务器地址//!@param addrlen 服务器地址长度//!@return 成功返回0，失败返回-1int ret2 = bind(fd, (struct sockaddr*)&addr, sizeof(addr));if(ret2 == -1){perror("bind err");exit(EXIT_FAILURE);}return fd;
}int TheLogin(char *ip, char *port){unsigned char login_status;int new_sockfd;//初始化套接字int sockfd = init_socket(ip, port);//线程创建pthread_t recv_thread;struct sockaddr_in client_addr;//客户端的地址int client_addr_len = sizeof(client_addr);while(1) {char recv_buf[1024]={0};int ret = recvfrom(sockfd, recv_buf, sizeof(recv_buf), 0, (struct sockaddr *) &client_addr, &client_addr_len);if (ret == -1) {perror("recvfrom err");exit(EXIT_FAILURE);}//打印接收到的信息char *ip_str = inet_ntoa(client_addr.sin_addr);//将网络字节序IP地址转换为点分十进制IP地址int port = ntohs(client_addr.sin_port); //将网络字节序端口号转换为主机字节序端口号printf("接收到来自%s:%d的数据：%s\n", ip_str, port, recv_buf);//登录验证//判断是否为登录请求login_status = ( strncmp(recv_buf, "login",5)==0 ? LOGIN_SUCCESS: LOGIN_FAIL ) ;if(login_status == LOGIN_SUCCESS){//使用子线程完成后续交互struct thread_arg pack;pack.ip = ip;pack.login_status = login_status;pack.thread_addr = client_addr;//创建子线程pthread_create(&recv_thread, NULL, pthread_todo, &pack);printf("子线程创建成功\n");} else{//回传失败消息sendto(sockfd, &login_status, sizeof(login_status), 0, (struct sockaddr *) &client_addr, client_addr_len);}//将新建的线程设置为分离状态pthread_detach(recv_thread);printf("子线程分离成功\n");}}void *pthread_todo(void *arg){//子线程函数struct thread_arg *pack = (struct thread_arg*)arg;//创建新的套接字文件描述符int new_sockfd = init_socket(pack->ip, "0");printf("子线程创建新的套接字文件描述符：%d\n", new_sockfd);sendto(new_sockfd, &pack->login_status, sizeof(pack->login_status), 0,\(struct sockaddr *) &pack->thread_addr, sizeof(pack->thread_addr));//接收数据recv_data(new_sockfd);pthread_exit(NULL);}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/web/49381.shtml

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

相关文章

MySQL的表，视图，索引创建

MySQL的表，视图，索引创建

一。创建表 1。创建Student表 mysql> create table Student(Sno int primary key auto_increment,Sname varchar(30) not null unique,Ssex varchar(2) check (Ssex 男 or Ssex 女) not null,Sage int not null,Sdept varchar(10) default 计算机 not null); 2.创建Cour…
阅读更多...
Infuse Pro for Mac全能视频播放器

Infuse Pro for Mac全能视频播放器

Mac分享吧 文章目录 效果一、下载软件二、开始安装1、双击运行软件&#xff0c;将其从左侧拖入右侧文件夹中&#xff0c;等待安装完毕2、应用程序显示软件图标&#xff0c;表示安装成功 三、运行测试安装完成&#xff01;&#xff01;&#xff01; 效果 一、下载软件 下载软件…
阅读更多...
java 求两个字符序列的最长公共字符子序列

java 求两个字符序列的最长公共字符子序列

/* 求两个字符序列的最长公共字符子序列。 给定两个字符串&#xff0c;求解这两个字符串的最长公共子序列&#xff08;Longest Common Sequence&#xff09;。 比如字符串1&#xff1a;BDCABA&#xff1b;字符串2&#xff1a;ABCBDAB&#xff0c; 则这两个字符串的最长公共子序…
阅读更多...
Dav_笔记11：SQL Tuning Overview-sql调优 之 5

Dav_笔记11：SQL Tuning Overview-sql调优 之 5

构建SQL测试用例 对于许多与SQL相关的问题&#xff0c;获得可重现的测试用例可以更轻松地解决问题。从11g第2版&#xff08;11.2&#xff09;开始&#xff0c;Oracle数据库包含SQL测试用例构建器&#xff0c;它可以自动完成收集和复制尽可能多的有关问题及其发生环境的信息的难…
阅读更多...
【JavaScript】深入理解 `let`、`var` 和 `const`

【JavaScript】深入理解 `let`、`var` 和 `const`

文章目录 一、var 的声明与特点二、let 的声明与特点三、const 的声明与特点四、let、var 和 const 的对比五、实战示例六、最佳实践 在 JavaScript 中&#xff0c;变量声明是编程的基础&#xff0c;而 let、var 和 const 是三种常用的变量声明方式。本文将详细介绍这三种变量声…
阅读更多...
如何防止用户通过打印功能复制页面文字

如何防止用户通过打印功能复制页面文字

简单防白嫖&#xff0c;要让打印出来的页面是空白&#xff0c;通常的做法是在打印时隐藏页面上的所有内容。这可以通过CSS的媒体查询&#xff08;Media Queries&#xff09;来实现&#xff0c;特别是针对media print的查询。 在JavaScript中&#xff0c;你通常不会直接控制打印…
阅读更多...
上传文件传参 pc端vue的formData

上传文件传参 pc端vue的formData

formData let formData new FormData(); formData.append("file", blob, ref ".png"); //添加参数并且重新命名文件名称 if(ref.toString().indexOf(qrcode) > 0) formData.append(noStbg, true)//添加参数 uploadType(formData, sour…
阅读更多...
USB转多路串口-纯硬件实现串口数据传输指示灯电路

USB转多路串口-纯硬件实现串口数据传输指示灯电路

前言 串口相关产品往往要求有数据收发时LED闪烁&#xff0c;我们经常会用软件实现&#xff0c;在MCU内注册一个定时器&#xff0c;有数据发送时就闪烁一段时间。软件点灯这种方式存在两个缺陷&#xff0c;一是接收方向不好实现&#xff1b;二是定时器一般用固定频率&#xff0…
阅读更多...
Linux系统：date命令

Linux系统：date命令

1、命令详解&#xff1a; date 命令可以用来显示或设定系统的日期与时间。 2、官方参数&#xff1a; -d, --dateSTRING 通过字符串显示时间格式&#xff0c;字符串不能是now。-f, --fileDATEFILE 类似 --date 在 DATEFILE 的每一行生效-I[FMT], --iso-8601[FMT…
阅读更多...
Redis底层数据结构的实现

Redis底层数据结构的实现

文章目录 1、Redis数据结构1.1 动态字符串1.2 intset1.3 Dict1.4 ZipList1.5 ZipList的连锁更新问题1.6 QuickList1.7 SkipList1.8 RedisObject 2、五种数据类型2.1 String2.2 List2.3 Set2.4 ZSET2.5 Hash 1、Redis数据结构 1.1 动态字符串 Redis中保存的Key是字符串&#xf…
阅读更多...
【C语言】VS的实用调试技巧

【C语言】VS的实用调试技巧

0. 前言 VS(Visual Studio)是集成开发环境&#xff0c;其内置了多种调试工具和技巧帮助开发人员在开发过程中解决问题。包含断点、监视窗口、自动窗口、调用堆栈等&#xff0c;通过这些技巧&#xff0c;开发人员可以有效地调试和解决程序中的问题。我们在VS编译器上写代码&…
阅读更多...
PHP Switch 语句

PHP Switch 语句

PHP 中的 switch 语句是一种多路分支语句&#xff0c;它允许一个变量的值对多个代码块进行选择执行。这通常比使用多个 if...elseif...else 语句更清晰、更易于维护。下面将详细介绍 PHP 中 switch 语句的使用方法。 基本语法 switch (n) {case label1:// 如果 n label1&…
阅读更多...
Codeforces 903 div3 A-F

Codeforces 903 div3 A-F

A 题目分析 数据范围很小&#xff0c;暴力枚举即可&#xff0c;然后给字符串x的长度设置一个上限&#xff0c;我设了50&#xff0c;因为n*m<25&#xff0c;多一倍够用了 C代码 #include<iostream> using namespace std; void solve(){int n,m;string x,s;cin>>…
阅读更多...
ssh免密登陆

ssh免密登陆

之前写过免密登陆的方法&#xff0c;但是有点不好用。此处重新写一下 步骤&#xff1a; 一般来说&#xff0c;客户端会产生两个秘钥ssh-keygen一路默认&#xff0c;产生私钥id_rsa与公钥id_rsa.pub在服务器上cd ~/.ssh注意&#xff1a; 如果没有.ssh文件夹&#xff0c;通过mkd…
阅读更多...
尚硅谷vue全家桶（vue2+vue3）笔记

尚硅谷vue全家桶（vue2+vue3）笔记

Vue2 一、Vue核心 01_简介 1.特点 采用组件化模式&#xff0c;提高代码复用率、且让代码更好维护。声明式编码&#xff0c;让编程人员无需直接操作DOM&#xff08;命令式编码&#xff09;&#xff0c;提高开发效率。使用虚拟DOM优秀的Diff算法&#xff0c;尽量复用DOM节点。…
阅读更多...
ReactHooks(一)

ReactHooks(一)

一.使用规则 hook和生命周期函数一样&#xff0c;必须写在函数最顶层&#xff1b;而且hook不应该被嵌套进条件或者循环语句中&#xff1b;hook只能在函数组件或者自定义hook中被使用&#xff0c;而不能用于普通函数或者class组件中。 二.useState&#xff1a;使用状态&#x…
阅读更多...
Java 面试相关问题（下）——JVM相关问题GC相关问题

Java 面试相关问题（下）——JVM相关问题GC相关问题

1. 类加载1.1 类的生命周期说一下&#xff1f;1.2 介绍下生命周期中的加载&#xff1f;1.3 介绍下生命周期中的验证&#xff1f;1.4 介绍下生命周期中的准备&#xff1f;1.5 介绍下生命周期中的解析&#xff1f;1.6 介绍下生命周期中的初始化&#xff1f;1.7 介绍下生命周期中的…
阅读更多...
科研绘图系列：R语言组合堆积图（stacked barplot with multiple groups）

科研绘图系列：R语言组合堆积图（stacked barplot with multiple groups）

介绍 通常堆积图的X轴表示样本，样本可能会存在较多的分组信息，通过组合堆积图和样本标签分组信息，我们可以得到一张能展示更多信息的可发表图形。 加载R包 knitr::opts_chunk$set(warning = F, message = F) library(tidyverse) library(cowplot) library(patchwork)导入…
阅读更多...
KubeSphere安装时候报22端口连接不上的错误

KubeSphere安装时候报22端口连接不上的错误

使用KubeKey在Linux机器上以单节点模式安装KubeSphere和Kubernetes/K3时候报错误&#xff1a; error: Pipeline[CreateClusterPipeline] execute failed: Module[GreetingsModule] exec failed: failed: [LAPTOP-R028MMAA] failed to connect to 172.26.246.173: could not es…
阅读更多...
富芮坤FR800X系列之按键检测模块设计

富芮坤FR800X系列之按键检测模块设计

FR800X系列按键检测模块 读者对象&#xff1a; 本文档主要适用以下工程师&#xff1a; 嵌入式系统工程师 单片机软件工程师 IOT固件工程师 BLE固件工程师 文章目录 1.概要2.用户如何设计按键检测模块2.1 GPIO初始化2.2按键模块初始化2.3设计中断函数&#xff1a;2.4循环…
阅读更多...
最新文章

Copyright @ 2022~2023