【Linux】Linux下使用套接字进行网络编程

🔥博客主页： 我要成为C++领域大神
🎥系列专栏：【C++核心编程】 【计算机网络】 【Linux编程】 【操作系统】
❤️感谢大家点赞👍收藏⭐评论✍️

本博客致力于知识分享，与更多的人进行学习交流

​

用于网络应用开发，使用系统提供的一套API函数接口，称为套接字函数

​

所有的I/O设备都被抽象为文件，一切皆文件，Everything is a File，磁盘、网络数据、终端，甚至进程间通信工具管道pipe等都被当做文件对待。

​

套接字文件描述符包含有IP地址和PORT端口号。

socket创建套接字

函数原型：int sockfd=socket(AF_INET,SOCKET_STREAM(流式or报式),int protocol(默认流式协议TCP))

成功返回sock_fd，失败返回-1，并设置errno

bind绑定IP和端口

函数原型：bind(sock_fd,struct sockaddr *addr)

struct sockaddr *addr是早期的网络通信结构体，为了向前兼容，仍然保留。

struct sockaddr_in addr网络信息结构体

addr.sin_family=AF_INET
addr.sin_port=大端(8080)
addr.sin_addr.s_addr=大端(ip)

大小端转换常用函数

htons()小端转大端端口

htonl()小端转大端IP

ntohs()大端转小端端口

ntohl()大端转小端IP

inet_pton(AF_INET,char *ip,void *addr)

inet_ntop(AF_INET,void *addr,char *ip,16)

绑定可以对socket设置自定义的IP和端口号，其次当绑定某端口的进程退出，可以临时禁用端口号，禁用时长为2MSL。

成功返回0，失败返回-1

listen网络事件监听（TCP）

函数原型：listen(int sockfd,int backlog)

backlog：监听序列数

​

成功返回0，错误返回-1，并设置errno，用于错误处理

connet请求TCP连接函数（主动端）

函数原型：connect(int mysockfd,struct sockaddr * dest,socklen_t addrlen)

客户端调用该函数向服务器发起TCP连接请求

成功返回0，错误返回-1，并设置errno，用于错误处理

Accept等待TCP连接请求，完成连接（被动端）

Accept为阻塞等待连接，每次只能连接一个客户端，如果要多次连接，要执行多次该函数

函数原型：

int client_fd=accpet(int server_fd,sockaddr * clientAddr(output),socklen_t *Addrlen(intput|output))

arg[1] 包含自身网络信息的socket

arg[2] 连接成功，传出保存客户端的网络信息（IP，port）

arg[3] 传入可以接收的网络信息大小，传出实际大小

成功返回请求端的socketfd，错误返回-1，并设置errno，用于错误处理

CS架构中，服务器socket只有一个，客户端socket有多个（server_fd用于连接，client_fd用于与客户端交互数据）

recv读取数据

在Linux下，read也可以读取socket数据（TCP），因为在Linux下，套接字以文件描述符的形式记录。

函数原型：ssize_t recv(int sockfd,void *buf,size_t size,int flag)

成功返回读取的数据量，失败返回-1

可以通过将flag设置为MSG_DONTWAIT实现非阻塞读取数据

send发送数据

在Linux下，write也可以发送socket数据（TCP），因为在Linux下，套接字以文件描述符的形式记录。

函数原型：ssize_t send(int sockfd,void *buf,size_t len,int flag)

面试题：

在编写一个服务端-客户端模型时，客户端异常退出，服务端也异常退出。

原因

当客户端异常退出时，客户端关闭了它的读端文件描述符。此时，如果服务端尝试向管道或套接字写数据，会触发 SIGPIPE 信号，默认行为是终止进程，因此服务端也会异常退出。

解决方案

可以在 send() 函数中使用 MSG_NOSIGNAL 标志位，来忽略 SIGPIPE 信号，从而避免服务端异常退出

send(int sockfd, buffer, len, MSG_NOSIGNAL);

使用 MSG_NOSIGNAL 标志位，写操作在对端关闭连接的情况下不会触发 SIGPIPE 信号，而是会返回 EPIPE 错误，程序可以根据这个错误码进行处理而不是直接终止。

在公网上利用TCP协议实现网络数据传输

由于服务端和客户端不在同一个局域网下，所以需要通过互联网进行通信，虚拟机要配置网络连接。

