testclient4.java

自己写的一个聊天的小程序 请多多指教

/*
 * Copyright (c) 2003 - 2007, Silvio Meier and Tobias Reinhard
 *
 * All rights reserved.
 * 
 * Redistribution and use in source and binary forms, 
 * with or without modification, are permitted provided 
 * that the following conditions are met:
 *
 *   o Redistributions of source code must retain the above 
 *     copyright notice, this list of conditions and the 
 *     following disclaimer.
 *   o Redistributions in binary form must reproduce the above 
 *     copyright notice, this list of conditions and the 
 *     following disclaimer in the documentation and/or other 
 *     materials provided with the distribution.
 *   o The names of its contributors may not be used to endorse 
 *     or promote products derived from this software without 
 *     specific prior written permission.
 *
 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
 * "AS IS" AND ANY EXPRESS 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 COPYRIGHT OWNER OR
 * 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.
 */
package net.sf.cscc.test;

import java.util.Date;
import java.util.Vector;

import net.sf.cscc.ClientConnectionManager;
import net.sf.cscc.CommunicationEvent;
import net.sf.cscc.CommunicationEventObserver;
import net.sf.cscc.DataEvent;
import net.sf.cscc.DataEventReceivingObserver;


// The server implements directly the data observer interface and the communication
// observer interface
// tests huge data sent over the component
public class TestClient4 implements DataEventReceivingObserver, CommunicationEventObserver {

    ClientConnectionManager ccm; //
    
    TestClient4() {
        ccm = new ClientConnectionManager(2510);
        // observer 
        ccm.addObserver((CommunicationEventObserver)this);
        ccm.addObserver((DataEventReceivingObserver)this);
        // connect to local client, ie. client and server are running on the
        // same machine
        //ccm.open("ifidyn153.ifi.unizh.ch");
        ccm.open("127.0.0.1");
        // send initial data event --> ping to server to start communication
        ccm.sendDataEvent(new DataEvent(new Long((new Date()).getTime()), "Ping"));
                
    }
    
    // starts up the client
    public static void main(String[] args) {
        TestClient4 tc = new TestClient4();      
        tc.send();
    }
    
    public void send() {
        while (true) {
            // new vector container
            Vector v = new Vector();
            
            v.add(new String("msg broker string vector"));
            v.add(new Integer(972));
            
            // Nachricht
            Message4 msg = new Message4(100, (Object) new String("1"),
            (Object) new String("2"),
            (Object) new String("msg broker string (ificomm)"), v);
            
            long time = (new Date()).getTime();
            System.out.println("Sent at Time " + time);    
            
            // data event creation
            DataEvent deRet = new DataEvent(new Long(time),msg);
            
            //System.out.println("send server before singel");
            // send messge to client.....
            //scm.sendDataEvent(deRet, de.getClientId());
            
            //System.out.println("send server after singel");
            
            // send bradcast message to client.
            //System.out.println("send server before multi");
            ccm.sendDataEvent(deRet);
            //System.out.println("send server after muli");
            System.gc();
        }
    }
        
    // receives all data events
    public void receiveEvent(DataEvent de) {        
        System.out.println("Client says " + de.getData().toString() + " / Time " + de.getEventKey()+ " / Current Time: " + new Date().getTime());
        // new vector container
        /*Vector v = new Vector();
        
        v.add(new String("msg broker string vector"));
	v.add(new Integer(972));
 	
        // Nachricht
        Message3 msg = new Message3(100, (Object) new String("1"),
 			(Object) new String("2"),
 			(Object) new String("msg broker string (ificomm)"), v);
*/
        long time = (new Date()).getTime();
        System.out.println("Sent at Time " + time);

        // data event creation
 	//DataEvent deRet = new DataEvent(new Long(time),msg); 	


        
        // send messge to client.....
        //System.out.println("send client after");
        //ccm.sendDataEvent(deRet);                                
        //System.out.println("send client after");
        System.gc();
    }
     
    // receives all communication events
    public void receiveEvent(CommunicationEvent ce) {
        
        switch (ce.getEventId()) {
            case (CommunicationEvent.CONNECTION_ESTABLISHED):
                System.out.println("connection opened!");
                break;
            case (CommunicationEvent.CONNECTION_BROKEN):
                System.out.println("connection broken");
                break;
            case (CommunicationEvent.CONNECTION_CLOSED):
                System.out.println("connection closed");
                break;                
            case (CommunicationEvent.CONNECTION_START_LISTENING):
                System.out.println("start listening");
                break;                
            case (CommunicationEvent.CONNECTION_STOP_LISTENING):
                System.out.println("stop listening");
                break;                
        }
    }
}