CTK插件框架学习-事件监听(04)

CTK插件框架学习-插件注册调用(03)icon-default.png?t=N7T8https://mp.csdn.net/mp_blog/creation/editor/136989802

一、主要流程

  • 发送者注册消息事件
  • 接收者订阅消息事件
  • 接收者相应消息事件

事件监听比插件接口调用耦合性更弱，事件由框架维护，不需要指定发送方和接收方

二、发布订阅插件

2.1、事件发布插件


发送消息类


==========================Publish.ch================================
#pragma once

#include "qstring.h"

typedef struct
{
	QString _name;
	QString _message;
}ST_Msg;

class ctkPluginContext;
class Publish
{
public:
	Publish(ctkPluginContext* context);

	//发布的消息
	void publishMessage(const ST_Msg& msg);

private:
	ctkPluginContext* m_context;
};


==========================Publish.cpp==============================
#include "Publish.h"
#include <qdebug.h>

#include "service/event/ctkEventAdmin.h"
#include "ctkPluginContext.h"

Publish::Publish(ctkPluginContext * context)
	:m_context(context)
{
}

void Publish::publishMessage(const ST_Msg & msg)
{
	ctkServiceReference ref = m_context->getServiceReference<ctkEventAdmin>();
	if (ref)
	{
		ctkEventAdmin* eventAdmin = m_context->getService<ctkEventAdmin>(ref);
		if (eventAdmin)
		{
			ctkDictionary dic;
			dic["name"] = msg._name;
			dic["message"] = msg._message;
			ctkEvent event("EVENT_MESSAGE", dic);

			qDebug() << "Publish message:" << dic;
			
			eventAdmin->sendEvent(event);//同步，消息发送后立即执行
			//eventAdmin->postEvent(event);//异步，由消息队列控制，有超时机制，超时后会被加入黑名单
		}
	}
}

激活器类

=============================PluginActivator.h===================================
#pragma once
#include <qobject.h>
#include "ctkPluginActivator.h"
#include "ctkPluginContext.h"

#include "Publish.h"

class PluginActivator :
	public QObject, ctkPluginActivator
{
	Q_OBJECT
	Q_INTERFACES(ctkPluginActivator)//向Qt的插件框架声明，希望将xxx插件放入到框架中。
	Q_PLUGIN_METADATA(IID "TestPublishPlugin")//向qt框架申明插件（qt5版本）


public:
	PluginActivator();
	virtual void start(ctkPluginContext* context);
	virtual void stop(ctkPluginContext* context);

private:
	QScopedPointer<Publish> m_publish;//智能指针,自动析构回收
};


=============================PluginActivator.cpp=================================
#include "PluginActivator.h"
#include <qdebug.h>

#include "ctkPluginFrameworkLauncher.h"

PluginActivator::PluginActivator()
{
}


void PluginActivator::start(ctkPluginContext* context)
{
	qDebug() << "my PublishPlugin start";
	m_publish.reset(new Publish(context));

	ST_Msg msg;
	msg._name = "Publish";
	msg._message = "hello Publish send message";
	m_publish.get()->publishMessage(msg);

	ctkPlugin::State sta = context->getPlugin()->getState();
}

void PluginActivator::stop(ctkPluginContext* context)
{
	qDebug() << "my PublishPlugin stop";
	Q_UNUSED(context)// Q_UNUSED,如果一个函数的有些参数没有用到、某些变量只声明不使用，但是又不想编译器、编辑器报警报，其他没有什么实际性作用


	m_publish.reset(NULL);

	ctkPlugin::State sta = context->getPlugin()->getState();
}

2.2、事件订阅插件
 

接收消息类

==========================SubscribeEventHandler.h================================
#pragma once

#include <qobject.h>
#include "service/event/ctkEventHandler.h"

class SubscribeEventHandler
	: public QObject, public ctkEventHandler
{
	Q_OBJECT
	Q_INTERFACES(ctkEventHandler)

public:
	SubscribeEventHandler();
	
	virtual void handleEvent(const ctkEvent& event);
};

