More clustering work.

git-svn-id: http://svn.igniterealtime.org/svn/repos/openfire/trunk@9217 b35dd754-fafc-0310-a699-88a17e54d16e

src/i18n/openfire_i18n_en.properties

@@ -233,13 +233,14 @@
 ##      Updated key: 'sidebar.server-settings.descr'
 ##      Updated key: 'index.title'
 ##      Updated key: 'index.title.info'
+##      Updated key: 'index.home'
+##      Updated key: 'index.jvm'
+##      Added section 'system.clustering.*'
 ##      Added key: 'user.roster.filter'
 ##      Added key: 'user.roster.filter.all'
 ##      Added key: 'user.roster.filter.noshared'
 ##      Added key: 'user.roster.filter.onlyshared'
 
-
-
 # Openfire
 
 short.title = Openfire
@@ -256,6 +257,8 @@ tab.server.descr=Click to manage server settings
         sidebar.system-props.descr=Click to manage server properties
         sidebar.server-locale=Language and Time
         sidebar.server-locale.descr=Click to set the language and time zone
+        sidebar.system-clustering=Clustering
+        sidebar.system-clustering.descr=Click to manage clustering settings
         sidebar.system-cache=Cache Summary
         sidebar.system-cache.descr=Click to manage data caches
         sidebar.server-db=Database
@@ -754,7 +757,7 @@ index.title.info=Below you will find server information, ports being used and la
 index.properties=Server Properties
 index.uptime=Server Uptime:
 index.version=Version:
-index.home=Server Home:
+index.home=Server Directory:
 index.certificate-warning=Found RSA certificate that is not valid for the server domain.
 index.server_name=Server Name:
 index.server_port=Server Ports
@@ -763,7 +766,7 @@ index.port_type=NORMAL
 index.port_type1=TLS (SSL)
 index.domain_name=Domain Name(s):
 index.environment=Environment
-index.jvm=JVM Version and Vendor:
+index.jvm=Java Version:
 index.app=Appserver:
 index.os=OS / Hardware:
 index.local=Locale / Timezone:
@@ -1944,10 +1947,6 @@ user.roster.items_per_page=Items per page
 user.roster.edit=Edit
 user.roster.add=Add New Item
 user.roster.none_found=No roster items found.
-user.roster.filter=Show
-user.roster.filter.all=All roster items
-user.roster.filter.noshared=No shared groups
-user.roster.filter.onlyshared=Only shared groups
 user.roster.click_view=Click to view...
 user.roster.deleted=Roster item deleted successfully.
 user.roster.delete.title=Delete Roster Item
@@ -2448,3 +2447,30 @@ muc.room.occupants.user=User
 muc.room.occupants.nickname=Nickname
 muc.room.occupants.role=Role
 muc.room.occupants.affiliation=Affiliation
+
+# Clustering page
+
+system.clustering.title=Clusterting
+system.clustering.info=Clustering allows the server to scale a lot more and at the same time avoid a single point of \
+  failure. Use the form to below to enable or disable clustering for this system. After disabling clustering this \
+  system will leave the cluster but the cluster will remain active with the remaining cluster nodes. When clustering \
+  is enabled this page will show information about the load each cluster node is having.
+system.clustering.enabled=Clustering was enabled successfully.
+system.clustering.disabled=Clustering was disabled successfully.
+system.clustering.failed-start=Failed to start or join an existing cluster. Check the error log for more information.
+system.clustering.enabled.legend=Clustering Enabled
+system.clustering.label_disable=Disabled
+system.clustering.label_disable_info=This system is not running in a cluster.
+system.clustering.label_enable=Enabled
+system.clustering.label_enable_info=This system is part of a cluster.
+system.clustering.label_enable_info2=Note: enabling clustering may take up to 30 seconds.
+system.clustering.overview.label=Cluster Overview
+system.clustering.overview.info=Below is an overview of your cluster. You have {0} node(s) running and you are \
+  licensed to {1} node(s) in this cluster. To see more information, click each node. The row in {2}yellow{3} \
+  indicates the local node.
+system.clustering.overview.node=Nodes
+system.clustering.overview.joined=Joined
+system.clustering.overview.clients=Clients
+system.clustering.overview.incoming_servers=Incoming Servers
+system.clustering.overview.outgoing_servers=Outgoing Servers
+system.clustering.overview.memory=Memory

