基于TCP的全双工网络编程实践

2024-01-15 09:44

本文主要是介绍基于TCP的全双工网络编程实践,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

首先我们先了解一下什么是全双工通信?

全双工数据通信允许数据同时在两个方向上传输,因此,全双工通信相当于是两个单工通信方式的结合,它要求发送设备和接收设备都有独立的接收和发送能力。

TCP服务端代码:

#include <stdio.h>             
#include <stdlib.h>           
#include <string.h>
#include <arpa/inet.h>             
#include <netdb.h>              
#include <netinet/in.h>       
#include <stdint.h>                       
#include <sys/socket.h>     
#include <sys/types.h>     
#include <unistd.h>      #define PORT 10000  void error()
{perror("Socket Creation Failed");exit(EXIT_FAILURE);
}int main()
{uint32_t sockfd,conn; char recvbuff[1024],sendbuff[1024]; struct sockaddr_in server_addr,client_addr;  socklen_t ClientLen; if ((sockfd = socket(AF_INET, SOCK_STREAM, 0)) < 0){error();  }bzero(&server_addr, sizeof(server_addr));server_addr.sin_family = AF_INET;server_addr.sin_port = htons(PORT);server_addr.sin_addr.s_addr = htonl(INADDR_ANY);printf("Server is running...\n");int on=1;if((setsockopt(sockfd,SOL_SOCKET,SO_REUSEADDR,&on,sizeof(on)))<0){perror("setsockopt failed");exit(EXIT_FAILURE);}if (bind(sockfd, (struct sockaddr *)&server_addr, sizeof(server_addr)) < 0){error(); }listen(sockfd, 5);printf("Server is listening...\n");conn = accept(sockfd, (struct sockaddr *)NULL, NULL);printf("Server is connected...\n");pid_t pid;pid = fork();if (pid == 0)  //子进程负责接收数据{while (1){bzero(&recvbuff, sizeof(recvbuff));recv(conn, recvbuff, sizeof(recvbuff), 0);printf("\nCLIENT : %s\n", recvbuff);sleep(5);}}else  //父进程负责发送发送数据{while (1){bzero(&sendbuff, sizeof(sendbuff));printf("\nType message here: ");fgets(sendbuff, 1024, stdin);send(conn, sendbuff, strlen(sendbuff) + 1, 0);printf("\nMessage Sent!\n");sleep(5);}}close(sockfd);printf("Server is offline...\n");return 0;
}

TCP服务端运行状态:

TCP客户端代码:

#include <stdio.h>             
#include <stdlib.h>          
#include <string.h> 
#include <arpa/inet.h>             
#include <netdb.h>               
#include <netinet/in.h>          
#include <stdint.h>                   
#include <sys/socket.h>     
#include <sys/types.h>     
#include <unistd.h>   #define PORT 10000  void error()
{perror("Socket Creation Failed");exit(EXIT_FAILURE);
}int main()
{uint32_t sockfd; char sendbuff[1024],recvbuff[1024]; struct sockaddr_in server_addr; if ((sockfd = socket(AF_INET, SOCK_STREAM, 0)) < 0){error();}bzero(&server_addr, sizeof(server_addr));server_addr.sin_family = AF_INET;server_addr.sin_port = htons(PORT);server_addr.sin_addr.s_addr = htonl(INADDR_ANY);printf("Client is running...\n");connect(sockfd, (struct sockaddr *)&server_addr, sizeof(server_addr));printf("Client is connected...\n");pid_t pid;pid = fork();if (pid == 0)  //子进程{while (1){bzero(&sendbuff, sizeof(sendbuff));printf("\nType message here: ");fgets(sendbuff, 1024, stdin);send(sockfd, sendbuff, strlen(sendbuff) + 1, 0);printf("\nMessage sent!\n");sleep(5);}}else  //父进程{while (1){bzero(&recvbuff, sizeof(recvbuff));recv(sockfd, recvbuff, sizeof(recvbuff), 0);printf("\nSERVER: %s\n", recvbuff);sleep(5);}}close(sockfd);printf("Client is offline...\n");return 0;
}

TCP客户端运行状态:

有时候我们会遇到这样的问题,当你第二次第三次......运行程序的时候,报如下的问题:

Socket Creation Failed: Address already in use

