网络编程之套接字

news2025/3/5 3:08:54

端口 && IP

在学习套接字编程之前，我们必须了解一下前缀知识。首先是IP和端口的作用。

在这之前，我们要明白一件事。那就是把数据从一台主机发送到另一台主机，是目的吗？？？当然不是！！我们要把数据从一台主机发送到另一台主机指定中的一个进程，再由这个进程对数据进行处理后返回给用户。这才是目的！！那么我们通过IP找到了指定的主机，如何找到主机上指定的进程呢？？ 那么我们就需要用到端口号(port)。

IP : 标识全网唯一一台主机(不太准确，暂时这么理解)

port 端口号 : 标识主机中唯一的一个进程

所以，IP + port 是不是就可以确定全网唯一 一个进程？ 因为 IP确定全网唯一一台主机，端口号确定主机上唯一的一个进程。所以 IP + port 就可以确定全网唯一 一个进程。

而这个时候，我们主机与主机之间的通信，就变成了进程与进程之间的通信！进程间通信的本质是什么？是让多个进程可以看到同一份资源！在本地主机中这份资源可以是内存，也可以是文件。但是在多台主机中，这份资源就是我们熟悉的网络！！

所以我们可以用server把数据发送到网络中，再由对端的client从网络中读。就类似于读文件和写文件的操作一样，就可以实现跨网络的进程间通信！！

注意！

端口一旦确定，那么就不能改变！！因为在对应的客户端必须要指定服务器的端口，而此时如果服务器改变了自己的端口号，那么客户端也必须做到相应的改变！但显然客户并不会意识到这一点，所以端口号一旦确定，不要轻易改变！！！

TCP && UDP

接下来我们再浅浅了解一下TCP和UDP 。

TCP协议的特点

  • 传输层协议
  • 会建立连接
  • 可靠传输
  • 面向字节流

UDP协议的特点

  • 传输层协议
  • 不建立连接
  • 不可靠传输
  • 面向数据报

有连接 && 无连接

显然，UDP和TCP都是传输层协议，那么建立连接这个怎么理解呢？这就很类似两个人打电话，必须要先有一方给另一方播电话。而另一方看到电话来了只有在接通之后两人才能进行通信。而这个过程就类似于TCP的连接过程。

而UDP是无连接的，就意味着你给对方发送数据压根就不用等对方确认。就相当于你给对方打电话，对方不能自己接通，而是电话自动接通。这就是无连接 。

**可靠传输 && 不可靠传输 **

首先我们要知道，可靠和不可靠在这里都是一个中性词。并不是一个贬义词，因此不能因为UDP是不可靠传输就说UDP差。我们要知道，保证可靠性是有代价的！！ 因为TCP提供了各种可靠性机制，所以这也就意味着TCP会非常复杂！而UDP是不可靠性传输，就意味着它比较简单。各有各的优势，还是看场景进行选择。

注意！！无论是UDP和TCP，没有明显的谁慢谁快。因为跨网络传输看的是两台主机之间的距离和当前的网络状态！！与协议关系并不大。

面向字节流 && 面向数据报

面向字节流就是以字节流的形式进行报文的发送，那么这就意味着发送的时候，报文可能并不完整！比如你主机的传输层缓冲区已经满了，但是你的报文只接收了前面一点点。就只能等缓冲区被提取后才会接收后面的数据。这种现象就是面向字节流的！

面向数据报则是每次发送/接收，都必须是完整的报文！不存在断截之后再续上的现象，这就叫做面向数据报传输！！

网络字节序

我们都知道内存的字节存储方式有大端和小端。

大端存储 高位放在低字节序，低位放在高字节序 如：0X11223344 在内存中存储是 11 22 33 44

小端存储 低位放在低字节序，高位放在高字节序 如：0X11223344 在内存中存储是 44 33 22 11

既然不同的机器有不同的存储方式，那你怎么保证你小端发送的数据和大端接收的数据是匹配的？

很简单！！只要规定在网络上传输的数据都必须按大端字节序来存储！！发送发如果是小端则只需要转到大端发送即可，接收方是小端再由大端转回小端即可，如果是大端则不需要操作。

