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

篇四 tcp,udp客户端服务器编程模型

一 前言

本篇内容主要介绍tcp,udp客户端服务器编程的基础API和示例代码。

二 API

API用途使用方
socket创建套接字,这是网络通信的桥梁Tcp,udp客户端,服务器
bind绑定本地IP地址和端口Tcp,udp客户端,服务器
listen监听端口,等待客户端连接tcp服务器
accept阻塞直到客户端连接,返回新sockettcp服务器
connect主动连接服务器tcp客户端
Recv,send收发Tcp 客户端服务器
Recvfrom,sendto收发Udp 客户端服务器

三 ubuntu下代码示例

  1. TCP server
#include <stdio.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <string.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <stdlib.h>
#include <unistd.h>#define SA struct sockaddrint main(int argc,const  char *argv[])
{int sockfd = socket(AF_INET,SOCK_STREAM,0);  //AF_INET  IPV4;SOCK_STREAM  TCP   SOCK_DGRAM  UDPif (sockfd < 0){perror("fail to socket");exit(1);}struct sockaddr_in my_addr,peer_addr;bzero(&my_addr,sizeof(my_addr));my_addr.sin_family = AF_INET;my_addr.sin_port = htons(8080);//转换字节序my_addr.sin_addr.s_addr = inet_addr("0.0.0.0");//inet_addr 把 IP 地址字符串转为整数;0.0.0.0表示绑定所有可用本地 IP,包括本地回环ip:127.0.0.1int ret_bind = bind(sockfd,(SA*)&my_addr,sizeof(my_addr));//绑定socket和本机ip,portif (ret_bind < 0){perror("fail to bind");exit(1);}char buf[128];socklen_t len = sizeof(peer_addr);listen(sockfd,5); //将绑定端口后的socket改为监听状态,准备接收客户端连接请求,5表示等待建立连接的队列的长度,并不是服务器所连客户端数目int ret_recv;while(1){int confd = accept(sockfd,(SA*)&peer_addr,&len); //调用后,如果 accept() 成功,peer_addr 中会被内核写入发起连接的客户端的 IP 地址和端口号if (confd < 0){perror("fail to accept");exit(1);}printf("ip:%s,port:%d is connect\n",inet_ntoa(peer_addr.sin_addr),ntohs(peer_addr.sin_port));while(1){bzero(buf,sizeof(buf));ret_recv = recv(confd,buf,sizeof(buf),0);if (ret_recv < 0){perror("fail to recv");//perror可以打印系统调用错误信息,括号内为打印字头close(confd);break;}else if (ret_recv == 0){printf("peer is shutdown\n");close(confd);break;}else{printf("%s\n",buf);send(confd,buf,ret_recv,0);}}}return 0;
}注:
1.在上面这些接口里面,只有accept和recv是阻塞的,其他立即返回
accept:  阻塞等待客户端连接,直到有连接请求到达才返回
recv:    阻塞等待接收数据,直到有数据可读或连接关闭
2.可用telnet 127.0.0.1 8080来测试
(1)telnet是一个远程登录与测试通信的命令行工具,基于tcp协议,不能用来测试udp
(2)相当于创建一个tcp client 去连接服务器 127.0.0.18080端口,实现命令行交互
  1. TCP client