src/i18n/openfire_i18n_es.properties

@@ -511,7 +511,7 @@ index.title.info=A continuaci\u00f3n est\u00e1n las propiedades de este servidor
 index.properties=Propiedades del Servidor
 index.uptime=Tiempo de Actividad del Servidor:
 index.version=Versi\u00f3n:
-index.home=Ruta al Openfire:
+index.home=Ruta al servidor:
 index.server_name=Nombre del Servidor:
 index.server_port=Puertos del Servidor
 index.server_ip=IP:Puerto, Seguridad:
@@ -519,7 +519,7 @@ index.port_type=NORMAL
 index.port_type1=TLS (SSL)
 index.domain_name=Nombre(s) de Dominio:
 index.environment=Ambiente
-index.jvm=Versi\u00f3n y Fabricante de la JVM:
+index.jvm=Versi\u00f3n de Java:
 index.app=Servidor de Aplicaciones:
 index.os=SO / Hardware:
 index.local=Idioma / Huso Horario:
@@ -2197,3 +2197,28 @@ muc.room.occupants.title=Ocupantes en el cuarto
 muc.room.occupants.user=Usuario
 index.cs_blog=Novedades de Ignite Realtime
 index.cs_blog.unavilable=No se ha podido leer novedades de Ignite Realtime
+system.clustering.disabled=Clustering fue deshabilitado exitosamente.
+system.clustering.enabled=Clustering fue habilitado exitosamente.
+system.clustering.enabled.legend=Clustering Habilitado
+system.clustering.failed-start=No se ha podido iniciar o unirse al cluster. Verifique el log de errores para m\u00e1s informaci\u00f3n.
+system.clustering.info=Clustering permite al servidor escalar a un numero mucho mayor de clientes y al mismo tiempo evitar tener \
+un unico punto de falla. Utilice el siguiente formulario para habilitar o deshabilitar clustering para este \
+sistema. Luego de deshabilitar clustering este servidor dejar\u00e1 el cluster pero el cluster seguir\u00e1 funcionando \
+con los restantes nodos. Cuando clustering este habilitado esta p\u00e1gina mostrar\u00e1 informaciu00f3n sobre la carga de \
+cada nodo del cluster.
+system.clustering.label_disable=Deshabilitado
+system.clustering.label_disable_info=Este sistema no es parte del cluster.
+system.clustering.label_enable=Habilitado
+system.clustering.label_enable_info=Este sistema es parte del cluster.
+system.clustering.label_enable_info2=Nota: habilitar el cluster puede tardar hasta 30 segundos.
+system.clustering.overview.clients=Clientes
+system.clustering.overview.incoming_servers=Servidores Entrantes
+system.clustering.overview.info=A continuaciu00f3n se puede observer el estado del cluster. Ud. tiene {0} nodo(s) corriendo y esta \
+habilitado para tener {1} nodo(s) en este cluster. Para ver m\u00e1s informacion haga click en cada \
+nodo. La fila en {2}amarillo{3} indica el nodo local.
+system.clustering.overview.joined=Conectado
+system.clustering.overview.label=Vision del Cluster
+system.clustering.overview.memory=Memmoria
+system.clustering.overview.node=Nodos
+system.clustering.overview.outgoing_servers=Servidores Salientes
+system.clustering.title=Clustering
\ No newline at end of file

src/java/org/jivesoftware/openfire/RoutingTable.java

@@ -255,6 +255,15 @@ public interface RoutingTable {
      */
     Collection<String> getServerHostnames();
 
+    /**
+     * Returns the number of outgoing server sessions hosted in this JVM. When runing inside of
+     * a cluster you will need to get this value for each cluster node to learn the total number
+     * of outgoing server sessions.
+     *
+     * @return the number of outgoing server sessions hosted in this JVM.
+     */
+    int getServerSessionsCount();
+
     /**
      * Returns the list of routes associated to the specified route address. When asking
      * for routes to a remote server then the requested JID will be included as the only

src/java/org/jivesoftware/openfire/SessionManager.java

@@ -65,7 +65,9 @@ public class SessionManager extends BasicModule implements ClusterEventListener
 
     /**
      * Counter of user connections. A connection is counted just after it was created and not
-     * after the user became available.
+     * after the user became available. This counter only considers sessions local to this JVM.
+     * That means that when running inside of a cluster you will need to add up this counter
+     * for each cluster node. 
      */
     private final AtomicInteger connectionsCounter = new AtomicInteger(0);
 
@@ -862,6 +864,21 @@ public class SessionManager extends BasicModule implements ClusterEventListener
         return total;
     }
 
