【Linux】网络基础_4

文章目录

  • 十、网络基础
    • 5. socket编程
      • 网络翻译服务
  • 未完待续

十、网络基础

5. socket编程

网络翻译服务

基于UDP，我们实现一个简单的翻译。
我们导入之前写的代码：
InetAddr.hpp：

#pragma once#include <iostream>
#include <sys/types.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <netinet/in.h>class InetAddr
{
private:void GetAddress(std::string *ip, uint16_t *port){*port = ntohs(_addr.sin_port);*ip = inet_ntoa(_addr.sin_addr);}public:InetAddr(const struct sockaddr_in &addr): _addr(addr){// 根据套接字结构获取IP地址和端口号GetAddress(&_ip, &_port);}std::string Ip(){return _ip;}uint16_t Port(){return _port;}~InetAddr(){}
private:// 套接字结构struct sockaddr_in _addr;// IP地址std::string _ip;// 端口号uint16_t _port;
};

LockGuard.hpp：

#ifndef __LOCK_GUARD_HPP__
#define __LOCK_GUARD_HPP__#include <iostream>
#include <pthread.h>class LockGuard
{
public:// 构造函数加锁LockGuard(pthread_mutex_t *mutex):_mutex(mutex){pthread_mutex_lock(_mutex);}// 析构函数解锁~LockGuard(){pthread_mutex_unlock(_mutex);}
private:pthread_mutex_t *_mutex;
};#endif

Log.hpp：

#pragma once#include <iostream>
#include <fstream>
#include <cstdio>
#include <string>
#include <ctime>
#include <cstdarg>
#include <sys/types.h>
#include <unistd.h>
#include <pthread.h>
#include "LockGuard.hpp"// 宏定义，用于定义日志格式
#define LOG(level, format, ...) do{LogMessage(__FILE__, __LINE__, gIsSave, level, format, ##__VA_ARGS__);}while (0)
// 将日志输入到文件
#define EnableFile() do{gIsSave = true;}while (0)
// 将日志输出到显示器
#define EnableScreen() do{gIsSave = false;}while (0)bool gIsSave = false;
// 日志文件名
const std::string logname = "log.txt";// 枚举日志级别
enum Level
{DEBUG = 0,INFO,WARNING,ERROR,FATAL
};// 保存日志到文件
void SaveFile(const std::string &filename, const std::string &message)
{std::ofstream out(filename, std::ios::app);if (!out.is_open()){return;}out << message;out.close();
}// 日志级别转字符串
std::string LevelToString(int level)
{switch (level){case DEBUG:return "Debug";case INFO:return "Info";case WARNING:return "Warning";case ERROR:return "Error";case FATAL:return "Fatal";default:return "Unknown";}
}// 获取当前时间字符串
std::string GetTimeString()
{time_t curr_time = time(nullptr);struct tm *format_time = localtime(&curr_time);if (format_time == nullptr)return "None";char time_buffer[1024];snprintf(time_buffer, sizeof(time_buffer), "%d-%d-%d %d:%d:%d",format_time->tm_year + 1900,format_time->tm_mon + 1,format_time->tm_mday,format_time->tm_hour,format_time->tm_min,format_time->tm_sec);return time_buffer;
}// 日志锁，同一时刻只能写一个日志
pthread_mutex_t lock = PTHREAD_MUTEX_INITIALIZER;// 日志信息
void LogMessage(std::string filename, int line, bool issave, int level, const char *format, ...)
{// 日志级别std::string levelstr = LevelToString(level);// 时间std::string timestr = GetTimeString();// 进程idpid_t selfid = getpid();// 日志内容char buffer[1024];va_list arg;va_start(arg, format);vsnprintf(buffer, sizeof(buffer), format, arg);va_end(arg);// 日志格式化std::string message = "[" + timestr + "]" + "[" + levelstr + "]" +"[" + std::to_string(selfid) + "]" +"[" + filename + "]" + "[" + std::to_string(line) + "] " + buffer;LockGuard lockguard(&lock);// 输出日志if (!issave){std::cout << message;}else{SaveFile(logname, message);}
}

UdpClient.cc：

#include <iostream>
#include <string>
#include <cstring>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <cstdlib>void Usage(std::string proc)
{std::cout << "Usage:\n\t" << proc << " local_ip local_prot\n" << std::endl;
}int main(int argc, char* argv[])
{if (argc != 3){Usage(argv[0]);exit(1);}// 获取本地IP地址和端口号std::string serverip = argv[1];uint16_t serverport = std::stoi(argv[2]);int sockfd = socket(AF_INET, SOCK_DGRAM, 0);if (sockfd < 0){std::cerr << "socket error" << std::endl;}// 构建目标主机的socket信息struct sockaddr_in server;memset(&server, 0, sizeof(server));server.sin_family = AF_INET;server.sin_port = htons(serverport);server.sin_addr.s_addr = inet_addr(serverip.c_str());std::string message;// 循环发送消息while (true){// 输入消息std::cout << "Please Enter# ";std::getline(std::cin, message);sendto(sockfd, message.c_str(), message.size(), 0, (struct sockaddr*)&server, sizeof(server));// 接收消息struct sockaddr_in peer;socklen_t len = sizeof(peer);char buffer[1024];ssize_t n = recvfrom(sockfd, buffer, sizeof(buffer) - 1, 0, (struct sockaddr*)&peer, &len);if (n > 0){buffer[n] = '\0';std::cout << "server echo# " << buffer << std::endl;}}return 0;
}

首先我们需要一个翻译服务。我们先创建一个 词库 ：
Dict.txt：

apple: 苹果
banana: 香蕉
cat: 猫
dog: 狗
book: 书
pen: 笔
happy: 快乐的
sad: 悲伤的
run: 跑
jump: 跳
teacher: 老师
student: 学生
car: 汽车
bus: 公交车
love: 爱
hate: 恨
hello: 你好
goodbye: 再见
summer: 夏天
winter: 冬天

这个词库代表当前我们所能翻译的能力范围，如果想要翻译更多单词，则需要往里面添加单词。
接着我们要将词库里的单词一一存入一个键值对当中。当客户端访问时以便能够提供服务。
Dict.hpp：

#pragma once#include <iostream>
#include <unordered_map>
#include <string>
#include <fstream>
#include "Log.hpp"namespace dict_ns
{// 默认字典文件路径const std::string defaultpath = "./Dict.txt";// 字典文件中词条和汉字之间的分隔符const std::string sep = ": ";class Dict{private:bool Load(){// 读取文件内容std::ifstream in(_dict_conf_filepath);if (!in.is_open()){LOG(FATAL, "open %s error\n", _dict_conf_filepath.c_str());return false;}std::string line;// 逐行读取while (std::getline(in, line)){// 跳过空行if (line.empty()) continue;// 解析词条和汉字auto pos = line.find(sep);if (pos == std::string::npos) continue;std::string word = line.substr(0, pos);if (word.empty()) continue;std::string han = line.substr(pos + sep.size());if (han.empty()) continue;LOG(DEBUG, "load info, %s: %s\n", word.c_str(), han.c_str());// 加入字典_dict.insert(std::make_pair(word, han));}// 关闭文件in.close();LOG(DEBUG, "load %s success\n", _dict_conf_filepath.c_str());return true;}public:Dict(const std::string& filepath = defaultpath): _dict_conf_filepath(filepath){Load();}std::string Translate(const std::string& word, bool& ok){ok = true;// 查找词条auto iter = _dict.find(word);// 检测词条存不存在if (iter == _dict.end()){ok = false;LOG(ERROR, "word %s not found\n", word.c_str());return "未找到";}// 返回汉字return iter->second;}~Dict(){}private:// 词典映射std::unordered_map<std::string, std::string> _dict;// 词典配置文件路径std::string _dict_conf_filepath;};
}

有了翻译服务就可以让服务器提供这个服务。为了让网络与服务之间解耦合，我们不能直接在服务器上直接调用函数，我们最好使用包装器包装一下函数，然后通过回调的方法来访问服务。
UdpServer.hpp：

#pragma once#include <iostream>
#include <string>
#include <cerrno>
#include <cstring>
#include <cstdlib>
#include <strings.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <netinet/in.h>
#include "Log.hpp"
#include "InetAddr.hpp"// 错误码
enum
{SOCKET_ERROR = 1,BIND_ERROR,USAGE_ERROR
};// 默认套接字
const static int defaultfd = -1;
using func_t = std::function<std::string(const std::string&, bool&ok)>;class UdpServer
{
public:UdpServer(uint16_t port, func_t func):_sockfd(defaultfd),_port(port),_isrunning(false),_func(func){}void InitServer(){// 创建 UDP socket 套接字_sockfd = socket(AF_INET, SOCK_DGRAM, 0);if (_sockfd < 0){LOG(FATAL, "socket error, %s, %d\n", strerror(errno), errno);exit(SOCKET_ERROR);}LOG(INFO, "socket create success, sockfd: %d\n", _sockfd);// 创建 sockaddr_in 结构体struct sockaddr_in local;// 清空结构体bzero(&local, sizeof(local));// 设置IP协议地址族为 AF_INET 即IPv4local.sin_family = AF_INET;// 端口号要经过网络传输，需要转换成网络字节序local.sin_port = htons(_port);// 绑定到本地地址，IP地址设置为 INADDR_ANY 即 0.0.0.0， 表示接收所有地址的消息local.sin_addr.s_addr = INADDR_ANY;// 将套接字和结构体绑定int n = bind(_sockfd, (struct sockaddr*)&local, sizeof(local));if (n < 0){LOG(FATAL, "bind error, %s, %d\n", strerror(errno), errno);exit(BIND_ERROR);}LOG(INFO, "socket bind success\n");}void Start(){// 启动服务器_isrunning = true;while (true){// 接收数据char request[1024];struct sockaddr_in peer;socklen_t len = sizeof(peer);// 接收数据ssize_t n = recvfrom(_sockfd, request, sizeof(request) - 1, 0, (struct sockaddr*)&peer, &len);if (n > 0){// 收到数据，打印request[n] = '\0';InetAddr addr(peer);LOG(DEBUG, "get message from [%s:%d]: %s\n", addr.Ip().c_str(), addr.Port(), request);bool ok;// 将请求传给回调函数std::string response = _func(request, ok);(void)ok;// 发送数据sendto(_sockfd, response.c_str(), response.size(), 0, (struct sockaddr*)&peer, len);}// sleep(1);// LOG(DEBUG, "server is running...\n");}_isrunning = false;}~UdpServer(){}
private:int _sockfd;// 服务器所用端口号uint16_t _port;bool _isrunning;// 给服务器设置回调函数，即服务函数func_t _func;
};

主函数：
Main.cc：

#include <iostream>
#include <memory>
#include "UdpServer.hpp"
#include "Dict.hpp"using namespace dict_ns;void Usage(std::string proc)
{std::cout << "Usage:\n\t" << proc << " local_prot\n" << std::endl;
}int main(int argc, char* argv[])
{if (argc != 2){Usage(argv[0]);exit(USAGE_ERROR);}EnableScreen();// std::string local_ip = argv[1];Dict dict;uint16_t port = std::stoi(argv[1]);std::unique_ptr<UdpServer> usvr(new UdpServer(port, std::bind(&Dict::Translate, &dict, std::placeholders::_1, std::placeholders::_2)));// 初始化服务器usvr->InitServer();// 启动服务器usvr->Start();return 0;
}

Makefile：

.PHONY:all
all:udpserver udpclientudpserver:Main.ccg++ -o $@ $^ -std=c++11
udpclient:UdpClient.ccg++ -o $@ $^ -std=c++11
.PHONY:clean
clean:rm -f udpserver udpclient

OK，我们来使用一下。
服务端：./udpserver 8888
客户端：./udpclient 127.0.0.1 8888

在这里插入图片描述
成功实现了简陋的网络翻译服务。

未完待续

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

如若内容造成侵权/违法违规/事实不符，请联系长河编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

开源智能低代码自动化助手：Obsei

开源智能低代码自动化助手：Obsei

**Obsei&#xff1a;**低代码&#xff0c;高效率&#xff0c;Obsei让AI自动化触手可及。- 精选真开源&#xff0c;释放新价值。 概览 Obsei是一款开源的低代码人工智能自动化工具&#xff0c;它为企业提供了一套灵活的解决方案&#xff0c;以应对日益增长的数据处理需求。该工…
阅读更多...
uvm_config_db 和 uvm_resource_db ：

uvm_config_db 和 uvm_resource_db ：

uvm_config_db class my_driver extends uvm_driver;int my_param;function new(string name, uvm_component parent);super.new(name, parent);endfunctionvirtual task run_phase(uvm_phase phase);// 在组件内部获取配置值if (!uvm_config_db#(int)::get(this, ""…
阅读更多...
[Git][远程操作]详细讲解

[Git][远程操作]详细讲解

1.理解分布式版本控制系统 形象理解&#xff1a;每个⼈的电脑上都是⼀个完整的版本库 这样⼯作的时候&#xff0c;就不需要联⽹了&#xff0c; 因为版本库就在⾃⼰的电脑上 既然每个⼈电脑上都有⼀个完整的版本库&#xff0c;那多个⼈如何协作呢&#xff1f; 例如&#xff1a;…
阅读更多...
ajax图书管理项目

ajax图书管理项目

bootstrap弹框 不离开当前页面&#xff0c;显示单独内容&#xff0c;让用户操作 功能&#xff1a;不离开当前页面&#xff0c;显示单独内容&#xff0c;供用户操作步骤&#xff1a; 1.引入bootstrap.css和bootstrap.js …
阅读更多...
Stegdetect教程：如何用Stegdetect检测和破解JPG图像隐写信息

Stegdetect教程：如何用Stegdetect检测和破解JPG图像隐写信息

一、Stegdetect简介 Stegdetect 是一个开源工具&#xff0c;专门设计用于检测图像文件&#xff08;JPG格式&#xff09;中的隐写信息。Stegdetect 可以检测多种常见的隐写方法&#xff0c;比如 JSteg、JPHide 和 OutGuess 等。 二、使用Stegdetect检测图像隐写 官方描述&#…
阅读更多...
NSS [SWPUCTF 2022 新生赛]file_master

NSS [SWPUCTF 2022 新生赛]file_master

NSS [SWPUCTF 2022 新生赛]file_master 开题&#xff0c;一眼文件上传。 network看看返回包。后端语言是PHP。 除了文件上传还有个查看文件功能。 起手式查询/etc/passwd&#xff0c;发现查询方法是GET提交参数&#xff0c;后端使用file_get_contents()函数包含文件。同时有op…
阅读更多...
企业级业务架构设计探讨

企业级业务架构设计探讨

引言 在数字化转型的浪潮中&#xff0c;企业业务架构的设计成为了连接企业战略与技术实现的桥梁&#xff0c;其重要性日益凸显。本文探讨企业级业务架构的设计原则、流程、工具和技术实现&#xff0c;并结合具体案例&#xff0c;为读者提供参考。 一、设计原则&#xff1a;奠…
阅读更多...
KubeSphere 部署的 Kubernetes 集群使用 GlusterFS 存储实战入门

KubeSphere 部署的 Kubernetes 集群使用 GlusterFS 存储实战入门

转载&#xff1a;KubeSphere 部署的 Kubernetes 集群使用 GlusterFS 存储实战入门 知识点 定级&#xff1a;入门级 GlusterFS 和 Heketi 简介 GlusterFS 安装部署 Heketi 安装部署 Kubernetes 命令行对接 GlusterFS 实战服务器配置(架构1:1复刻小规模生产环境&#xff0c;…
阅读更多...
新手学习Gazebo+ros仿真控制小车-----易错和自己理解

新手学习Gazebo+ros仿真控制小车-----易错和自己理解

赵虚左老师讲的很详细&#xff0c;这里只是理一下思路&#xff0c;说下突然出现“新”概念之间的关系。 urdf文件:里面是配置模型的&#xff0c;既有模型的位置、尺寸、颜色&#xff0c;也包含复杂的物理模型信息比如&#xff1a;转动惯量&#xff0c;碰撞box大小等等&#xff…
阅读更多...
黑马Java零基础视频教程精华部分_11_面向对象进阶(3)_抽象类、接口、适配器

黑马Java零基础视频教程精华部分_11_面向对象进阶(3)_抽象类、接口、适配器

《黑马Java零基础视频教程精华部分》系列文章目录 黑马Java零基础视频教程精华部分_1_JDK、JRE、字面量、JAVA运算符 黑马Java零基础视频教程精华部分_2_顺序结构、分支结构、循环结构 黑马Java零基础视频教程精华部分_3_无限循环、跳转控制语句、数组、方法 黑马Java零基础视…
阅读更多...
书生大模型基础岛-第二关：8G 显存玩转书生大模型 Demo

书生大模型基础岛-第二关：8G 显存玩转书生大模型 Demo

1.来源 https://github.com/InternLM/Tutorial/blob/camp3/docs/L1/Demo/task.md 2.过程 在 /root/share/pre_envs 中配置好了预置环境 icamp3_demo conda activate /root/share/pre_envs/icamp3_demo创建一个目录&#xff0c;用于存放我们的代码。并创建一个 cli_demo.py …
阅读更多...
【hive】HiveSQL中两个json解析函数的使用json路径定位小工具

【hive】HiveSQL中两个json解析函数的使用json路径定位小工具

文章目录 1.HiveSQL中两个json解析函数1&#xff09;get_json_object2&#xff09;json_tuple 2.json中key所在层级路径定位小工具 关于json&#xff1a; https://blog.csdn.net/atwdy/article/details/124668815 1.HiveSQL中两个json解析函数 1&#xff09;get_json_object …
阅读更多...
C语言程序设计-[3] 运算符和表达式

C语言程序设计-[3] 运算符和表达式

C语言的运算符也存在优先级和结合性的概念&#xff0c;在同一表达式中&#xff0c;优先级高的先结合&#xff0c;优先级相同时&#xff0c;就需要考虑结合性(分为左结合性和右结合性——对于单目、三目和赋值运算符表达式&#xff0c;从右至左运算&#xff1b;其他运算符表达式…
阅读更多...
【Mind+】掌控板入门教程04 迷你动画片

【Mind+】掌控板入门教程04 迷你动画片

还记得小时候每天放学必看的动画片吗&#xff1f;还记得那些年陪伴我一起长大的卡通人物吗&#xff1f;勇救爷爷的葫芦娃&#xff0c;我们的朋友小哪吒&#xff0c;相信这些经典的动画形象已经成为了一代人童年的美好回忆。今天就让我们用掌控板来制作一部迷你动画片吧。 项目示…
阅读更多...
什么是云原生？

什么是云原生？

1. 前言 停下手头的工作&#xff0c;让你的同事定义“云原生”一词。你很可能会得到几个不同的答案。 1.1 让我们从一个简单的定义开始&#xff1a; 云原生架构和技术是一种设计、构建和操作在云中构建并充分利用云计算模型的工作负载的方法。 1.2 云原生计算基金会给出了官方…
阅读更多...
Godot的节点与场景

Godot的节点与场景

要深入的理解节点与场景&#xff0c;我们需要跳出这两个概念来看他。说的再直白一些godot本质就是一个场景编辑器&#xff01; 场景的概念应该在我们平时看电影看电视时会经常提到&#xff0c;比如某一个打斗的场景&#xff0c;这个场景可能会被设在某一个街道&#xff0c;那么…
阅读更多...
数据湖之Hudi

数据湖之Hudi

Apache Hudi&#xff08;Hadoop Upserts Deletes and Incrementals&#xff09;是一个用于管理大规模数据湖的开源框架&#xff0c;旨在高效地进行数据的插入、更新和删除操作&#xff0c;并支持流式数据的处理。Hudi 的设计目标是解决传统数据湖在数据管理和查询性能上的不足&…
阅读更多...
如何将本地代码上传到github

如何将本地代码上传到github

将本地文件上传到GitHub仓库的过程通常包括以下几个步骤&#xff1a; 一 创建GitHub仓库&#xff1a; 如果你还没有一个GitHub仓库&#xff0c;首先需要在GitHub上创建一个新的仓库。登录到你的GitHub账户&#xff0c;然后点击“New repository”按钮&#xff0c;填写仓库的相关…
阅读更多...
oracle(19c)用户管理

oracle(19c)用户管理

简介 本文介绍 Oracle 中的用户管理&#xff0c;包含以下内容&#xff1a; 概念介绍 系统用户 解锁 hr 用户 创建用户 用户相关案例 使用 Profile 管理用户口令 Oracle 的认证方式 重置管理员(sys)密码 1. 概念介绍 Oracle 中可以创建多个 Database 实例&#xff0c;…
阅读更多...
（STM32笔记）九、RCC时钟树与时钟 第一部分

（STM32笔记）九、RCC时钟树与时钟 第一部分

我用的是正点的STM32F103来进行学习&#xff0c;板子和教程是野火的指南者。 之后的这个系列笔记开头未标明的话&#xff0c;用的也是这个板子和教程。 九、RCC时钟树与时钟 九、RCC时钟树与时钟1、时钟树HSE时钟HSI时钟锁相环时钟系统时钟HCLK时钟PCLK1时钟PCLK2时钟RTC时钟独…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023