Socket网络编程(服务端和客户端代码示例)

本文主要讲解Socket网络编程。
首先介绍socket,包括TCP和UDP通信过程;然后介绍常用的函数;最后编写client-server例子,并进行测试。

文章目录

  • Socket介绍
    • TCP通信过程
      • 服务器端通信过程:
      • 客户端通信过程:
    • UDP通信过程
      • 服务器端通信过程:
      • 客户端通信过程:
  • 常用函数介绍
    • socket
      • 函数原型
      • 参数介绍
    • bind
      • 函数原型
      • 参数介绍
    • listen
      • 函数原型
      • 参数介绍
    • connect
      • 函数原型
      • 参数介绍
    • accept
      • 函数原型
      • 参数介绍
    • close
      • 函数原型
      • 参数介绍
    • recv
      • 函数原型
      • 参数介绍
    • send
      • 函数原型
      • 参数介绍
    • recvmsg
      • 函数原型
      • 参数介绍
    • sendmsg
      • 函数原型
      • 参数介绍
      • msghdr
      • flag
    • setsockopt
      • 函数原型
      • 参数介绍
  • demo
    • 服务端代码
    • 客户端代码
    • 测试结果

Socket介绍

C 语言中的 socket 编程是一种用于在网络上进行通信的编程接口。通过 socket,程序可以在不同的计算机之间进行数据交换,实现网络通信的功能。

TCP通信过程

在这里插入图片描述

服务器端通信过程:

  1. 创建 Socket:使用 socket() 函数创建一个套接字,指定地址族为 AF_INET,类型为 SOCK_STREAM(表示流式套接字),协议为 IPPROTO_TCP。这一步通常会得到一个套接字描述符。

  2. 绑定 Socket:调用 bind() 函数将套接字与服务器所在主机的 IP 地址和端口号绑定。这样服务器就可以监听来自该端口的连接请求。

  3. 监听连接请求:使用 listen() 函数开始监听客户端的连接请求,并设置最大连接数。

  4. 接受连接:当有客户端发起连接请求时,使用 accept() 函数接受连接,返回一个新的套接字描述符用于与该客户端进行通信。

  5. 数据通信:通过新的套接字描述符,使用 send() 和 recv() 函数发送和接收数据。通常在一个循环中进行数据交换,直到通信结束。

  6. 关闭连接:通信结束后,关闭新的套接字描述符,释放资源。

客户端通信过程:

  1. 创建 Socket:同样使用 socket() 函数创建套接字,地址族为 AF_INET,类型为 SOCK_STREAM,协议为 IPPROTO_TCP。

  2. 连接服务器:使用 connect() 函数向服务器发起连接请求,指定服务器的 IP 地址和端口号。

  3. 数据通信:连接建立后,使用 send() 和 recv() 函数发送和接收数据,通常也是在一个循环中进行数据交换,直到通信结束。

  4. 关闭连接:通信结束后,关闭套接字描述符,释放资源。

UDP通信过程

在这里插入图片描述

服务器端通信过程:

  1. 创建 Socket:调用socket()函数创建一个套接字,指定地址族为AF_INET,类型为SOCK_DGRAM(数据报套接字),协议为IPPROTO_UDP。这一步通常会得到一个套接字描述符。

  2. 绑定 Socket:使用bind()函数将套接字与服务器所在主机的IP地址和端口号绑定。这样服务器就可以监听来自该端口的数据报。

  3. 数据通信:通过绑定的套接字描述符,使用sendto()和recvfrom()函数发送和接收数据报。UDP是无连接的协议,因此每次发送数据时都需要指定目标的IP地址和端口号。

  4. 关闭连接:通信结束后,关闭套接字描述符,释放资源。

客户端通信过程:

  1. 创建 Socket:同样使用socket()函数创建套接字,地址族为AF_INET,类型为SOCK_DGRAM,协议为IPPROTO_UDP。

  2. 数据通信:通过创建的套接字描述符,使用sendto()和recvfrom()函数发送和接收数据报。UDP是无连接的协议,因此每次发送数据时都需要指定目标的IP地址和端口号。

  3. 关闭连接:通信结束后,关闭套接字描述符,释放资源。

