开发openfire 消息拦截器插件PacketInterceptor

开发消息拦截器的步骤跟开发简单插件步骤一样，要开发消息拦截器插件，首先继承PacketInterceptor包拦截类，然后在initializelPlugin（）方法中注册拦截器，就可以实现interceptPackage（）方法中拦截包（即此方法中的packet参数）了。并且，可以通过入参incoming来判断是服务器发送的包还是接受的包（注：true为服务器接收的包；false为发出的包）。processed参数用处暂不明，猜想是对请求做了什么处理的标识，但不影响我们对包进行拦截和处理。

这个扩展方式与前一种相比的好处在于，这种方式不仅没有修改原注册流程的代码，而且最大程度的使用了原注册流程。这样可以避免一些不必要的风险。

  1. package com.bis.plugin.messageplugin;
  2.  
  3. import java.io.File;
  4.  
  5. import org.jivesoftware.openfire.container.Plugin;
  6. import org.jivesoftware.openfire.container.PluginManager;
  7. import org.jivesoftware.openfire.interceptor.InterceptorManager;
  8. import org.jivesoftware.openfire.interceptor.PacketInterceptor;
  9. import org.jivesoftware.openfire.interceptor.PacketRejectedException;
  10. import org.jivesoftware.openfire.session.Session;
  11. import org.xmpp.packet.Packet;
  12.  
  13. public class MessagePlugIn implements Plugin,PacketInterceptor {
  14. private static PluginManager pluginManager;
  15. private InterceptorManager interceptoerManager;
  16.  
  17.  
  18.  
  19. public MessagePlugIn() {
  20. interceptoerManager = InterceptorManager.getInstance();
  21. }
  22.  
  23. @Override
  24. public void initializePlugin(PluginManager manager, File pluginDirectory) { 
    interceptoerManager = InterceptorManager.getInstance();
  25. pluginManager = manager;
  26. interceptoerManager.addInterceptor(this);
  27. System.out.println("加载插件成功！");
  28. }
  29.  
  30. @Override
  31. public void destroyPlugin() {
  32. interceptoerManager.removeInterceptor(this);
  33. System.out.println("销毁插件成功！");
  34. }
  35.  
  36. @Override
  37. public void interceptPacket(Packet packet, Session session,
  38. boolean incoming, boolean processed) throws PacketRejectedException {
  39. System.out.println("接收到的消息内容："+packet.toXML());
  40. }
  41.  
  42. }

1、继承Plugin接口，就是在系统启动的时候会执行initializePlugin()方法，表示这是一个插件类

2、继承PacketInterceptor接口，表示这个类是一个拦截Message的消息类，当拦截的时候，会执行interceptPacket方法

关于openfire是如何管理消息拦截器的？

