http://blog.csdn.net/otangba/article/details/8212593
openfire的组件分为内部组件和外部组件两种,可能大家不一定完全明白什么意思,我解释一下:
内部组件是工作在openfire运行环境的插件,是以独立的jar包存在,具有访问和控制openfire主域的权限,其最主要的能力就是,可以参与和控制主域的通信。
外部组件是实现XEP-0114规范的实例,确切的说就是独立的应用程序,通过tcp通信的方式连接到openfire上,只能参与和控制独立的子域通信。
因此,内外部组件的应用场景非常容易区分,就是看,你是否需要使用服务器主域资源。
例如,你需要在某些特定场景下枚举服务器上所有的用户,那么你无法用外部组件实现,只能通过内部组件实现。
那么为什么要有外部组件呢,子域又是什么,请看我的例子:
有2家公司,各有员工500人,需要实现xmpp互通,但是是受到逻辑约束的,某些人只能和另外公司的某些人沟通,你也许想说,把两个公司的员工都放在主域上,用内部组件进行控制,的确,没问题,但是如果两家公司各自通信有特殊的业务需求怎么办?是不是要在内部组件写很多的分支呢。
于是我们假设A公司的子域为coma,B公司子域为comb,服务器主域为example.com,那么我们就可以创建2个外部组件(类)来分别控制2个公司的通信,第一个外部组件componenta负责域coma.example.com,componentb负责comb.example.com
我们通过实现2个类来完成2个外部组件的操作,一旦实例化并和服务器建立了安全连接之后,所有的业务逻辑就很简单了。
对于外部组件今天我先暂且搁置,先说说内部组件。
下面涉及的代码是一个例子项目,任务是把openfire的用户在线状态同步到redis里,类似的解决方案在openfire源码自带的presence service插件里也有实现,不过那个是提供了一个web的rest接口,用起来当然没有redis爽快。
实现逻辑,注册一个组件,注入到包通信中,截获presence包
当presence的type为unavaiable时,认为用户离线,对比redis内原来用户状态,如果变更,则将离线状态写入redis。
当截获到type为空的presence包,则认为用户在线。
另外为组件实现一个web控制台,可以删除所有的用户以及初始化同步一次openfire已有的用户状态。
内部组件的编写比较简单,基本上下载了openfire源码就可以开始写,不用准备额外的jar包。
一个合法的内部组件,首先,位置必须在src/plugins下,建立组件的目录,再创建src/java存放java代码src/web存放web console的jsp页面
上图就是一个合法的内部组件的位置
在组件目录,例子中的synUserStateToRedis里,需要plugin.xml。这个文件是组件的描述文件,必须。
文件的内容大家可以打开源码内任何一个看看,不需要过多介绍,如果没有web console,可以把<adminconsole>节点忽略。
在src/java目录下,建立组件的package和类代码:
至于编译则非常简单,在eclipse里打开ant的panel,添加位于openfire源码的build下的build.xml
展开之后双击plugins就可以编译所有的组件,如果需要单独编译你的组件,在ant的配置中添加-Dplugin=你的组件名,该组件名是在xml里面配置的名称,也是组件类getName()方法返回的那个字符串,不是组件的类名。
组件的实现有多种方式,这个可以参考jivesoftware的官方文档,不过我看用的比较多的还是PacketInterceptor模式。
新建一个类,实现Plugin,PacketInterceptor,必须完成三个方法的重写,interceptPacket,initializePlugin,destroyPlugin。
顾名思义,分别是实现包的注入,初始化组件和销毁组件。外部组件的某些开发方式中,jivesoftware提供了继承component类来更简单的重写对不同类型数据包的操作,而在这里,你只能利用interceptPacket来完成对所有类型的包进行操作。
例如我要处理presence包,我会这么写:
- public void interceptPacket(Packet packet, Session session,
- boolean incoming, boolean processed) throws PacketRejectedException {
- if (!processed && incoming) {
- if (packet instanceof Presence) {
- // Respond to presence subscription request or presence probe
- Presence presence = (Presence) packet;
- processPresence(presence);
- }
- }
- }
如果要让你的组件在openfire后台有嵌入的界面,那么就在src/web下编写你的jsp页面
主要部分:
- <%@ page import="java.util.*,
- org.jivesoftware.openfire.XMPPServer,
- org.jivesoftware.util.*,
- org.jivesoftware.openfire.plugin.SynUserStateToRedis"
- errorPage="error.jsp"
- %>
- <%@ page contentType="text/html; charset=UTF-8"%>
- <%@ taglib uri="http://java.sun.com/jstl/core_rt" prefix="c" %>
- <%@ taglib uri="http://java.sun.com/jstl/fmt_rt" prefix="fmt" %>
- <%-- Define Administration Bean --%>
- <jsp:useBean id="admin" class="org.jivesoftware.util.WebManager" />
- <c:set var="admin" value="${admin.manager}" />
- <% admin.init(request, response, session, application, out ); %>
- <% // Get parameters
- boolean init = request.getParameter("init") != null;
- SynUserStateToRedis plugin = (SynUserStateToRedis) XMPPServer.getInstance().getPluginManager().getPlugin("synuserstatetoredis");
- %>
为了让jsp页面实现初始化同步用户的逻辑,我们在组件的类里添加一个方法:
- public int initUserStates() {
- int cnt=0;
- Jedis jedis = RedisManager.getInstance().getRedis();
- Pipeline pl = jedis.pipelined();
- Collection<User> users = userManager.getUsers();
- try {
- for (User u : users) {
- int state = STATUS_ONLINE;
- Presence p = presenceManager.getPresence(u);
- if (p == null) {
- state = STATUS_OFFLINE;
- } else if (p.getType() == Type.unavailable) {
- state = STATUS_OFFLINE;
- }
- pl.hset(REDIS_KEY, u.getUsername(), String.valueOf(state));
- cnt ++;
- }
- pl.sync();
- } catch (Exception e) {
- // TODO: handle exception
- }
- RedisManager.getInstance().returnJedis(jedis);
- return cnt;
- }
这个方法是将openfire的用户枚举并且判断其状态,批量写入到redis
在jsp中这样调用即可
- <% if (init) {
- String initedUserNum=String.valueOf(plugin.initUserStates());
- %>
- <div class="jive-success">
- <table cellpadding="0" cellspacing="0" border="0">
- <tbody>
- <tr><td class="jive-icon"><img src="images/success-16x16.gif" width="16" height="16" border="0"></td>
- <td class="jive-icon-label">
- 操作执行成功,同步了<%=initedUserNum%>个用户。
- </td></tr>
- </tbody>
- </table>
- </div><br>
- <% }%>
完成之后,编译,在openfire后台直接上传
相关的web console:
应该说开发内部组件还是比较简单的,理解了原理之后对于java程序员来说应该是小意思,
总体来说openfire还是性能不错的xmpp服务器,大家不妨可以换个思路考虑一下是否可以利用即时通信服务来实现原来基于web实现的业务。
相关推荐
提供1.3和2.0两个版本插件,分别支持openfire3.9.1以上和3.9.3以上的版本。具体的openfire集群配置请参看考:http://blog.csdn.net/jimoshazhouleng360/article/details/44651177
让人快速上手openfire插件的开发,让你节省更多时间了解源码。
Openfire二次开发问题分析及解决资料,列举了二次开发过程中可能会遇到的问题及解决的把办法。
IOS 开发OPENFIRE聊天DEMO
spark+openfire二次开发,包括配置基本插件实现等等
目的:主要是为了监控Openfire各类message,然后对message body做进一步...局限:因为时间有限,本插件并没有对Openfire message协议进行扩展,都是基于原生的xml协议,因此后续开发还需要进行更加深入的二次开发操作。
openfire源码部署开发 openfire源码部署开发 openfire源码部署开发
我可以说你在任何地方任何书上找不到这个,是我和同事开发时搜集整理再加上自己编辑出来的,包括一些国内外网站论坛内容和论文,如果想用xmpp开发Openfire或者类似的可以看看,我觉得很有价值。
这是为openfire服务器开发插件的简单demo,参照博客:http://blog.csdn.net/ibm_hoojo/
OpenFire二次开发环境搭建
openfire webchat开发包!
openfire开发文档[汇编].pdf
不错的OpenFire入门配置,从下载到配置。
Openfire调试、编译开发环境与安装
详细介绍了openfire的源码部署流程及开发技术。
这是一个文档,内容是如何编写Openfire开发插件、部署源码
openfire搭建本地开发环境所需jar。 包含:coherence.jar、coherence-work.jar、tangosol.jar、bouncycastle.jar
openfire即时通讯开发文档,包括如何部署,以及代码的讲解
对openfire的服务端组件开发有好处
NULL 博文链接:https://beautyofprogram.iteye.com/blog/772281