openfire spark 二次 开发 服务插件

====================  废话 begin   ============================

最近老大让我为研发平台增加即时通讯功能。告诉我用comet 在web端实现即时通讯。

最初狂搜集资料。不能让自己方向错了。这是很重要的。

不过还是难免的周折了一番。测试了一个comet4j的聊天小例子。用它前后端开发成本太大、对服务器也太大压力放弃了。

最终决定使用openfire +jsjac.js + JabberHTTPBind 然后实现老大要求的 web 及时通讯功能。

很庆幸找到了 hoojo大哥的demo 很不幸，他为了让大家复制代码，自己练习。不提供jar包js下载。（虽然好心但是足足浪费了我两天时间）一个jsjac.js库版本有问题。很费劲的看源码。哎。

然后、拿这个小demo 先交差。顺便展示了 spark  和 web聊天窗口，交互即时聊天。

顺便构想了一下，修改openfire用户表。让用户来自系统。组织则用自带的。（当然这是预想。其实openfire已经帮我们想过了。）

接着、全局搜索了openfire源码中包含ofuser表sql的类。只有两个类。很庆幸。改了之后,改造用户密码加密认证方式。

当然这样做是错误的。直到我发现类名字似乎有些不对的时候。DefaultUserProvider  哈哈、嘲讽啊。 不出所料有一个实现类JDBCUuserProvider 。直接配置就可以搞定、但是加密sha256加密过程和我平台不一样。改造后就顺利搞定。

接着、到了插件开发过程。这个过程很烦人。网上很多帖子很多人去讲这个开发过程。或许是两三年前的贴了。很多过时了。只能有一点帮助。更多的是走向了错误的道路。磕磕碰碰。最终还是只能从源码中寻求出路。

这个过程整整浪费了我两星期时间。很痛苦。所以。我会针对最新代码聊聊，spark 开发一个组织架构树插件。展示出用户。并可以与之聊天。打包openfire，spark插件过程。打包项目为exe文件。等

=======================  废话 end  =========================

openfire10，出来啦。^_^  支持自定义组，性能优化很多。

本文内容有：

　　1、openfire自定义用户表 需要注意的地方

　　2、openfire服务器插件开发 （开发环境搭建不说了。下载项目，目前3.10，3.93都没有任何错）

　　3、openfire插件打包。

　　3、spark插件开发

　　4、openfire/spark 打包exe

　　

一、Openfire自定义用户表

userManager 会在初始化的时候从数据库读取UserProvider/AuthProvider的实现类。默认是defaultUserProvider

这些实现类参数被保存在ofproperty 表中。我们直接通过更新表完成对自定义用户表的配置。