==========================SubscribeEventHandler.cpp==============================

#include "SubscribeEventHandler.h"
#include <qdebug.h>

#include "service/event/ctkEventAdmin.h"
#include "ctkPluginContext.h"

SubscribeEventHandler::SubscribeEventHandler()
{
}

void SubscribeEventHandler::handleEvent(const ctkEvent & event)
{
	QString name = event.getProperty("name").toString();
	QString message = event.getProperty("message").toString();

	qDebug() << "Subscribe name:" << name;
	qDebug() << "Subscribe message:" << message;
}

激活器类

=============================PluginActivator.h================================
#pragma once

#include <QObject>
#include "ctkPluginActivator.h"
#include "ctkPluginContext.h"

#include "SubscribeEventHandler.h"

class PluginActivator  : public QObject, public ctkPluginActivator
{
	Q_OBJECT
	Q_INTERFACES(ctkPluginActivator)//向Qt的插件框架声明，希望将xxx插件放入到框架中。
	Q_PLUGIN_METADATA(IID "TestSubscribePlugin")//向qt框架申明插件（qt5版本）

public:
	PluginActivator();
	void start(ctkPluginContext *context);
	void stop(ctkPluginContext *context);

private:
	QScopedPointer<SubscribeEventHandler> m_subscribeEventHandler;//智能指针,自动析构回收
};

=============================PluginActivator.cpp==============================

#include "PluginActivator.h"
#include <qdebug.h>

#include "ctkPluginFrameworkLauncher.h"
#include "service/event/ctkEventConstants.h"

PluginActivator::PluginActivator()
{}

void PluginActivator::start(ctkPluginContext* context)
{
	qDebug() << "my SubscribePlugin start";
	m_subscribeEventHandler.reset(new SubscribeEventHandler());

	ctkDictionary dic;
	dic[ctkEventConstants::EVENT_TOPIC] = "EVENT_MESSAGE";//订阅的主题
	dic[ctkEventConstants::EVENT_FILTER] = "(name=Publish)";//过滤的事件
	context->registerService<ctkEventHandler>(m_subscribeEventHandler.get(), dic);

	ctkPlugin::State sta = context->getPlugin()->getState();
}

void PluginActivator::stop(ctkPluginContext* context)
{
	qDebug() << "my SubscribePlugin stop";
	Q_UNUSED(context)// Q_UNUSED,如果一个函数的有些参数没有用到、某些变量只声明不使用，但是又不想编译器、编辑器报警报，其他没有什么实际性作用

	m_subscribeEventHandler.reset(NULL);

	ctkPlugin::State sta = context->getPlugin()->getState();
}

2.3、测试插件

#include "CTKPlugin.h"
#include <QtWidgets/QApplication>


