testclient2.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 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 the sending of not serializable objects
public class TestClient2 implements DataEventReceivingObserver, CommunicationEventObserver {

    ClientConnectionManager ccm; //
    
    TestClient2() {
        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("127.0.0.1");
        // send initial data event --> ping to server to start communication
        ccm.sendDataEvent(new DataEvent(new Integer(1), "Ping"));
                
    }
    
    // starts up the client
    public static void main(String[] args) {
        TestClient2 tc = new TestClient2();       
    }
    
    // receives all data events
    public void receiveEvent(DataEvent de) {        
        // received data from the server
        System.out.println("Server says " + de.getData().toString());        

        // send another ping
        ccm.sendDataEvent(new DataEvent(new Integer(1), "Ping"));
    }
     
    // 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;                
        }
    }
}