但是如果让我们自己来转换，那是不是太麻烦了呢？所以操作系统提供了下面的接口来供我们转换序列。

#include <arpa/inet.h>

uint32_t htonl(uint32_t hostlong); //主机转网络序列，转成long类型
uint16_t htons(uint16_t hostshort); //主机转网络序列，转成short类型
uint32_t ntohl(uint32_t netlong); //网络序列转主机序列，转成long类型
uint16_t ntohs(uint16_t netshort); //网络序列转主机序列，转成short类型

其中的h代表主机host，to就是到的意思，n则是network网络的意思。l对应long，s对应short。所以上面的函数其实很好记忆。

Socket套接字编程

Socket是一个套接字，它的本质就是一个文件描述符。对应的是网卡文件，我们只需要往文件描述符里面写入，就可以把数据发送到网络。

函数介绍

套接字的创建(UDP/TCP/服务端/客户端)

#include <sys/types.h>          /* See NOTES */
#include <sys/socket.h>

int socket(int domain, int type, int protocol);

int domain : 通信范围，例如AF_UNIX，AF_LOCAL是本地通信，AF_INET是IPV4，AF_INET6是IPV6
int type: 通信类型，最常见的是TCP的SOCK_STREAM面向字节流，UDP的SOCK_DGRAM面向数据报
int protocol: 确定socket支持的哪个协议，一般默认为0即可。
返回值：一个文件描述符，小于0则代表创建套接字(打开文件)失败

端口号绑定(UDP/TCP/服务端/客户端)

对套接字绑定端口，一般服务器显示绑定。客户端OS自动绑定。

#include <sys/types.h>          /* See NOTES */
#include <sys/socket.h>

int bind(int sockfd, const struct sockaddr *addr,
socklen_t addrlen);

*int sockfd： 要绑定的套接字文件描述符
const struct sockaddr addr ：一个结构体的指针，该结构体包含了domain,port,ip等信息…
socklen_t addrlen：结构体体长度
返回值：成功返回0，绑定失败返回-1，或者返回错误码

这个结构体的首元素是一个16位地址类型，虽然下面的内容都不一样，但只要统一强转成 struct sockaddr，那么就可以拿到前16位。再根据前16位判断出结构体的类型，再做出对应的处理。我们可以把sockaddr 看成是一个父类，sockaddr_in 和 sockaddr_un 是它的子类。而无论我们是使用sockaddr_in还是sockaddr_un，我们都可以用sockaddr来接收。再根据前16位判断地址类型，做出选择。这就很像我们的多态，因为这个功能出来的时候，C语言没有void*指针这个功能，所以我们传入时必须要进行类型强转。

在这里插入图片描述

监听套接字(TCP/服务端)

UDP不会用到监听套接字这个函数，因为UDP是无连接的。而TCP是有连接的，所以必须把这个套接字设置为监听状态。

#include <sys/types.h>          /* See NOTES */
#include <sys/socket.h>

int listen(int sockfd, int backlog);

int sockfd：要监听的套接字
int backlog：连接同时存在的最大数量(因为监听是有消耗的，如果大量连接过来，监听不过来了，那么就会把这些连接暂时存储起来，而backlog就是存储的最大数量。)
返回值: 成功返回0，监听失败返回-1，或者返回错误码

接收连接请求(TCP/服务端)

#include <sys/types.h>          /* See NOTES */
#include <sys/socket.h>

int accept(int sockfd, struct sockaddr *addr, socklen_t *addrlen);
int sockfd  监听后的套接字

**struct sockaddr addr: 存储对端domain,port,ip的结构体
socklen_t addrlen: 结构体的大小
返回值: 一个可以直接通信的套接字

建立连接(TCP/客户端)

#include <sys/types.h>          /* See NOTES */
#include <sys/socket.h>

int connect(int sockfd, const struct sockaddr *addr,
socklen_t addrlen);

int sockfd：的套接字

**const struct sockaddr *addr： ** 对端的addr结构体，可以提取到对端的IP和端口

