【C++】POCO学习总结(九):网络

【C++】郭老二博文之:C++目录

1、Poco::Net::IPAddress IP地址

Poco::Net::IPAddress类存储IPv4或IPv6主机地址。
Poco::Net::IPAddress可以从字符串解析,也可以格式化为字符串。支持IPv4格式(d.d.d.d)和IPv6格式(x: x: x: x: x: x: x: x)。

常用函数:
是否包含通配符:isWildcard()
是否是广播地址:isBroadcast()
是否是回环地址:isLoopback()
是否是多播地址:isMulticast()

2、Poco::Net::SocketAddress 网络地址

Poco::Net::SocketAddress 是将 Poco::Net::IPAddress与端口号结合起来,从而标识IP网络连接的端点。
Poco::Net::SocketAddress支持值语义,但不支持比较。
Poco::Net::SocketAddress可以由IPAddress +端口号、字符串IP地址+端口号 或 以冒号分隔的IP地址和端口号的字符串创建。

3、Poco::Net::DNS 域名

Poco::Net::DNS类提供了一个域名系统的接口,将域名映射到IP地址,或者从IP地址映射到域名。

4、Poco::Net::HostEntry 主机信息

Poco::Net::HostEntry包含主机地址信息,包含主机名称、别名列表和IP地址列表。

示例:$ vi host.cpp

#include "Poco/Net/DNS.h"
#include <iostream>using Poco::Net::DNS;
using Poco::Net::IPAddress;
using Poco::Net::HostEntry;int main(int argc, char** argv)
{const HostEntry& entry = DNS::hostByName("www.baidu.com");std::cout << "Canonical Name: " << entry.name() << std::endl;const HostEntry::AliasList& aliases = entry.aliases();HostEntry::AliasList::const_iterator it = aliases.begin();for (; it != aliases.end(); ++it)std::cout << "Alias: " << *it << std::endl;const HostEntry::AddressList& addrs = entry.addresses();HostEntry::AddressList::const_iterator ita = addrs.begin();for (; ita != addrs.end(); ++ita)std::cout << "Address: " << ita->toString() << std::endl;return 0;
}

编译:

g++ host.cpp -I ~/git/poco/install/include -L ~/git/poco/install/lib -lPocoNet -std=c++11

输出:

Canonical Name: www.baidu.com
Address: 39.156.66.14
Address: 39.156.66.18
Address: 2409:8c00:6c21:104f:0:ff:b03f:3ae	
Address: 2409:8c00:6c21:1051:0:ff:b0af:279a

5、Poco::Net::Socket 套接字

Poco::Net::Socket是各种Socket的基类。

支持套接字常用接口:

  • select() and poll()
  • 设置和获取各种套接字选项(超时、缓冲区大小、重用地址标志等)
  • 获取套接字地址和对端地址
    在这里插入图片描述

6、Poco::Net::StreamSocket TCP客户端

Poco::Net::StreamSocket用于创建到服务器的TCP连接。
使用sendBytes()和receiveBytes()来发送和接收数据;
或者使用Poco::Net::SocketStream类,它为StreamSocket提供了一个I/O流接口。

示例:$ vi tcp.cpp

#include "Poco/Net/SocketAddress.h"
#include "Poco/Net/StreamSocket.h"
#include "Poco/Net/SocketStream.h"
#include "Poco/StreamCopier.h"
#include <iostream>int main(int argc, char** argv)
{Poco::Net::SocketAddress sa("www.appinf.com", 80);Poco::Net::StreamSocket socket(sa);Poco::Net::SocketStream str(socket);str << "GET / HTTP/1.1\r\n""Host: www.appinf.com\r\n""\r\n";str.flush();Poco::StreamCopier::copyStream(str, std::cout);return 0;
}

编译:

$ g++ tcp.cpp -I ~/git/poco/install/include -L ~/git/poco/install/lib -lPocoNet -lPocoFoundation

输出:

HTTP/1.1 301 Moved Permanently
Date: Sun, 03 Dec 2023 10:04:01 GMT
Server: Apache
Strict-Transport-Security: max-age=63072000; includeSubdomains;
X-Frame-Options: SAMEORIGIN
Location: https://www.appinf.com/
Content-Length: 295
Content-Type: text/html; charset=iso-8859-1<!DOCTYPE HTML PUBLIC "-//IETF//DTD HTML 2.0//EN">
<html><head>
<title>301 Moved Permanently</title>
</head><body>
<h1>Moved Permanently</h1>
<p>The document has moved <a href="https://www.appinf.com/">here</a>.</p>
<hr>
<address>Apache Server at www.appinf.com Port 80</address>
</body></html>

7、Poco::Net::ServerSocket TCP服务端

Poco::Net::ServerSocket用于创建TCP服务器套接字。
Poco::Net::ServerSocket是较底层次的封装,在创建TCP服务器时,推荐使用Poco::Net::TCPServer或Reactor框架。

示例:

#include "Poco/Net/ServerSocket.h"
#include "Poco/Net/StreamSocket.h"
#include "Poco/Net/SocketStream.h"
#include "Poco/Net/SocketAddress.h"int main(int argc, char** argv)
{Poco::Net::ServerSocket srv(8080); for (;;){Poco::Net::StreamSocket ss = srv.acceptConnection();Poco::Net::SocketStream str(ss);str << "HTTP/1.0 200 OK\r\n""Content-Type: text/html\r\n""\r\n""<html><head><title>My 1st Web Server</title></head>""<body><h1>Hello, world!</h1></body></html>"<< std::flush;}return 0;
}

8、Poco::Net::DatagramSocket UDP报文

Poco::Net::DatagramSocket用于发送和接收UDP报文。
Poco::Net::DatagramSocket的子类Poco::Net::MulticastSocket允许发送组播数据报。
要接收组播消息,必须加入组播组,使用MulticastSocket::joinGroup()。

示例1:udp接收方
$ vi udp-recv.cpp

#include "Poco/Net/DatagramSocket.h"
#include "Poco/Net/SocketAddress.h"
#include <iostream>
int main(int argc, char** argv)
{
Poco::Net::SocketAddress sa(Poco::Net::IPAddress(), 5514);
Poco::Net::DatagramSocket dgs(sa, false);
char buffer[1024];for (;;){Poco::Net::SocketAddress sender;int n = dgs.receiveFrom(buffer, sizeof(buffer)-1, sender);buffer[n] = '\0';std::cout << sender.toString() << ": " << buffer << std::endl;}return 0;
}

编译:

g++ -o udp-recv udp-recv.cpp  -I ~/git/poco/install/include -L ~/git/poco/install/lib -lPocoNet -lPocoFoundation

示例2:udp发送方

#include "Poco/Net/DatagramSocket.h"
#include "Poco/Net/SocketAddress.h"
#include "Poco/Timestamp.h"
#include "Poco/DateTimeFormatter.h"
int main(int argc, char** argv)
{Poco::Net::SocketAddress sa("localhost", 5514);Poco::Net::DatagramSocket dgs;dgs.connect(sa);Poco::Timestamp now;std::string msg = Poco::DateTimeFormatter::format(now, "<14>%w %f %H:%M:%S Hello, world!");dgs.sendBytes(msg.data(), msg.size());return 0;
}

编译:

g++ -o udp-send udp-send.cpp  -I ~/git/poco/install/include -L ~/git/poco/install/lib -lPocoNet -lPocoFoundation

先运行接收方,再运行发送方,打印信息如下:

$ ./udp-recv 
127.0.0.1:41406: <14>Tue  5 13:07:54 Hello, world!
127.0.0.1:48117: <14>Tue  5 13:07:56 Hello, world!

9、Poco::Net::TCPServer TCP服务器框架

Poco::Net::TCPServer实现了一个多线程的TCP服务器。
1)ServerSocket
服务器使用一个ServerSocket来接受传入的连接。在将ServerSocket传递给TCPServer之前,必须将其置于侦听模式。

2)队列
服务器为进入的连接维护一个队列。
可变数量的工作线程从队列中获取连接并处理它们。工作线程的数量会根据队列中等待的连接数量自动调整。
可以限制队列中的连接数
TCPServer创建自己的线程,该线程接受连接并将它们放入队列。