常用函数介绍

socket

函数原型

创建一个新的套接字,返回一个 int 类型的套接字文件描述符,用于后续的网络连接操作。

#include <sys/socket.h>int socket(int domain, int type, int protocol);

参数介绍

  • domain:指定 Socket AF(Address Family,地址族)可选:AF_INET(IPv4)或AF_INET6(IPv6)
  • type:指定数据传输方式,可选:
    • SOCK_STREAM(面向连接的 TCP)
    • SOCK_DGRAM(无连接的 UDP)
    • SOCK_RAW(原始 IP 数据包)
  • protocol:指定具体的传输层协议,可选:
    • IPPROTO_TCP
    • IPPTOTO_UDP
  • 函数返回值:
    • 成功:返回 Socket fd。
    • 失败:返回 -1。

bind

函数原型

将套接字与一个本地 IP:Port 绑定。通常用于服务端,以便在本地监听网络连接

#include <sys/socket.h>int bind(int socket, struct sockaddr *addr, socklen_t addrlen); 

参数介绍

  • socket:指定 Server socket 文件描述符。
  • addr:指定 Server sockaddr 结构体变量,指针类型。
  • addrlen:指定 addr 变量的大小,使用 sizeof() 计算得出。
  • 函数返回值:
    • 成功:返回 0。
    • 失败:返回 -1。

listen

函数原型

开始监听来自远程主机的连接请求。通常用于服务器端,在套接字上等待来自客户端的连接请求。

#include <sys/socket.h>int listen(int socket, int backlog);

参数介绍

  • socket:指定需要进入监听状态的 Server socket 文件描述符。
  • backlog:指定请求队列的最大长度,当队列满了之后,就不再接收请求。
  • 函数返回值:
    • 成功:返回 0。
    • 失败:返回 -1。

connect

函数原型

建立与远程主机的连接。通常用于客户端,以便连接到远程服务器

#include <sys/socket.h>int connect(int socket, struct sockaddr *serv_addr, socklen_t addrlen);  

参数介绍

  • socket:指定 Client socket 文件描述符。
  • serv_addr:指定 Server sockaddr 结构体变量,指针类型。
  • addrlen:指定 addr 变量的大小,使用 sizeof() 计算得出。
  • 函数返回值:
    • 成功:返回 0。
    • 失败:返回 -1。

accept

函数原型

接受一个连接请求,返回一个新的、表示客户端的 Socket 文件描述符,作为服务端和客户端之间发送与接收操作的句柄。通常用于服务器端,用于接收客户端的连接请求。

#include <sys/socket.h>int accept(int sock, struct sockaddr *addr, socklen_t *addrlen);

参数介绍

  • socket:指定 Server socket 文件描述符。
  • addr:指定 Client sockaddr 结构体变量,指针类型。
  • addrlen:指定 addr 变量的大小,使用 sizeof() 计算得出。
  • 函数返回值:
    • 成功:返回 Client socket fd。
    • 失败:返回 -1。

close

函数原型

关闭套接字连接。

#include <unistd.h>int close(int fildes);

参数介绍

  • fd:指定要关闭的 Socket 的文件描述符。
  • 函数返回值:
    • 成功:返回0。
    • 失败:返回 -1。

recv

函数原型

从套接字接收数据

#include <sys/socket.h>ssize_t recv(int sockfd, void *buf, size_t len, int flags);

参数介绍

  • sockfd:指定要接收 TCP 数据的 Socket 文件描述符。
  • buf:指定接收数据缓冲区的入口地址。
  • len:指定要接收的数据的 Byte 数目。
  • flags:指定接收数据时的选项,常设为 0。
  • 函数返回值:
    • 成功:返回接收的字节数。
    • 失败:返回 -1。

send

函数原型

向套接字发送数据。

 #include <sys/socket.h>ssize_t send(int sockfd, const void *buf, size_t len, int flags);