**socklen_t addrlen： ** 要接收的长度。

UDP通信测试

介绍2个函数，UDP传输要用的两个函数。 因为udp是无连接的，所以需要特定的函数来进行通信。

sendto函数

#include <sys/types.h>
#include <sys/socket.h>
ssize_t sendto(int sockfd, const void *buf, size_t len, int flags,
const struct sockaddr *dest_addr, socklen_t addrlen);

该函数的功能是往网络套接字中发送数据，如果调用该函数时套接字还没有绑定端口，那么该函数会自动为套接字随机分配端口。

**int sockfd: 套接字 **

*void buf, size_t len： 发送的数据

size_t len：发送数据的大小

int flags：发送方式，0为阻塞发送

*const struct sockaddr dest_addr：该参数包含着目标主机的IP和端口，根据该参数找到服务器

socklen_t addrlen：传入的sockaddr的长度

recvfrom函数

#include <sys/types.h>
#include <sys/socket.h>
ssize_t recvfrom(int sockfd, void *buf, size_t len, int flags,
                 struct sockaddr *src_addr, socklen_t *addrlen);

该函数的功能是往从网络套接字中读取数据。

int sockfd: 套接字

*void buf, size_t len： 读取数据的缓冲区

size_t len：读取数据的大小

int flags：是否阻塞读取，0为阻塞

*const struct sockaddr dest_addr：输出型参数，该参数对端主机的IP和端口，可以用来获取对端的主机IP和端口

socklen_t addrlen：接收的sockaddr 的长度

udp代码演示

服务器代码

server.cc文件

#include "server.hpp"
#include <memory>

int main(int argc , char* argv[])
{
    if(argc != 2) //命令行参数不为2就退出
    {
        std::cout << "Usage : " << argv[0] << "   bindport" << std::endl;  //打印使用手册
        exit(1);
    }
    uint16_t port = atoi(argv[1]); //命令行传的端口转换成16位整形
    std::unique_ptr<UdpServer> s(new UdpServer(port)); //创建UDP服务器
    s->init(); //初始化服务器，创建 + 绑定
    s->start(); //运行服务器
}

server.hpp 代码：

#pragma once
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <iostream>
#include <unistd.h>
#include <arpa/inet.h>

class UdpServer
{
private:
    int _sock; 
    uint16_t _port;
public:
    UdpServer(uint16_t port): _port(port) { }
    ~UdpServer() { close(_sock); }
    void init()
    {
        _sock = socket(AF_INET,SOCK_DGRAM,0);  //创建套接字
        if(_sock < 0)
        {
            //创建失败
            std::cout << "create socket failed...." << std::endl;
            abort();
        }
        //绑定 
        struct sockaddr_in ser; 
        ser.sin_port = htons(_port);  //填入端口
        ser.sin_family = AF_INET; // 填入地址类型
        ser.sin_addr.s_addr = INADDR_ANY; //填入IP地址
        if(bind(_sock,(sockaddr*)&ser,sizeof ser) != 0) //绑定
        {
            //绑定失败
            std::cout << "bind socket failed...." << std::endl;
            abort();
        }
    }

    void start()
    {
        struct sockaddr_in peer; //对端
        socklen_t peer_len = sizeof peer;
        char buff[1024] = {0};   
        while(1)
        {
            //接收对端发来的消息
            int n = recvfrom(_sock,buff,1023,0,(struct sockaddr*)&peer,&peer_len); 
            buff[n] = 0;
            if(read == 0) //对端关闭了
            {
                std::cout << "one client quit..." << std::endl;
                continue;
            }else if(read < 0) //读取出错了
            {
                 std::cout << "read error..." << std::endl;
                 break;
            }
            //读取正常...
            std::string clientip = inet_ntoa(peer.sin_addr); //获取对端的IP
            uint16_t clientport = ntohs(peer.sin_port);// 获取对端的端口
            //打印信息....
            std::cout << "["<< clientip <<"] "<< clientport << ": say : " << buff << std::endl; 
            
        }
    } 
};

客户端代码

client.cc:

#include "client.hpp"
#include <memory>

int main(int argc , char* argv[])
{
    if(argc != 3) //命令行参数少于3个退出，因为必须 ./client 服务器ip 端口号  才可以调用
    {
        std::cout << "Usage : " << argv[0] << "   serverip  serverport" << std::endl; 
        exit(1);
    }
    uint16_t port = atoi(argv[2]); //获取服务器端口
    std::string ip = argv[1]; //获取服务器IP
    std::unique_ptr<UdpClient> cli(new UdpClient(port,ip)); //创建客户端
    cli->init(); //初始化客户端
    cli->start(); //客户端运行
}

client.hpp

#pragma once
#include <string>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <unistd.h>
#include <iostream>
#include <arpa/inet.h>

class UdpClient
{
public: 
    UdpClient(uint16_t port , const std::string& ip) : _port(port), _svr_ip(ip){}
    ~UdpClient(){ close(_sock); }

    void init()
    {
        //创建套接字
         _sock = socket(AF_INET,SOCK_DGRAM,0); 
        if(_sock < 0)
        {
            std::cout << "create socket failed...." << std::endl;
            abort();
        }   
    }
    void start()
    {
        struct sockaddr_in svr; //该结构体填入服务器的端口和IP
        svr.sin_port = htons(_port);  //填入端口
        svr.sin_addr.s_addr = inet_addr(_svr_ip.c_str());  //填入IP
        svr.sin_family = AF_INET; //设置地址类型，ipv4
        int i = 1;  //打印数字，随意，可要可不要
        //char buff[1024] = {0};  如果需要读数据可用的输出缓冲区
        while(1)
        {
            std::string message = "hello server " + std::to_string(i++); //构建发送消息
            //发送消息
            sendto(_sock,message.c_str(),message.size(),0,(struct sockaddr*)&svr,sizeof svr);
            //可以通过下面代码再接收服务器发送的数据，如果服务器有发送的话
            // int n = recvfrom(_sock,buff,1023,0,nullptr,nullptr);
            // buff[n] = 0 ;
            // std::cout << "server say# " << buff << std::endl;
            sleep(1); // 睡眠1s
        }
    }

private: 
    int _sock; //套接字
    uint16_t _port; //服务器的端口
    std::string _svr_ip; //服务的IP

};

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

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

相关文章

TOP-K问题和向上调整算法和向下调整算法的时间复杂度问题的分析

TOP-K问题和向上调整算法和向下调整算法的时间复杂度问题的分析

TOP-K问题 TOP-K问题&#xff1a;即求数据结合中前K个最大的元素或者最小的元素&#xff0c;一般情况下数据量都比较大 比如&#xff1a;专业前10名、世界500强、富豪榜、游戏中前100的活跃玩家等 对于Top-K问题&#xff0c;能想到的最简单直接的方式就是排序&#xff0c;但是…
阅读更多...
聊聊测试for Jeffky

聊聊测试for Jeffky

什么是测试 测试是一个系统性的过程&#xff0c;它涉及到在已开发的软件中执行程序、应用工具和技术来评估其质量、功能和性能。这个过程的目的是发现并纠正程序中的错误&#xff0c;提高软件的可靠性和稳定性&#xff0c;以满足用户的需求。 测试的分类 什么是自动化测试 自动…
阅读更多...
Android Termux 安装Kali Linux 或 kali Nethunter史诗级详细教程

Android Termux 安装Kali Linux 或 kali Nethunter史诗级详细教程

Android Termux 安装Kali Linux 或 kali Nethunter史诗级详细教程 一、Termux配置1、下载安装2、配置存储和换源3、基本工具安装 二、Kali Linux安装1、下载安装脚本2、更换apt源3、图形化安装 三、Kali Nethunter安装1、下载安装脚本2、更换apt源3、图形化连接 四、报错汇总1、…
阅读更多...
五、关闭三台虚拟机的防火墙和Selinux

五、关闭三台虚拟机的防火墙和Selinux