3)连接 TCPServerConnection
TCPServer使用TCPServerConnection对象来处理连接。
可以使用工厂的方法创建TCPServerConnection,工厂对象需要传递给TCPServer的构造函数。

TCPServerConnection的子类必须run()方法。在run()方法中,可以处理连接后的逻辑。
当run()返回时,TCPServerConnection对象将被删除,连接将被关闭。

示例

#include "Poco/Net/TCPServer.h"
#include "Poco/Net/TCPServerConnection.h"
#include "Poco/Net/TCPServerConnectionFactory.h"
#include "Poco/Net/StreamSocket.h"
#include "Poco/NumberParser.h"
#include "Poco/Logger.h"
#include "Poco/Process.h"
#include "Poco/NamedEvent.h"
#include <iostream>using Poco::Net::TCPServer;
using Poco::Net::TCPServerConnectionFilter;
using Poco::Net::TCPServerConnection;
using Poco::Net::TCPServerConnectionFactory;
using Poco::Net::TCPServerConnectionFactoryImpl;
using Poco::Net::StreamSocket;
using Poco::UInt16;
using Poco::NumberParser;
using Poco::Logger;
using Poco::Event;
using Poco::NamedEvent;
using Poco::Process;
using Poco::ProcessImpl;
using Poco::Exception;namespace
{class ClientConnection: public TCPServerConnection{public:ClientConnection(const StreamSocket& s): TCPServerConnection(s){}void run(){StreamSocket& ss = socket();char buffer[256];int n = ss.receiveBytes(buffer, sizeof(buffer));while (n > 0){std::cout << "Received " << n << " bytes:" << std::endl;std::string msg;Logger::formatDump(msg, buffer, n);std::cout << msg << std::endl;n = ss.receiveBytes(buffer, sizeof(buffer));}}};typedef TCPServerConnectionFactoryImpl<ClientConnection> TCPFactory;Event terminator;
}int main(int argc, char** argv)
{Poco::UInt16 port = NumberParser::parse((argc > 1) ? argv[1] : "2001");TCPServer srv(new TCPFactory(), port);srv.start();std::cout << "TCP server listening on port " << port << '.'<< std::endl << "Press Ctrl-C to quit." << std::endl;terminator.wait();return 0;
}

10、Poco::Net::SocketReactor反应堆框架

反应器框架基于反应器设计模式。
它是非阻塞套接字和select()与NotificationCenter.的联合
Poco::Net::SocketReactor观察任意数量的套接字的状态,并在套接字的状态发生变化(变为可读、可写或发生错误)时发送通知。

使用Poco::Net::SocketReactor类注册一个套接字和一个回调函数。
SocketReactor与SocketAcceptor一起使用。SocketAcceptor等待传入的连接。
当一个新的连接请求到达时,SocketAcceptor接受这个连接并创建一个新的ServiceHandler对象来处理这个连接。
当ServiceHandler处理完连接后,它必须删除自己

11、HTTPServer

POCO包含一个现成的HTTP服务器框架

  • 多线程
  • HTTP 1.0/1.1
  • 认证支持
  • cookie支持
  • 使用NetSSL库访问HTTPS

简单示例:

#include "Poco/Net/HTTPRequestHandlerFactory.h"
#include "Poco/Net/HTTPServerRequest.h"
#include "RootHandler.h"
#include "DataHandler.h"
class MyRequestHandlerFactory: publicPoco::Net::HTTPRequestHandlerFactory 
{ 
public: MyRequestHandlerFactory() {}Poco::Net::HTTPRequestHandler* createRequestHandler(const Poco::Net::HTTPServerRequest& request){if (request.getURI() == "/") return new RootHandler(); else return new DataHandler(); } 
};int main(int argc, char** argv)
{Poco::UInt16 port = 9999; HTTPServerParams* pParams = new HTTPServerParams; pParams->setMaxQueued(100); pParams->setMaxThreads(16); ServerSocket svs(port);HTTPServer srv(new MyRequestHandlerFactory(), svs, pParams);  srv.start(); waitForTerminationRequest(); srv.stop();
}