参数介绍

  • sockfd:指定要发送 TCP 数据的 Socket 文件描述符。
  • buf:指定发送数据缓冲区入的口地址。
  • len:指定要发送数据的 Byte 数目。
  • flags:指定发送数据时的选项,常设为 0。
  • 函数返回值:
    • 成功:返回发送的字节数。
    • 失败:返回 -1。

recvmsg

函数原型

#include <sys/socket.h>ssize_t sendmsg(int sockfd, const struct msghdr *msg, int flags);

参数介绍

  • sock:指定要接收 TCP 或 UDP 数据的 Socket 文件描述符。
  • msg:指示将接收的数据存储到 msghdr 结构体中。
  • flags:支持函数的行为,可选 0 或者 MSG_DONTWAIT 等标志位。
  • 函数返回值:
    • 成功:返回接收的字节数。
    • 失败:返回 -1。

sendmsg

函数原型

#include <sys/socket.h>ssize_t sendmsg(int sockfd, const struct msghdr *msg, int flags);

参数介绍

  • sock:指定要发送 TCP 或 UDP 数据的 Socket 文件描述符。
  • msg:指示 msghdr 结构体中包含了要发送的数据、数据长度等信息。
  • flags:支持函数的行为,可选 0 或者 MSG_DONTWAIT 等标志位。
  • 函数返回值:
    • 成功:返回发送的字节数。
    • 失败:返回 -1。

msghdr

struct msghdr {/* 指定接收或发送数据的对端地址,可以为 NULL 或 0,表示不需要使用对端地址。*/void         *msg_name;       /* optional address */socklen_t     msg_namelen;    /* size of address *//* 指定接收或发送数据的缓冲区和缓冲区大小,可以使用多个缓冲区同时接收或发送数据。*/struct iovec *msg_iov;        /* scatter/gather array */size_t        msg_iovlen;     /* # elements in msg_iov *//* 指定一些附加的控制信息,可以为 NULL 或 0。*/void         *msg_control;    /* ancillary data, see below */size_t        msg_controllen; /* ancillary data buffer len *//* 指定函数的行为,例如是否需要接收带外数据等。*/int           msg_flags;      /* flags on received message */
};

flag

  • MSG_PEEK:允许从接收队列中查看数据而不将其删除。这意味着,如果接收队列中有数据,recv() 函数将返回数据的一个副本,但是该数据仍将留在接收队列中。这对于查看接收队列中的数据而不实际处理它们非常有用。此外,使用 MSG_PEEK 选项,我们可以检查套接字缓冲区中是否有足够的数据可供读取,以便稍后调用 recv() 函数。
  • MSG_WAITALL:如果套接字缓冲区中没有足够的数据,则 recv() 函数将一直等待,直到收到请求的数据量。
  • MSG_DONTWAIT:指定此标志后,recv() 函数将立即返回,即使没有收到数据也不会阻塞。如果没有数据可用,则 recv() 将返回 -1,并将 errno 设置为 EAGAIN 或 EWOULDBLOCK。
  • MSG_OOB:用于处理带外数据,即紧急数据。带外数据不遵循正常的传输控制协议(如 TCP),可以使用此标志将其标记为紧急数据并将其与其他数据分开处理。
  • MSG_TRUNC:如果接收缓冲区中的数据比接收缓冲区长度长,则截断数据并返回。
  • MSG_CTRUNC:如果接收缓冲区中的控制消息(例如带外数据或错误消息)比接收缓冲区长度长,则截断消息并返回。

setsockopt

函数原型

设置socket选项值

#include <sys/socket.h>int setsockopt(int sockfd, int level, int optname, const void *optval, socklen_t optlen);