服务端：

服务端是运行在公网上的阿里云服务器。

#include <stdio.h>
#include <stdlib.h>
#include <arpa/inet.h>
#include <sys/socket.h>
#include <string.h>

#define _SERVER_IP "xxx.xxx.xxx.xxx"
#define _PORT 8080
#define _BACKLOG 128
#define _SHUTDOWN 1
#define _TRUE 1
#define _FALSE 0
#define _IPSIZE 16
#define _RECVLEN 1500


int main()
{
        struct sockaddr_in serverAddr,clientAddr;
        int server_fd;
        int client_fd;
        char Result[_RECVLEN];
        char client_ip[_IPSIZE];
        socklen_t Addrlen;
        serverAddr.sin_family=AF_INET;
        serverAddr.sin_port=htons(_PORT);
        serverAddr.sin_addr.s_addr=htonl(INADDR_ANY);
        server_fd=socket(AF_INET,SOCK_STREAM,0);
        bind(server_fd,(struct sockaddr*)&serverAddr,sizeof(serverAddr));
        listen(server_fd,_BACKLOG);
        printf("Test TCP Server Version 1.1.0 is Running...\n");
        while(_SHUTDOWN)
        {
        Addrlen=sizeof(clientAddr);
        if((client_fd=accept(server_fd,(struct sockaddr*)&clientAddr,&Addrlen))>0)
        {
           bzero(Result,sizeof(Result));
           bzero(client_ip,sizeof(client_ip));
           inet_ntop(AF_INET,&clientAddr.sin_addr.s_addr,client_ip,_IPSIZE);
           printf("Connection From :IP[%s],PORT[%d]\n",client_ip,ntohs(clientAddr.sin_port));
           sprintf(Result,"Hi [%s] Welcome to my TCP test server!service version 1.1.0...",client_ip);
           send(client_fd,Result,strlen(Result),0);
           close(client_fd);
        }
        else
        {
        perror("accpet failed");
        close(server_fd);
        exit(0);
        }
        }
        close(server_fd);
        return 0;
}

客户端：

客户端是运行在本地上的虚拟机镜像

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <sys/socket.h>
#include <arpa/inet.h>

//客户端源码编写，连接服务器成功，服务器反馈信息

#define _IP "xxx.xxx.xxx.xxx"
#define _PORT 8080
int main()
{
    struct sockaddr_in ServerAddr;
    bzero(&ServerAddr,sizeof(ServerAddr));
    ServerAddr.sin_family=AF_INET;
	ServerAddr.sin_port=htons(_PORT);
    inet_pton(AF_INET,_IP,&ServerAddr.sin_addr.s_addr);
    
    int Myfd=socket(AF_INET,SOCK_STREAM,0);
    //看需求决定是否要绑定
    char Response[1024];//存放服务端反馈信息
    ssize_t recvlen;
    bzero(Response,sizeof(Response));

    if((connect(Myfd,(struct sockaddr *)&ServerAddr,sizeof(ServerAddr)))==0)
    {
        if((recvlen=recv(Myfd,Response,sizeof(Response),0))>0)
        {
            printf("%s\n",Response);
        }
    }
    else
    {
        printf("Connect failed\n");
        close(Myfd);
        exit(0);
    }
    close(Myfd);
    printf("Client is Over\n");
    return 0;
}

运行结果：

​

函数二次包裹

在我们编写代码时，通常需要根据函数的返回值来判断函数调用情况，这个过程需要大量的if else语句，减少了代码阅读的简洁性。所以为了方便我们阅读，需要对函数进行二次包裹。

什么是二次包裹？

在自定义的头文件中重新声明一个函数，函数名与接口函数不同，返回值、参数均与接口函数相同。在相应的源文件中定义我们的函数，将逻辑判断的过程放在函数中。这样在调用函数时就省去大量的if else判断

#ifndef __MySock_H__
#define __MySock_H__
#include <sys/socket.h>
#include <arpa/inet.h>
#include <unistd.h>
#include <stdio.h>
#include <string.h>
#include <stdlib.h>