我们可以看看MessageRouter类的route(Message packet)方法

  1. public void route(Message packet) {
  2. if (packet == null) {
  3. throw new NullPointerException();
  4. }
  5. ClientSession session = sessionManager.getSession(packet.getFrom());
  6. try {
  7. // Invoke the interceptors before we process the read packet
  8. //系统的拦截器就是在这里调用的，遍历动态添加的所有拦截器
  9. InterceptorManager.getInstance().invokeInterceptors(packet, session, true, false);
  10. if (session == null || session.getStatus() == Session.STATUS_AUTHENTICATED) {
  11. JID recipientJID = packet.getTo();
  12.  
  13. // Check if the message was sent to the server hostname
  14. if (recipientJID != null && recipientJID.getNode() == null && recipientJID.getResource() == null &&
  15. serverName.equals(recipientJID.getDomain())) {
  16. if (packet.getElement().element("addresses") != null) {
  17. // Message includes multicast processing instructions. Ask the multicastRouter
  18. // to route this packet
  19. multicastRouter.route(packet);
  20. }
  21. else {
  22. // Message was sent to the server hostname so forward it to a configurable
  23. // set of JID‘s (probably admin users)
  24. sendMessageToAdmins(packet);
  25. }
  26. return;
  27. }
  28.  
  29. try {
  30. // Deliver stanza to requested route
  31. routingTable.routePacket(recipientJID, packet, false);
  32. }
  33. catch (Exception e) {
  34. log.error("Failed to route packet: " + packet.toXML(), e);
  35. routingFailed(recipientJID, packet);
  36. }
  37. }
  38. else {
  39. packet.setTo(session.getAddress());
  40. packet.setFrom((JID)null);
  41. packet.setError(PacketError.Condition.not_authorized);
  42. session.process(packet);
  43. }
  44. // Invoke the interceptors after we have processed the read packet
  45. //系统的拦截器就是在这里调用的，遍历动态添加的所有拦截器
  46. InterceptorManager.getInstance().invokeInterceptors(packet, session, true, true);
  47. } catch (PacketRejectedException e) {
  48. // An interceptor rejected this packet
  49. if (session != null && e.getRejectionMessage() != null && e.getRejectionMessage().trim().length() > 0) {
  50. // A message for the rejection will be sent to the sender of the rejected packet
  51. Message reply = new Message();
  52. reply.setID(packet.getID());
  53. reply.setTo(session.getAddress());
  54. reply.setFrom(packet.getTo());
  55. reply.setType(packet.getType());
  56. reply.setThread(packet.getThread());
  57. reply.setBody(e.getRejectionMessage());
  58. session.process(reply);
  59. }
  60. }
  61. }
  1. public void route(Message packet) {
  2. if (packet == null) {
  3. throw new NullPointerException();
  4. }
  5. ClientSession session = sessionManager.getSession(packet.getFrom());
  6. try {
  7. // Invoke the interceptors before we process the read packet
  8. //系统的拦截器就是在这里调用的，遍历动态添加的所有拦截器
  9. InterceptorManager.getInstance().invokeInterceptors(packet, session, true, false);
  10. if (session == null || session.getStatus() == Session.STATUS_AUTHENTICATED) {
  11. JID recipientJID = packet.getTo();
  12.  
  13. // Check if the message was sent to the server hostname
  14. if (recipientJID != null && recipientJID.getNode() == null && recipientJID.getResource() == null &&
  15. serverName.equals(recipientJID.getDomain())) {
  16. if (packet.getElement().element("addresses") != null) {
  17. // Message includes multicast processing instructions. Ask the multicastRouter
  18. // to route this packet
  19. multicastRouter.route(packet);
  20. }
  21. else {
  22. // Message was sent to the server hostname so forward it to a configurable
  23. // set of JID‘s (probably admin users)
  24. sendMessageToAdmins(packet);
  25. }
  26. return;
  27. }
  28.  
  29. try {
  30. // Deliver stanza to requested route
  31. routingTable.routePacket(recipientJID, packet, false);
  32. }
  33. catch (Exception e) {
  34. log.error("Failed to route packet: " + packet.toXML(), e);
  35. routingFailed(recipientJID, packet);
  36. }
  37. }
  38. else {
  39. packet.setTo(session.getAddress());
  40. packet.setFrom((JID)null);
  41. packet.setError(PacketError.Condition.not_authorized);
  42. session.process(packet);
  43. }
  44. // Invoke the interceptors after we have processed the read packet
  45. //系统的拦截器就是在这里调用的，遍历动态添加的所有拦截器
  46. InterceptorManager.getInstance().invokeInterceptors(packet, session, true, true);
  47. } catch (PacketRejectedException e) {
  48. // An interceptor rejected this packet
  49. if (session != null && e.getRejectionMessage() != null && e.getRejectionMessage().trim().length() > 0) {
  50. // A message for the rejection will be sent to the sender of the rejected packet
  51. Message reply = new Message();
  52. reply.setID(packet.getID());
  53. reply.setTo(session.getAddress());
  54. reply.setFrom(packet.getTo());
  55. reply.setType(packet.getType());
  56. reply.setThread(packet.getThread());
  57. reply.setBody(e.getRejectionMessage());
  58. session.process(reply);
  59. }
  60. }
  61. }

最后附上xmpp的相关协议：

  1. .openfire注册相关协议
  2. 1./*用户注册，原本的协议中没有province字段，这里为扩展*/
  3. <iq id="g0G4m-1" to="zhanglj" type="set">
  4. <query xmlns="jabber:iq:register">
  5. <username>re3</username>
  6. <email></email>
  7. <name></name>
  8. <password>1</password>
  9. <province>合肥</province>
  10. </query>
  11. </iq>
  12.  
  13. 2.用户注册成功
  14. <iq type="result" id="g0G4m-1" from="zhanglj" to="[email protected]/Spark 2.6.3"/>
  15.  
  16. 3.用户注册失败
  17. i. 用户名为空：code=‘500"
  18. <iq type="error" id="g0G4m-1" from="zhanglj" to="[email protected]/Spark 2.6.3">
  19. <query xmlns="jabber:iq:register">
  20. <username/>
  21. <email/>
  22. <name/>
  23. <password>1</password>
  24. <province>合肥</province>
  25. </query>
  26. <error code="500" type="wait">
  27. <internal-server-error xmlns="urn:ietf:params:xml:ns:xmpp-stanzas"/>
  28. </error>
  29. </iq>
  30.  
  31. ii.密码为空：code=‘406"
  32. <iq type="error" id="g0G4m-1" from="zhanglj" to="re3@zhanglj/Spark 2.6.3">
  33. <query xmlns="jabber:iq:register">
  34. <username>r</username>
  35. <email/>
  36. <name/>
  37. <password/>
  38. </query>
  39. <error code="406" type="modify"><not-acceptable xmlns="urn:ietf:params:xml:ns:xmpp-stanzas"/>
  40. </error>
  41. </iq>
  42.  
  43. iii.用户已存在：code=‘409"
  44. <iq id="g0G4m-1" to="[email protected]/Spark 2.6.3" from="zhanglj" type="error">
  45. <query xmlns="jabber:iq:register">
  46. <username>re5</username>
  47. <email/>
  48. <name/>
  49. <province>合肥</province>
  50. <password>1</password>
  51. </query>
  52. <error code="409" type="CANCEL">
  53. <conflict xmlns="urn:ietf:params:xml:ns:xmpp-stanzas"/>
  54. </error>
  55. </iq>