参数介绍

  • sockfd:指定 socket fd。
  • level:指定选项的协议层,可选 SOL_SOCKET、IPPROTO_TCP、IPPROTO_IP 等。
  • optname:指定要设置的选项名。
    • SO_REUSEADDR:int 类型,表示重用 IP 地址。
    • SO_KEEPALIVE:int 类型,用于启用/禁用 Keepalive(保持连接)功能。
    • SO_LINGER:struct linger 类型,用于指定关闭套接字时的行为。
    • TCP_NODELAY:int 类型,用于禁用 Nagle 算法,从而实现数据的实时传输。
  • optval:指定存放选项值的缓冲区入口。
  • optlen:指定选项值缓冲区的长度。
  • 函数返回值:
    • 成功:0。
    • 失败:-1,并设置了 errno 错误码。

demo

服务端代码

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <arpa/inet.h>
#include <sys/socket.h>#define PORT 8888
#define MAXLINE 1024int main() {int sockfd, connfd;char buffer[MAXLINE];struct sockaddr_in servaddr, cli;sockfd = socket(AF_INET, SOCK_STREAM, 0);// 创建TCP套接字if (sockfd == -1) {printf("socket creation failed");return EXIT_FAILURE;}// 设置服务器地址结构servaddr.sin_family = AF_INET; // IPv4servaddr.sin_addr.s_addr = INADDR_ANY;servaddr.sin_port = htons(PORT);// 绑定服务器套接字if (bind(sockfd, (struct sockaddr*)&servaddr, sizeof(servaddr)) != 0) {printf("socket bind failed");return EXIT_FAILURE;}// 监听连接if (listen(sockfd, 5) != 0) {printf("listen failed");return EXIT_FAILURE;}socklen_t len = sizeof(cli);// 接受连接connfd = accept(sockfd, (struct sockaddr*)&cli, &len);if (connfd < 0) {printf("server accept failed");return EXIT_FAILURE;}// 读取客户端消息ssize_t num = recv(connfd, buffer, sizeof(buffer),0);if (num < 0){printf("read data from client fail, num=%ld\n", num);return EXIT_FAILURE;}printf("Client message: %s, size: %ld\n", buffer, num);char * data = "hello world";// 发送消息给客户端num = send(connfd, data, strlen(data),0);if (num < 0){printf("write data to client fail, num=%ld\n", num);return EXIT_FAILURE;}// 关闭连接close(sockfd);return 0;
}

客户端代码

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <arpa/inet.h>
#include <sys/socket.h>#define PORT 8888
#define MAXLINE 1024int main() {int sockfd;char buffer[MAXLINE];struct sockaddr_in servaddr;// 创建TCP套接字sockfd = socket(AF_INET, SOCK_STREAM, 0);if (sockfd == -1) {printf("socket creation failed\n");return EXIT_FAILURE;}// 设置服务器地址结构servaddr.sin_family = AF_INET; // IPv4servaddr.sin_port = htons(PORT);servaddr.sin_addr.s_addr = inet_addr("127.0.0.1");// 连接服务器if (connect(sockfd, (struct sockaddr*)&servaddr, sizeof(servaddr)) != 0 ) {printf("connection with server failed\n");return EXIT_FAILURE;}char *data = "client send data";// 发送消息给服务器ssize_t num = send(sockfd, data, strlen(data),0);if (num < 0 ){printf("write data to server fail\n");return EXIT_FAILURE;}// 读取服务器响应num = recv(sockfd, buffer, sizeof(buffer),0);if (num < 0 ){printf("read data from client fail\n");return EXIT_FAILURE;}printf("Server response: %s\n", buffer);// 关闭连接close(sockfd);return 0;
}

测试结果

编译和运行服务端:在这里插入图片描述
编译和运行客户端:
在这里插入图片描述

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

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

相关文章

SA实战 ·《SpringCloud Alibaba实战》第13章-服务网关:项目整合SpringCloud Gateway网关

