PF4J+SpringBoot

plugin-common

pom.xml相关配置

<groupId>pub.qingyun</groupId>
<artifactId>plugin-common</artifactId>
<version>0.0.1-SNAPSHOT</version>
<description>插件配置类</description><dependency><groupId>org.pf4j</groupId><artifactId>pf4j</artifactId><version>3.12.0</version>
</dependency><!--插件打包时使用的Maven插件,插件ID:Plugin-Id,使用mvn clean package 打出*jar-with-dependencies.jar的插件包-->
<build><plugins><plugin><groupId>org.apache.maven.plugins</groupId><artifactId>maven-assembly-plugin</artifactId><configuration><archive><manifest><addClasspath>true</addClasspath></manifest><manifestEntries><Plugin-Id>common-impl</Plugin-Id><Plugin-Version>0.0.1</Plugin-Version></manifestEntries></archive><descriptorRefs><descriptorRef>jar-with-dependencies</descriptorRef></descriptorRefs></configuration><executions><execution><id>make-assembly</id><phase>package</phase><goals><goal>single</goal></goals></execution></executions></plugin></plugins>
</build>

插件服务接口

pub.qingyun.service.IExtensionHandler

public interface IExtensionHandler extends Runnable, ExtensionPoint {String execute(String param);
}

实现类

import org.pf4j.Extension;
import pub.qingyun.service.IExtensionHandler;@Extension
public class TestExtensionHandler implements IExtensionHandler {@Overridepublic void run() {System.out.println("TestExtensionHandler run...");}@Overridepublic String execute(String param) {System.out.println("TestExtensionHandler.execute...param=" + param);return param;}
}

plugin-spring-boot

pom.xml相关配置

<groupId>pub.qingyun</groupId>
<artifactId>plugin-spring-boot</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>plugin-spring-boot</name>
<description>plugin-spring-boot</description><properties><java.version>1.8</java.version><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding><spring-boot.version>2.6.13</spring-boot.version>
</properties>
<dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>pub.qingyun</groupId><artifactId>plugin-common</artifactId><version>1.0-SNAPSHOT</version></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><optional>true</optional></dependency>...
</dependencies>
<dependencyManagement><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-dependencies</artifactId><version>${spring-boot.version}</version><type>pom</type><scope>import</scope></dependency></dependencies>
</dependencyManagement>

spring-boot

@Configuration
public class PluginConfig {// 插件目录,对应插件jar包/zip@Value("${pf4j.pluginPath}")private String pf4jPluginPath;@Beanpublic PluginManager initPluginManager() {Path pluginPath = Paths.get(pf4jPluginPath);PluginManager pluginManager = new JarPluginManager(pluginPath);//加载所有插件pluginManager.loadPlugins();//开启所有插件pluginManager.startPlugins();//启动指定插件
//        pluginManager.startPlugin("demo-plugin");//卸载插件
//        pluginManager.unloadPlugin("demo-plugin");return pluginManager;}
}

控制层实现

