【C++】POCO学习总结（九）：网络

news2024/11/27 22:32:20

【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: public

Poco::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.coloradmin.cn/o/1286798.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

行业内卷严重到什么程度了？

行业内卷严重到什么程度了？

一.内卷现状 最近大家都吐槽找工作难&#xff0c;确实很难。 不得不说&#xff0c;现在找工作的难度是以前的很多倍。甚至可以说地狱级都不为过。 以前只要简历一挂到网上&#xff0c;就有很多电话打过来。特别是在一线城市&#xff0c;各种类型企业的HR都来找&#xff0c;希…
阅读更多...
《opencv实用探索·十》opencv双边滤波的简单理解

《opencv实用探索·十》opencv双边滤波的简单理解

1、引言 OpenCV中的双边滤波&#xff08;Bilateral Filtering&#xff09;是一种保持边缘清晰的滤波方法&#xff0c;它考虑像素的空间关系和像素值之间的差异。双边滤波对于去除噪声的同时保持图像的边缘非常有效&#xff0c;它也是一种非线性滤波。 双边滤波采用了两个高斯滤…
阅读更多...
获取网络ppt资源

获取网络ppt资源

背景&#xff1a; ​ 某度上有很多优质的PPT资源和文档资源&#xff0c;但是大多数需要付费才能获取。对于一些经济有限的用户来说&#xff0c;这无疑是个遗憾&#xff0c;因为我们更倾向于以免费的方式获取所需资源。 解决方案&#xff1a; ​ 然而&#xff0c;幸运的是&am…
阅读更多...
vivado如何进行增量编译

vivado如何进行增量编译

情况1 如果是根据 placement 或者 routing 进行增量编译&#xff0c;直接右键点击要跑的 implement,&#xff0c;选择set incremental implement &#xff0c; 然后选第二项&#xff0c;指定 要参考的 routing.dcp 或者 placement.dcp 的路径即可 情况2 如果只参考 synthesis …
阅读更多...
西工大计算机学院计算机系统基础实验一（环境配置）

西工大计算机学院计算机系统基础实验一（环境配置）

首先&#xff0c;不要焦虑&#xff0c;稳住心态慢慢来&#xff0c;一点一点做&#xff0c;跟着作者把基础打好&#xff0c;比什么都重要。作者曾经经历过这份痛苦&#xff0c;知道它有多么不好受。当初的作者高中之前甚至都没有自己的一台笔记本&#xff0c;上了大学以后学C语言…
阅读更多...
设计模式：装饰者模式

设计模式：装饰者模式

目录 一、定义 二、场景 三、例子 四、优缺点 优点&#xff1a; 缺点&#xff1a; 一、定义 在不改变已有对象结构的情况下&#xff0c;动态添加新的功能到对象上&#xff0c;是继承的一种替代方案。属于结构型模式。 二、场景 1.扩展一个类的功能&#xff0c;添加附加职责…
阅读更多...
Python如何传递任意数量的实参及什么是返回值

Python如何传递任意数量的实参及什么是返回值

Python如何传递任意数量的实参 传递任意数量的实参 形参前加一个 * &#xff0c;Python会创建一个已形参为名的空元组&#xff0c;将所有收到的值都放到这个元组中&#xff1a; def make_pizza(*toppings):print("\nMaking a pizza with the following toppings: "…
阅读更多...
【部署】预处理和后处理加速方案：CVCuda

【部署】预处理和后处理加速方案：CVCuda

预处理 和 后处理加速方案大概可以包括以下几种 &#xff08;1&#xff09;nvidia开源的CVCuda &#xff08;2&#xff09;使用opencv4的cuda加速模块 &#xff08;3&#xff09;手写cuda算子 这一章我们先从CVCuda开始 一.基本要求 1.1 何时可以使用CVcuda库 在模型的 预…
阅读更多...
SpringBoot_02

SpringBoot_02

Web后端开发_07 SpringBoot_02 SpringBoot原理 1.配置优先级 1.1配置 SpringBoot中支持三种格式的配置文件&#xff1a; application.propertiesapplication.ymlapplication.yaml properties、yaml、yml三种配置文件&#xff0c;优先级最高的是properties 配置文件优先级…
阅读更多...
【前端开发】每一位高级Web工程师都应该掌握的10个Web API！

【前端开发】每一位高级Web工程师都应该掌握的10个Web API！

Photo by Hisu lee on Unsplash JavaScript中的某些API的使用率可能相对较低。下面我们将逐一介绍它们的使用和使用场景。 Blob API Blob API用于处理二进制数据&#xff0c;可以轻松地将数据转换为Blob对象或从Blob对象读取数据。 // Create a Blob object const myBlob …
阅读更多...
【Vulnhub 靶场】【hacksudo: FOG】【简单 - 中等】【20210514】