int SOCKET(int domain,int type,int protocol);
int BIND(int sockfd,struct sockaddr* addr,socklen_t addrlen);
ssize_t RECV(int sockfd,void *buf,size_t len,int flags);
ssize_t SEND(int sockfd,void *buf,size_t len,int flags);
int CONNECT(int sockfd,struct sockaddr *addr,socklen_t addrlen);
int ACCEPT(int sockfd,struct sockaddr *addr,socklen_t *addrlen);
int LISTEN(int sockfd,int backlog);

#endif

#include "MySock.h"
int SOCKET(int domain,int type,int protocol)
{
    int reval=socket(domain,type,protocol);    
    if(reval==-1)
    {
     perror("socket call failed");   
     exit(0);
    }
     return reval;
}
int BIND(int sockfd,struct sockaddr* addr,socklen_t addrlen)
{
    int reval=bind(sockfd,addr,addrlen);
    if(reval==-1)
    {
        perror("bind call failed");
        exit(0);
    }
    return reval;
}
ssize_t RECV(int sockfd,void *buf,size_t len,int flags)
{
    ssize_t reval;
    reval=recv(sockfd,buf,len,flags);
    if(reval==0)
        perror("recv call failed");
    return reval;
}
ssize_t SEND(int sockfd,void *buf,size_t len,int flags)
{
    ssize_t reval;
    reval=send(sockfd,buf,len,flags);
    if(reval==-1)
        perror("send call failed");
    return reval;
}
int CONNECT(int sockfd,struct sockaddr *addr,socklen_t addrlen)
{
    int reval=connect(sockfd,addr,addrlen);
    if(reval==-1)
    {
        perror("connect call failed");
        exit(0);
    }
    return reval;
}

int ACCEPT(int sockfd,struct sockaddr* addr,socklen_t *addrlen)
{
    int reval=accept(sockfd,addr,addrlen);
    if(reval==-1)
    {
        perror("accept call failed");
        exit(0);
    }
    return reval;
}
int LISTEN(int sockfd,int backlog)
{
    int reval=listen(sockfd,backlog);
    if(reval==-1)
    {
        perror("listen call failed");
        exit(0);
    }
    return reval;
}

使用包裹后的函数对我们TCP通信的客户端进行改写：

代码看起来简洁多了

#include "MySock.h"


//客户端源码编写，连接服务器成功，服务器反馈信息

#define _IP "xxx.xxx.xxx.xxx"
#define _PORT 8080
int main()
{
    struct sockaddr_in ServerAddr;
    bzero(&ServerAddr,sizeof(ServerAddr));
    ServerAddr.sin_family=AF_INET;
	ServerAddr.sin_port=htons(_PORT);
    inet_pton(AF_INET,_IP,&ServerAddr.sin_addr.s_addr);
    
    int Myfd=SOCKET(AF_INET,SOCK_STREAM,0);
    //看需求决定是否要绑定
    char Response[1024];//存放服务端反馈信息
    ssize_t recvlen;
    bzero(Response,sizeof(Response));

    if((CONNECT(Myfd,(struct sockaddr *)&ServerAddr,sizeof(ServerAddr)))==0)
    {
        if((recvlen=recv(Myfd,Response,sizeof(Response),0))>0)
        {
            printf("%s\n",Response);
        }
    }
    close(Myfd);
    printf("Client is Over\n");
    return 0;
}

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

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

知识图谱——Neo4j数据库实战

知识图谱——Neo4j数据库实战

数据与代码链接见文末 1.Neo4j数据库安装 JDK 安装：https://www.oracle.com/java/technologies/javase-downloads.html Neo4j 安装：https://neo4j.com/download-center/ 配置好 JDK 和 Neo4j 的环境变量
阅读更多...
嵌入式Linux系统编程 — 4.1 字符串输入输出

嵌入式Linux系统编程 — 4.1 字符串输入输出

目录 1 字符串输出 1.1 字符串输出函数简介 1.2 示例程序 2 字符串输入 2.1 字符串输入简介 2.2 示例程序 程序运行时&#xff0c;需打印信息至标准输出 stdout 设备 或标准错误 stderr设备&#xff08;譬如屏幕&#xff09;&#xff0c;如调试信息、报错信息、中间产生的…
阅读更多...
数据库课程知识点总结

数据库课程知识点总结