package pub.qingyun.controller;import lombok.extern.slf4j.Slf4j;
import org.pf4j.PluginManager;
import org.pf4j.PluginState;
import org.pf4j.PluginWrapper;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import pub.qingyun.service.impl.TestExtensionHandler;import javax.annotation.Resource;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;/*** @author CQY* @version 1.0* @date 2024/7/17 14:19**/
@Slf4j
@RestController
public class PluginController {@Resourceprivate PluginManager pluginManager;/*** 打印所有插件信息** @return List<Map < String, Object>>*/@GetMapping(value = "/printAllPlugin")public ResponseEntity<List<Map<String, Object>>> printAllPlugin() {List<PluginWrapper> plugins = pluginManager.getPlugins();List<Map<String, Object>> collect = plugins.stream().map((item) -> {Map<String, Object> map = new HashMap<>();map.put("pluginId", item.getPluginId());map.put("pluginDescription", item.getDescriptor());map.put("pluginPath", item.getPluginPath());map.put("pluginState", item.getPluginState());map.put("pluginClassLoader", item.getPluginClassLoader());return map;}).collect(Collectors.toList());return ResponseEntity.ok(collect);}/*** 启动插件** @param pluginId 插件id* @return PluginState*/@GetMapping(value = "/startPluginById")public ResponseEntity<String> startPluginById(String pluginId) {PluginState pluginState = pluginManager.startPlugin(pluginId);return ResponseEntity.ok(pluginState.toString());}/*** 停止插件** @param pluginId 插件id* @return PluginState*/@GetMapping(value = "/stopPluginById")public ResponseEntity<String> stopPluginById(String pluginId) {PluginState pluginState = pluginManager.stopPlugin(pluginId);return ResponseEntity.ok(pluginState.toString());}/*** 禁用插件** @param pluginId 插件id* @return boolean true表示成功*/@GetMapping(value = "/disablePluginById")public ResponseEntity<Boolean> disablePluginById(String pluginId) {boolean result = pluginManager.disablePlugin(pluginId);return ResponseEntity.ok(result);}/*** 启用插件** @param pluginId 插件id* @return boolean true表示成功*/@GetMapping(value = "/enablePluginById")public ResponseEntity<Boolean> enablePluginById(String pluginId) {boolean result = pluginManager.enablePlugin(pluginId);return ResponseEntity.ok(result);}/*** 卸载插件** @param pluginId 插件id* @return boolean true表示成功*/@GetMapping(value = "/unloadPluginById")public ResponseEntity<Boolean> unloadPluginById(String pluginId) {boolean result = pluginManager.unloadPlugin(pluginId);return ResponseEntity.ok(result);}/*** 加载插件** @return String*/@GetMapping(value = "/loadPlugins")public ResponseEntity<String> loadPlugins() {pluginManager.loadPlugins();//开启所有插件pluginManager.startPlugins();return ResponseEntity.ok("SUCCESS");}/*** 执行插件中的扩展点** @param pluginId 插件id* @return String 执行结果*/@GetMapping(value = "/executePluginExtensionHandlerById")public ResponseEntity<String> executePluginExtensionHandlerById(String pluginId) {List<Class<?>> extensionClasses = pluginManager.getExtensionClasses(pluginId);for (Class<?> extensionClass : extensionClasses) {if (extensionClass.getName().equals("pub.qingyun.service.impl.TestExtensionHandler")) {try {Class<?> clz = Class.forName("pub.qingyun.service.impl.TestExtensionHandler", true, Thread.currentThread().getContextClassLoader());TestExtensionHandler extensionHandler = (TestExtensionHandler) clz.newInstance();String execute = extensionHandler.execute("hello");extensionHandler.run();} catch (InstantiationException | IllegalAccessException | ClassNotFoundException e) {throw new RuntimeException(e);}}}return ResponseEntity.ok("SUCCESS");}
}

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

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

相关文章

TCP与UDP网络编程

TCP与UDP网络编程

网络通信协议 java.net 包中提供了两种常见的网络协议的支持: UDP&#xff1a;用户数据报协议(User Datagram Protocol)TCP&#xff1a;传输控制协议(Transmission Control Protocol) TCP协议与UDP协议 TCP协议 TCP协议进行通信的两个应用进程&#xff1a;客户端、服务端 …
阅读更多...
好玩的调度技术-场景编辑器

好玩的调度技术-场景编辑器

好玩的调度技术-场景编辑器 文章目录 好玩的调度技术-场景编辑器前言一、演示一、代码总结好玩系列 前言 这两天写前端写上瘾了&#xff0c;顺手做了个好玩的东西&#xff0c;好玩系列也好久没更新&#xff0c;正好作为素材写一篇文章&#xff0c;我真的觉得蛮好玩的&#xff…
阅读更多...
编程中的智慧之设计模式一

编程中的智慧之设计模式一

设计模式&#xff1a;编程中的智慧之道 设计模式是软件开发中的一种解决方案&#xff0c;提供了在特定上下文中解决常见问题的模板。这些模式帮助我们构建更加灵活、可维护和可扩展的系统。本文将探讨设计模式的不同类型及其在Java中的应用。 设计模式的层次 设计模式可以类…
阅读更多...
【C#】Array和List

【C#】Array和List

C#中的List<T>和数组&#xff08;T[]&#xff09;在某些方面是相似的&#xff0c;因为它们都是用来存储一系列元素的集合。然而&#xff0c;它们在功能和使用上有一些重要的区别&#xff1a; 数组&#xff08;Array&#xff09; 固定大小&#xff1a;数组的大小在声明时…
阅读更多...
LinuxShell编程1———shell基础命令

LinuxShell编程1———shell基础命令

文章目录 前言 一、shell基础知识 1、shell概念 2、Shell的功能 接收&#xff1a;用户命令 调用&#xff1a;相应的应用程序 解释并交给&#xff1a;内核去处理 返还&#xff1a;内核处理结果 3、Shell种类&#xff08;了解&#xff09; 3.1、MS-DOS 3.2、Windows的…
阅读更多...
数据的守护者：深入解析 Elasticsearch 的副本机制

数据的守护者：深入解析 Elasticsearch 的副本机制

标题&#xff1a;数据的守护者&#xff1a;深入解析 Elasticsearch 的副本机制 在分布式搜索引擎 Elasticsearch 中&#xff0c;副本是确保数据高可用性和查询性能的关键特性。通过副本机制&#xff0c;Elasticsearch 能够在集群中复制数据&#xff0c;从而提高数据的可靠性和…
阅读更多...
高并发服务器-使用多进程（Multi-Process）实现【C语言】

高并发服务器-使用多进程（Multi-Process）实现【C语言】

在上期的socket套接字的使用详解中&#xff08;socket套接字的使用详解&#xff09;最后实现的TCP服务器只能处理一个客户端的请求发送&#xff0c;当有其他客户端请求连接时会被阻塞。为了能同时处理多个客户端的连接请求&#xff0c;本期使用多进程的方式来解决。 解决方案步…
阅读更多...
SDF学习笔记整理

SDF学习笔记整理

1 SDF的用处 SDF文件是标准延时文件&#xff0c;该文件由于其扩展名为.sdf即filename.sdf故被常叫做SDF文件。该文件是综合吐出的文件&#xff0c;也可以来自于静态时序分析&#xff08;STA&#xff09;&#xff0c;前者称为pre_sdf文件&#xff0c;后者称为post_sdf。 两者主…
阅读更多...
R语言进行K折交叉验证问题

R语言进行K折交叉验证问题

在使用R语言进行模型参数评估优化时候&#xff0c;会使用K折交叉验证&#xff0c;其中会遇到各种各样问题&#xff1a; 错误: C5.0 models require a factor outcome > (1-mean(E0));(1-mean(E1)) [1] 1 [1] 1 报错说明C5.0模型需要因子变量输出&#xff0c;源代码如下&am…
阅读更多...
无人机技术优势及发展详解

无人机技术优势及发展详解

一、技术优势 无人机&#xff08;Unmanned Aerial Vehicle&#xff0c;UAV&#xff09;作为一种新兴的空中智能平台&#xff0c;凭借其独特的技术优势&#xff0c;已经在众多领域中展现出强大的应用潜力和实用价值。以下是无人机的主要技术优势&#xff1a; 1. 自主导航与远程…
阅读更多...
Java 程序员面试笔记 - 数据库

Java 程序员面试笔记 - 数据库

12.1 SQL DML&#xff1a;插入数据、修改数据和删除数据。 DDL&#xff1a;数据定义语句&#xff0c;可以对数据库用户、基本表、视图等进行定义和撤销。 DCL&#xff1a;用于对数据库进行统一的控制管理。 12.2 内连接与外连接 内链接&#xff1a;两个表匹配的数据才出现…
阅读更多...
【Harmony】SCU暑期实训鸿蒙开发学习日记Day2

【Harmony】SCU暑期实训鸿蒙开发学习日记Day2

目录 Git 参考文章 常用操作 ArkTS的网络编程 Http编程 发送请求 GET POST 处理响应 JSON数据解析 处理响应头 错误处理 Web组件 用生命周期钩子实现登录验证功能 思路 代码示例 解读 纯记录学习日记&#xff0c;杂乱&#xff0c;误点的师傅可以掉了&#x1…
阅读更多...
How to integrate GPT-4 model hosted on Azure with the gptstudio package

How to integrate GPT-4 model hosted on Azure with the gptstudio package

题意&#xff1a;怎样将托管在Azure上的GPT-4模型与gptstudio包集成&#xff1f; 问题背景&#xff1a; I am looking to integrate the OpenAI GPT-4 model into my application. Here are the details I have: Endpoint: https://xxxxxxxxxxxxxxx.openai.azure.com/Locatio…
阅读更多...
【前端】SpringBootWeb 篇-入门了解 Spring Cache、Spring Task与WebSocket 框架

【前端】SpringBootWeb 篇-入门了解 Spring Cache、Spring Task与WebSocket 框架

在SpringBootWeb开发中&#xff0c;Spring Cache、Spring Task与WebSocket框架是三个非常重要的组件&#xff0c;它们分别用于缓存管理、任务调度和实时通信。以下是对这三个框架的入门了解&#xff1a; 一、Spring Cache 1. 简介 Spring Cache是Spring框架提供的缓存抽象&a…
阅读更多...
LG 选择 Flutter 来增强其智能电视操作系统 webOS

LG 选择 Flutter 来增强其智能电视操作系统 webOS

可以这个话题会让大多数人困惑&#xff0c;2024 年了为什么还会冒出 webOS 这种老古董&#xff1f;然后 LG 为什么选择 webOS &#xff1f;现在为什么又选择 Flutter &#xff1f; 其实早在 Google I/O 发布 Flutter 3.22 版本的时候&#xff0c;就提到了 LG 选择 Flutter 来增…
阅读更多...
tinymce富文本支持word内容同时粘贴文字图片上传 vue2

tinymce富文本支持word内容同时粘贴文字图片上传 vue2

效果图 先放文件 文件自取tinymce: tinymce富文本简单配置及word内容粘贴图片上传 封装tinymce 文件自取&#xff1a;tinymce: tinymce富文本简单配置及word内容粘贴图片上传 页面引用组件 <TinymceSimplify refTinymceSimplify v-model"knowledgeBlockItem.content…
阅读更多...
Socket、WebSocket 和 MQTT 的区别

Socket、WebSocket 和 MQTT 的区别

Socket 协议 定义&#xff1a;操作系统提供的网络通信接口&#xff0c;抽象了TCP/IP协议&#xff0c;支持TCP和UDP。特点&#xff1a; 通用性&#xff1a;不限于Web应用&#xff0c;适用于各种网络通信。协议级别&#xff1a;直接使用TCP/UDP&#xff0c;需要手动管理连接和数…
阅读更多...
vue3 项目的创建、组合式API、rective和ref、watch函数

vue3 项目的创建、组合式API、rective和ref、watch函数

vue3项目的创建&#xff1a; npm init vuelatest 在执行上述代码以后&#xff0c;按需勾选项目所需的东西就可以 然后再命令行依次执行&#xff1a; // 进入项目 cd vuedemo //安装下来对应的包 npm install //启动项目 npm run dev文件解读&#xff1a; package.json &am…
阅读更多...
【leetcode】 字符串相乘（大数相乘、相加）

【leetcode】 字符串相乘（大数相乘、相加）

记录一下大数相乘相加方法&#xff1a; 给定两个以字符串形式表示的非负整数 num1 和 num2&#xff0c;返回 num1 和 num2 的乘积&#xff0c;它们的乘积也表示为字符串形式。 注意&#xff1a;不能使用任何内置的 BigInteger 库或直接将输入转换为整数。 示例 1: 输入: nu…
阅读更多...
vue3前端开发-执行npm run dev提示报错怎么解决

vue3前端开发-执行npm run dev提示报错怎么解决

vue3前端开发-执行npm run dev提示报错怎么解决&#xff01;今天在本地安装初始化了一个vue3的案例demo。但是当我执行npm run dev想启动它时报错了说&#xff0c;找不到dev。让我检查package.json文件是否包含dev。如下图所示&#xff1a; 实际上&#xff0c;不必惊慌&#xf…
阅读更多...
最新文章

Copyright @ 2022~2023