大家好,我是冰河~~ 一不小心[SpringCloud Alibaba实战》专栏都更新到第13章了,再不上车就跟不上了,小伙伴们快跟上啊! 在《SpringCloud Alibaba实战》专栏前面的文章中,我们实现了用户微服务、商品微服务和订单微服务之间的远程调用,并且实现了服务调用的负载均衡。也基于…

FusionDiff:第一个基于扩散模型实现的多聚焦图像融合的论文

文章目录 1. 论文介绍2. 研究动机3. 模型结构3.1 网络架构3.2 前向扩散过程3.3 逆向扩散过程3.4 训练和推理过程 4. 小样本学习4. 实验结果 1. 论文介绍 题目&#xff1a;FusionDiff: Multi-focus image fusion using denoising diffusion probabilistic models 作者&#xf…

【Mysql系列】Mysql基础篇

&#x1f49d;&#x1f49d;&#x1f49d;欢迎来到我的博客&#xff0c;很高兴能够在这里和您见面&#xff01;希望您在这里可以感受到一份轻松愉快的氛围&#xff0c;不仅可以获得有趣的内容和知识&#xff0c;也可以畅所欲言、分享您的想法和见解。 推荐:kwan 的首页,持续学…

Smart Link 和 Monitor Link应用

定义 Smart Link常用于双上行链路组网&#xff0c;提高接入的可靠性。 Monitor Link通过监视上行接口&#xff0c;使下行接口同步上行接口状态&#xff0c;起到传递故障信息的作用。 Smart Link&#xff0c;又叫做备份链路。一个Smart Link由两个接口组成&#xff0c;其中一个…

医用污水处理一体化设备怎么选

选择医用污水处理一体化设备时&#xff0c;可以从以下几个方面进行考虑&#xff1a; 设备材质&#xff1a;选择耐腐蚀、耐磨损、抗老化的材质&#xff0c;例如不锈钢、玻璃钢等。同时要确保设备罐体的抗压性能。工艺流程&#xff1a;选择高效、稳定、安全的工艺流程&#xff0…

智慧渔业捕捞计数项目设计书

&#xff08;一&#xff09;项目背景 根据捕捞水域的不同&#xff0c;我国水产捕捞可划分为海洋捕捞、远洋捕捞以及淡水捕捞三大类型。其中&#xff0c;淡水渔业主要是指在淡水水域进行捕捞、养殖以获得淡水水产品并对这些水产品进行加工的社会生产领域。 近年来&#xff0c;随…

vim相关命令讲解!

本文旨在讲解vim 以及其相关的操作&#xff01; 希望读完本文&#xff0c;读者会有一定的收获&#xff01;好的&#xff0c;干货马上就来&#xff01; 初识vim 在讲解vim之前&#xff0c;我们首先要了解vim是什么&#xff0c;有什么作用&#xff1f;只有了解了vim才能更好的理…

【Amazon】云上探索实验室—了解 AI 编程助手 Amazon Codewhisperer

文章目录 一、前言&#x1f4e2;二、关于云上探索实验室&#x1f579;️三、领学员需要做什么&#xff1f;✴️四、领学员能获得什么&#xff1f;&#x1f523;五、学课通道入口&#x1f447;1️⃣CSDN平台2️⃣网易云课堂3️⃣Skill Builder 平台 六、活动详情链接 一、前言&a…

详解IP安全:IPSec协议簇 | AH协议 | ESP协议 | IKE协议

目录 IP安全概述 IPSec协议簇 IPSec的实现方式 AH&#xff08;Authentication Header&#xff0c;认证头&#xff09; ESP&#xff08;Encapsulating Security Payload&#xff0c;封装安全载荷&#xff09; IKE&#xff08;Internet Key Exchange&#xff0c;因特网密钥…

Shell脚本 CPU,内存,磁盘占用率检测

CPU&#xff1a;运算资源占用 内存&#xff1a;RAM类介质 磁盘&#xff1a;ROM类介质 一、CPU #!/bin/bash# 设置阈值&#xff0c;当CPU占用超过该阈值时进行输出提示 threshold80while true do# 使用top命令获取CPU占用信息&#xff0c;并使用grep和awk筛选和解析输出结果…

开源会议通知H5页面邀请函制作源码系统+自动翻页 带完整的搭建教程

现如今&#xff0c;线上活动越来越频繁&#xff0c;而会议邀请函也成为了活动组织者不可或缺的工具。然而&#xff0c;传统的邮件、短信等方式发送邀请函已经无法满足现代人的需求。因此&#xff0c;开发一款现代化的、功能丰富的会议邀请函系统势在必行。下面源码小编将来给大…

Wireshark学习 与 TCP/IP协议分析

Wireshark简介和工具应用 如何开始抓包&#xff1f; 打开wireshark&#xff0c;显示如下网络连接。选择你正在使用的&#xff0c;&#xff08;比如我正在使用无线网上网&#xff09;&#xff0c;双击 可以先看下自己的ip地址和网关ip地址&#xff08;看抓包数据时候会用到&…

【React】Antd 组件基本使用

Antd 组件基本使用 第一步 安装并引入 antd 包 使用命令下载这个组件库 yarn add antd在我们需要使用的文件下引入&#xff0c;我这里是在 App.jsx 内引入 import { Button } from antd现在我们可以在 App 中使用 Button 组件 <div>App..<Button type"prima…

基于Mahony互补滤波的IMU数据优化_学习笔记整理

这周自己被安排进行优化软件 IMU 姿态解算项目&#xff0c;之前自己只简单了解四元数&#xff0c;对IMU数据处理从未接触&#xff0c;通过这一周的学习感觉收获颇丰&#xff0c;在今天光棍节之际&#xff0c;&#xff0c;&#xff0c;用大半天的时间对这一周的收获进行整理&…

程序员刚毕业找工作,选大厂和小厂有什么区别

前言 **关于应届生毕业之后应该去大厂好还是小厂好&#xff0c;一直都是被热议的话题之一。**对于刚毕业的应届生来说是一个特别难的问题&#xff0c;怕选择错会后悔。同时周围的亲戚朋友也各抒己见&#xff1a;‘’一定要去大公司&#xff01;大公司名气响&#xff0c;在那里…

Amazon Bedrock | 大语言模型CLAUDE 2体验

这场生成式AI与大语言模型的饥饿游戏&#xff0c;亚马逊云科技也参与了进来。2023年&#xff0c;亚马逊云科技正式发布了 Amazon Bedrock&#xff0c;是客户使用基础模型构建和扩展生成式AI应用程序的最简单方法&#xff0c;为所有开发者降低使用门槛。在 Bedrock 上&#xff0…

医学统计学必备知识点分享,常笑医学为医学生答疑解惑

医学统计学作为医学生必修的一门课程&#xff0c;贯穿了医学生的整个职业生涯&#xff0c;在论文撰写、科研课题设计、医学研究职业发展等方面有着不可替代的重要性。 但是医学统计的学习门槛很高&#xff0c;大学开设的课程往往只侧重于理论&#xff0c;而没有结合实际工作&a…

什么叫做云安全?云安全有哪些要求?

云安全(Cloud Security)是一种基于云计算的安全防护策略&#xff0c;旨在保护企业数据和应用程序的安全性和完整性。云安全利用云计算的分布式处理和存储能力&#xff0c;以更高效、更灵活的方式提供安全服务。 云安全的要求主要包括以下几个方面&#xff1a; 数据安全和隐私保…

reticulate | R-python调用 | 安装及配置 | conda文件配置

reticulate | R-python安装及配置 | conda文件配置 1. 基础知识2. 安装reticulate from CRAN3. 包含了用于Python和R之间协同操作的全套工具&#xff0c;在R和Rstudio中均可使用4. 配置python环境4.1 4种环境配置方式4.2 miniconda 环境install_miniconda()报错一install_minic…

(论文阅读30/100)Convolutional Pose Machines

30.文献阅读笔记CPMs 简介 题目 Convolutional Pose Machines 作者 Shih-En Wei, Varun Ramakrishna, Takeo Kanade, and Yaser Sheikh, CVPR, 2016. 原文链接 https://arxiv.org/pdf/1602.00134.pdf 关键词 Convolutional Pose Machines&#xff08;CPMs&#xff09;…