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

news/2024/4/30 10:22:40

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为弱依赖没有找到也正常启动

四、类通信和信号槽区别

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

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

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

相关文章

nodeJs 实现视频的转换(超详细教程)

nodeJs 实现视频的转换(超详细教程)

前段时间拿到一个视频是4k的&#xff0c;没法播放&#xff0c;于是通过 node.js 和 ffmpeg 实现了视频的转换。在win10 系统下实现。 所需工具 node 16.19 直接安装 ffmpeg-5.1.1-essentials_build 解压后重名 ffmpeg 放到C盘 然后配置下环境变量 Git-2.42.0.2-64-bit 直接…
阅读更多...
Databend 开源周报第 138 期

Databend 开源周报第 138 期

Databend 是一款现代云数仓。专为弹性和高效设计&#xff0c;为您的大规模分析需求保驾护航。自由且开源。即刻体验云服务&#xff1a;https://app.databend.cn 。 Whats On In Databend 探索 Databend 本周新进展&#xff0c;遇到更贴近你心意的 Databend 。 支持多表插入 …
阅读更多...
Kafka架构概述

Kafka架构概述

Kafka的体系结构 Kafka是由Apache软件基金会管理的一个开源的分布式数据流处理平台。Kafka具有支持消息的发布/订阅模式、高吞吐量与低延迟、持久化、支持水平扩展、高可用性等特点。可以将Kafka应用于大数据实时处理、高性能数据管道、流分析、数据集成和关键任务应用等场景。…
阅读更多...
触想四代ARM架构工业一体机助力手功能康复机器人应用

触想四代ARM架构工业一体机助力手功能康复机器人应用

一、行业发展背景 手功能康复机器人是医疗机器人的一个分支&#xff0c;设计用于帮助肢体障碍患者进行手部运动和力量训练&#xff0c;在医疗健康领域有着巨大的成长空间。 手功能康复机器人融合了传感、控制、计算、AI视觉等智能科技与医学技术&#xff0c;能够帮助患者改善康…
阅读更多...
面试算法-140-接雨水

面试算法-140-接雨水

题目 给定 n 个非负整数表示每个宽度为 1 的柱子的高度图&#xff0c;计算按此排列的柱子&#xff0c;下雨之后能接多少雨水。 示例 1&#xff1a; 输入&#xff1a;height [0,1,0,2,1,0,1,3,2,1,2,1] 输出&#xff1a;6 解释&#xff1a;上面是由数组 [0,1,0,2,1,0,1,3,2…
阅读更多...
OpenHarmony实战：Combo解决方案之ASR芯片移植案例

OpenHarmony实战：Combo解决方案之ASR芯片移植案例

本方案基于 OpenHarmony LiteOS-M 内核&#xff0c;使用 ASR582X 芯片的 DEV.WIFI.A 开发板进行开发移植。作为典型的 IOT Combo&#xff08;Wi-FiBLE&#xff09;解决方案&#xff0c;本文章介绍 ASR582X 的适配过程。 编译移植 目录规划 本方案的目录结构使用 Board 和 So…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023

友情链接： 我的编程经验分享 一条长河网 尧图网站开发 尧图建网站 广利置业