【文章內(nèi)容簡介】 version */ public class GroupTreePlugin implements Plugin { private XMPPServer server。 /* * (nonJavadoc) * * @see destroyPlugin() */ public void destroyPlugin() { } /* * (nonJavadoc) * * @see initializePlugin(ginManager, * ) */ public void initializePlugin(PluginManager manager, File pluginDirectory) { (注冊群組樹 IQ 處理器 )。 server = ()。 ().addHandler(new GroupTreeIQHander())。 //1 ().addHandler(new UserInfoIQHandler())。 ().addHandler(new DelUserIQHandler())。 ().addHandler(new CreateUserIQHandler())。 ().addHandler(new AddGroupUserIQHandler())。 ().addHandler(new SetRoleIQHandler())。 } } 上例所示，在初始化中先找到 IQRouter，然后通過 IQRouter 注冊一批 IQHandler，這些IQHander 會自動監(jiān)聽相應(yīng)命名空間的 IQ，然后進行處理；由于這個 Plugin 不需要做資源釋放的工作，所以在 destroyPlugin() 方法中沒有任何內(nèi)容。具體的 IQHander 類如下 GroupTreeIQHander /** * 處理客戶端發(fā)來的 IQ，并回送結(jié)果 IQ * * @author Phoenix * * Mar 14, 2020 4:55:33 PM * * version */ public class GroupTreeIQHander extends IQHandler { private static final String MODULE_NAME = group tree handler。 private static final String NAME_SPACE = :im:group。 private IQHandlerInfo info。 public GroupTreeIQHander() { super(MODULE_NAME)。 info = new IQHandlerInfo(gruops, NAME_SPACE)。 } /* * (nonJavadoc) * * @see getInfo() */ @Override public IQHandlerInfo getInfo() { return info。 } /* * (nonJavadoc) * * @see handleIQ() */ @Override public IQ handleIQ(IQ packet) throws UnauthorizedException { IQ reply = (packet)。 Element groups = ()。//1 if (!(())) { (非法的請求類型 )。 (())。 ()。 return reply。 } String userName = (().toString(),@)。 ().initElement(groups,userName)。 (())。//2 (返回的最終 XML ())。 return reply。 } } 可以看到主要有兩個方法，一個是 getInfo() 這個方法的目的是提供要解析的命名空間，在本例中，這個 IQHandler 對每個命名空間為 :im:group 的實例進行處理；還有一個最重要的方法： handleIQ() 該方法對包含指定命名空間的 XML 進行解析，然后返回一個解析好的 IQ。其實我認為，這個 IQHandler 和 IQ 的關(guān)系就是 Controller 和 Model 的關(guān)系（如果你了解 MVC 的話，那么你一定知道我再說什么），只不過這里并沒有指定什么 View，你完全可以把 IQ 當(dāng)成 Model 類進行理解。在這里，我用了 GroupManager 進行了 XML 的處理，因為我返回的 IQ 內(nèi)容中要從數(shù)據(jù)庫讀取所有群組信息，所以轉(zhuǎn)交給 GroupManager 進行處理，你完全可以在這個方法中進行具體 的 XML 處理，在這里，解析和創(chuàng)建新的 XML 主要用到的是 JDOM（如果你對 Java 解析 XML 有所了解，那真的太好了?。３绦?//1 處主要是獲取創(chuàng)建返回的 IQ，并獲取原來 IQ 的子元素（用于創(chuàng)建我們返回的 IQ）；程序 //2 處很關(guān)鍵，如果你不調(diào)用 createCopy 方法，程序會出錯（程序會死鎖還是什么，忘記咧，不好以西）。 這就是程序的主體部分，我在這里有一個建議，能不用 Openfire 原始的程序函數(shù)，就不要用它們。我的提取數(shù)據(jù)庫方式都是自己寫的 Bean，這樣有利于你自己對程序的掌控，其實更有利 于快速開發(fā)（這世道不是啥都講究敏捷么，哇哈哈） 打包插件 打包依然遵循二次打包的原則（如果你不了解啥叫要二次打包，請看上一篇） 這是我的 ant 文件，由于 Eclipse 幫我做了 build 等很多工作，實際我的 ant 工作就是在打包，并放入插件目錄下的 plugin 文件夾下 ?xml version= encoding=UTF8? project name=IM default=release basedir=. property name= value=E:/workspace/europa/openfire_src/target/openfire / property name= value=classes / property name= value=lib / target name=jar jar jarfile=${}/ basedir=${} fileset dir=. include name=*.jar/ /fileset /jar jar jarfile=${}/plugins/ fileset dir=. include name=lib/*.jar / include name= / include name= / include name= / include name= / include name= / include name= / /fileset /jar /target target name=release depends=jar /target /project 好了，至此 XMPP Spark Openfire 的插件開發(fā)三部曲徹底結(jié)束了，希望你們對這個開發(fā)流程有了系統(tǒng)的了 解。 第三章：代碼研究 Openfire 的 socket 網(wǎng)絡(luò)連接包括： ![if !supportLists]1. ![endif]服務(wù)器和服務(wù)器之間的連接（監(jiān)聽在端口 5269） ![if !supportLists]2. ![endif]外部組件和服務(wù)器之間的連接（監(jiān)聽在端口 5275） ![if !supportLists]3. ![endif]多元 (plex)連接（監(jiān)聽在端口 5269） ![if !supportLists]4. ![endif]客戶端和服務(wù)器的連接（監(jiān)聽在端口 5222） ![if !supportLists]5. ![endif]和客戶端通過 TLS/ 和服務(wù)器的連接。（監(jiān)聽在端口 5223） 這些連接都是通過 ConnectionManager 接口實現(xiàn)管理的，程序中對 ConnectionManager接口的實現(xiàn)類是 ConnectionManagerImpl，它是作為一個模塊（ Module）類加載到服務(wù)器中的。 下面分析的是客戶端和服務(wù)器的連接。 在 ConnectionManagerImpl中是通過調(diào)用 startClientListeners方法來初始化和開始端口監(jiān)聽的。 ![endif]在 startClientListeners方法使用的是 Apache的 Mina框架來實現(xiàn)網(wǎng)絡(luò)連接的， Mina 框架的模式如下： IoFilter： IoFilter 為 MINA的功能擴展提供了接口。它攔截所有的 IO 事件進行事件的預(yù)處理和后處理。它與 Servlet 中的 filter 機制十分相似。多個 IoFilter 存放在 IoFilterChain 中 IoFilter 能夠?qū)崿F(xiàn)以下功能： 數(shù)據(jù)轉(zhuǎn)換 事件日志 性能檢測 在 Openfire 中主要用 filter 這種機制來進行數(shù)據(jù)轉(zhuǎn)換。 Protocol Codec Factory： Protocol Codec Factory 提供了方便的 Protocol 支持，通過它的 Encoder 和 Decoder，可以方便的擴展并支持各種基于 Socket 的網(wǎng)絡(luò)協(xié)議，比如 HTTP 服務(wù)器、 FTP 服務(wù)器、 Tel 服務(wù)器等等。 要實現(xiàn)自己的編碼 /解碼器 (codec)只需要實現(xiàn) interface: ProtocolCodecFactory 即可，在 Openfire 中實現(xiàn) ProtocolCodecFactory 的類為 XMPPCodecFactory。 IoHandler: MINA 中，所有的業(yè)務(wù)邏輯都有實現(xiàn)了 IoHandler 的 class 完成 ，當(dāng)事件發(fā)生時，將觸發(fā) IoHandler 中的方法 : sessionCreated sessionOpened sessionClosed sessionIdle exceptionCaught messageReceived messageSent 在 Openfire 中客戶端和服務(wù)器連接的 IoHandler 實現(xiàn)類是 ClientConnectionHandler，它是從 ConnectionHandler 中繼承來的。 startClientListeners 方法首先為 Mian 框架設(shè)置線程池，再將一個由 XMPPCodecFactory 作為 Protocol Codec Factory 的 Filter 放入到 FilterChain 中，然后綁定到端口 5222，并將 ClientConnectionHandler 作為 IoHandler 對數(shù)據(jù)進行處理。完成這些步驟后 Openfire 就在 5222 等待客戶端的連接。 客戶端連接的處理過程： 當(dāng)有客戶端進行連接時根據(jù) Mina 框架的模式首先調(diào)用的是 sessionOpened 方法。 sessionOpened 首先為此新連接構(gòu)造了一個 parser（ XMLLightWeightParser），這個 parser 是專門給 XMPPDecoder（是 XMPPCodecFactory 的解碼器類）使用的，再