loopingsocketserver.java

java2 primer plus一书源程序

/*
 * LoopingSocketServer.java
 *
 * Created on October 2, 2002, 5:24 PM
 */

package ch20;

import java.net.*;
import java.io.*;

/**
 *
 * @author  Stephen Potts
 */
public class LoopingSocketServer
{
    ServerSocket servSocket;
    Socket fromClientSocket;
    int cTosPortNumber = 1777;
    String str;
    
    
    /** Creates a new instance of LoopingSocketServer */
    public LoopingSocketServer()
    {
        // Create ServerSocket to listen for connections
        try
        {
            servSocket = new ServerSocket(cTosPortNumber);
            
            // Wait for client to connnect, then get Socket
            System.out.println("ServerSocket created");
            System.out.println("Waiting for a connection on " +
            cTosPortNumber);
            
            fromClientSocket = servSocket.accept();
            System.out.println("fromClientSocket accepted");
            
            // Use ObjectOutputStream to send String to the client
            ObjectOutputStream oos =
            new ObjectOutputStream(fromClientSocket.getOutputStream());
            
            //Use ObjectInputStream to get String from client
            ObjectInputStream ois =
            new ObjectInputStream(fromClientSocket.getInputStream());
            
            
            while ((str = (String) ois.readObject()) != null)
            {
                System.out.println("The message from client is *** " +
                                                                  str);
                
                if (str.equals("bye"))
                {
                    oos.writeObject("bye bye");
                    break;
                }
                else
                {
                    str = "Server returns " + str;
                    oos.writeObject(str);
                }
                
            }
            oos.close();
            
            // Close Sockets
            fromClientSocket.close();
        } catch (Exception e)
        {
            System.out.println("Exception " + e);
        }
    }
    
    public static void main(String args[])
    {
        LoopingSocketServer lss = new LoopingSocketServer();
    }
    
    
}