#include <iostream>
#include <QStyleFactory>
#include <QDir>
#include <QDirIterator>
#include <QDebug>
#include "ctkPluginFrameworkFactory.h"
#include "ctkPluginFramework.h"
#include "ctkPluginException.h"
#include "ctkPluginContext.h"
#include "ctkPluginFrameworkLauncher.h"
#include "../TestPlugin/iTestPlugin.h"
#include "../TestPlugin2/IService1.h"
#include "../TestPlugin2/IService2.h"
#include "../TestPlugin3/IService.h"
/*
* 1、注意：Plugin-SymbolicName要满足这里的前缀是：TARGET/META-INF格式。TARGET的名字最好和工程名一致，不然可能出现device not open错误。
* 2、如果CTK初始化、插件安装启动等是在一个类中，则与CTK相关的变量应定义成类的属性，不能是成员变量，否则获取不到服务
* 3、CTK插件组成：
（1）每个插件有自己的注册器Activator，继承自QObject和ctkPluginActivator的一个类，并实现ctkPluginActivator的start、stop函数
（2）每个插件必须有一个资源文件，名称一般与插件名称一致，前缀必须为TARGET/META-INF，例：插件名称/META-INF
（3）每个插件必须添加一个元数据文件，名字必须为MANIFEST.MF，并添加到资源文件中
* 4、QSharedPointer framework这个对象既可以作为对象也可以作为对象指针，但要作为插件框架使用必须要用指针方法调用
* 5、生成的插件名(TARGET)不要有下划线，因为CTK会默认将插件名中的下划线替换成点号，最后导致找不到插件 
*/
int main(int argc, char *argv[])
{
	QApplication::setAttribute(Qt::AA_EnableHighDpiScaling);

    QApplication a(argc, argv);
	a.setApplicationName("ctktest");//Linux下没有名称报错

	QString path = QCoreApplication::applicationDirPath();

#ifdef _DEBUG
	ctkPluginFrameworkLauncher::addSearchPath(path + "/CTKPlugins");
#else
	ctkPluginFrameworkLauncher::addSearchPath(path + "/CTKPlugins");
#endif // _DEBUG
	// 设置并启动 CTK 插件框架
	try {
		ctkPluginFrameworkLauncher::start("org.commontk.eventadmin");
	}
	catch (ctkException e)
	{
		std::cout << e.message().toStdString() << std::endl;
	}

	// 启动插件工厂
	ctkPluginFrameworkFactory* ctkFrameWorkFactory = new ctkPluginFrameworkFactory;
	QSharedPointer<ctkPluginFramework> framework = ctkFrameWorkFactory->getFramework();
	try {
		framework->init();
		framework->start();
	}
	catch (const ctkPluginException& e)
	{
		std::cout << "framework init fail" << std::endl;
	}

	QSharedPointer<ctkPlugin> plugin;

/*
* 使用MANIFEST.MF启动依赖插件方法未成功，采用独立加载插件方法
*/
#if 0
	QDirIterator iter(path + "/plugins/", { "*.dll" }, QDir::NoFilter, QDirIterator::Subdirectories);
	while (iter.hasNext()) {
		//qDebug() << iter.next();
		QString dllPath = iter.next();
		QUrl url = QUrl::fromLocalFile(dllPath);
		try
		{
			plugin = framework->getPluginContext()->installPlugin(url);
			qDebug() << QString("Plugin[%1_%2] installed...").arg(plugin->getSymbolicName()).arg(plugin->getVersion().toString());
			
			//获取MANIFEST.MF中的数据
			QHash<QString, QString> headers = plugin->getHeaders();
			ctkVersion version = ctkVersion::parseVersion(headers.value(ctkPluginConstants::PLUGIN_VERSION));
			QString name = headers.value(ctkPluginConstants::PLUGIN_NAME);
		}
		catch (ctkPluginException e) {
			std::cout << e.message().toStdString() << e.getType() << std::endl;
		}

		try {
			plugin->start(ctkPlugin::START_TRANSIENT);//表示立即启用插件，不设置参数的话加载后也不会立即打印输出
			qDebug() << QString("Plugin[%1_%2] started").arg(plugin->getSymbolicName()).arg(plugin->getVersion().toString());
		}
		catch (ctkPluginException e) {
			std::cout << e.message().toStdString() << e.getType() << std::endl;
		}
	}

#else
	
	try
	{
		QUrl url = QUrl::fromLocalFile(path + "/plugins/TestSubscribePlugin.dll");
		plugin = framework->getPluginContext()->installPlugin(url);
		qDebug() << QString("Plugin[%1_%2] installed...").arg(plugin->getSymbolicName()).arg(plugin->getVersion().toString());

		//获取MANIFEST.MF中的数据
		QHash<QString, QString> headers = plugin->getHeaders();
		ctkVersion version = ctkVersion::parseVersion(headers.value(ctkPluginConstants::PLUGIN_VERSION));
		QString name = headers.value(ctkPluginConstants::PLUGIN_NAME);
	}
	catch (ctkPluginException e) {
		std::cout << e.message().toStdString() << e.getType() << std::endl;
	}

	try {
		plugin->start(ctkPlugin::START_TRANSIENT);//表示立即启用插件，不设置参数的话加载后也不会立即打印输出
		qDebug() << QString("Plugin[%1_%2] started").arg(plugin->getSymbolicName()).arg(plugin->getVersion().toString());
	}
	catch (ctkPluginException e) {
		std::cout << e.message().toStdString() << e.getType() << std::endl;
	}

	try
	{
		QUrl url = QUrl::fromLocalFile(path + "/plugins/TestPublishPlugin.dll");
		plugin = framework->getPluginContext()->installPlugin(url);
		qDebug() << QString("Plugin[%1_%2] installed...").arg(plugin->getSymbolicName()).arg(plugin->getVersion().toString());

		//获取MANIFEST.MF中的数据
		QHash<QString, QString> headers = plugin->getHeaders();
		ctkVersion version = ctkVersion::parseVersion(headers.value(ctkPluginConstants::PLUGIN_VERSION));
		QString name = headers.value(ctkPluginConstants::PLUGIN_NAME);
	}
	catch (ctkPluginException e) {
		std::cout << e.message().toStdString() << e.getType() << std::endl;
	}

	try {
		plugin->start(ctkPlugin::START_TRANSIENT);//表示立即启用插件，不设置参数的话加载后也不会立即打印输出
		qDebug() << QString("Plugin[%1_%2] started").arg(plugin->getSymbolicName()).arg(plugin->getVersion().toString());
	}
	catch (ctkPluginException e) {
		std::cout << e.message().toStdString() << e.getType() << std::endl;
	}
#endif

	//ctkPlugin::State sta = plugin->getState();
	//ctkPluginFrameworkLauncher::stop();
	//plugin->stop(); 
	//plugin->uninstall();
	//sta = plugin->getState();

	CTKPlugin c;
	c.show();
    return a.exec();
}