【Vulnhub 靶场】【hacksudo: FOG】【简单 - 中等】【20210514】

1、环境介绍 靶场介绍&#xff1a;https://www.vulnhub.com/entry/hacksudo-fog,697/ 靶场下载&#xff1a;https://download.vulnhub.com/hacksudo/hacksudo-FOG.zip 靶场难度&#xff1a;简单 - 中等 发布日期&#xff1a;2021年05月14日 文件大小&#xff1a;1.3 GB 靶场作…
阅读更多...
Centos7 制作Openssh9.5 RPM包

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…
阅读更多...
15.（vue3.x+vite）组件间通信方式之默认插槽（匿名插槽）

15.（vue3.x+vite）组件间通信方式之默认插槽（匿名插槽）

前端技术社区总目录（订阅之前请先查看该博客） 示例效果 默认插槽（匿名插槽） 插槽 slot 通常用于两个父子组件之间，最常见的应用就是我们使用一些 UI 组件库中的弹窗组件时，弹窗组件的内容是可以让我们自定义的，这就是使用了插槽的原理。 （1）slot 是 Vue中的内置标签…
阅读更多...
vmware ubuntu22 访问github

vmware ubuntu22 访问github

1.虚拟机选NAT模式。 2.firefox找到下图setting。 3.选第四个&#xff0c;填主机ip和局域网代理的端口号。 4. 此时你应该能访问github了。
阅读更多...
JAVA 线程池，及7大参数，4大拒绝策略详解

JAVA 线程池，及7大参数，4大拒绝策略详解

为什么要使用线程池 线程的生命周期&#xff1a;运行、就绪、运行、阻塞、死亡 下面是一个简单的创建多线程的方法。注意&#xff1a;工作中不可取。 创建线程的时候&#xff0c;我们避不开线程的生命周期。上面的方法虽然可以创建多线程&#xff0c;但是创建完成后&#xff0c…
阅读更多...
设计一个简易版本的分布式任务调度系统

设计一个简易版本的分布式任务调度系统

&#x1f44f;作者简介&#xff1a;大家好&#xff0c;我是爱吃芝士的土豆倪&#xff0c;24届校招生Java选手&#xff0c;很高兴认识大家&#x1f4d5;系列专栏&#xff1a;Spring源码、JUC源码、Kafka原理、分布式技术原理&#x1f525;如果感觉博主的文章还不错的话&#xff…
阅读更多...
【Math】高斯分布的乘积 Product of Guassian Distribution【附带Python实现】

【Math】高斯分布的乘积 Product of Guassian Distribution【附带Python实现】

【Math】高斯分布的乘积 Product of Guassian Distribution【附带Python实现】 文章目录 【Math】高斯分布的乘积 Product of Guassian Distribution【附带Python实现】1.推导2. CodeReference 结果先放在前面 1.推导 在学习PEARL算法的时候&#xff0c;encoder的设计涉及到了…
阅读更多...
读书笔记-《数据结构与算法》-摘要3[选择排序]

读书笔记-《数据结构与算法》-摘要3[选择排序]

选择排序 核心&#xff1a;不断地选择剩余元素中的最小者。 找到数组中最小元素并将其和数组第一个元素交换位置。在剩下的元素中找到最小元素并将其与数组第二个元素交换&#xff0c;直至整个数组排序。 性质&#xff1a; 比较次数(N-1)(N-2)(N-3)…21~N^2/2交换次数N运行…
阅读更多...
jquery 判断是手机端还是电脑端

jquery 判断是手机端还是电脑端

判断为手机端&#xff1a; var sUserAgent navigator.userAgent.toLowerCase(); var bIsIpad sUserAgent.match(/ipad/i) "ipad"; var bIsIphoneOs sUserAgent.match(/iphone os/i) "iphone os"; var bIsMidp sUserAgent.match(/midp/i) "mid…
阅读更多...
Navicat在分辨率不同的屏幕窗口显示大小不一致问题解决

Navicat在分辨率不同的屏幕窗口显示大小不一致问题解决

1.主屏幕为2560*1600分辨率&#xff0c;能够显示较多数据连接 2.在第二屏幕分辨率低&#xff0c;字体变大&#xff0c;显示内容变少 解决办法&#xff1a; 1.右击navicat图标-属性 2.选择【兼容性】-在兼容性页面中选择**“更改高DPI设置”** 3…勾选“高DPI缩放替代”&a…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023