+    /**
+     * Returns number of sessions coming from remote servers. <i>Current implementation is only counting
+     * sessions connected to this JVM and not adding up sessions connected to other cluster nodes.</i>
+     *
+     * @param onlyLocal true if only sessions connected to this JVM will be considered. Otherwise count cluster wise.
+     * @return number of sessions coming from remote servers.
+     */
+    public int getIncomingServerSessionsCount(boolean onlyLocal) {
+        int total = localSessionManager.getIncomingServerSessions().size();
+        if (!onlyLocal) {
+            // TODO Implement this when needed
+        }
+        return total;
+    }
+
     /**
      * Returns the number of sessions for a user that are available. For the count
      * of all sessions for the user, including sessions that are just starting

src/java/org/jivesoftware/openfire/cluster/ClusterManager.java

@@ -19,8 +19,8 @@ import org.jivesoftware.util.cache.CacheFactory;
 import org.jivesoftware.util.lock.LocalLockFactory;
 import org.jivesoftware.util.lock.LockManager;
 
-import java.util.Queue;
 import java.util.Collection;
+import java.util.Queue;
 import java.util.concurrent.BlockingQueue;
 import java.util.concurrent.ConcurrentLinkedQueue;
 import java.util.concurrent.LinkedBlockingQueue;
@@ -32,8 +32,7 @@ import java.util.concurrent.LinkedBlockingQueue;
  * @author Gaston Dombiak
  */
 public class ClusterManager {
-
-    private static String CLUSTER_PROPERTY_NAME = "clustering.enabled";
+    public static String CLUSTER_PROPERTY_NAME = "clustering.enabled";
     private static Queue<ClusterEventListener> listeners = new ConcurrentLinkedQueue<ClusterEventListener>();
     private static BlockingQueue<Event> events = new LinkedBlockingQueue<Event>();
 
@@ -184,7 +183,6 @@ public class ClusterManager {
      * met again then this JVM stopped being the senior member.
      */
     public static void fireLeftCluster() {
-        CacheFactory.leftCluster();
         // Now notify rest of the listeners
         for (ClusterEventListener listener : listeners) {
             try {
@@ -303,13 +301,13 @@ public class ClusterManager {
         }
         JiveGlobals.setXMLProperty(CLUSTER_PROPERTY_NAME, Boolean.toString(enabled));
         if (!enabled) {
-            CacheFactory.stopClustering();
+            shutdown();
         }
         else {
             // Reload Jive properties. This will ensure that this nodes copy of the
             // properties starts correct.
            JiveProperties.getInstance().init();
-           CacheFactory.startClustering();
+           startup();
         }
     }
 
@@ -355,6 +353,16 @@ public class ClusterManager {
         return CacheFactory.getClusterNodesInfo();
     }
 
+    /**
+     * Returns the maximum number of cluster members allowed. A value of 0 will
+     * be returned when clustering is not allowed.
+     *
+     * @return the maximum number of cluster members allowed or 0 if clustering is not allowed.
+     */
+    public static int getMaxClusterNodes() {
+        return CacheFactory.getMaxClusterNodes();
+    }
+
     /**
      * Returns the id of the node that is the senior cluster member. When not in a cluster the returned
      * node id will be the {@link XMPPServer#getNodeID()}.

src/java/org/jivesoftware/openfire/spi/RoutingTableImpl.java

@@ -541,6 +541,10 @@ public class RoutingTableImpl extends BasicModule implements RoutingTable, Clust
         return serversCache.keySet();
     }
 
+    public int getServerSessionsCount() {
+        return localRoutingTable.getServerRoutes().size();
+    }
+
     public boolean hasClientRoute(JID jid) {
         return usersCache.containsKey(jid.toString()) || isAnonymousRoute(jid);
     }

src/java/org/jivesoftware/util/cache/CacheFactory.java

@@ -9,6 +9,8 @@ package org.jivesoftware.util.cache;
 
 import org.jivesoftware.openfire.XMPPServer;
 import org.jivesoftware.openfire.XMPPServerListener;
+import org.jivesoftware.openfire.cluster.ClusterEventListener;
+import org.jivesoftware.openfire.cluster.ClusterManager;
 import org.jivesoftware.openfire.cluster.ClusterNodeInfo;
 import org.jivesoftware.openfire.container.Plugin;
 import org.jivesoftware.openfire.container.PluginClassLoader;
@@ -167,6 +169,15 @@ public class CacheFactory {
         return cacheFactoryStrategy.getClusterNodesInfo();
     }
 
+    /**
+     * Returns the maximum number of cluster members allowed. A value of 0 will
+     * be returned when clustering is not allowed.
+     *
+     * @return the maximum number of cluster members allowed or 0 if clustering is not allowed.
+     */
+    public static int getMaxClusterNodes() {
+        return cacheFactoryStrategy.getMaxClusterNodes();
+    }
     /**
      * Invokes a task on other cluster members in an asynchronous fashion. The task will not be
      * executed on the local cluster member. If clustering is not enabled, this method
@@ -279,9 +290,23 @@ public class CacheFactory {
                                 destroyed = true;
                             }
                         });
+                        ClusterManager.addListener(new ClusterEventListener() {
+                            public void joinedCluster() {}
+
+                            public void joinedCluster(byte[] nodeID) {}
+
+                            public void leftCluster() {
+                                destroyed = true;
+                                ClusterManager.removeListener(this);
+                            }
+
+                            public void leftCluster(byte[] nodeID) {}
+
+                            public void markedAsSeniorClusterMember() {}
+                        });
 
                         // Run the timer indefinitely.
-                        while (!destroyed) {
+                        while (!destroyed && ClusterManager.isClusteringEnabled()) {
                             // Publish cache stats for this cluster node (assuming clustering is
                             // enabled and there are stats to publish).
                             try {
@@ -298,6 +323,7 @@ public class CacheFactory {
                                 // Ignore.
                             }
                         }
+                        statsThread = null;
                         Log.debug("Cache stats thread terminated.");
                     }
                 };

src/java/org/jivesoftware/util/cache/CacheFactoryStrategy.java

@@ -63,6 +63,14 @@ public interface CacheFactoryStrategy {
      */
     Collection<ClusterNodeInfo> getClusterNodesInfo();
 
+    /**
+     * Returns the maximum number of cluster members allowed. A value of 0 will
+     * be returned when clustering is not allowed.
+     *
+     * @return the maximum number of cluster members allowed or 0 if clustering is not allowed.
+     */
+    int getMaxClusterNodes();
+    
     /**
      * Returns a byte[] that uniquely identifies this senior cluster member or <tt>null</tt>
      * when not in a cluster.

src/java/org/jivesoftware/util/cache/DefaultLocalCacheStrategy.java

@@ -7,10 +7,10 @@
  */
 package org.jivesoftware.util.cache;
 
+import org.jivesoftware.openfire.cluster.ClusterNodeInfo;
 import org.jivesoftware.util.JiveConstants;
 import org.jivesoftware.util.JiveGlobals;
 import org.jivesoftware.util.Log;
-import org.jivesoftware.openfire.cluster.ClusterNodeInfo;
 
 import java.util.Collection;
 import java.util.Collections;
@@ -164,6 +164,10 @@ public class DefaultLocalCacheStrategy implements CacheFactoryStrategy {
         return Collections.emptyList();
     }
 
+    public int getMaxClusterNodes() {
+        return 0;
+    }
+
     public byte[] getSeniorClusterMemberID() {
         return null;
     }

src/resources/jar/admin-sidebar.xml

@@ -28,6 +28,11 @@
                   url="server-locale.jsp"
                   description="${sidebar.server-locale.descr}"/>
 
+            <!-- Clustering -->
+            <item id="system-clustering" name="${sidebar.system-clustering}"
+                  url="system-clustering.jsp"
+                  description="${sidebar.system-clustering.descr}"/>
+
             <!-- System Cache -->
             <item id="system-cache" name="${sidebar.system-cache}"
                   url="system-cache.jsp"

src/web/index.jsp

@@ -8,14 +8,19 @@
   - a copy of which is included in this distribution.
 --%>
 
-<%@ page import="org.apache.mina.transport.socket.nio.SocketAcceptor,
-                 org.jivesoftware.admin.AdminConsole,
-                 org.jivesoftware.openfire.Connection"
+<%@ page import="com.sun.syndication.feed.synd.SyndEntry,
+                 com.sun.syndication.feed.synd.SyndFeed,
+                 com.sun.syndication.fetcher.FeedFetcher"
 %>
-<%@ page import="org.jivesoftware.openfire.ServerPort"%>
-<%@ page import="org.jivesoftware.openfire.XMPPServer"%>
-<%@ page import="org.jivesoftware.openfire.container.AdminConsolePlugin"%>
-<%@ page import="org.jivesoftware.openfire.filetransfer.proxy.FileTransferProxy"%>
+<%@ page import="com.sun.syndication.fetcher.impl.FeedFetcherCache"%>
+<%@ page import="com.sun.syndication.fetcher.impl.HashMapFeedInfoCache"%>
+<%@ page import="org.apache.mina.transport.socket.nio.SocketAcceptor"%>
+<%@ page import="org.jivesoftware.admin.AdminConsole"%>
+<%@ page import="org.jivesoftware.openfire.Connection" %>
+<%@ page import="org.jivesoftware.openfire.ServerPort" %>
+<%@ page import="org.jivesoftware.openfire.XMPPServer" %>
+<%@ page import="org.jivesoftware.openfire.container.AdminConsolePlugin" %>
+<%@ page import="org.jivesoftware.openfire.filetransfer.proxy.FileTransferProxy" %>
 <%@ page import="org.jivesoftware.openfire.http.HttpBindManager" %>
 <%@ page import="org.jivesoftware.openfire.mediaproxy.MediaProxyService" %>
 <%@ page import="org.jivesoftware.openfire.net.SSLConfig" %>
@@ -25,18 +30,12 @@
 <%@ page import="org.jivesoftware.openfire.stun.STUNService" %>
 <%@ page import="org.jivesoftware.openfire.update.Update" %>
 <%@ page import="org.jivesoftware.openfire.update.UpdateManager" %>
+<%@ page import="org.jivesoftware.util.*" %>
 <%@ page import="java.net.InetSocketAddress" %>
 <%@ page import="java.net.SocketAddress" %>
-<%@ page import="java.text.DecimalFormat" %>
 <%@ page import="java.net.URL" %>
+<%@ page import="java.text.DecimalFormat" %>
 <%@ page import="java.util.List" %>
-<%@ page import="org.jivesoftware.util.*" %>
-<%@ page import="com.sun.syndication.fetcher.FeedFetcher" %>
-<%@ page import="com.sun.syndication.fetcher.impl.FeedFetcherCache" %>
-<%@ page import="com.sun.syndication.fetcher.impl.HashMapFeedInfoCache" %>
-<%@ page import="com.sun.syndication.io.FeedException" %>
-<%@ page import="com.sun.syndication.feed.synd.SyndEntry" %>
-<%@ page import="com.sun.syndication.feed.synd.SyndFeed" %>
 
 <%@ taglib uri="http://java.sun.com/jstl/core_rt" prefix="c" %>
 <%@ taglib uri="http://java.sun.com/jstl/fmt_rt" prefix="fmt" %>
@@ -370,7 +369,7 @@
                     List entries = lastBlogFeed.getEntries();
                     for (int i = 0; i < entries.size() && i < 3; i++) {
                         SyndEntry entry = (SyndEntry) entries.get(i); %>
-                        <h5><a href="<%= entry.getLink() %>"><%= entry.getTitle()%></a>,
+                        <h5><a href="<%= entry.getLink() %>" target="_blank"><%= entry.getTitle()%></a>,
                         <span class="jive-blog-date"><%= JiveGlobals.formatDateTime(entry.getPublishedDate())%></span></h5>
                     <% }
 
@@ -384,7 +383,7 @@
                     List entries = lastReleaseFeed.getEntries();
                     for (int i = 0; i < entries.size() && i < 3; i++) {
                         SyndEntry entry = (SyndEntry) entries.get(i); %>
-                        <h5><a href="<%= entry.getLink() %>"><%= entry.getTitle()%></a>,
+                        <h5><a href="<%= entry.getLink() %>" target="_blank"><%= entry.getTitle()%></a>,
                         <span class="jive-blog-date"><%= JiveGlobals.formatDateTime(entry.getPublishedDate())%></span></h5>
                     <% }