pouncelistener.java

用jxse开发的一个p2p通讯软件 有聊天 文件共享 视频3大功能

/*
*  Copyright (c) 2001 Sun Microsystems, Inc.  All rights
*  reserved.
*
*  Redistribution and use in source and binary forms, with or without
*  modification, are permitted provided that the following conditions
*  are met:
*
*  1. Redistributions of source code must retain the above copyright
*  notice, this list of conditions and the following disclaimer.
*
*  2. Redistributions in binary form must reproduce the above copyright
*  notice, this list of conditions and the following discalimer in
*  the documentation and/or other materials provided with the
*  distribution.
*
*  3. The end-user documentation included with the redistribution,
*  if any, must include the following acknowledgment:
*  "This product includes software developed by the
*  Sun Microsystems, Inc. for Project JXTA."
*  Alternately, this acknowledgment may appear in the software itself,
*  if and wherever such third-party acknowledgments normally appear.
*
*  4. The names "Sun", "Sun Microsystems, Inc.", "JXTA" and "Project JXTA"
*  must not be used to endorse or promote products derived from this
*  software without prior written permission. For written
*  permission, please contact Project JXTA at http://www.jxta.org.
*
*  5. Products derived from this software may not be called "JXTA",
*  nor may "JXTA" appear in their name, without prior written
*  permission of Sun.
*
*  THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED
*  WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
*  OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
*  DISCLAIMED.  IN NO EVENT SHALL THE APACHE SOFTWARE FOUNDATION OR
*  ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
*  SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
*  LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
*  USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
*  ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
*  OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT
*  OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
*  SUCH DAMAGE.
*  ====================================================================
*
*  This software consists of voluntary contributions made by many
*  individuals on behalf of Project JXTA.  For more
*  information on Project JXTA, please see
*  <http://www.jxta.org/>.
*
*  This license is based on the BSD license adopted by the Apache Foundation.
*
*  $Id: PounceListener.java,v 1.9 2007/06/10 21:15:14 nano Exp $
*/

package net.jxta.myjxta.dialog.listener;

import net.jxta.logging.Logging;
import net.jxta.myjxta.dialog.Dialog;
import net.jxta.myjxta.dialog.DialogListener;
import net.jxta.myjxta.dialog.DialogMessage;
import net.jxta.myjxta.dialog.DialogMessageWrapper;
import net.jxta.myjxta.util.Resources;

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

/**
 * @author james todd [gonzo at jxta dot org]
 * @author mike mcangus [mcangus at jxta dot org]
 * @version $Id: PounceListener.java,v 1.9 2007/06/10 21:15:14 nano Exp $
 */

public class PounceListener
        implements DialogListener {

    private static final ResourceBundle STRINGS = Resources.getStrings();
    private static final String POUNCE = STRINGS.getString("label.pounce");
    private static final String POUNCE_SUFFIX = STRINGS.getString("label.pounce.suffix");
    private static final String SPACE = " ";
    // private static final String PERIOD = ".";
    private static final int SLEEP = 7 * 1000;
    private static final int MAX_NO_POUNCE = 20 * 1000 * 3 * 20;

    static final Logger LOG = Logger.getLogger(PounceListener.class.getName());

    HashMap<String, Long> cache = null;

    {
        Thread t = new Thread(new Runnable() {
            public void run() {
                while (true) {
                    try {
                        Thread.sleep(SLEEP);
                    } catch (InterruptedException ignored) {
                        // ignored
                    }

                    if (cache != null) {
                        long now = System.currentTimeMillis();
                        long l = 0;
                        String k;

                        for (String s : cache.keySet()) {
                            k = s;
                            l = cache.get(k).longValue();

                            if (now - l >= MAX_NO_POUNCE) {
                                cache.remove(k);
                            }
                        }
                    }
                }
            }
        }, getClass().getName() + ":reap");

        t.setDaemon(true);

        t.start();
    }

    /**
     * Sends a "hi" message to each new user (not seen in the last 20 minutes)
     * if the message text of the DialogMessage is not empty.
     *
     * @see net.jxta.myjxta.dialog.DialogListener#receive(net.jxta.myjxta.dialog.DialogMessage)
     */
    public void receive(DialogMessage msg) {
        DialogMessageWrapper dw = (DialogMessageWrapper) msg;
        String s = msg != null ? msg.getHtmlMessage() : null;
        String o = msg != null ? msg.getOriginator() : null;
        String me = dw.getDialog().getGroup().getPeerGroup().getPeerName();

        s = s != null ? s.trim() : null;
        o = o != null ? o.trim() : null;

        if (s != null &&
                s.length() > 0 &&
                o != null &&
                o.length() > 0 &&
                !o.equals(me)) {
            if (this.cache == null ||
                    !this.cache.containsKey(o)) {
                pounce(dw.getDialog(), o);
            }
        }
    }

    private void pounce(final Dialog dialog, String originator) {
        String o = originator.trim();

        if (this.cache == null) {
            this.cache = new HashMap<String, Long>();
        }

        this.cache.put(o, new Long(System.currentTimeMillis()));

        final String pounce = POUNCE + SPACE + o + SPACE + POUNCE_SUFFIX;

        new Thread(new Runnable() {

            public void run() {
                try {
                    Thread.sleep(SLEEP);
                }
                catch (InterruptedException ignored) {
                }
                if (Logging.SHOW_FINE && LOG.isLoggable(Level.FINE)) {
                    LOG.fine(pounce);
                }
                dialog.dispatch(pounce);
            }
        }, getClass().getName() + ":pounce").start();
    }
}