https://blog.csdn.net/zhonglunshun/article/details/84695804

原文地址：https://www.cnblogs.com/tiancai/p/10064631.html

时间： 2024-11-05 18:30:51

开发openfire 消息拦截器插件PacketInterceptor的相关文章

openfire开发(四)消息拦截器

大家好,我是LD,今天给大家介绍openfire的消息拦截器.通常,我们在开发插件的过程中会有一种需求,需要对客户端发送的消息来做一些我们自己的处理,比如保存数据等等.这里我们就会使用到拦截器, 在openfire中,自定义拦截器需要实现PacketInterceptor接口.下面我们写一个简单的拦截器来介绍一下. import org.jivesoftware.openfire.interceptor.PacketInterceptor; import org.jivesoftware.ope

C#制作一个消息拦截器（intercept）1

首先,我们先要制作一个自定义Attribute,让他可以具有上下文读取功能,所以我们这个Attribute类要同时继承Attribute和IContextAttribute. 接口IContextAttribute中有两个方法需要实现 1.bool   IsContextOK(Context ctx, IConstructionCallMessage msg); 2.void  GetPropertiesForNewContext(IConstructionCallMessage msg); 简

C#制作一个消息拦截器（intercept）3

之前为InterceptAttribute的上下文环境添加了"Intercept"属性(InterceptProperty),正因为InterceptProperty继承了IContributeObjectSink,所以我们要实现GetObjectSink(),继而我们要创建一个继承ImessageSink的类来作为返回值. 这样就引发出了InterceptSink类的实现: public class InterceptSink : IMessageSink { private IMe

C#制作一个消息拦截器（intercept）4

ok,我们拦截器基本构造完成,接下来我来告诉大家如何去使用. 注意一个问题,object拦截器我们要拦截什么,那么我们就要在需要拦截的类上面做手脚了. 首先,创建我们需要被拦截的类. 然后,我们再对类进行相应的包装: 1.该类要标记InterceptAttribute属性 2.该类要继承ContextBoundObject,只有继承ContextBoundObject的类,vs才能知道该类需要访问Context,这样标记的InterceptAttribute才有效. /// <summary>

基于Bootstrap和Knockout.js的ASP.NET MVC开发实战 关于 拦截器的 学习 部分

先贴一段: 下面贴代码: 上面这段代码呢,有几个点迷糊.可以找找看

Struts开发一个权限验证拦截器来判断用户是否登录

开发一个权限验证拦截器来判断用户是否登录 当用户请求受保护资源时,先检查用户是否登录 如果没有登录,则向用户显示登录页面 如果已经登录,则继续操作 实现步骤 开发权限验证拦截器 在配置文件中定义拦截器并引用它 开发权限验证拦截器 public class AuthInterceptor extends AbstractInterceptor { public String intercept(ActionInvocation invocation) throws Exception { //获取

笔记：Struts2 拦截器

配置拦截器 Struts.xml 配置文件中,使用<interceptor-/>来定义拦截器,有属性 name 表示拦截器的名称,class 表示拦截器的具体首先类,可以使用<param-/>子元素来配置拦截器的参数,配置示例: <package name="包名称" extends="抽象包名称"> <interceptors> <interceptor name="拦截器名称" class

Struts2的拦截器

拦截器的作用: 拦截器可以动态地拦截发送到指定Action的请求,通过拦截器机制,可以载Action执行的前后插入某些代码,植入我们的逻辑思维. 拦截器的实现原理: 拦截器通过代理的方式来调用,通过动态代理我们的Action,在Action的执行前后植入我们的拦截代码.这种拦截器的思想就是一种AOP,取得业务处理过程的切面,在特定切面 通过系统自动插入特定方法. Struts2中的拦截器: 在平常的项目中,我们经常需要解析上传表单中的文件域,防止表单多次提交……,这些操作不是所有Action都需

struts2内置拦截器和自定义拦截器详解(附源码）

一.Struts2内置拦截器 Struts2中内置类许多的拦截器,它们提供了许多Struts2的核心功能和可选的高级特 性.这些内置的拦截器在struts-default.xml中配置.只有配置了拦截器,拦截器才可以正常的工作和运行.Struts 2已经为您提供丰富多样的,功能齐全的拦截器实现.大家可以至struts2的jar包内的struts-default.xml查看关于默认的拦截器与 拦截器链的配置.内置拦截器虽然在struts2中都定义了,但是并不是都起作用的.因为并不是所有拦截器都被加