网络: 套接字

news2024/9/23 22:39:36

套接字: 在网络上进行进程间通信

网络字节序与主机字节序的转化

sockaddr

sockaddr

struct sockaddr {
    sa_family_t sa_family; // 地址族
    char        sa_data[14]; // 地址数据,具体内容与地址族相关
};

sockaddr_in :主要是地址类型, 端口号, IP地址. 基于IPv4编程时, 使用的数据结构sockaddr_in

struct sockaddr_in {
    sa_family_t    sin_family;  // 地址族,通常为 AF_INET
    in_port_t      sin_port;    // 端口号,网络字节顺序
    struct in_addr sin_addr;    // IPv4 地址结构
    char           sin_zero[8]; // 无用字段,通常用零填充
};

struct in_addr {
    in_addr_t s_addr; // IPv4 地址,32 位无符号整数,网络字节顺序
};

地址转换函数

字符串转in_addr的函数

in_addr转字符串的函数

sock常见API

头文件: <sys/socket.h>  <netinet/in.h>  <arpa/inet.h>  <fcntl.h>

// 创建 socket 文件描述符(TCP/UDP, 客户端 + 服务器) (返回一个套接字描述符,失败返回 -1)
int socket(int domain, int type, int protocol);

// 绑定端口号 (TCP/UDP, 服务器) (成功绑定返回 0,失败返回 -1)
int bind(int socket, const struct sockaddr *address,socklen_t address_len);

// 开始监听socket (TCP, 服务器) (成功返回 0,失败返回 -1)
int listen(int socket, int backlog);

// 接收请求 (TCP, 服务器) (成功返回一个套接字描述符,失败返回 -1)
int accept(int socket, struct sockaddr* address,socklen_t* address_len);

// 建立连接 ((TCP, 客户端) (成功返回0, 失败返回-1)
int connect(int sockfd, const struct sockaddr *addr,socklen_t addrlen);

//关闭文件描述符 (成功返回 0, 失败返回-1)
close(sockfd);


// 发送数据 (TCP/UDP) (返回发送的字节数,失败返回 -1)
ssize_t send(int sockfd, const void *buf, size_t len, int flags);

// 接收数据 (TCP/UDP) (返回接收的字节数,失败返回 -1)
ssize_t recv(int sockfd, void *buf, size_t len, int flags);

// 发送数据到指定目标 (UDP)
ssize_t sendto(int sockfd, const void *buf, size_t len, int flags, 
             const struct sockaddr *dest_addr, socklen_t addrlen);

// 接收数据并记录发送端地址信息 (UDP)
ssize_t recvfrom(int sockfd, void *buf, size_t len, int flags,
               struct sockaddr *src_addr, socklen_t *addrlen);

TCP套接字

  • 客户端
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>