insert  into ofProperty(name,propValue)values
(‘jdbcProvider.driver‘,‘com.mysql.jdbc.Driver‘),
(‘jdbcProvider.connectionString‘,‘jdbc:mysql://主机地址/数据库?user=root&password=root‘),
 --用户表数据库连接信息
(‘admin.authorizedJIDs‘,‘[email protected]‘),
--管理员账号信息，@amy-tang是安装openfire服务器时填写的IP，也可以写成服务器的域名。(‘jdbcAuthProvider.passwordSQL‘,‘SELECT password FROM sys_user WHERE account=?‘),
-- 校验用户名密码sql语句
(‘jdbcAuthProvider.passwordType‘,‘sha256‘),-- 用户表加密方式
(‘jdbcUserProvider.loadUserSQL‘,‘SELECT fullname, email FROM sys_user WHERE account=?‘),
-- 查询用户的sql语句
(‘jdbcUserProvider.userCountSQL‘,‘SELECT COUNT(*) FROM sys_user‘),
(‘jdbcUserProvider.allUsersSQL‘,‘SELECT account FROM sys_user‘),
(‘jdbcUserProvider.usernameField‘,‘account‘),
(‘jdbcUserProvider.nameField‘,‘fullname‘),
(‘jdbcUserProvider.emailField‘,‘Email‘),
--用户表关键字段的字段名称。模糊查询用户拼装sql使用.account是账号唯一标示，fullname是用户名。sys_user是用户表

UPDATE ofProperty SET propValue=‘org.jivesoftware.openfire.user.JDBCUserProvider‘ WHERE name=‘provider.user.className‘ ;
--设置用户数据库持久层实现类
UPDATE ofProperty SET propValue=‘org.jivesoftware.openfire.auth.JDBCAuthProvider‘ WHERE name=‘provider.auth.className‘
--设置密码校验持久层实现类

注意事项：1、加密key  ：plain/md5/sha1/sha256/sha512  加密过程详见org.jivesoftware.util.StringUtils.hash(password, "MD5");

　　　　　2、admin.authorizedJIDs   = [email protected]主机地址    当Openfire修改了主机地址/域名的配置后admin无法登陆服务器。需要修改数据库中配置的主机地址，

二、Openfire服务器插件开发

1、openfire中插件目录介绍，以及开发前准备。

Openfire源码环境搭建很简单。目前3.10版，3.9版都没有任何问题直接能用，不用多余下载任何jar。将源码解压至工作空间，新建相同项目名称即可。如图：

暂时没用的插件可以  build path remove from path先从工作空间移除。剩下需要的开发插件如上图右

10 的source output folder 有点问题，指向了一个插件里面。修改即可。

项目右键—》build path—》configure build path..—》 Source—》output folder： openfire_src/bin

9问题也不多，网上很多文章都很有用可以检索 openfire二次开发去查阅相关搭建开发环境的文章。

开发前，建议先吧xmldebugger 插件打开，或者留在src 中。会把所有交互xml打印输出非常有利于调试。

开发插件前，我们可以先看下，自带的那些插件的目录结构。

可以看出来开发插件都是依赖项目开发的，这样直接可以引用项目中的资源，bean。不建议单独起一个project去开发插件

2、插件开发介绍

例如组织架构插件，我是将它作为一个服务组件进行开发，对外提供组织树的服务。当客户端访问服务器 jabber:iq:loadOrg 的服务的时候，根据提供的参数返回组织架构，与用户信息、

该插件需要实现两个接口 Component, Plugin。 贴下代码

package com.hotent.openfire.plugin;

import java.io.File;
import java.util.List;
import java.util.Map;

import net.sf.json.JSONArray;

import org.dom4j.DocumentHelper;
import org.dom4j.Element;
import org.dom4j.QName;
import org.jivesoftware.openfire.XMPPServer;
import org.jivesoftware.openfire.auth.DefaultAuthProvider;
import org.jivesoftware.openfire.container.Plugin;
import org.jivesoftware.openfire.container.PluginManager;
import org.jivesoftware.openfire.user.UserManager;
import org.jivesoftware.util.PropertyEventDispatcher;
import org.jivesoftware.util.PropertyEventListener;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.xmpp.component.Component;
import org.xmpp.component.ComponentException;
import org.xmpp.component.ComponentManager;
import org.xmpp.component.ComponentManagerFactory;
import org.xmpp.packet.IQ;
import org.xmpp.packet.JID;
import org.xmpp.packet.Packet;

public class OrgTreePlugin implements Component, Plugin {
    private static final Logger Log = LoggerFactory.getLogger(OrgTreePlugin.class);

    public static final String NAMESPACE_JABBER_IQ_SEARCH = "jabber:iq:loadOrg";
    public static final String SERVICENAME = "plugin.loadOrg.serviceName";

    private UserManager userManager;
    private PluginManager pluginManager;
    private ComponentManager componentManager;
    private String serviceName = "loadOrg";
    private String serverName ;
    private OrgTreeProvider orgTreeProvider;

     // 插件初始化的时候，注入bean。
    public OrgTreePlugin(){
        userManager = UserManager.getInstance();
        serverName = XMPPServer.getInstance().getServerInfo().getXMPPDomain();
        orgTreeProvider = DefaultOrgTreeProvider.getInstance();
    }

    public String getName() {
        return pluginManager.getName(this);
    }

    public String getDescription() {
        return pluginManager.getDescription(this);
    }
    // 初始化插件调用的方法。此时注册插件服务。
    @Override
    public void initializePlugin(PluginManager manager, File pluginDirectory) {
        pluginManager = manager;
        componentManager = ComponentManagerFactory.getComponentManager();
        try {
            //注册服务。
            componentManager.addComponent(serviceName, this);
        } catch (ComponentException e) {
            Log.error("===================OrgTree 注册服务失败！！=====================================");
            throw new RuntimeException("OrgTree 注册服务失败！！",e);
        }
        Log.info("===================OrgTree 注册服务成功！！=====================================");

    }

    public void initialize(JID jid, ComponentManager componentManager) {
    }

    public void start() {
    }

    public void destroyPlugin() {
        pluginManager = null;
        try {
            componentManager.removeComponent(serviceName);
            componentManager = null;
        } catch (Exception e) {

        }
        serviceName = null;
        userManager = null;
    }

    @Override
    public void shutdown() {
    }
    // 当客户端请求该服务时，访问该方法，接下来处理消息包
    //第一次访问注册服务时候， 也会测试性质的访问该服务。如果出现异常，将从服务列表移除
    //
    @Override
    public void processPacket(Packet p) {
        if (!(p instanceof IQ)) {
            return;
        }
        final IQ packet = (IQ) p;

        if (packet.getType().equals(IQ.Type.error) || packet.getType().equals(IQ.Type.result)) {
            return;
        }
        //将消息包处理，并将结果数据，返回给请求者。
        final IQ replyPacket = reply(packet);

        try {
            componentManager.sendPacket(this, replyPacket);
        } catch (ComponentException e) {
        }

    }
    /***
     * 处理消息包，转成回执包
     * @param packet
     * @return
     */
    private IQ reply(IQ packet) {
        /*if (!packet.getType().equals(IQ.Type.get)) {
            throw new IllegalArgumentException("This method only accepts ‘get‘ typed IQ stanzas as an argument.");
        }*/
        String orgId ="";
        final Element element = packet.getChildElement();
        if(element != null){
            Element e = element.element("orgId");
            if(e!= null)orgId = e.attribute("id").getText();
        }

        String authId = packet.getFrom().toString();
        if(authId .contains("@"))
        authId = authId.substring(0, authId.indexOf("@"));

        IQ replyPacket = IQ.createResultIQ(packet);

        Element queryResult = DocumentHelper.createElement(QName.get("query", NAMESPACE_JABBER_IQ_SEARCH));
        //去数据库获取数据
        List<OrgTreeNode> orgTreeList = orgTreeProvider.LoadOrgChildOrgUser(orgId, authId);
        //orgTreeList.remove(orgTreeList.size()-1);
        JSONArray json = JSONArray.fromObject(orgTreeList);

        queryResult.addElement("orgTreeList").addText(json.toString());
        replyPacket.setChildElement(queryResult);

        return replyPacket;
    }

}

OrgTreePlugin 代码，

请看打开代码自己查看。该插件需要实现两个接口Component, Plugin，并实现相应方法。

插件的初始在PluginManager中419 行。 可以断点查看插件初始化过程。

419                String className = pluginXML.selectSingleNode("/plugin/class").getText().trim();
420                plugin = (Plugin)pluginLoader.loadClass(className).newInstance();

服务注册也很简单 如：OrgTreePlugin 代码initializePlugin 方法。

componentManager.addComponent(serviceName, this);

只是需要注意的是，该服务注册为服务组件的时候，会测试的访问该服务，测试是否正常。

如果出现异常就会自动 调用componentManager.removeComponent(serviceName);，将改服务移除服务组件。

具体代码可以查看InternalComponentManager 的addComponent()方法。代码很简单。

DefaultOrgTreeProvider则为数据访问层。不再贴了。

插件目录结构如下：

3、插件打包

最初在看openfire插件开发相关文章的时候、都提供了很多打包的方法，不过用着很不开心。

其实项目已经提供了所有各个功能的ant脚本build目录下 build.xml文件。

三、spark插件开发


spark插件开发与openfire大略相似，

需要自身了解 AWT相关的知识。

打包插件需要注意一点在 build.xml 中 target name="build.plugins" 添加自己插件。这样运行  ant  build.plugins 的时候就可以打包自己的jar 了

build.plugins

    <subant target="">
            <fileset dir="./src/plugins/orgTree/" includes="*/build.xml" />
        </subant>

获取请求服务，处理数据关键代码

//请求消息 定义
public class OrgTreeLoad extends IQ

 private JSONArray getOrgTreeJSON(String orgId) throws XMPPException {
        //获取host
        Connection con = SparkManager.getConnection();
        host = con.getHost();

        OrgTreeLoad search = new OrgTreeLoad();
        search.setType(org.jivesoftware.smack.packet.IQ.Type.SET);
        search.setTo("loadOrg."+host); //消息包处理
        search.addExtension(OrgTreePacketExtension.getNewPacketExtension(orgId));
        PacketCollector collector = con.createPacketCollector(new PacketIDFilter(search.getPacketID()));
        con.sendPacket(search);

        IQ response = (IQ)collector.nextResult(SmackConfiguration.getPacketReplyTimeout());
        collector.cancel();
        //请求超时
        if(response == null)
            throw new XMPPException("No response from server on status set.");
        //出错
        if(response.getError() != null)
            return  null;//
        else{　　　　　　　//response 也是类似IQ的消息包，xml格式，获取返回的数据，并处理。
            String xml = response.getChildElementXML();
            if(xml ==null) return null;
            try {
                Document d = DocumentHelper.parseText(xml);
                if(d!= null) xml =d.getRootElement().getText();
            } catch (DocumentException e) {
                e.printStackTrace();
            }
            //
            return JSONArray.fromObject(xml);
        }
    }

打开一个聊天窗口，发起聊天

   private void openChatRoom(String authId,String name,String orgName) {
        ChatManager chatManager = SparkManager.getChatManager();
        ChatRoom chatRoom = chatManager.createChatRoom(authId+"@"+host, orgName+" :"+name,name);

        ChatContainer chatRooms = chatManager.getChatContainer();
        chatRooms.activateChatRoom(chatRoom);
    }

spark 自己顺着登陆代码，跟进去、慢慢看。看如何加载所有面板，加载用户信息，好友信息。搜索好友面板。等等。代码都可以看的懂的。

实在找不到具体实现代码 可以先找到中文spark_i18n_zh_CN.properties， 然后通过对应的res Key找全文搜索，找到 Res.getString("menuitem.bookmark.room")

就能代码定位了。百试不爽。

其他就不赘述，篇幅精力有限。

4、openfire/spark 打包exe

在build /installer 下 spark/openfire.install4j  下载了install4j   破解后，直接双击，即可。或者配置下install4j  目录直接运行ant命令installer

openfire.install4j 文件配置了打包exe所有的配置、可以自己根据需要进行修改。打包成自己需要的exe文件。

自己摸索吧。貌似都少不了磕磕碰碰一番。

时间： 2024-10-06 03:01:52

openfire spark 二次 开发 服务插件的相关文章

PC端 Spark 二次开发 自动接收好友请求并同意

本次Spark二次开发是为了客服模块的开发, 能让用户一旦点击该客服则直接自动添加好友,而客服放则需自动添加好友,不同弹出对话框进行同意,这方便的广大客服. 现在废话不多说,直接上代码. package org.jivesoftware.spark.ui; import java.util.ArrayList; import org.jivesoftware.spark.util.log.Log; import org.jivesoftware.spark.util.ModelUtil; imp

【工业串口和网络软件通讯平台(SuperIO)教程】七.二次开发服务驱动

SuperIO相关资料下载:http://pan.baidu.com/s/1pJ7lZWf 1.1    服务接口的作用 围绕着设备驱动模块采集的数据,根据需求提供多种应用服务,例如:数据上传服务.数据请求服务.4-20mA服务.短信服务.LED服务以及OPC服务等.保障数据实时性.稳定性的前提下,服务接口可以提供丰富的功能服务机制,方便开发者进行二次开发. 1.2    接口功能说明 开发设备输出接口,主要考虑到在集成项目中,集成过程中或被集成过程的各种数据格式的输出.需要继承SuperIO.

NetSuite二次开发服务改变中小企业发展困境！

目前国内的中小企业广泛采用国产ERP/CRM软件,主要是因为这些软件适应国内的发展模式,与国内的财务汇报形式需求相一致. 然而,许多公司发现这些国产软件的优势仅仅停留在表面,像国产ERP/CRM系统由于其隐形成本高,配置复杂,缺乏可扩展性,会为企业带来一定的负担.在这里,我们一起来关注一个来自美国的云系统-NetSuite,是如何满足不同企业需求,并实现在整个ERP领域,排在全球主流ERP厂商中的第一位. NetSuite成立于1998年,专注于云系统超过15年,在超过10个国家拥有办公场所,已

ecshop二次开发功能插件计划列表

原文地址:php ecshop 二次开发 http://phpecshop.blog.51cto.com/6296699/1854849 ecshop功能开发计划列表 1.搜索页面添加筛选功能,类似京东 2.搜索结合coreseek实现中文分词功能,后台可以添加修改删除关键词 3.搜索框输入关键词自动提示,类似京东效果 4.缓存使用memcached储存,加快访问速度 5.添加多语言,一个后台管理多个语言商城内容 6.每天登录送积分,设置连续登录不同的天数再奖励相应的积分 7.注册添加手机验证码

提供织梦dedecms网站安装、调试、修改、二次开发服务

提供网站定制.仿站.修改.安装.调试.搬家等技术支持服务.具体的价钱按照修改的难以程度来定, 修改的地方越多价钱越优惠, 具体的可以加旺旺/qq客服/左侧微信进行沟通详谈! 服务说明: 1.标价10元是为了方便拍,具体联系店主: 2.根据您的需求来调整和修改,满意为止: 3.目标网站以链接形式发给我, 我将以你发的链接页面为准进行修改.安装.调试: 4.合作流程:协商修改范围> 报价 >拍下>修改>满意发货>买家确认收货: 5.修改要求请一次性提出, 接受任务后途中不接纳新的

如何开发jQuery插件

一:普及JQuery知识 知识1:用JQuery写插件时,最核心的方法有如下两个: $.extend(object) 可以理解为,为JQuery 类添加一个静态方法. $.fn.extend(object) 可以理解为,为JQuery实例添加一个成员函数. 基本的定义与调用: //$.extend的定义 $.extend({ pluginName:function(){ //... } }); //$.extend的调用 $.pluginName(); //$.fn.extend的定义 $.fn

搭建rtmp直播流服务之4:videoJS/ckPlayer开源播放器二次开发(播放rtmp、hls直播流及普通视频)

前面几章讲解了使用nginx-rtmp搭建直播流媒体服务器,以及使用ffmpeg推流到nginx-rtmp服务器,java通过命令行调用ffmpeg实现推流服务,后端的事情到这里就已经全部完成了. 本章讲一下播放器的选用和二次开发,前端的播放器虽然有flex(flash)可以用,但是很遗憾flex接触的并不多,学习成本又太高,那么基于第三方开源的flash播放器二次开发就显得很有必要. 一.几种播放器选择 那么播放器,哪些已经不再更新的和收费的,这里不会介绍,只介绍两种轻量级的开源播放器. 1.

搭建rtmp直播流服务之4:videojs和ckPlayer开源播放器二次开发(播放rtmp、hls直播流及普通视频)

前面几章讲解了使用 nginx-rtmp搭建直播流媒体服务器; ffmpeg推流到nginx-rtmp服务器; java通过命令行调用ffmpeg实现推流服务; 从数据源获取,到使用ffmpeg推流,再到nginx-rtmp发布流,后端的服务到这里就已经全部完成了. 如果这里的流程没走通,那么这里的播放器也是没办法播放实时流的. 本章讲一下播放器的选用和二次开发,前端的播放器虽然有flex(flash)可以用,但是很遗憾flex接触的并不多,学习成本又太高,那么基于第三方开源的flash播放器二

使用 PySide2 开发 Maya 插件系列二：继承 uic 转换出来的 py 文件中的类 Ui_Form

使用 PySide2 开发 Maya 插件系列二:继承 uic 转换出来的 py 文件中的类 Ui_Form 开发环境: Wing IDE 6.1 步骤1: 打开 Wing IDE,创建一个新的 project,保存这个 project 到某个路径下,把之前生产的 py 文件所在的文件夹添加到该 project 中,然后在文件夹下新建一个 py 文件,我这里命名为 PySideTest.py 图中 PySide2ToPySide.py 是一个 PySide2 兼容 PySide 的一个补丁代码,