常用类:

Poco::Net::HTTPClientSession
Poco::Net::HTTPStreamFactory
Poco::Net::HTMLForm
Poco::Net::HTTPCookie
Poco::Net::HTTPRequest
Poco::Net::HTTPResponse

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

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

相关文章

springboot整合阿里云oss上传图片,解决无法预览的问题

1.前置工作 需要申请一个域名,需要备案&#xff0c;对接这个踩了不少坑,写的很详细,guan fang tong guo bu 了,各位参考别的博客结合看吧,主要是域名配置,还有看service里面的实现 2.进入控制台 bucket列表 选择bucket 选择域名管理 复制你申请的域名,比如域名:abkhkajs…

1970-2022年中国省级国家级开发区数据集

1970-2022年Z国省级国家级开发区数据集 1、时间&#xff1a;1970-2022年 2、指标&#xff1a;单位名称、所属区域、所属省份、所属级别、开发区类型、关注热度、成立时间、核准面积、主导产业、地址、联系电话、经纬度 3、范围&#xff1a;2781个开发区 4、来源&#xff1a…

MagicPipe3D地下管网三维建模数据规格

经纬管网建模系统MagicPipe3D&#xff08;www.magic3d.net&#xff09;本地离线参数化构建三维地下管网&#xff08;含管道、接头、附属物等&#xff09;模型&#xff0c;输出标准3DTiles、Obj等格式&#xff0c;支持Cesium、Unreal、Unity等引擎可视化查询。MagicPipe3D三维建…

c++基本常见错误总结

我们无论是在学习中还是在工作当中&#xff0c;总是会遇到各种各样的c编译错误问题&#xff0c;经常会有一种情况就是上一次好像遇到过这种问题&#xff0c;但是就是想不起来了&#xff08;我就是这样&#xff09;所以下面这一篇文章就是总结自己遇到的编译以及运行错误。 注意…

【C语言】函数递归详解(二)

前言 在上一篇博客函数递归详解&#xff08;一&#xff09;中讲解了什么是递归&#xff0c;递归的思想及限制条件以及两个递归的例子&#xff0c;这一篇博客将讲解递归与迭代的关系。 递归与迭代 递归是一种很好的编程技巧&#xff0c;但是同很多技巧一样也是可能被误用的&…

Centos7 制作Openssh9.5 RPM包

Centos7 制作Openssh9.5 RPM包 最近都在升级Openssh版本到9.3.在博客里也放了openssh 9.5的rpm包. 详见:https://blog.csdn.net/qq_29974229/article/details/133878576 但还是有小伙伴不停追问这个rpm包是怎么做的,怕下载别人的rpm包里被加了盐. 于是做了个关于怎么用官方的o…

yolov5实现多图形识别和图像训练

1.使用了yolov7,检测更好,但是训练上有问题,运行不起来,转了一圈发现yolov5是应用更广泛使用简单 2.怎么使用 //下载代码 https://github.com/ultralytics/yolov5 //安装依赖 pip install -r requirements.txt -i https://pypi.tuna.tsinghua.edu.cn/simple some-package //按…

CMake中的CACHE关键字

2023年12月5日&#xff0c;周二晚上 在 CMake 中&#xff0c;CACHE 关键字用于在变量定义时将其值缓存起来&#xff0c;以便在后续的 CMake 运行中重用。这对于在多次构建过程中保持变量的持久性和一致性非常有用。 当使用 CACHE 关键字定义一个变量时&#xff0c;CMake 将会为…

【Axure高保真原型】3D大屏可视化模板

今天和大家分享3D大屏可视化的原型模板&#xff0c;里面包括3D条形图、3D柱状图、3D饼图、3D环形图、3D金字塔图&#xff0c;鼠标移入图表&#xff0c;对应区域会高亮变色&#xff0c;并且显示对应的数据标签&#xff0c;具体效果可以点击下方视频观看或打开下方预览地址查看哦…

【PduR路由】PduR模块详细介绍