数据库概述 数据库基本特点&#xff1a;数据结构化&#xff0c;数据独立性&#xff0c;数据冗余小&#xff0c;易扩充&#xff0c;统一管理和控制&#xff0c;永久存储&#xff0c;有组织&#xff0c;可共享 三级模式 模式&#xff1a;一个数据库只有一个模式&#xff0c;是对…
阅读更多...
将idea项目代码部署到Linux系统中

将idea项目代码部署到Linux系统中

目录 1. 将idea与虚拟机建立连接 2. 设置上传到虚拟机的目录 3.上传项目代码 1. 将idea与虚拟机建立连接 打开idea要上传的项目,找到Tools -> Development -> Configuration 设置一个连接的名称,我这里设置为centos 将Type设置为SFTP,点击SSH configuration 开始配…
阅读更多...
数据库物理结构设计-定义数据库模式结构（概念模式、用户外模式、内模式）、定义数据库、物理结构设计策略

数据库物理结构设计-定义数据库模式结构（概念模式、用户外模式、内模式）、定义数据库、物理结构设计策略

一、引言 如何基于具体的DBMS产品&#xff0c;为数据库逻辑结构设计的结果&#xff0c;即关系数据库模式&#xff0c;制定适合应用要求的物理结构 1、在设计数据库物理结构前&#xff0c;数据库设计人员首先 要充分了解所用的DBMS产品的功能、性能和特点&#xff0c;包括提供…
阅读更多...
抖音集成：通过MessageBox引领数字化营销新潮流

抖音集成：通过MessageBox引领数字化营销新潮流

抖音集成&#xff1a;通过MessageBox引领数字化营销新潮流 在数字化营销的大潮中&#xff0c;企业需要不断探索新的方式来优化其营销策略&#xff0c;以抓住更多的市场机会。抖音作为一款全球知名的短视频社交平台&#xff0c;凭借其庞大的用户群体和高度互动的特性&#xff0…
阅读更多...
亿发进销存管理系统+：多终端无缝协同，实现经营销售场景全覆盖

亿发进销存管理系统+：多终端无缝协同，实现经营销售场景全覆盖

亿发软件凭借产品、市场、业务的深入理解&#xff0c;在进销存基础上进行了延伸&#xff0c;推出多终端、一体化的“进销存管理系统”多元产品矩阵。对企业经营中进货、出货、销售、付款等进行全程跟踪管理。有效辅助企业解决业务管理、销售管理、库存管理、财务管理等一系列问…
阅读更多...
【论文阅读】-- TSR-TVD：时变数据分析和可视化的时间超分辨率

【论文阅读】-- TSR-TVD：时变数据分析和可视化的时间超分辨率

TSR-TVD: Temporal Super-Resolution for Time-Varying Data Analysis and Visualization 摘要1 引言2 相关工作3 我们的循环生成方法3.1 损失函数3.2 网络架构 4 结果与讨论4.1 数据集和网络训练4.2 结果4.3 讨论 5 结论和未来工作致谢参考文献附录1 训练算法及优化2 网络分析…
阅读更多...
02.Ambari自定义服务开发-metainfo.xml介绍

02.Ambari自定义服务开发-metainfo.xml介绍

文章目录 metainfo.xml 介绍配置说明Hbase metainfo.xml配置说明配置参数详细介绍配置文件样例DORIS metainfo.xml 介绍 ​ 在Ambari自定义开发中&#xff0c;metainfo.xml 配置文件起着至关重要的作用。它用于定义服务的元数据信息&#xff0c;包括服务的版本、组件、执行脚本…
阅读更多...
RabbitMQ基本概念

RabbitMQ基本概念

RabbitMQ是AMQP协议的一个开源实现&#xff0c;所以其基本概念也就是的 AMQP 协 议中的基本概念。如图3-1所示是 RabbitMQ 的整体架构图。 Message(消息):消息是不具名的&#xff0c;它由消息头和消息体组成。消息体是不透明的&#xff0c; 而消息头则由一系列可选属性组成&…
阅读更多...
六西格玛绿带可以跳过，直接学六西格玛黑带吗？真实情况告诉你

六西格玛绿带可以跳过，直接学六西格玛黑带吗？真实情况告诉你