int main() 
{
    int sockfd;
    struct sockaddr_in server_addr;
    char buffer[1024];

    // 1.创建套接字 (-1表示失败)
    sockfd = socket(AF_INET, SOCK_STREAM, 0);

    // 设置服务器地址信息
    server_addr.sin_family = AF_INET;
    server_addr.sin_port = htons(8080); // 服务器端口
    server_addr.sin_addr.s_addr = inet_addr("127.0.0.1"); // 服务器 IP 地址

    // 2.连接服务器 (-1表示是啊比)
    connect(sockfd, (struct sockaddr *)&server_addr, sizeof(server_addr)

    // 3.发送数据
    send(sockfd, "Hello, server!", strlen("Hello, server!"), 0);

    // 4.接收数据
    recv(sockfd, buffer, sizeof(buffer), 0);
    printf("Server says: %s\n", buffer);

    // 5.关闭套接字
    close(sockfd);

    return 0;
}
  • 服务端
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>

int main() 
{
    int sockfd, newsockfd;
    struct sockaddr_in server_addr, client_addr;
    socklen_t client_len;
    char buffer[1024] = "Hello, client!";

    // 1.创建套接字 (-1表示失败)
    sockfd = socket(AF_INET, SOCK_STREAM, 0);

    // 设置服务器地址信息
    server_addr.sin_family = AF_INET;
    server_addr.sin_port = htons(8080);       // 监听端口
    server_addr.sin_addr.s_addr = INADDR_ANY; // 监听所有网络接口

    // 2.绑定端口(-1表示失败)
    bind(sockfd, (struct sockaddr *)&server_addr, sizeof(server_addr)

    // 3.监听连接(-1表示失败)
    listen(sockfd, 5);

    // 4.接受连接(-1表示失败)
    client_len = sizeof(client_addr);
    newsockfd = accept(sockfd, (struct sockaddr *)&client_addr, &client_len);

    // 5.接收数据
    recv(newsockfd, buffer, sizeof(buffer), 0);
    printf("Client says: %s\n", buffer);

    // 6.发送数据
    send(newsockfd, "Hello, client!", strlen("Hello, client!"), 0);

    // 7.关闭连接
    close(newsockfd);
    close(sockfd);

    return 0;
}

UDP套接字

  • 客户端
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <arpa/inet.h>

#define SERVER_IP "127.0.0.1"
#define PORT 12345
#define MAX_LINE 100

int main() {
    int sockfd;
    struct sockaddr_in server_addr;
    char buffer[MAX_LINE];
    socklen_t server_len;
    ssize_t bytes_sent, bytes_received;

    // 1.创建套接字(返回值 < 0 表示失败)
    sockfd = socket(AF_INET, SOCK_DGRAM, 0);

    // 设置服务器地址
    memset(&server_addr, 0, sizeof(server_addr));
    server_addr.sin_family = AF_INET;
    server_addr.sin_port = htons(PORT);
    //将一个文本格式的 IPv4 或 IPv6 地址转换为网络字节序(大端序)的二进制形式
    inet_pton(AF_INET, SERVER_IP, &server_addr.sin_addr);


    // 发送数据 (返回值 < 0 表示失败)
    char *message = "Hello, server!";
    server_len = sizeof(server_addr);
    bytes_sent = sendto(sockfd, message, strlen(message), 0, 
                (struct sockaddr*)&server_addr, server_len);

    // 接收数据 (返回值< 0 表示出错)
    bytes_received = recvfrom(sockfd, buffer, MAX_LINE, 0, NULL, NULL);
    buffer[bytes_received] = '\0';
    printf("Received from server: %s\n", buffer);

    // 关闭套接字
    close(sockfd);

    return 0;
}
  • 服务端
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <arpa/inet.h>

#define PORT 12345
#define MAX_LINE 100

int main() 
{
    int sockfd;
    struct sockaddr_in server_addr, client_addr;
    char buffer[MAX_LINE];
    socklen_t client_len;
    ssize_t bytes_received, bytes_sent;

    // 1.创建套接字
    sockfd = socket(AF_INET, SOCK_DGRAM, 0);

    // 设置服务器地址
    memset(&server_addr, 0, sizeof(server_addr));
    server_addr.sin_family = AF_INET;
    server_addr.sin_addr.s_addr = htonl(INADDR_ANY);
    server_addr.sin_port = htons(PORT);

    // 2.绑定端口
    bind(sockfd, (struct sockaddr *)&server_addr, sizeof(server_addr));

    // 3.接收数据
    client_len = sizeof(client_addr);
    bytes_received = recvfrom(sockfd, buffer, MAX_LINE, 0, 
            (struct sockaddr *)&client_addr, &client_len);
    buffer[bytes_received] = '\0';

    // 4.发送数据
    char *message = "Hello, client!";
    bytes_sent = sendto(sockfd, message, strlen(message), 0, 
                (struct sockaddr *)&client_addr, client_len);

    // 5.关闭套接字
    close(sockfd);

    return 0;
}

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

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

相关文章

openGauss学习笔记-251 openGauss性能调优-使用Plan Hint进行调优-行数的Hint

文章目录 openGauss学习笔记-251 openGauss性能调优-使用Plan Hint进行调优-行数的Hint251.1 功能描述251.2 语法格式251.3 参数说明251.4 建议251.5 示例 openGauss学习笔记-251 openGauss性能调优-使用Plan Hint进行调优-行数的Hint 251.1 功能描述 指明中间结果集的大小&a…

初识C++(三)构造函数和析构函数

目录 一、构造函数&#xff1a; 1.构造函数的概念&#xff1a; 2.构造函数的特性&#xff1a; 3.构造函数的形式&#xff1a; 4.为什么要引出构造函数这一概念 5.默认构造函数包括&#xff1a; 6.对默认生成的构造函数不处理内置类型的成员这事的解决办法&#xff1a; …

Adobe Illustrator和Photoshop哪个难学?另一款好用设计软件上位!

当设计开始时&#xff0c;几乎没有人不知道。 Adobe 公司的两大设计软件&#xff1a;Adobe Illustrator 和 Photoshop。虽然 Adobe Illustrator和 Photoshop 很有名&#xff0c;有一定设计经验的设计师在前期探索使用后可以对 Adobe Illustrator和 Photoshop 的使用差异有一个大…

拓展 Amazon S3 技术边界: Amazon S3 Express One Zone 的创新之路

自 Amazon S3 服务推出以来&#xff0c;一直是全球各行各业数百万客户钟爱的云存储服务。然而&#xff0c;随着新兴用例的不断涌现&#xff0c;传统存储方式面临性能瓶颈&#xff0c;尤其是对于对延迟极为敏感的应用程序。为前不久展开的亚马逊云科技 re:Invent 2023 大会上发布…

AI:154-利用机器学习进行电力系统故障检测与预测

本文收录于专栏:精通AI实战千例专栏合集 从基础到实践,深入学习。无论你是初学者还是经验丰富的老手,对于本专栏案例和项目实践都有参考学习意义。 每一个案例都附带关键代码,详细讲解供大家学习,希望可以帮到大家。正在不断更新中~ 一.利用机器学习进行电力系统故障检测…

自增不再简单:深入探索MySQL自增ID的持久化之道

概述 MySQL中的自增特性估计大家或多或少都是用过。一张表中只能由一个自增字段&#xff0c;通常我们会把它设置为主键&#xff0c;但是随着大家系统越来越分布式&#xff0c;为了一些性能和可扩展性问题&#xff0c;大家目前选择更多的都是分布式ID&#xff08;雪花算法、UUI…

Nextcloud激活被锁用户

Nextcloud激活用户 如果docker下没有安装sudo 和 vim执行下面命令&#xff0c;安装了则跳过 #进入docker内部 #更新apt-get apt-get update #安装sudo apt-get install sudo #安装vim apt-get install vim 修改下面文件内容&#xff0c;否则执行occ命令可能报错 进入上面查询…

吴恩达深度学习笔记:浅层神经网络(Shallow neural networks)3.1-3.5

目录 第一门课&#xff1a;神经网络和深度学习 (Neural Networks and Deep Learning)第三周&#xff1a;浅层神经网络(Shallow neural networks)3.1 神经网络概述&#xff08;Neural Network Overview&#xff09;3.2 神经网络的表示&#xff08;Neural Network Representation…

搭建 canal 监控mysql数据到RabbitMQ

项目需求&#xff1a; 使用canal监控mysql某个库某个表&#xff0c;或者多个库&#xff0c;多个表---- update/inster/create 操作&#xff0c; 系统版本mysql版本java版本canal版本rabbitMQ版本Rocky 9.2MySQL 8.0.26openjdk 11.0.221.1.6rabbitmq-server 3.12.4 mysql 配置…

JMeter元件作用域和执行顺序

JMeter元件作用域和执行顺序 元件的基本介绍基本元件总结 作用域的基本介绍作用域的原则元件执行顺序Jmeter第一个案例&#xff1a; Jmeter三个重要组件&#xff08;重点&#xff09;线程组特点线程组分类线程组的属性案例分析 HTTP请求案例一&#xff08;使用HTTP请求路径来传…

Mysql如何创建存储过程,Navicat如何创建存储过程

一、 通过sql创建和调用存储过程 DELIMITER // CREATE PROCEDURE no_parameters_procedure_name() BEGIN -- 代码块 select 测试无参存储过程; END //DELIMITER ;call no_parameters_procedure_name();二、 通过Navicat界面创建存储过程 格式为 CREATE DEFINERroot% PROCE…

cas学习2:idea里搭建cas项目

在上篇中介绍了cas服务在tomcat中怎么启动的及某j集成cas&#xff0c;这篇讲下idea怎么集成cas成一个项目&#xff0c;为后续的定制化开发做好铺垫。 1.下载CAS 模板 Overlay Template&#xff0c;我这里使用 Apereo CAS 5.3 版本&#xff0c;JDK需要1.8 地址&#xff1a;Git…

目前国内体验最佳的AI问答助手:kimi.ai

文章目录 简介图片理解长文档解析 简介 kimi.ai是国内初创AI公司月之暗面推出的一款AI助手&#xff0c;终于不再是四字成语拼凑出来的了。这是一个非常存粹的文本分析和对话工具&#xff0c;没有那些东拼西凑花里胡哨的AIGC功能&#xff0c;实测表明&#xff0c;这种聚焦是对的…

基于nodejs+vue家装一体化平台python-flask-django-php

提高现下家装一体化平台的准确度&#xff0c;同时降低经济波动带来的不良影响&#xff0c;希望本文能对广大学者的研究提供参考。 前端技术&#xff1a;nodejsvueelementui, Express 框架于Node运行环境的Web框架, 语言 node.js 框架&#xff1a;Express 前端:Vue.js 数据库&am…

使用git下载github/gitee仓库部分或单个文件的方法

前言 有些时候在github或者gitee仓库中我们只需要下载整个项目中的我门需要的那一部分文件夹或文件就行了&#xff0c;不需要下载所有的项目。这样可以节省很多流量和时间 步骤 1.建立一个新的 git 本地仓库 这里我在D:\test中初始化 命令&#xff1a; git init2.在本地仓…

使用JMeter进行梯度压测

使用JMeter进行梯度压测 梯度压测配置如下&#xff1a; 使用线程:5&#xff0c;然后循环5000次&#xff0c;共2.5万个样本使用线程:10&#xff0c;然后循环5000次&#xff0c;共5万个样本使用线程:15&#xff0c;然后循环5000次&#xff0c;共7.5万个样本使用线程:20&#xff…

Excel·VBA数组分组问题

看到一个帖子《excel吧-数据分组问题》&#xff0c;对一组数据分成4组&#xff0c;使每组的和值相近 目录 代码思路1&#xff0c;分组形式、可分组数代码1代码2代码2举例 2&#xff0c;数组所有分组形式举例 这个问题可以转化为2步&#xff1a;第1步&#xff0c;获取一组数据…

【msyql】mysqldump: 未找到命令...

使用mysqldump备份数据库出现错误提示&#xff1a; mysqldump: 未找到命令... 执行的命令如下&#xff1a; mysqldump -uroot -proot --databases db_user > /home/backups/databackup.sql 解决方法 确认mysql是否安装 查看mysql版本 mysql --version 查找mysql安装路…

STM32学习笔记(6_5)- TIM定时器的输出捕获原理

无人问津也好&#xff0c;技不如人也罢&#xff0c;都应静下心来&#xff0c;去做该做的事。 最近在学STM32&#xff0c;所以也开贴记录一下主要内容&#xff0c;省的过目即忘。视频教程为江科大&#xff08;改名江协科技&#xff09;&#xff0c;网站jiangxiekeji.com 现在开…

在for循环加判断条件当条件都满足时,同时显现的解决方法

一、代码示例 function fu(s) {str ;ste ;console.log(s);let Things s;for (let i 0; i < Things.length; i) {if (Things[i].pid kk) {console.log(Things[i].pid);ste <div class"commodity_nei"><div class"zxc_pic"><div cl…