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_OBJECTQ_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_OBJECTQ_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_OBJECTQ_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 _DEBUGctkPluginFrameworkLauncher::addSearchPath(path + "/CTKPlugins");
#elsectkPluginFrameworkLauncher::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 0QDirIterator 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;}}#elsetry{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为弱依赖没有找到也正常启动

四、类通信和信号槽区别

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

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

相关文章

提升工作效率：B端工作台设计基础详解

提升工作效率：B端工作台设计基础详解

随着互联网和信息技术的快速发展&#xff0c;越来越多的企业开始以数字化、智能化的方式管理和运营自己的业务。B端工作台设计作为企业应用的重要组成部分&#xff0c;越来越受到重视。本文将从三个方面对B端工作台设计进行全面分析。让我们看看。 1. B端工作台设计原则 B端工…
阅读更多...
Vulnhub：BROKEN: GALLERY

Vulnhub：BROKEN: GALLERY

目录 信息收集 1、arp 2、nmap 3、nikto 4、whatweb WEB wen信息收集 目录扫描 进制转换 ssh登录 提权 信息收集 1、arp ┌──(root㉿ru)-[~/kali/vulnhub] └─# arp-scan -l Interface: eth0, type: EN10MB, M…
阅读更多...
HTML——5.表单、框架、颜色

HTML——5.表单、框架、颜色

一、表单 HTML 表单用于在网页中收集用户输入的数据&#xff0c;例如登录信息、搜索查询等。HTML 提供了一系列的表单元素&#xff0c;允许用户输入文本、选择选项、提交数据等。 <!DOCTYPE html> <html lang"en"> <head> <meta charset&q…
阅读更多...
uniapp 开发之原生Android插件

uniapp 开发之原生Android插件

开发须知 在您阅读此文档时&#xff0c;我们假定您已经具备了相应Android应用开发经验&#xff0c;使用Android Studio开发过Android原生。也应该对HTML,JavaScript,CSS等有一定的了解, 并且熟悉在JavaScript和JAVA环境下的JSON格式数据操作等。 为了插件开发者更方便快捷的开…
阅读更多...
ElasticSearch实战之搜索项目，并高亮显示

ElasticSearch实战之搜索项目，并高亮显示

文章目录 一、前言二、基础速过1、索引操作2、文档操作3、查找操作 三、获取数据四、编写实体类五、将数据存入ES六、编写service七、编写controller层八、导入前端运行 一、前言 这几天学习了 Elasticsearch 的各种基本操作&#xff0c;为了加强对 Elasticsearch 的使用和理解…
阅读更多...
前端工程化理解 （2024 面试题）

前端工程化理解 （2024 面试题）

最好介绍远古世界最好随性一点&#xff0c;不要太刻板 &#xff0c;不然像背书 什么是前端工程化&#xff1f; - 知乎 前端工程化的历史 互联网初期&#xff0c;09 年以前&#xff0c;页面只需要展示一些列表、表格、文章内容以及简单图片即可&#xff0c;其目的是为了传送信…
阅读更多...
【LeetCode热题100】17. 电话号码的字母组合（回溯）

【LeetCode热题100】17. 电话号码的字母组合（回溯）

一.题目要求 给定一个仅包含数字 2-9 的字符串&#xff0c;返回所有它能表示的字母组合。答案可以按 任意顺序 返回。 给出数字到字母的映射如下&#xff08;与电话按键相同&#xff09;。注意 1 不对应任何字母。 二.题目难度 中等 三.输入样例 示例 1&#xff1a; 输入…
阅读更多...
EasyDarwin 、ffmpeg 音视频推流拉流；OBS视频推理软件、obs-rtspserver服务器；python读取rtsp流

EasyDarwin 、ffmpeg 音视频推流拉流；OBS视频推理软件、obs-rtspserver服务器；python读取rtsp流

参考&#xff1a;https://blog.csdn.net/N71FS1/article/details/130019563 一、EasyDarwin ffmpeg ffmpeg 推送音视频流到rtsp流服务器 EasyDarwin 作为rtsp流服务器 &#xff08;下载&#xff1a;https://www.easydarwin.org/p/easydarwin.html&#xff09;OBS 直播音视频录…
阅读更多...
QUndoCommand的使用

QUndoCommand的使用

目录 引言基本实现主要组成命令&#xff08;QUndoCommand&#xff09;命令栈&#xff08;QUndoStack&#xff09; 优化技巧组合命令合并命令 完整代码 引言 实现撤销重做&#xff08;Undo/Redo&#xff09;是编辑器的必备功能&#xff0c;诸如文本编辑器、电子表格、图像编辑器…
阅读更多...
2023年移动游戏逆势增长，原来消息推送是这么玩的！

2023年移动游戏逆势增长，原来消息推送是这么玩的！

Unity公布了2024游戏报告&#xff0c;2023年全球移动游戏DAU中位数对比前两年再度提升&#xff0c;证明了移动游戏仍在增长&#xff1b;全球移动玩家的首日留存率和7日留存率中位数分别下滑1%和0.1%。这两条意味着虽然游戏玩家在增多&#xff0c;但是怎么让他们始终保持兴趣在变…
阅读更多...
电脑内存不够用了怎么办？！如何给电脑加速？

电脑内存不够用了怎么办？！如何给电脑加速？

大家好呀&#xff0c;在教大家如何给系统清理增加内存空间之前&#xff0c;我们要理清两个概念&#xff1a;系统的内存和储存是两个不同的硬件&#xff0c;用英文说&#xff0c;内存是RAM、储存是ROM&#xff1b;分别对应着内存条和机械硬盘或固态硬盘这两种硬件设备。 我们可以…
阅读更多...
怎么倒放视频教程？3个简单易行方法分享

怎么倒放视频教程？3个简单易行方法分享

怎么倒放视频教程&#xff1f;视频倒放是一种创意性的视频编辑方式&#xff0c;通过倒序播放视频内容&#xff0c;可以为观众带来全新的视觉体验。无论是为了制作搞笑视频&#xff0c;还是为了创作具有艺术感的短片&#xff0c;倒放视频都是一个非常实用的技巧。同时&#xff0…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023