#include <stdio.h>
#include <sys/types.h>	       /* See NOTES */
#include <sys/socket.h>
#include <strings.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>#define SA struct sockaddr
int main(int argc,const char* argv[])
{if (argc != 3){printf("please input ip,port\n");exit(1);}int sockfd = socket(AF_INET,SOCK_STREAM,0);//创建一个套接字if (sockfd < 0){perror("fail to socket\n");exit(1);}struct sockaddr_in my_addr,peer_addr;bzero(&my_addr,sizeof(my_addr));my_addr.sin_family = AF_INET;my_addr.sin_port = htons(6000);my_addr.sin_addr.s_addr = inet_addr("0.0.0.0");int ret_bind = bind(sockfd,(SA*)&my_addr,sizeof(my_addr));//将套接字和本机ip,port绑定if(ret_bind < 0){perror("fail to bind\n");close(sockfd);exit(1);}char buf[128];socklen_t len = sizeof(peer_addr);bzero(&peer_addr,sizeof(peer_addr));peer_addr.sin_family = AF_INET;peer_addr.sin_port = htons(atoi(argv[2]));peer_addr.sin_addr.s_addr = inet_addr(argv[1]);int ret_connect = connect(sockfd,(SA*)&peer_addr,len);//connect 连接服务器if (ret_connect < 0){perror("fail to connect\n");close(sockfd);exit(1);}while(1){bzero(buf,sizeof(buf));fgets(buf,sizeof(buf),stdin);send(sockfd,buf,strlen(buf),0);bzero(buf,sizeof(buf));recv(sockfd,buf,sizeof(buf),0);printf("%s\n",buf);}return 0;}
  1. UDP server
#include <stdio.h>
#include <sys/types.h>	       /* See NOTES */
#include <sys/socket.h>
#include <strings.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>#define SA struct sockaddr
int main(int argc,const char*argv)
{int sockfd = socket(AF_INET,SOCK_DGRAM,0);if (sockfd < 0){perror("fail to socket\n");exit(1);}struct sockaddr_in my_addr,peer_addr;socklen_t len=sizeof(peer_addr);bzero(&my_addr,sizeof(my_addr));my_addr.sin_family = AF_INET;my_addr.sin_port = htons(8080);my_addr.sin_addr.s_addr = inet_addr("0.0.0.0");int ret_bind = bind(sockfd,(SA*)&my_addr,sizeof(my_addr));if (ret_bind < 0){perror("fail to bind\n");close(sockfd);exit(1);}char buf[128];while(1){bzero(buf,sizeof(buf));bzero(&peer_addr,len);recvfrom(sockfd,buf,sizeof(buf),0,(struct sockaddr*)(&peer_addr),&len); //接收到数据时才知道对端信息printf("ip:%s port:%d buf:%s \n",inet_ntoa(peer_addr.sin_addr),ntohs(peer_addr.sin_port),buf);sendto(sockfd,buf,strlen(buf),0,(struct sockaddr*)&peer_addr,len);}return 0;
}//recvfrom,sendto和tcp recv,send是不一样的接口
//nc 是一个强大的网络调试工具 nc -u 127.0.0.1 8080 可用来创建udp客户端来测试

4.udp client

#include <stdio.h>
#include <sys/types.h>	       /* See NOTES */
#include <sys/socket.h>
#include <strings.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>#define SA struct sockaddr
int main(int argc,const char*argv[])
{if (argc != 3){printf("please input ip and port\n");return -1;}int sockfd = socket(AF_INET,SOCK_DGRAM,0);if (sockfd < 0){perror("fail to socket\n");exit(1);}struct sockaddr_in my_addr,peer_addr;bzero(&my_addr,sizeof(my_addr));my_addr.sin_family = AF_INET;my_addr.sin_port = htons(6000);my_addr.sin_addr.s_addr = inet_addr("0.0.0.0");int ret_bind = bind(sockfd,(SA*)&my_addr,sizeof(my_addr));if (ret_bind < 0){perror("fail to bind\n");close(sockfd);exit(1);}char buf[128];bzero(&peer_addr,sizeof(peer_addr));peer_addr.sin_family = AF_INET;peer_addr.sin_port = htons(atoi(argv[2]));peer_addr.sin_addr.s_addr = inet_addr(argv[1]);while(1){bzero(buf,sizeof(buf));fgets(buf,sizeof(buf),stdin);sendto(sockfd,buf,strlen(buf),0,(SA*)&peer_addr,sizeof(peer_addr));bzero(buf,sizeof(buf));recvfrom(sockfd,buf,sizeof(buf),0,NULL,NULL);printf("%s\n",buf);}return 0;}

四 总结

1.tcp服务器和客户端编程,最关键的点其实是各调用了哪些API,及API调用顺序,其他都是细枝末节
2.udp相对简单些,API调用较少,但是要注意和tcp调用上的差别,参数,接口不全一样

http://www.lryc.cn/news/597394.html

相关文章:

  • MYSQL 笔记3
  • 实验室信息管理系统的设计与实现/实验室管理系统
  • lwIP学习记录5——裸机lwIP工程学习后的总结
  • 【bug】websocket协议不兼容导致的一个奇怪问题
  • Linux 723 磁盘配额 限制用户写入 quota;snap快照原理
  • Linux 环境下安装 MySQL 8.0.34 二进制 详细教程 附docker+k8s启动
  • VU2 学习笔记4 计算属性、监视属性
  • 北京互联网公司面试题精华解析
  • 计算机网络学习----Https协议
  • 直接偏好优化(DPO):原理、演进与大模型对齐新范式
  • python-82-基于ORM操作数据库(一)简单模型CRUD
  • UniappDay01
  • JavaWeb笔记12
  • MySQL深度理解-深入理解MySQL索引底层数据结构与算法
  • 容联云携手信通院,启动“智能体服务生态共创计划”
  • 华为云ELB(弹性负载均衡)持续报异常
  • 2025年Zigbee技术白皮书:全球物联网无线通信的关键创新
  • HF86611_VC1/HF86611Q_VC1:多通道USB HiFi音频解码器固件技术解析
  • 【自动化运维神器Ansible】深入解析Ansible Host-Pattern:精准控制目标主机的艺术
  • .Net core 部署到IIS出现500.19Internal Server Error 解决方法
  • Ubuntu系统下FFmpeg源码编译安装
  • 内网穿透技术深析:从原理到工具应用的全方位解读,无公网IP本地服务器外网访问实操
  • IGM弧焊机器人气体节约
  • 【数据结构】哈希——位图与布隆过滤器
  • 彩色转灰度的核心逻辑:三种经典方法及原理对比
  • zabbix监控MySQL数据库
  • 企业选择将服务器放在IDC机房托管的优势
  • React+Three.js实现3D场景压力/温度/密度分布可视化
  • Spring Boot与Python的联动:实战案例解析
  • 【智能模型系列】Unity通过访问Ollama调用DeepSeek模型进行本地部署