目录 1、关闭每台虚拟机的防火墙 2、关闭每台虚拟机的Selinux 2.1 什么是SELinux
阅读更多...
《第一行代码：Android》第三版4.2常用控件的使用方法（1）

《第一行代码：Android》第三版4.2常用控件的使用方法（1）

概述 本文主要讲解常用控件的使用&#xff0c;包括&#xff1a;TextView、Button、EditText、ImageView、ProgressBar、AlertDialog。 布局文件 布局文件是activity_main.xml,内容如下&#xff1a; <?xml version"1.0" encoding"utf-8"?> <…
阅读更多...
Spring Cloud笔记 —— 什么是Spring Cloud？

Spring Cloud笔记 —— 什么是Spring Cloud？

引言&#xff1a; 在写这篇博客之前&#xff0c;其实吧&#xff0c;博主很久之前有过一段时间的Spring Cloud的案例项目开发经验&#xff0c;就是一个案例项目开发而已&#xff0c;也说不上有多高大上&#xff0c;那个时候&#xff0c;我其实也是从众而已罢了&#xff0c;毕竟现…
阅读更多...
Asp.Net Core Web Api内存泄漏问题

Asp.Net Core Web Api内存泄漏问题

背景 使用Asp.Net Core Web Api框架开发网站中使用到了tcp socket通信&#xff0c;网站作为服务端开始tcp server&#xff0c;其他的客户端不断高速给它传输信息时&#xff0c;tcp server中读取信息每次申请的byte[]没有得到及时的释放&#xff0c;导致内存浪费越来越多&#…
阅读更多...
WEBAPI返回图片显示在VUE前端

WEBAPI返回图片显示在VUE前端

WEBAPI部分 通过nuget安装Opencvsharp &#xff0c;这部分用来做图像处理 在controller中写如下方法&#xff0c;我要对原图进行旋转使用了Opencv&#xff0c;如果不需要旋转可以用注释的代码 [HttpGet(Name "ShowImage")]public async Task<IActionResult> …
阅读更多...
基于Java+Swing+Mysql图书管理系统(含实训报告)

基于Java+Swing+Mysql图书管理系统(含实训报告)

基于JavaSwingMysql图书管理系统-含实训报告 一、系统介绍二、功能展示1.用户登陆 四、其他系统实现五、获取源码 一、系统介绍 该系统实现了查看登录界面、主页界面、图书类别管理、用户借阅记录、用户图书查询、用户图书归还、用户信息修改。 运行环境&#xff1a;idea、jd…
阅读更多...
selenium三猛士

selenium三猛士

selenium包括三个项目&#xff0c;分别是&#xff1a;Selenium WebDriver,Selenium IDE&#xff0c;Selenium Grid。 Selenium WebDriver Selenium WebDriver是客户端API接口&#xff0c;测试人员通过调用这些接口&#xff0c;来访问浏览器驱动&#xff0c;浏览器再访问浏览器…
阅读更多...
亚马逊云科技 re:Invent 2023：科技前沿风向标，探索未来云计算之窗

亚马逊云科技 re:Invent 2023：科技前沿风向标，探索未来云计算之窗

文章目录 一、前言二、什么是亚马逊云科技 re:Invent&#xff1f;三、亚马逊云科技 re:Invent 2023 将于何时何地举行四、亚马逊云科技 re:Invent 2023 有什么内容&#xff1f;4.1 亚马逊云科技 re:Invent 2023 主题演讲4.2 亚马逊云科技行业专家探实战 五、更多亚马逊云科技活…
阅读更多...
竞赛选题 ： 题目：基于深度学习的水果识别 设计 开题 技术

竞赛选题 ： 题目：基于深度学习的水果识别 设计 开题 技术

1 前言 Hi&#xff0c;大家好&#xff0c;这里是丹成学长&#xff0c;今天做一个 基于深度学习的水果识别demo 这是一个较为新颖的竞赛课题方向&#xff0c;学长非常推荐&#xff01; &#x1f9ff; 更多资料, 项目分享&#xff1a; https://gitee.com/dancheng-senior/pos…
阅读更多...
深入解析SpringBoot的请求响应机制

