OPENFIRE 启动流程
阅读原文时间:2023年07月16日阅读:1

在java>org>jivesoftware>openfire>starter,该类中的main方法启动,有图为证:

在start中方法分别调用unpackArchives和findParentClassLoader方法,确定openfire目录,并解压相关jia包,并创建一个org.jivesoftware.openfire.XMPPServer类的实例,有图为证:

在XMPPServer类中,依次执行start>initialize>locateOpenfire加载相关的配置文件,初始化缓存工厂设置相关的缓存大小,然后接着保存设置,在start方法中有一句判断: if (!setupMode) ,这里的setupMode是从openfire文件夹下的config文件夹下面的openfire.xml配置文件获取,有图为证:

如果想重置openfire或者设置数据库连接把setup设置为false就可以重新配置openfire了;如果已经设置为true了,则会执行verifyDataSource进行数据库验证,loadModules加载模块,initModules初始化模块,startModules启动模块,启动插件管理器 pluginManager.start();最后设置监听。

private void loadModules() {
// Load boot modules
loadModule(RoutingTableImpl.class.getName());
loadModule(AuditManagerImpl.class.getName());
loadModule(RosterManager.class.getName());
loadModule(PrivateStorage.class.getName());
// Load core modules
loadModule(PresenceManagerImpl.class.getName());
loadModule(SessionManager.class.getName());
loadModule(PacketRouterImpl.class.getName());
loadModule(IQRouter.class.getName());
loadModule(MessageRouter.class.getName());
loadModule(PresenceRouter.class.getName());
loadModule(MulticastRouter.class.getName());
loadModule(PacketTransporterImpl.class.getName());
loadModule(PacketDelivererImpl.class.getName());
loadModule(TransportHandler.class.getName());
loadModule(OfflineMessageStrategy.class.getName());
loadModule(OfflineMessageStore.class.getName());
loadModule(VCardManager.class.getName());
// Load standard modules
loadModule(IQBindHandler.class.getName());
loadModule(IQSessionEstablishmentHandler.class.getName());
loadModule(IQAuthHandler.class.getName());
loadModule(IQPingHandler.class.getName());
loadModule(IQPrivateHandler.class.getName());
loadModule(IQRegisterHandler.class.getName());
loadModule(IQRosterHandler.class.getName());
loadModule(IQTimeHandler.class.getName());
loadModule(IQEntityTimeHandler.class.getName());
loadModule(IQvCardHandler.class.getName());
loadModule(IQVersionHandler.class.getName());
loadModule(IQLastActivityHandler.class.getName());
loadModule(PresenceSubscribeHandler.class.getName());
loadModule(PresenceUpdateHandler.class.getName());
loadModule(IQOfflineMessagesHandler.class.getName());
loadModule(IQPEPHandler.class.getName());
loadModule(IQPEPOwnerHandler.class.getName());
loadModule(MulticastDNSService.class.getName());
loadModule(IQSharedGroupHandler.class.getName());
loadModule(AdHocCommandHandler.class.getName());
loadModule(IQPrivacyHandler.class.getName());
loadModule(DefaultFileTransferManager.class.getName());
loadModule(FileTransferProxy.class.getName());
loadModule(MediaProxyService.class.getName());
loadModule(PubSubModule.class.getName());
loadModule(IQDiscoInfoHandler.class.getName());
loadModule(IQDiscoItemsHandler.class.getName());
loadModule(UpdateManager.class.getName());
loadModule(FlashCrossDomainHandler.class.getName());
loadModule(InternalComponentManager.class.getName());
loadModule(MultiUserChatManager.class.getName());
loadModule(ClearspaceManager.class.getName());
loadModule(IQMessageCarbonsHandler.class.getName());

     // Load this module always last since we don't want to start listening for clients  
     // before the rest of the modules have been started  
     loadModule(ConnectionManagerImpl.class.getName());  
     // Keep a reference to the internal component manager  
     componentManager = getComponentManager();  
 }

在启动加载模块的过程中会依次加载这些模块。这些模块全部直接继承或间接继承BasicModule类,BasicModule类继承Module接口,Module接口定义五个方法,有图为证:

执行完loadModules这个方法之后所有的模块都保存在 private Map modules = new LinkedHashMap(); 这个LinkedHashMap中,执行startModules()时回按顺序执行LinkedHashMap中键值的start方法.

