（三）Openfire插件开发

2024-06-11 02:18

文章标签 开发 openfire 插件

本文主要是介绍（三）Openfire插件开发，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

此部分是Openfire的第三大部分，本部分的开发必须基于前两部分

本文档基于消息拦截器插件功能进行开发。

新建插件messageFilter：

在openfire插件源码的plugins目录下新建文件夹messageFilter
messageFilter文件夹下新建lib和src文件夹。lib包下放jar包，src文件夹下放要开发的插件源码。
将changelog.html、logo_large.gif、logo_small.gif、plugin.xml、pom.xml、readme.html在其他的插件中复制到messageFilter目录下
src文件夹下新建文件夹java并右键选择Mark Directory as-→Sources root
java目录下新建Package com.weishuai
com.weishuai下新建类MessageFilter并实现Plugin和PacketInterceptor接口
修改plugin.xml,主要是class标签的内容为插件类的权限定名。如下图：

此时我们的插件结构如下图所示

代码如下：

fromid为发信息的id，可以通过断点的而形式在packet的message标签中from属性获取，同理获得toid

public class DemoPlugin implements Plugin, PacketInterceptor {//B: 消息拦截器private InterceptorManager interceptorManager;@Overridepublic void initializePlugin(PluginManager manager, File pluginDirectory) {// 将当前插件加入到消息拦截管理器（interceptorManager ）中，当消息到来或者发送出去的时候，会触发本插件的interceptPacket方法。interceptorManager = InterceptorManager.getInstance();interceptorManager.addInterceptor(this);}@Overridepublic void destroyPlugin() {// 当插件被卸载的时候，主要通过openfire管理控制台卸载插件时，被调用。注意interceptorManager的addInterceptor和removeInterceptor需要成对调用。interceptorManager.removeInterceptor(this);}@Overridepublic void interceptPacket(Packet packet, Session session, boolean incoming, boolean processed) throws PacketRejectedException {//入参incoming来判断是服务器发送的包还是接受的包（注：true为服务器接收的包；false为发出的包）;// processed为false，表示本条消息没有被openfire处理过。这说明这是一条处女消息，也就是没有被处理过的消息。String strXML = packet.toXML();Document doc = null;try {doc = DocumentHelper.parseText(strXML);} catch (DocumentException e) {e.printStackTrace();}//1.1读取根标签Element rootElem = doc.getRootElement();//1.2获取标签的名称String rootName = rootElem.getName();
//        Element conElem = rootElem.element("contact");// 1.1 在标签上获取属性（根据属性的名称来获取属性值）String fromid = rootElem.attributeValue("from");String toid = rootElem.attributeValue("to");if (incoming && !processed) {if (packet instanceof Message) {if (fromid.equals("test@desktop-r4sp4pf/Spark")) {PacketRejectedException rejectedException = new PacketRejectedException();
//                        rejectedException.setRejectionMessage("the friend already in black.");throw rejectedException;}}}}
}