深入解析SpringBoot的请求响应机制

SpringBootWeb请求响应 前言1. 请求1.1 Postman介绍 1.2 简单参数1.2.1 原始方式1.2.2 SpringBoot方式1.2.3 参数名不一致 1.3 实体参数1.3.1 简单实体对象1.3.2 复杂实体对象 1.4 数组集合参数1.4.1 数组1.4.2 集合 1.5 日期参数1.6 JSON参数1.7 路径参数 2. 响应2.1 Response…
阅读更多...
SATA模块物理层OOB信号分析总结（三）

SATA模块物理层OOB信号分析总结（三）

目录 一、简介二、总体解析2.1 OOB作用2.2 OOB信号的组成2.3 总体phy link过程2.4 整体PHY LINK Trace2.5 PHY LINK状态查询 三、其他相关链接1、SATA模块之HBA卡开发总结&#xff08;一&#xff09;2、SATA信息传输FIS结构总结&#xff08;二&#xff09;3、PCIe物理层总结-PC…
阅读更多...
【前端】利用正则生成目录，附加解决a链接锚点偏移

【前端】利用正则生成目录，附加解决a链接锚点偏移

前言 从html字符串中提取出来目录。 目标和源内容都很明确&#xff0c;源内容是html字符串&#xff0c;提取目标是html字符串中h1~h6元素和其闭合标签中间的内容。 思路 分析 获取html字符串 第一步要获取html字符串内容。 观察html字符串 第二步&#xff0c; 观察html字…
阅读更多...
分享85个节日PPT，总有一款适合您

分享85个节日PPT，总有一款适合您

分享85个节日PPT&#xff0c;总有一款适合您 85个节日PPT下载链接&#xff1a;https://pan.baidu.com/s/1FTbSj2Baix-Cj6n42Cz26g?pwd6666 提取码&#xff1a;6666 Python采集代码下载链接&#xff1a;采集代码.zip - 蓝奏云 学习知识费力气&#xff0c;收集整理更不易。…
阅读更多...
C语言-指针_01

C语言-指针_01

指针基础 1. 概述 地址编号&#xff1a;计算机为了存储数据&#xff0c;每一个程序在 32位 机中 占4G&#xff0c;最小操作单位 是 一个字节&#xff0c;每一个字节都有其对应的地址&#xff0c;该地址就是 地址编号。 指针&#xff1a;地址编号这个数据 的 数据类型。 指针变…
阅读更多...
职位招聘管理与推荐系统Python+Django网页界面+协同过滤推荐算法

职位招聘管理与推荐系统Python+Django网页界面+协同过滤推荐算法

一、介绍 职位招聘管理与推荐系统。本系统使用Python作为主要开发语言&#xff0c;以WEB网页平台的方式进行呈现。前端使用HTML、CSS、Ajax、BootStrap等技术&#xff0c;后端使用Django框架处理用户请求。 系统创新点&#xff1a;相对于传统的管理系统&#xff0c;本系统使用…
阅读更多...
利用Python中的Manim进行数学绘画和创作

利用Python中的Manim进行数学绘画和创作

相信很多同学就算没听过3Blue1Brown&#xff0c;也一定曾看过他们出品的视频&#xff0c;其从独特的视觉角度解说各种数学概念&#xff0c;内容包括线性代数、微积分、神经网络、傅里叶变换以及四元数等晦涩难懂的知识点。例如最火的《线性代数本质》系列视频。 那么这些视频是…
阅读更多...
01-使用Git操作本地库,如初始化本地库,提交工作区文件到暂存区和本地库,查看版本信息,版本切换命令等

01-使用Git操作本地库,如初始化本地库,提交工作区文件到暂存区和本地库,查看版本信息,版本切换命令等

Git的使用 概述 Git是一个分布式版本控制工具, 通常用来管理项目中的源代码文件(Java类、xml文件、html页面等)进行管理,在软件开发过程中被广泛使用 Git可以记录文件修改的历史记录并形成备份从而实现代码回溯, 版本切换, 多人协作, 远程备份的功能Git具有廉价的本地库,方便…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023