public class RoutingTableImpl extends BasicModule implements RoutingTable, ClusterEventListener

public class AuditManagerImpl extends BasicModule implements AuditManager

public class RosterManager extends BasicModule implements GroupEventListener, UserEventListener

public class PrivateStorage extends BasicModule implements UserEventListener

public class PresenceManagerImpl extends BasicModule implements PresenceManager, UserEventListener, XMPPServerListener

public class SessionManager extends BasicModule implements ClusterEventListener

public class PacketRouterImpl extends BasicModule implements PacketRouter

public class IQRouter extends BasicModule

public class MessageRouter extends BasicModule

public class PresenceRouter extends BasicModule

public class MulticastRouter extends BasicModule implements ServerFeaturesProvider, IQResultListener

public class PacketTransporterImpl extends BasicModule

public class PacketDelivererImpl extends BasicModule implements PacketDeliverer

public class TransportHandler extends BasicModule implements ChannelHandler

public class OfflineMessageStrategy extends BasicModule

public class OfflineMessageStore extends BasicModule implements UserEventListener

public class VCardManager extends BasicModule implements ServerFeaturesProvider

public class IQBindHandler extends IQHandler

public class IQSessionEstablishmentHandler extends IQHandler

public class IQAuthHandler extends IQHandler implements IQAuthInfo

public class IQPingHandler extends IQHandler implements ServerFeaturesProvider

public class IQPrivateHandler extends IQHandler implements ServerFeaturesProvider

public class IQRegisterHandler extends IQHandler implements ServerFeaturesProvider

public class IQRosterHandler extends IQHandler implements ServerFeaturesProvider

public class IQTimeHandler extends IQHandler implements ServerFeaturesProvider

public final class IQEntityTimeHandler extends IQHandler implements ServerFeaturesProvider

public class IQvCardHandler extends IQHandler

public class IQVersionHandler extends IQHandler implements ServerFeaturesProvider

public class IQLastActivityHandler extends IQHandler implements ServerFeaturesProvider

public class PresenceSubscribeHandler extends BasicModule implements ChannelHandler

public class PresenceUpdateHandler extends BasicModule implements ChannelHandler, ClusterEventListener

public class IQOfflineMessagesHandler extends IQHandler implements ServerFeaturesProvider, DiscoInfoProvider, DiscoItemsProvider

public class IQPEPHandler extends IQHandler implements ServerIdentitiesProvider, ServerFeaturesProvider, UserIdentitiesProvider, UserItemsProvider, PresenceEventListener, RosterEventListener, UserEventListener

public class IQPEPOwnerHandler extends IQHandler

public class MulticastDNSService extends BasicModule

public class IQSharedGroupHandler extends IQHandler

public class AdHocCommandHandler extends IQHandler
implements ServerFeaturesProvider, DiscoInfoProvider, DiscoItemsProvider

public class IQPrivacyHandler extends IQHandler implements ServerFeaturesProvider, UserEventListener

public class DefaultFileTransferManager extends BasicModule implements FileTransferManager

public class FileTransferProxy extends BasicModule implements ServerItemsProvider, DiscoInfoProvider, DiscoItemsProvider, RoutableChannelHandler

public class MediaProxyService extends BasicModule implements ServerItemsProvider, RoutableChannelHandler, DiscoInfoProvider, DiscoItemsProvider

public class PubSubModule extends BasicModule implements ServerItemsProvider, DiscoInfoProvider, DiscoItemsProvider, RoutableChannelHandler, PubSubService, PropertyEventListener

public class IQDiscoInfoHandler extends IQHandler implements ClusterEventListener

public class IQDiscoItemsHandler extends IQHandler implements ServerFeaturesProvider, ClusterEventListener, UserItemsProvider

public class UpdateManager extends BasicModule

public class FlashCrossDomainHandler extends BasicModule

public class InternalComponentManager extends BasicModule implements ComponentManager, RoutableChannelHandler

public class MultiUserChatManager extends BasicModule implements ClusterEventListener, MUCServicePropertyEventListener, UserEventListener

public class ClearspaceManager extends BasicModule implements ExternalComponentManagerListener, ComponentEventListener, PropertyEventListener, CertificateEventListener

public final class IQMessageCarbonsHandler extends IQHandler implements ServerFeaturesProvider

public class ConnectionManagerImpl extends BasicModule implements ConnectionManager, CertificateEventListener

先做个记录吧。