在现代企业管理中&#xff0c;六西格玛&#xff08;Six Sigma&#xff09;已经成为提升质量和效率的重要工具。对于很多企业而言&#xff0c;培养内部的六西格玛专家&#xff0c;特别是黑带&#xff08;Black Belt&#xff09;&#xff0c;是推动持续改进的关键。然而&#xff…
阅读更多...
如何用Vue3和Plotly.js实现一个交互式世界地图动画

如何用Vue3和Plotly.js实现一个交互式世界地图动画

本文由ScriptEcho平台提供技术支持 项目地址&#xff1a;传送门 利用 Plotly.js 创建交互式世界生命预期地图 应用场景 本代码展示了如何使用 Plotly.js 创建一个交互式世界生命预期地图&#xff0c;允许用户按年份浏览不同国家和地区的生命预期数据。该地图可以用于研究世…
阅读更多...
电脑文件concrt140.dll丢失要怎么恢复？靠谱修复方法分析

电脑文件concrt140.dll丢失要怎么恢复？靠谱修复方法分析

电脑文件concrt140.dll丢失这种情况&#xff0c;相对来说还是比较少见的&#xff01;但是不代表没有&#xff0c;既然有人出现这种情况了&#xff0c;那么小编势必要给大家详细的讲解一下concrt140.dll这个文件&#xff0c;以及我们要怎么去解决concrt140.dll文件丢失的问题。下…
阅读更多...
技术贴 | RNA甲基化修饰m6A的检测——MeRIP-seq

技术贴 | RNA甲基化修饰m6A的检测——MeRIP-seq

01 m6A是什么 目前在细胞RNA中已经识别到了超过100种化学修饰&#xff0c;其中RNA甲基化修饰在生命活动中有着非常重要的作用(Xu et al 2020)。RNA甲基化是指在甲基转移酶的催化下&#xff0c;在RNA分子上的某一个原子上添加一个甲基基团(CH3)。RNA甲基化修饰类型有很多&#…
阅读更多...
架构师篇-5、架构语言-ArchiMate

架构师篇-5、架构语言-ArchiMate

内容摘要&#xff1a; TOGAF内容元模型TOGAF架构语言ArchiMate3ArchiMate实践案例分享 TOGAF内容框架【核心内容元模型】 作为一个通用且开放式的标准&#xff0c;TOGAF需要采用一种非常灵活的方式来对其内容元模型进行定义&#xff0c;从而使得不同的企业可以根据自身需要对…
阅读更多...
Swagger2及常用校验注释说明

Swagger2及常用校验注释说明

Api(value "后台用户管理") RestController RequestMapping("bossuser") public class BossUserController {ApiOperation(value "测试接口")PostMapping("test")public String testUser(Valid RequestBody TestUser user) {LOG.inf…
阅读更多...
vue表头字段添加鼠标悬浮提示

vue表头字段添加鼠标悬浮提示

<el-table-column prop"jfScore" align"center" min-width"100px"><template slot"header" slot-scope"scope"><div><span>信用积分</span><el-tooltip:aa"scope"class"it…
阅读更多...
nodepad 中换行符、tab替换

nodepad 中换行符、tab替换

1 nodepad 主要符号 换行符: \r\n&#xff08;windows&#xff09; tab: \t 2 展示符号 3 相互替换 tip:需要点击扩展 参考&#xff1a; https://blog.csdn.net/lijing742180/article/details/85174564
阅读更多...
服务器出现意外情况。(Exception from HRESULT: 0x80010105(RPC E SERVERFAULT))

服务器出现意外情况。(Exception from HRESULT: 0x80010105(RPC E SERVERFAULT))

这种情况一般出现在excel2007版本&#xff0c;下载了什么阅读器之类的 2007改不了这个加载项&#xff0c;需要重装一个其他版本&#xff08;2010版本可以&#xff09; 然后如下操作修改为COM加载项
阅读更多...
步步深入SpringMvc DispatcherServlet源码掌握springmvc全流程原理

步步深入SpringMvc DispatcherServlet源码掌握springmvc全流程原理

文章目录 步步深入SpringMvc DispatcherServlet源码掌握springmvc全流程原理继承关系入口 DispatcherServlet#doDispatch多文件上传解析获取处理器handler的完整注册流程获取HandlerAdapter执行拦截器PreHandle执行HandlerAdapter.handle参数解析器HandlerMethodArgumentResolv…
阅读更多...
最新文章

Copyright @ 2022~2023