三、MANIFEST.MF文件参数

实现插件依赖启动

Plugin-SymbolicName:本插件名称

Plugin-Version:本插件版本号

Require-Plugin:依赖插件名称

Plugin-version=依赖插件版本号， 默认为1.0

resolution=mandatory为强依赖没有找到则本插件不能启动，optional为弱依赖没有找到也正常启动

四、类通信和信号槽区别

1、使用event发送效率优于信号槽，信号槽方式会在qt信号槽机制中转再发送到ctk框架

2、两种方式可以混合使用

3、同步：sendEvent / Qt::DirectConnection

4、异步：postEvent / Qt::QueuedConnection

CTK插件框架学习-信号槽(05)icon-default.png?t=N7T8https://mp.csdn.net/mp_blog/creation/editor/137240105

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

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

tensflow模型转onnx实践

tensflow模型转onnx实践

一、基础知识介绍 1、TensorFlow介绍 TensorFlow™是一个基于数据流编程&#xff08;dataflow programming&#xff09;的符号数学系统&#xff0c;被广泛应用于各类机器学习&#xff08;machine learning&#xff09;算法的编程实现&#xff0c;其前身是谷歌的神经网络算法库…
阅读更多...
WebGIS 之 Openlayer

WebGIS 之 Openlayer

1.导入第三方依赖 <link rel"stylesheet" href"https://lib.baomitu.com/ol3/4.6.5/ol.css"> <script src"https://lib.baomitu.com/ol3/4.6.5/ol.js"></script>2.初始化地图 初始化地图new ol.Map({}) 参数target:制定初始化…
阅读更多...
阻塞队列(BlockingQueue)

阻塞队列(BlockingQueue)

何为阻塞队列 当阻塞队列是空时,从队列中获取元素的操作将被阻塞当阻塞队列是满时,往队列中添加元素将会被阻塞试图从空的阻塞队列中获取元素的线程将会被阻塞,直到其他线程往空的队列中插入新的元素试图往满的队列中,添加新的元素的线程也会被阻塞,直到其他线程从队列中移除…
阅读更多...
基于SSM的社区疫情防控管理信息系统

