TCP socket

TCP的socket和UDP大同小异,基本的代码结构都是相同的。一些相同的接口本文就不赘述了,例如,socket,bind,有需要看这篇文章UDP socket

服务端server

两步:初始化服务端,运行服务端

初始化服务端

创建socket,bind IP和端口号,listen监听

socket的第二个参数使用SOCK_STREAM,因为与UDP不同的是TCP面向字节流。其余的与UDP无异。

listen接口

。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。 

    void init(){// socketsockfd_ = socket(AF_INET, SOCK_STREAM, 0);if (sockfd_ < 0){exit(1);}// bindstruct sockaddr_in local;local.sin_family = AF_INET;inet_pton(AF_INET, ip_.c_str(), &local.sin_addr);local.sin_port = htons(port_);int n = bind(sockfd_, (struct sockaddr *)&local, sizeof(local));if (n < 0){exit(2);}// listenif (listen(sockfd_, 10) < 0){exit(3);}}

运行服务端

四步:accept接收请求,接收数据,处理数据,最后发送数据

accept接口

 初始化socket得到的文件描述符是用来listen的,而accept获得的文件描述符才是用来传输数据的,read和write接口就是用这个描述符的。

read和write很简单,第一个参数是文件描述符,第二个参数是读取/发送的数据地址,第三个参数是数据的大小

void run(){while (1){// acceptstruct sockaddr_in client;socklen_t len = sizeof(client);int lis_fd = accept(sockfd_, (struct sockaddr *)&client, &len);// 接收数据char buf[1024] = {0};int n = read(lis_fd, buf, sizeof(buf));if (n < 0){break;}else if (n == 0){cout << "quit" << endl;break;}else{buf[n] = 0;std::cout << "server get msg:" << buf << std::endl;// 处理数据std::string msg = "server say: I have get msg >_";msg += buf;write(lis_fd, msg.c_str(), msg.size());}}}

客户端client

五步:创建socket(同服务端)->bind(由OS完成)->connect请求连接->发送数据write->接收数据read

connect接口

第一个参数是socket获得的文件描述符,第二个是要连接的服务端的属性结构体(记得类型转换),TCP的结构体数据类型是struct sockaddr_in。第三个是结构体大小

int main(int argc, char *argv[])
{if (argc != 3){std::cout << argv[0] << "[ip]" << "[port]" << std::endl;return -1;}// 获取命令行参数uint16_t port = stoi(argv[2]);string ip = argv[1];struct sockaddr_in server;server.sin_family = AF_INET;server.sin_port = htons(port);server.sin_addr.s_addr = inet_addr(ip.c_str());while (1){// socketint sockfd = socket(AF_INET, SOCK_STREAM, 0);if (sockfd < 0){std::cout << "client create fail" << endl;exit(1);}// bind由os随机分配端口完成// connectint n = connect(sockfd, (struct sockaddr *)&server, (socklen_t)sizeof(server));if (n < 0){std::cout << "client connect fail" << std::endl;exit(2);}std::string msg;std::cout << "Please Enter>_";getline(std::cin, msg);// 发送数据n = write(sockfd, msg.c_str(), msg.size());if (n < 0){std::cout << "write fail" << std::endl;continue;}char buf[1024] = {0};// 接收数据n = read(sockfd, buf, sizeof(buf));if (n < 0){std::cout << "read fail" << std::endl;continue;}buf[n] = 0;cout << buf << endl;}
}

序列化和反序列化

序列化是将数据结构或对象转换为一种可以存储或传输的格式,反序列化是序列化的逆过程,它将序列化后的数据重新还原为原始的对象或数据结构。

其实这本质和协议是一样的,都是一种约定。服务端和客户端都按照一个相同的规则将收发的数据做处理,以便于数据的传输。

序列化和反序列化的应用场景

  1. 网络编程

    客户端与服务器之间传输数据时,往往通过序列化和反序列化的方式来进行。例如,在你写的 TCP 客户端/服务器代码中,客户端需要将数据(如数学表达式)序列化后发送给服务器,服务器再反序列化处理并返回结果。
  2. 数据持久化

    将内存中的数据或对象序列化后保存到数据库或文件中,以便稍后可以重新加载数据并继续使用。
  3. 跨进程通信

    当两个不同的进程需要交换数据时,序列化可以将复杂数据结构转换为字节流,方便在进程之间传递。

源码

//tcpserver.hpp
#include <iostream>
#include <string>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <unistd.h>enum
{SocketFail = 1,BindFail,ListenError
};
class tcpServer
{
public:tcpServer(std::string ip = "0.0.0.0", uint16_t port = 8888): ip_(ip), port_(port){}~tcpServer(){}void init(){// socketsockfd_ = socket(AF_INET, SOCK_STREAM, 0);if (sockfd_ < 0){exit(SocketFail);}// bindstruct sockaddr_in local;local.sin_family = AF_INET;inet_pton(AF_INET, ip_.c_str(), &local.sin_addr);local.sin_port = htons(port_);int n = bind(sockfd_, (struct sockaddr *)&local, sizeof(local));if (n < 0){exit(BindFail);}// listenif (listen(sockfd_, 10) < 0){exit(ListenError);}}void run(){while (1){// acceptstruct sockaddr_in client;socklen_t len = sizeof(client);int lis_fd = accept(sockfd_, (struct sockaddr *)&client, &len);// 接收数据char buf[1024] = {0};int n = read(lis_fd, buf, sizeof(buf));if (n < 0){break;}else if (n == 0){cout << "quit" << endl;break;}else{buf[n] = 0;std::cout << "server get msg:" << buf << std::endl;// 处理数据std::string msg = "server say: I have get msg >_";msg += buf;write(lis_fd, msg.c_str(), msg.size());}}}private:int sockfd_;std::string ip_;uint16_t port_;
};
//tcpclient.cpp
#include <iostream>
#include <string>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <unistd.h>int main(int argc, char *argv[])
{if (argc != 3){std::cout << argv[0] << "[ip]" << "[port]" << std::endl;return -1;}// 获取命令行参数uint16_t port = stoi(argv[2]);string ip = argv[1];struct sockaddr_in server;server.sin_family = AF_INET;server.sin_port = htons(port);server.sin_addr.s_addr = inet_addr(ip.c_str());while (1){// socketint sockfd = socket(AF_INET, SOCK_STREAM, 0);if (sockfd < 0){std::cout << "client create fail" << endl;exit(1);}// bind由os随机分配端口完成// connectint n = connect(sockfd, (struct sockaddr *)&server, (socklen_t)sizeof(server));if (n < 0){std::cout << "client connect fail" << std::endl;exit(2);}std::string msg;std::cout << "Please Enter>_" << std::endl;getline(std::cin, msg);// 发送数据n = write(sockfd, msg.c_str(), msg.size());if (n < 0){std::cout << "write fail" << std::endl;continue;}char buf[1024] = {0};// 接收数据n = read(sockfd, buf, sizeof(buf));if (n < 0){std::cout << "read fail" << std::endl;continue;}buf[n] = 0;cout << buf << endl;}
}
//main.cpp
#include "tcpServer.hpp"
#include <memory>int main()
{std::unique_ptr<tcpServer> server(new tcpServer);server->init();server->run();return 0;
}

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

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

相关文章

物品识别——基于python语言

目录 1.物品识别 2.模型介绍 3.文件框架 4.代码示例 4.1 camera.py 4.2 interaction.py 4.3 object_detection.py 4.4 main.py 4.5 运行结果 5.总结 1.物品识别 该项目使用Python&#xff0c;OpenCV进行图像捕捉&#xff0c;进行物品识别。我们将使用YOLO&#xff08…

人工智能——猴子摘香蕉问题

一、实验目的 求解猴子摘香蕉问题&#xff0c;根据猴子不同的位置&#xff0c;求解猴子的移动范围&#xff0c;求解对应的过程&#xff0c;针对不同的目标状态进行求解。 二、实验内容 根据场景有猴子、箱子、香蕉&#xff0c;香蕉挂天花板上。定义多种谓词描述位置、状态等…

Vue生命周期;Vue路由配置;vue网络请求;vue跨域处理

一&#xff0c;Vue生命周期 <template><div > <h1 click"changeText">{{ info }}</h1></div> </template><script> export default {name: HelloWorld,data(){return{info:"介绍组件生命周期"}},methods:{chang…

CenterNet官方代码—目标检测模型推理部分

CenterNet模型推理部分解析 CenterNet官方代码环境部署 CenterNet作为2019年CVPR推出的论文&#xff0c;论文中给出了官方代码所在的github仓库地址。https://github.com/xingyizhou/CenterNet。 整个代码的代码量并不是特别大&#xff0c;但整个项目的难点在于使用了老版本的…

Djourney新手入门基础,AI摄影+AI设计+AI绘画-AIGC作图

人工智能技术的飞速发展&#xff0c;AI正逐渐渗透进创意领域&#xff0c;特别是在摄影、设计和绘画方面&#xff0c;AIGC&#xff08;Artificial Intelligence for Generative Content&#xff09;技术正在重塑我们的创作方式。本文将深入探讨Djourney这款创新工具&#xff0c;…

XML_Tomcat_HTTP

第四章 XML_Tomcat10_HTTP 一 XML XML是EXtensible Markup Language的缩写&#xff0c;翻译过来就是可扩展标记语言。所以很明显&#xff0c;XML和HTML一样都是标记语言&#xff0c;也就是说它们的基本语法都是标签。 可扩展 三个字表面上的意思是XML允许自定义格式。但这不代…

推荐这款神器:Perplexity

今天推荐是一款AI搜索引擎&#xff0c;还支持gpt-4模型的使用&#xff0c;虽然4小时只能使用5次&#xff0c;但是相比于常规的搜索引擎&#xff0c;在某些方面还是很强的&#xff0c;个人感觉优于newbing。 页面简洁&#xff0c;没有广告&#xff0c;内容丰富&#xff0c;功能…

LinkedHashMap 如何实现排序

目录 一、LinkedHashMap二、排序实现三、代码片段分析 一、LinkedHashMap LinkedHashMap 是 Java 中的一个集合类&#xff0c;它是 HashMap 的一个子类&#xff0c;继承了 HashMap 的所有特性&#xff0c;并且在此基础上增加了一个双向链表来维护元素的插入顺序或者访问顺序。L…

Day26_0.1基础学习MATLAB学习小技巧总结(26)——数据插值

利用空闲时间把碎片化的MATLAB知识重新系统的学习一遍&#xff0c;为了在这个过程中加深印象&#xff0c;也为了能够有所足迹&#xff0c;我会把自己的学习总结发在专栏中&#xff0c;以便学习交流。 参考书目&#xff1a; 1、《MATLAB基础教程 (第三版) (薛山)》 2、《MATL…

C++ STL中sort函数

STL的sort算法&#xff0c;数据量大时采用QuickSort快排算法&#xff0c;分段归并排序。一旦分段后的数据量小于某个门槛&#xff08;16&#xff09;&#xff0c;为避免QuickSort快排的递归调用带来过大的额外负荷&#xff0c;就改用Insertion Sort插入排序。如果递归层次过深&…

C++入门基础知识69(高级)——【关于C++ 动态内存】

成长路上不孤单&#x1f60a;&#x1f60a;&#x1f60a;&#x1f60a;&#x1f60a;&#x1f60a; 【14后&#x1f60a;///C爱好者&#x1f60a;///持续分享所学&#x1f60a;///如有需要欢迎收藏转发///&#x1f60a;】 今日分享关于C 动态内存的相关内容&#xff01; 目录…

[产品管理-19]:NPDP新产品开发 - 17 - 产品设计与开发工具 - 实体化设计工具:联合分析、功能分析、FAST技术图和逆向工程

目录 前言&#xff1a; 一、什么是实体化设计 1.1 什么是实体化设计 1、定义与概述 2、设计流程 3、关键要素 4、应用领域 5、举例说明 1.2 实体化设计与概念设计的区别 实体化设计 概念设计 区别归纳 1.3 实体化设计与初步设计、规格设计的区别 1、定义与目的 …

51单片机-LCD1602(液晶显示屏)- 写驱动

时间永远是检验真理唯一标准&#xff01;Whappy&#xff01; 主要简单写出几个驱动 初始化、显示字符、显示字符串、显示整形数据、有符号数据、十六进制、二进制&#xff01; void LCD_Init(); void LCD_ShowChar(unsigned char Line,unsigned char Column,char Char); vo…

平安养老险阜阳中心支公司开展金融教育宣传专项活动

为全面深入开展“金融教育宣传月”的各项工作&#xff0c;不断完善金融惠民利民举措&#xff0c;提升金融服务质效&#xff0c;帮助基层群众增强维权意识、防非反诈的自我保护能力。近日&#xff0c;平安养老保险股份有限公司&#xff08;以下“平安养老险”&#xff09;阜阳中…

【Node.js】RabbitMQ 延时消息

概述 在 RabbitMQ 中实现延迟消息通常需要借助插件&#xff08;如 RabbitMQ 延迟队列插件&#xff09;&#xff0c;因为 RabbitMQ 本身不原生支持延迟消息。 延迟消息的一个典型场景是&#xff0c;当消息发布到队列后&#xff0c;等待一段时间再由消费者消费。这可以通过配置…

带你0到1之QT编程:十一、掌握Containers容器艺术,一网打尽开发利器

此为QT编程的第十一谈&#xff01;关注我&#xff0c;带你快速学习QT编程的学习路线&#xff01; 每一篇的技术点都是很很重要&#xff01;很重要&#xff01;很重要&#xff01;但不冗余&#xff01; 我们通常采取总-分-总和生活化的讲解方式来阐述一个知识点&#xff01; …

npm install报错,gyp verb `which` failed Error: not found: python

主要错误 gyp verb which failed Error: not found: python2 gyp ERR! configure error gyp ERR! stack Error: Cant find Python executable "python", you can set the PYTHON env variable. npm ERR! node-sass4.14.1 postinstall: node scripts/build.js 全部错…

几分钟学会搭建一个自己的外卖霸王餐系统

大家好&#xff0c;我是鲸天科技千千&#xff0c;大家都知道我是做小程序开发的&#xff0c;平时会给大家分享一些互联网相关的创业项目&#xff0c;感兴趣的可以跟我关注一下。 搭建一个首先就是要搭建一个自己的霸王餐小程序&#xff0c;我们自己的工作就是把这个小程序推广…

合肥鲸天科技的外卖会员卡系统有人做过吗?赚钱吗?

我们先来了解一下这个合肥鲸天科技&#xff0c;通过我在网上找到的资料和企业查询&#xff0c;这家公司还是很有实力的&#xff0c;合肥鲸天科技有限公司也是欢迎有合作的人到公司来进行一个考察和合作其他一些项目的。 外卖会员卡简介绍&#xff1a; 这个外卖会员卡&#xf…

地震勘探原理视频总结(1-6)

目录 一、为什么要学好这门课&#xff1f; 1.1 为什么要学这门课&#xff08;为啥学&#xff09;&#xff1f; 1.2 课程包括哪些主要内容&#xff08;学什么&#xff09;&#xff1f; 1.3 如何学好这门课&#xff08;怎么学&#xff09;&#xff1f; 二、石油的生成与聚集…