解决方法:

    int on=1;
    if((setsockopt(sockfd,SOL_SOCKET,SO_REUSEADDR,&on,sizeof(on)))<0)
    {
        perror("setsockopt failed");
        exit(EXIT_FAILURE);
    }

【欢迎关注编码小哥,学习更多实用的编程方法】

这篇关于基于TCP的全双工网络编程实践的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/608480

相关文章

Spring Boot集成/输出/日志级别控制/持久化开发实践

《SpringBoot集成/输出/日志级别控制/持久化开发实践》SpringBoot默认集成Logback,支持灵活日志级别配置(INFO/DEBUG等),输出包含时间戳、级别、类名等信息,并可通过... 目录一、日志概述1.1、Spring Boot日志简介1.2、日志框架与默认配置1.3、日志的核心作用

破茧 JDBC:MyBatis 在 Spring Boot 中的轻量实践指南

《破茧JDBC:MyBatis在SpringBoot中的轻量实践指南》MyBatis是持久层框架,简化JDBC开发,通过接口+XML/注解实现数据访问,动态代理生成实现类,支持增删改查及参数... 目录一、什么是 MyBATis二、 MyBatis 入门2.1、创建项目2.2、配置数据库连接字符串2.3、入

Android Paging 分页加载库使用实践

《AndroidPaging分页加载库使用实践》AndroidPaging库是Jetpack组件的一部分,它提供了一套完整的解决方案来处理大型数据集的分页加载,本文将深入探讨Paging库... 目录前言一、Paging 库概述二、Paging 3 核心组件1. PagingSource2. Pager3.

在Java中使用OpenCV实践

《在Java中使用OpenCV实践》用户分享了在Java项目中集成OpenCV4.10.0的实践经验,涵盖库简介、Windows安装、依赖配置及灰度图测试,强调其在图像处理领域的多功能性,并计划后续探... 目录前言一 、OpenCV1.简介2.下载与安装3.目录说明二、在Java项目中使用三 、测试1.测

MyBatis-Plus 自动赋值实体字段最佳实践指南

《MyBatis-Plus自动赋值实体字段最佳实践指南》MyBatis-Plus通过@TableField注解与填充策略,实现时间戳、用户信息、逻辑删除等字段的自动填充,减少手动赋值,提升开发效率与... 目录1. MyBATis-Plus 自动赋值概述1.1 适用场景1.2 自动填充的原理1.3 填充策略

Olingo分析和实践之EDM 辅助序列化器详解(最佳实践)

《Olingo分析和实践之EDM辅助序列化器详解(最佳实践)》EDM辅助序列化器是ApacheOlingoOData框架中无需完整EDM模型的智能序列化工具,通过运行时类型推断实现灵活数据转换,适用... 目录概念与定义什么是 EDM 辅助序列化器?核心概念设计目标核心特点1. EDM 信息可选2. 智能类

Olingo分析和实践之OData框架核心组件初始化(关键步骤)

《Olingo分析和实践之OData框架核心组件初始化(关键步骤)》ODataSpringBootService通过初始化OData实例和服务元数据,构建框架核心能力与数据模型结构,实现序列化、URI... 目录概述第一步:OData实例创建1.1 OData.newInstance() 详细分析1.1.1

Olingo分析和实践之ODataImpl详细分析(重要方法详解)

《Olingo分析和实践之ODataImpl详细分析(重要方法详解)》ODataImpl.java是ApacheOlingoOData框架的核心工厂类,负责创建序列化器、反序列化器和处理器等组件,... 目录概述主要职责类结构与继承关系核心功能分析1. 序列化器管理2. 反序列化器管理3. 处理器管理重要方

虚拟机Centos7安装MySQL数据库实践

《虚拟机Centos7安装MySQL数据库实践》用户分享在虚拟机安装MySQL的全过程及常见问题解决方案,包括处理GPG密钥、修改密码策略、配置远程访问权限及防火墙设置,最终通过关闭防火墙和停止Net... 目录安装mysql数据库下载wget命令下载MySQL安装包安装MySQL安装MySQL服务安装完成

SpringBoot整合(ES)ElasticSearch7.8实践

《SpringBoot整合(ES)ElasticSearch7.8实践》本文详细介绍了SpringBoot整合ElasticSearch7.8的教程,涵盖依赖添加、客户端初始化、索引创建与获取、批量插... 目录SpringBoot整合ElasticSearch7.8添加依赖初始化创建SpringBoot项