基于SSM的社区疫情防控管理信息系统

目录 背景 技术简介 系统简介 界面预览 背景 随着时代的进步&#xff0c;计算机技术已经全方位地影响了社会的发展。随着居民生活质量的持续上升&#xff0c;人们对社区疫情防控管理信息系统的期望和要求也在同步增长。在社区疫情防控日益受到广泛关注的背景下&#xff0c…
阅读更多...
OpenHarmony实战：Makefile方式组织编译的库移植

OpenHarmony实战：Makefile方式组织编译的库移植

以yxml库为例&#xff0c;其移植过程如下文所示。 源码获取 从仓库获取yxml源码&#xff0c;其目录结构如下表&#xff1a; 表1 源码目录结构 名称描述yxml/bench/benchmark相关代码yxml/test/测试输入输出文件&#xff0c;及测试脚本yxml/Makefile编译组织文件yxml/.gitat…
阅读更多...
Python基础之pandas：字符串操作与透视表

Python基础之pandas：字符串操作与透视表

文章目录 一、字符串操作备注&#xff1a;如果想要全部行都能输出&#xff0c;可输入如下代码 1、字符检索2、字符转换3、字符类型判断4、字符调整5、字符对齐与填充6、字符检索7、字符切割8、字符整理 二、透视表1、pd.pivot_table2、多级透视表 一、字符串操作 备注&#xf…
阅读更多...
黄锈水过滤器 卫生热水工业循环水色度水处理器厂家工作原理动画

黄锈水过滤器 卫生热水工业循环水色度水处理器厂家工作原理动画

​ 1&#xff1a;黄锈水处理器介绍 黄锈水处理器是一种专门用于处理“黄锈水”的设备&#xff0c;它采用机电一体化设计&#xff0c;安装方便&#xff0c;操作简单&#xff0c;且运行费用极低。这种处理器主要由数码射频发生器、射频换能器、活性过滤体三部分组成&#xff0c;…
阅读更多...
2024年第九届亚太智能机器人系统国际会议即将召开！

2024年第九届亚太智能机器人系统国际会议即将召开！

2024年第九届亚太智能机器人系统国际会议 (ACIRS 2024) 将于2024年7月18-20日在中国大连举办&#xff0c;由大连理工大学主办&#xff0c;高性能精密制造全国重点实验室、辽宁黄海实验室和智能制造龙城实验联合承办。该会议旨在为智能机器人系统等领域的专家学者建立一个广泛有…
阅读更多...
实现顺序表（增、删、查、改）

实现顺序表（增、删、查、改）

引言&#xff1a;顺序表是数据结构中的一种形式&#xff0c;就是存储数据的一种结构。 这里会用到动态内存开辟&#xff0c;指针和结构体的知识 1.什么是数据结构 数据结构就是组织和存储数据的结构。 数据结构的特性&#xff1a; 物理结构&#xff1a;在内存中存储的数据是否连…
阅读更多...
k8s calico由IPIP模式切换为BGP模式

k8s calico由IPIP模式切换为BGP模式

按照官网calico.yaml部署后&#xff0c;默认是IPIP模式 查看route -n &#xff0c; 看到是tunl0口进行转发 怎么切换到BGP模式呢&#xff1f; kubectl edit ippool 将ipipMode由Always修改为Never &#xff0c;修改后保存文件即可。无需做任何操作&#xff0c;自动就切换为BG…
阅读更多...
picgo启动失败解决

picgo启动失败解决

文章目录 报错信息原因分析解决方案 报错信息 打开Picgo&#xff0c;显示报错 A JavaScript error occurred in the main process Uncaught Exception: Error:ENOENT:no such file or directory,open ‘C:\Users\koko\AppData\Roaming\picgo\data.json\picgo.log’ 原因分析…
阅读更多...
绝不忽视！List.add方法揭秘：你绝对需要了解的覆盖现象

绝不忽视！List.add方法揭秘：你绝对需要了解的覆盖现象

