`

tigase component (一)

阅读更多

本文翻译自 – http://www.tigase.org/content/basic-information
下面是当你需要创建一个新的Component所需要关注的接口列表:

  1. tigase.server.ServerComponent – 这是一个非常基本的component接口。所有的component都必须实现接口中定义的方法。
    /**
     * Interface ServerComponent
     * 这种类型的对象可以被MessageRouter管理.
     * 所有被MessageRouter加载的类必须要实现这个接口。
     */
    public interface ServerComponent {
     void setName(String name);
     String getName();
    
     JID getComponentId();
     void release();
     /**
      * processPacket是所有components都必须实现的阻塞性方法.
      * 这个方法处理packet并且不等待任何资源立即返回results
      *
      */
     void processPacket(Packet packet, Queue results);
     void initializationCompleted();
    }
  2. tigase.server.MessageReceiver – 这个接口extends ServerComponent,所有希望接收数据packets的Component都需要实现接口中定义的方法,比如session manager和c2s connection manager。
    /**
     * Interface MessageReceiver
     * 这种类型的对象可以接收消息,它们事实上也可以根据最终地址进行消息路由。
     * 消息在MessageRouter类中被路由到正确的目的地。
     */
    public interface MessageReceiver extends ServerComponent {
     /**
      * 这里缺少方法表述
      *
      * @param packet a Packet value
      * @return 如果packet被成功添加了,返回true。否则否则返回false
      */
    boolean addPacket(Packet packet);
    boolean addPacketNB(Packet packet);
    boolean addPackets(Queue packets);
    BareJID getDefHostName();
    boolean isInRegexRoutings(String address);
    void setParent(MessageReceiver msg_rec);
    void start();}
  3. tigase.conf.Configurable – 如果希望components可以被配置,则需要实现这个接口。在运行时,配置信息会被推送到这种类型的对象。components必须能够在运行时对变更的配置项进行处理,这一点在实现时要留神。
    /**
     * Interface Configurable
     *
     * 实现这个接口的对象实例对象是可配置的。 在Tigase系统中组件是不能够请求配置信息的。
     * 配置信息是可以在任何时候被推送到组件。这种方式提供了运行时的动态配置机制。
     */
    public interface Configurable extends ServerComponent {
     /**
      * 常量 GEN_CONFIG 是所有配置类型的前缀.
      */
    public static final String GEN_CONFIG = "--gen-config";
     /**
      * 常量 GEN_CONFIG_ALL 是所有直接被服务加载的components配置类型的参数名.
      */
    public static final String GEN_CONFIG_ALL = GEN_CONFIG + "-all";
     /**
      * 常量 GEN_CONFIG_SM 是session manager的配置信息参数名,
      * 也是 会预先配置并连接到 “具有ClientConnectionMananger的服务实例”
      * XEP-0114 component的配置信息参数名。
      */
    public static final String GEN_CONFIG_SM = GEN_CONFIG + "-sm";
     /**
      * 常量 GEN_CONFIG_CS 是 ClientConnectionManager 的配置信息参数名。
      * 也是 会预先配置并连接到 “具有SessionManager的服务实例”
      * 的XEP-0114 component的配置信息参数名。
      */
    public static final String GEN_CONFIG_CS = GEN_CONFIG + "-cs";
     /**
      * 常量 GEN_CONFIG_DEF 是 SessionManager,ClientConnectionManager
      * 和ServerConnectionManager的常用配置想参数名。
      */
    public static final String GEN_CONFIG_DEF = GEN_CONFIG + "-default";
    
    public static final String GEN_CONFIG_COMP = GEN_CONFIG + "-comp";
     /**
      * 常量 CLUSTER_MODE 设置集群工作状态,true 或 false
      * 默认状态下 CLUSTER_MODE 为 false
      */
    public static final String CLUSTER_MODE = "--cluster-mode";
     /**
      * 常量 CLUSTER_NODES 用来设置集群中的节点列表
      */
    public static final String CLUSTER_NODES = "--cluster-nodes";
     /** Field description */
    public static final String CLUSTER_LISTEN = "cluster-listen";
     /** Field description */
    public static final String CLUSTER_CONECT = "cluster-connect";
     /** Field description */
    public static final String GEN_CONF = "--gen-";
     /** Field description */
    public static final String GEN_TEST = "--test";
     /** Field description */
    public static final String GEN_COMP_NAME = "--comp-name";
     /** Field description */
    public static final String GEN_COMP_CLASS = "--comp-class";
     /** Field description */
    public static final String GEN_EXT_COMP = "--ext-comp";
     /** Field description */
    public static final String GEN_USER_DB = "--user-db";
     /** Field description */
    public static final String USER_REPO_POOL_CLASS = "--user-repo-pool";
     /** Field description */
    public static final String USER_DOMAIN_POOL_CLASS = "--user-domain-repo-pool";
     /** Field description */
    public static final String GEN_AUTH_DB = "--auth-db";
     /** Field description */
    public static final String AUTH_REPO_POOL_CLASS = "--auth-repo-pool";
     /** Field description */
    public static final String AUTH_DOMAIN_POOL_CLASS = "--auth-domain-repo-pool";
     /** Field description */
    public static final String GEN_USER_DB_URI_PROP_KEY = "user-db-uri";
     /** Field description */
    public static final String GEN_USER_DB_URI = "--" + GEN_USER_DB_URI_PROP_KEY;
     /** Field description */
    public static final String GEN_AUTH_DB_URI = "--auth-db-uri";
     /** Field description */
    public static final String GEN_ADMINS = "--admins";
     /** Field description */
    public static final String GEN_TRUSTED = "--trusted";
     /** Field description */
    public static final String GEN_VIRT_HOSTS = "--virt-hosts";
     /** Field description */
    public static final String GEN_SM_PLUGINS = "--sm-plugins";
     /** Field description */
    public static final String GEN_DEBUG = "--debug";
     /** Field description */
    public static final String GEN_DEBUG_PACKAGES = "--debug-packages";
     /** Field description */
    public static final String GEN_MAX_QUEUE_SIZE = "--max-queue-size";
     /** Field description */
    public static final String GEN_SCRIPT_DIR = "--script-dir";
     /** Field description */
    public static final String GEN_SREC_DB = "--gen-srec-db";
     /** Field description */
    public static final String GEN_SREC_DB_URI = "--gen-srec-db-uri";
     /** Field description */
    public static final String GEN_SREC_ADMINS = "--gen-srec-admins";
     /** Field description */
    public static final String MONITORING = "--monitoring";
     /** Field description */
    public static final String USER_REPO_POOL_SIZE = "--user-repo-pool-size";
     /** Field description */
    public static final String STRINGPREP_PROCESSOR = "--stringprep-processor";
     /** Field description */
    public static final String XML_REPO_CLASS_PROP_VAL = "tigase.db.xml.XMLRepository";
     /** Field description */
    public static final String MYSQL_REPO_CLASS_PROP_VAL = "tigase.db.jdbc.JDBCRepository";
     /** Field description */
    public static final String DERBY_REPO_CLASS_PROP_VAL = "tigase.db.jdbc.JDBCRepository";
     /** Field description */
    public static final String PGSQL_REPO_CLASS_PROP_VAL = "tigase.db.jdbc.JDBCRepository";
     /** Field description */
    public static final String TIGASE_AUTH_REPO_CLASS_PROP_VAL = "tigase.db.jdbc.TigaseAuth";
     /** Field description */
    public static final String TIGASE_CUSTOM_AUTH_REPO_CLASS_PROP_VAL = "tigase.db.jdbc.TigaseCustomAuth";
     /** Field description */
    public static final String DRUPALWP_REPO_CLASS_PROP_VAL = "tigase.db.jdbc.DrupalWPAuth";
     /** Field description */
    public static final String LIBRESOURCE_REPO_CLASS_PROP_VAL = "tigase.db.jdbc.LibreSourceAuth";
     /** Field description */
    public static final String SHARED_USER_REPO_PROP_KEY = "shared-user-repo";
     /** Field description */
    public static final String SHARED_USER_REPO_PARAMS_PROP_KEY = "shared-user-repo-params";
     /** Field description */
    public static final String SHARED_AUTH_REPO_PROP_KEY = "shared-auth-repo";
     /** Field description */
    public static final String SHARED_AUTH_REPO_PARAMS_PROP_KEY = "shared-auth-repo-params";
     /** Field description */
    public static final String XML_REPO_URL_PROP_VAL = "user-repository.xml";
     /** Field description */
    public static final String MYSQL_REPO_URL_PROP_VAL ="jdbc:mysql://localhost/tigase?user=root&password=mypass";
     /** Field description */
    public static final String DERBY_REPO_URL_PROP_VAL = "jdbc:derby:tigase-derbydb;create=true";
     /** Field description */
    public static final String PGSQL_REPO_URL_PROP_VAL = "jdbc:postgresql://localhost/tigase?user=tigase";
     /** Field description */
    public static final String TIGASE_AUTH_REPO_URL_PROP_VAL = "jdbc:mysql://localhost/tigasedb?user=tigase_user&password=mypass";
     /** Field description */
    public static final String DRUPAL_REPO_URL_PROP_VAL = "jdbc:mysql://localhost/drupal?user=root&password=mypass";
     /** Field description */
    public static final String LIBRESOURCE_REPO_URL_PROP_VAL = "jdbc:postgresql://localhost/libresource?user=demo";
     /** Field description */
    public static final String DEF_SM_NAME = "sess-man";
     /** Field description */
    public static final String DEF_MONITOR_NAME = "monitor";
     /** Field description */
    public static final String DEF_C2S_NAME = "c2s";
     /** Field description */
    public static final String DEF_S2S_NAME = "s2s";
     /** Field description */
    public static final String DEF_EXT_COMP_NAME = "ext-comp";
     /** Field description */
    public static final String DEF_COMP_PROT_NAME = "ext";
     /** Field description */
    public static final String DEF_CL_COMP_NAME = "cl-comp";
     /** Field description */
    public static final String DEF_SSEND_NAME = "ssend";
     /** Field description */
    public static final String DEF_SRECV_NAME = "srecv";
     /** Field description */
    public static final String DEF_BOSH_NAME = "bosh";
     /** Field description */
    public static final String DEF_STATS_NAME = "stats";
     /** Field description */
    public static final String DEF_CLUST_CONTR_NAME = "cluster-contr";
     /** Field description */
    public static final String DEF_VHOST_MAN_NAME = "vhost-man";
     /** Field description */
    public static final String ROUTER_COMP_CLASS_NAME = "tigase.server.MessageRouter";
     /** Field description */
    public static final String C2S_COMP_CLASS_NAME = "tigase.server.xmppclient.ClientConnectionManager";
     /** Field description */
    public static final String C2S_CLUST_COMP_CLASS_NAME = "tigase.cluster.ClientConnectionClustered";
     /** Field description */
    public static final String S2S_COMP_CLASS_NAME = "tigase.server.xmppserver.S2SConnectionManager";
     /** Field description */
    public static final String S2S_CLUST_COMP_CLASS_NAME = "tigase.cluster.S2SConnectionClustered";
     /** Field description */
    public static final String SM_COMP_CLASS_NAME = "tigase.server.xmppsession.SessionManager";
     /** Field description */
    public static final String SM_CLUST_COMP_CLASS_NAME = "tigase.cluster.SessionManagerClustered";
     /** Field description */
    public static final String EXT_COMP_CLASS_NAME = "tigase.server.xmppcomponent.ComponentConnectionManager";
     /** Field description */
    public static final String MONITOR_CLASS_NAME = "tigase.server.monitor.MonitorComponent";
     /** Field description */
    public static final String MONITOR_CLUST_CLASS_NAME = "tigase.server.monitor.MonitorClustered";
     /** Field description */
    public static final String COMP_PROT_CLASS_NAME = "tigase.server.ext.ComponentProtocol";
     /** Field description */
    public static final String CL_COMP_CLASS_NAME = "tigase.cluster.ClusterConnectionManager";
     /** Field description */
    public static final String SSEND_COMP_CLASS_NAME = "tigase.server.ssender.StanzaSender";
     /** Field description */
    public static final String SRECV_COMP_CLASS_NAME = "tigase.server.sreceiver.StanzaReceiver";
     /** Field description */
    public static final String BOSH_COMP_CLASS_NAME = "tigase.server.bosh.BoshConnectionManager";
     /** Field description */
    public static final String STATS_CLASS_NAME = "tigase.stats.StatisticsCollector";
     /** Field description */
    public static final String CLUSTER_CONTR_CLASS_NAME = "tigase.cluster.ClusterController";
     /** Field description */
    public static final String VHOST_MAN_CLASS_NAME = "tigase.vhosts.VHostManager";
     /** Field description */
    public static final String USER_REPO_URL_PROP_KEY = "user-repo-url";
     /** Field description */
    public static final String USER_REPO_PARAMS_NODE = "user-repo-params";
     /** Field description */
    public static final String USER_REPO_POOL_SIZE_PROP_KEY = "user-repo-pool-size";
     /** Field description */
    public static final String USER_REPO_DOMAINS_PROP_KEY = "user-repo-domains";
     /** Field description */
    public static final String AUTH_REPO_DOMAINS_PROP_KEY = "auth-repo-domains";
     /** Field description */
    public static final String AUTH_REPO_URL_PROP_KEY = "auth-repo-url";
     /** Field description */
    public static final String AUTH_REPO_PARAMS_NODE = "auth-repo-params";
     /** Field description */
    public static final String HOSTNAMES_PROP_KEY = "hostnames";
     /** Field description */
    public static final String ADMINS_PROP_KEY = "admins";
     /** Field description */
    public static final String TRUSTED_PROP_KEY = "trusted";
     /** Field description */
    public static final String DEF_HOSTNAME_PROP_KEY = "def-hostname";
     /** Field description */
    public static final String COMPONENT_ID_PROP_KEY = "component-id";
     /** Field description */
    public static final String CLUSTER_NODES_PROP_KEY = "cluster-nodes";
     //~--- get methods ----------------------------------------------------------
     /**
       * 返回对象的默认配置信息
       * @param params
       * @return
       */
    Map getDefaults(Map params);
     //~--- set methods ----------------------------------------------------------
     /**
       * 批量设置配置信息
       * @param properties
       */
    void setProperties(Map properties);
    }
  4. tigase.disco.XMPPService – 实现了这个对象的类可以对“ServiceDiscovery”请求做出响应。
    /**
     * Interface XMPPService
     * <p/>
     * 实现了这个接口的对象可以对“ServiceDiscovery”请求做出应答。
     * ManagerRouter管理所有的“ServiceDiscovery”请求
     */
    public interface XMPPService extends ServerComponent {
    
        /**
         * 一个方便的服务发现信息xmlns字符串常量
         */
        public static final String INFO_XMLNS =
                "http://jabber.org/protocol/disco#info";
        /**
         * 一个方便的服务发现对象xmlns字符串常量
         */
        public static final String ITEMS_XMLNS =
                "http://jabber.org/protocol/disco#items";
        /**
         * 一个方便的服务发现 二进制流特性 常量
         */
        public static final String[] DEF_FEATURES = {INFO_XMLNS, ITEMS_XMLNS};
        /**
         * A convenience constant with component features related to ad-hoc commands.
         */
        public static final String[] CMD_FEATURES =
                {
                        "http://jabber.org/protocol/commands", "jabber:x:data"};
    
        /**
         * 为component返回服务发现信息。如果jid是null,那么返回top level的服务发现信息。
         * SessionMananger可以返回top level的服务发现信息,其他component不行。
         *
         * @param node 服务发现的对象节点,如果是null,则返回top level的服务发现信息
         * @param jid  服务发现请求的接收者,“被询问人”
         * @param from 服务发现请求的发出者. “询问人”。一些服务发现信息仅能提供给系统管理器
         * @return returns 一个 XML 元素格式的服务发现数据
         */
        Element getDiscoInfo(String node, JID jid, JID from);
    
        /**
         * 为component返回服务发现对象。 如果jid是空,则返回top level的服务发现对象,
         * SessionMananger可以返回top level的服务发现对象,其他component则返回null。
         *
         * @param node 服务发现的对象节点
         * @param jid  服务发现请求的接收者,“被询问人”
         * @param from 服务发现请求的发出者. “询问人”。一些服务发现对象仅能提供给系统管理器
         * @return 一个服务发现对象的列表,对于top level请求,返回component自己的服务发现对象
         */
        List<Element> getDiscoItems(String node, JID jid, JID from);
    
        /**
         * 获取top level的服务发现特性
         *
         * @param from 请求发出者的地址。 一些服务发现特性仅能返回给系统管理器,
         *             所以component需要检查请求的发起者是不是系统管理器,并返回响应的内容。
         * @return 服务发现特性列表
         */
        List<Element> getDiscoFeatures(JID from);
    
    }
  5. tigase.stats.StatisticsContainer – 实现了这个对象的类可以返回运行时的统计信息。任何一个对象都可以实现这个接口用来收集统计信息
    public interface StatisticsContainer extends ServerComponent {
        public void getStatistics(StatisticsList list);
    }
分享到:
评论

相关推荐

    Tigase 概述

    Tigase 是一个功能强大且灵活的 XMPP 服务器,提供了许多出色的特性和功能,以下是其主要特点和实现的 XMPP 扩展协议: 为什么选择 Tigase Tigase 完全实现了 XMPP 协议,除了全面实施的两个核心协议,它支持...

    tigase-server-tigase-server-8.0.0.zip 源码

    Tigase服务器是一款开源的XMPP(Extensible Messaging and Presence Protocol)服务器,用于构建实时通信系统,如即时消息、语音和视频通话、群聊等。它的源码是用Java语言编写的,具有高度可扩展性和模块化设计,...

    tigase-local

    在提供的"tigase-local"压缩包中,只有一个文件名`tigase-local`,这可能是指一个包含特定配置或插件的子目录,或者是一个自定义的启动脚本。具体功能需要根据实际文件内容来判断。 **五、常见问题及解决方法** 1....

    tigase http-api 源码部署

    Tigase是一个开源的XMPP(可扩展消息与出席协议,最初被称为 Jabber)服务器,它允许实时通讯和在线状态信息的交换。HTTP API是Tigase服务器的一个可选模块,它允许通过HTTP请求进行与服务器的交互,这样的方式对于...

    Tigase Server 7.0.1 源代码

    Tigase Server,作为一款基于Java语言开发的轻量级、可伸缩的Jabber/XMPP服务器,自诞生以来就以其高效能和高并发能力受到业界的广泛关注。在7.0.1版本中,Tigase Server继续优化了性能,增强了稳定性,并提供了更多...

    tigase 内部处理流程

    - 对于每一个`ServerComponent`,都会调用`registr.addComponent(comp)`方法,确保所有组件都被正确注册。 3. **组件初始化**: - 通过`setProperties(Map, Object&gt; props)`方法完成组件初始化。 - 分离所有组件...

    tigase-server_配置好的.zip

    首先,我们来看一下"Tigase-server_配置好的.zip"这个压缩包,其中包含的"tigase-server-tigase-server-8.0.0"文件是Tigase服务器的一个特定版本,包含了运行服务器所需的所有文件和库。在开始配置之前,确保你的...

    Tigase学习笔记整理

    组件(Component)是Tigase服务器的基础,其中`tigase.server.ServerComponent`是最顶层的组件接口,所有组件都必须实现这个接口。`tigase.server.MessageReceiver`接口用于接收和处理数据包,如果你的组件需要像...

    XMPP_tigase_IM服务部署安装

    Tigase是一个开源项目,使用Java语言编写,遵循Jabber(即XMPP)协议标准,为用户提供了一个高性能且可扩展的消息传递和即时通讯(IM)平台。Tigase的核心优势在于其能够支持大量的并发用户连接,并通过集群技术实现...

    tigase组件

    Tigase是一款开源的XMPP服务器,用于实现即时通讯和在线状态服务。它采用Java语言编写,具有跨平台性,并且支持多种扩展协议,如多用户聊天(MUC)、消息存档(Message Archiving)和发布订阅(PubSub)等。在你提供...

    tigase 集群设置

    Tigase是一个用Java编写的开源XMPP服务器,它具有高性能、高度可伸缩和模块化的特点。在构建需要处理大量并发用户和高消息吞吐量的系统时,部署一个Tigase集群变得非常必要。集群模式允许将多个Tigase服务器实例组合...

    tigase-utils-3.5.1.jar

    tigase相关jar包

    tigase-web-chat

    【Tigase Web Chat】是基于Tigase服务器的一个实时通信解决方案,专为构建Web端的聊天和协作应用而设计。Tigase是一款开源、跨平台的XMPP(Extensible Messaging and Presence Protocol)服务器,支持多种协议,如...

    Spark客户端连接Tigase

    Spark连接Tigase服务器,完整的步骤,很清晰的看到。大家可以参考。

    tigase开发手册

    Tigase开发手册是一份专业的文档,专门针对Tigase服务器的开发与定制进行说明和指导。Tigase是一个开源的XMPP(可扩展消息与出席协议)服务器,用于即时通讯、协同工作以及构建类似Jabber的通信平台。本文将基于文档...

    tigase-server.7.0.2

    《Tigase服务器7.0.2:一个强大的XMPP服务器详解》 Tigase服务器,作为一款开源的、跨平台的XMPP(Extensible Messaging and Presence Protocol)服务器,为全球范围内的即时通讯和在线状态服务提供了高效且可扩展...

    tigase 5.2完整代码数据库eclipse完美启动版本

    Tigase是一个开源的XMPP(Extensible Messaging and Presence Protocol)服务器,用于构建即时通讯和在线状态服务。Tigase 5.2是该服务器的一个版本,提供了强大的可扩展性和稳定性,支持多种协议如XMPP、Jabber等。...

    tigase-server 组件

    Tigase服务器是一款开源的XMPP(Extensible Messaging and Presence Protocol)服务器,它支持即时通讯、在线状态服务、多用户聊天室以及各种扩展协议。在IT行业中,掌握Tigase服务器的配置和使用对于开发实时通信...

    tigase monitor配置

    Tigase Monitor是一款用于监控Tigase XMPP服务器性能和状态的工具,特别适用于Tigase 7.0版本。本文将详细介绍如何在Tigase 7.0上配置Monitor模块,包括客户端和服务器部分。 首先,确保你已安装了Java Development...

    tigase快速配置

    Tigase是一款开源的XMPP(Extensible Messaging and Presence Protocol)服务器,用于实现即时通讯和在线状态服务。在本文中,我们将深入探讨如何在Linux系统下快速配置和部署Tigase服务器,以帮助您搭建自己的即时...

Global site tag (gtag.js) - Google Analytics