cmsfilesharingplugin.java

Myjxta的源代码 基于JXTA的P2P即时通信系统

package net.jxta.myjxta.plugins.share;

import net.jxta.myjxta.MyJXTA;
import net.jxta.myjxta.plugin.IPluginNotificationHandler;
import net.jxta.myjxta.plugin.Plugin;
import net.jxta.myjxta.plugin.PluginBase;
import net.jxta.myjxta.share.IShareManager;
import net.jxta.myjxta.share.IShareManagerProvider;
import net.jxta.myjxta.util.Group;
import net.jxta.myjxta.util.Resources;

import java.util.ArrayList;
import java.util.ResourceBundle;
import java.util.logging.Level;
import java.util.logging.Logger;

public final class CmsFileSharingPlugin extends PluginBase implements Plugin, IPluginNotificationHandler, IShareManagerProvider {

    private static final Logger LOG = Logger.getLogger(CmsFileSharingPlugin.class.getName());
    private static final ResourceBundle STRINGS = Resources.getStrings();
//    HTTPServer m_httpServer=null;


    private final ArrayList<Group> m_joinedGroups = new ArrayList<Group>();


    public CmsFileSharingPlugin() {
        LOG.log(java.util.logging.Level.FINE,
                "CmsFileSharingPlugin Constructor called");
    }


    public void start() {
        super.start();

        //we want a simple test menu entry on the peer nodes
        //m_container.registerPopupProvider(this);

        //start can be called multiple times.. maybe we already have some joined groups... start listeners for em
        for (Group group : m_joinedGroups) {
            startListenerForGroup(group);
        }
    }

    public void stop() {
        //m_container.removePopupProvider(this);
        for (Group group : m_joinedGroups) {
            stopListenerForGroup(group);
        }
        super.stop();
    }

    public void destroy() {
        if (m_running) {
            stop();
        }
        super.destroy();
    }

    public String getName() {
        return "CMS FileSharing Plugin";
    }

    // END OF PLUGIN API

    // HELPER METHODS

    private void startListenerForGroup(Group p_group) {
        if (p_group.isVisible()) {
            m_container.getMyJxta().setStatus(STRINGS.getString("status.share.register"));

            try {
                ShareManager.getShareManager(m_container.getMyJxta(), p_group, true);
            } catch (Throwable t) {
                // Catch exception so that Main Initializer does not fail.
                if (net.jxta.logging.Logging.SHOW_SEVERE && LOG.isLoggable(Level.SEVERE)) {
                    LOG.log(Level.SEVERE, "Caught unexpected Exception", t);
                }
            }
        }


    }

    private void stopListenerForGroup(Group p_group) {
        m_container.getMyJxta().setStatus(STRINGS.getString("status.share.resign") + ": "
                + p_group.getName());

        // stop the share manger
        ShareManager shareManager = ShareManager.getShareManager(m_container.getMyJxta(), p_group,
                false);
        if (shareManager != null) {
            shareManager.unshareAll();
            shareManager.stop();
        }

    }

    public IPluginNotificationHandler getPluginNotificationHander() {
        return this;  //for now we will implement this interface ourselve, it it will grow so we cant stay here...
    }

    public void groupJoined(Group p_group) {
        if (!p_group.isVisible())
            return;

        m_joinedGroups.add(p_group);

        if (isRunning()) {
            startListenerForGroup(p_group);
        }
    }

    public void groupResigned(Group p_group) {
        if (!p_group.isVisible())
            return;

        m_joinedGroups.remove(p_group);
        if (isRunning()) {
            stopListenerForGroup(p_group);
        }
    }

    //this may be fired multiple times, for example if we change from rdv to peer node
    public void groupStateChanged(Group p_group) {
        if (!p_group.isVisible())
            return;

        if (!isRunning()) { // if we are not active we are not interested in connection events
            return;
        }


        if (p_group.isConnected()) {
            //we are connected
            if (p_group.isOwnPeerRdv()) {
                //we are a Rendeszvous
            } else {
                //we are a simple peer
            }
        } else {
            //we lost the connection to the group (so we are not a rdv and we dont have a rdv right now
        }
    }

    public IShareManager getShareManager(MyJXTA myJXTA, Group group, boolean p_create) {
        if (!m_running) {
            start();
        }
        return ShareManager.getShareManager(myJXTA, group, p_create);

    }
}