文章目录 引言一、背景介绍1.1 事件背景1.2 List.add()方法简介示例影响 二、覆盖现象解决方案1. 每次循环创建新对象2. 使用工厂方法或建造者模式3. 深拷贝4. 不可变对象 三、解决方案1. 使用深拷贝2. 创建新对象3. 避免直接修改原对象 四、 结论 引言 在 Java 编程中&#x…
阅读更多...
MyBatis的基本应用

MyBatis的基本应用

源码地址 01.MyBatis环境搭建 添加MyBatis的坐标 <!--mybatis坐标--><dependency><groupId>org.mybatis</groupId><artifactId>mybatis</artifactId><version>3.5.9</version></dependency><!--mysql驱动坐…
阅读更多...
VSCode调试C++

VSCode调试C++

1、环境准备 1.1、g的安装与使用 1.1.1、安装 方式一&#xff1a;Xcode安装 苹果的开发集成工具是Xcode.app&#xff0c;其中包含一堆命令行工具。 在 App store 可以看到其大小有好几个G&#xff0c;有点大。 方式二&#xff1a;Command Line Tools 安装 Command Line Too…
阅读更多...
OpenHarmony实战：小型系统器件驱动移植

OpenHarmony实战：小型系统器件驱动移植

本章节讲解如何移植各类器件驱动。 LCD驱动移植 移植LCD驱动的主要工作是编写一个驱动&#xff0c;在驱动中生成模型的实例&#xff0c;并完成注册。 这些LCD的驱动被放置在源码目录//drivers/hdf_core/framework/model/display/driver/panel中。 创建Panel驱动 创建HDF驱动…
阅读更多...
高级数据结构与算法习题（6）

高级数据结构与算法习题（6）

一、单选题 1、In the Tic-tac-toe game, a "goodness" function of a position is defined as f(P)=Wcomputer​−Whuman​ where W is the number of potential wins at position P. In the following figure, O represents the computer and X the human. What i…
阅读更多...
农业保险利用卫星遥感监测、理赔、农作物风险评估

农业保险利用卫星遥感监测、理赔、农作物风险评估

​农业保险一直是农民和农业生产者面临的重要课题&#xff0c;而卫星遥感技术的不断发展正为农业保险带来全新的解决方案。通过高分辨率的卫星遥感监测&#xff0c;农业保险得以更精准、及时地评估农田状况&#xff0c;为农业经营者提供可靠的风险管理手段。 **1. 灾害监测与风…
阅读更多...
2024年第三期丨全国高校大数据与人工智能师资研修班邀请函

2024年第三期丨全国高校大数据与人工智能师资研修班邀请函

2024年第三期 杭州线下班 数据采集与机器学习实战&#xff08;Python&#xff09; 线上班 八大专题 大模型技术与应用实战 数据采集与处理实战&#xff08;Python&八爪鱼&#xff09; 大数据分析与机器学习实战&#xff08;Python&#xff09; 商务数据分析实战&…
阅读更多...
29.使线程以固定顺序输出结果

29.使线程以固定顺序输出结果

借助wait和notify方法控制线程以固定的顺序执行&#xff1a; /*** 控制输出字符的顺序&#xff0c;必须是固定顺序2,1* 采用wait-notify实现* param args*/public static void main(String[] args) {new Thread(() -> {synchronized (lock) {while (!isPrint2) {try {lock.…
阅读更多...
【c++】STl-list使用list模拟实现

【c++】STl-list使用list模拟实现

主页&#xff1a;醋溜马桶圈-CSDN博客 专栏&#xff1a;c_醋溜马桶圈的博客-CSDN博客 gitee&#xff1a;mnxcc (mnxcc) - Gitee.com 目录 1. list的介绍及使用 1.1 list的介绍 1.2 list的使用 1.2.1 list的构造 1.2.2 list iterator的使用 1.2.3 list capacity 1.2.4 …
阅读更多...
最新文章

Copyright @ 2022~2023