目录 1.PDUR模块功能介绍 2.关键概念理解 3.功能详细设计 3.1I-PDU handling 3.1.1 I-PDU Reception to upper module(s) 3.1.1.1 Communication Interface 3.1.1.2 Transport Protocol 3.1.2 I-PDU Transmission from upper module(s) 3.1.2.1 Multicast 3.1.2.2 Co…

LeetCode 2477. 到达首都的最少油耗:深度优先搜索(DFS)

【LetMeFly】2477.到达首都的最少油耗&#xff1a;深度优先搜索(DFS) 力扣题目链接&#xff1a;https://leetcode.cn/problems/minimum-fuel-cost-to-report-to-the-capital/ 给你一棵 n 个节点的树&#xff08;一个无向、连通、无环图&#xff09;&#xff0c;每个节点表示一…

仓库管理系统【GUI/Swing+MySQL】(Java课设)

系统类型 Swing窗口类型Mysql数据库存储数据 使用范围 适合作为Java课设&#xff01;&#xff01;&#xff01; 部署环境 jdk1.8Mysql8.0Idea或eclipsejdbc 运行效果 本系统源码地址&#xff1a; 更多系统资源库地址&#xff1a;更多Java课设系统 更多系统运行效果展示…

JavaSE基础50题:5. 求两个正整数的最大公约数

方法 我们用到辗转相除法&#xff0c;也叫欧几里得算法。 如&#xff1a;求 32和26 的最大公约数。 32➗ 26 1……6 &#xff08;此时余数不为0&#xff0c;继续&#xff0c;此行的除数26作为下一行的被除数&#xff0c;余数6作为下一行的除数&#xff09; 26 ➗ 6 4……2&a…

为什么Nginx被称为反向代理

下图显示了 &#x1d41f;&#x1d428;&#x1d42b;&#x1d430;&#x1d41a;&#x1d42b;&#x1d41d; &#x1d429;&#x1d42b;&#x1d428;&#x1d431;&#x1d432; 和 &#x1d42b;&#x1d41e;&#x1d42f;&#x1d41e;&#x1d42b;&#x1d42c;&#…

甘草书店:#7 2023年11月19日 星期日 波澜不惊的日子里稳步前行

前进&#xff0c;可以伴着惊涛骇浪&#xff0c;也可以波澜不惊。 几番沟通&#xff0c;多方协商之后&#xff0c;甘草书店硬装方案基本确定&#xff0c;近期开始施工。 书目选择方面也在逐步推进。 就像之前设想的&#xff0c;划分成企业经管和个人成长两大类的前提下&#…

SpringBoot3-创建自定义启动器,使用自定义starter启动器

1、创建自定义启动工程pom.xml <?xml version"1.0" encoding"UTF-8"?> <project xmlns"http://maven.apache.org/POM/4.0.0"xmlns:xsi"http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation"http://maven.a…

软件设计之适配器模式

类模式 我们知道插座的电压为交流电220V&#xff0c;而日常电器使用的是直流电且电压会较小&#xff0c;比如手机充电会通过插头适配器达到额定的输入电流。下面我们实现这个案例&#xff1a;将220V电压转化为5V的电压。 package Adapter.Class;public class Adapter extends …

算法通关村——数论问题

数论是一个很重要的学科&#xff0c;覆盖领域极广&#xff0c;小到小学的智力问题&#xff0c;大到世界顶级科学家都一直在研究相关问题&#xff0c;因此其难度跨度非常大。在程序设计里 &#xff0c;也经常会出现数论的问题&#xff0c;但是&#xff0c;这些一般都是比较基本的…

【@ConfigurationProperties注解的用处】

介绍 ConfigurationProperties 是 Spring 框架中的一个注解&#xff0c;用于将配置文件中的属性映射到 Java 对象的字段上。它的主要用途是简化配置文件与 Java 对象之间的映射过程&#xff0c;使得配置更加方便、可读&#xff0c;并提供类型安全的属性访问。 用途和特性 属性…

vmware ubuntu22 访问github

1.虚拟机选NAT模式。 2.firefox找到下图setting。 3.选第四个&#xff0c;填主机ip和局域网代理的端口号。 4. 此时你应该能访问github了。