bufferedsocketserver.java

java2 primer plus一书源程序

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

package ch20;

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

/**
 *
 * @author  Stephen Potts
 */
public class BufferedSocketServer
{
    ServerSocket servSocket;
    Socket fromClientSocket;
    int cTosPortNumber = 1777;
    String str;
    
    
    /** Creates a new instance of BufferedSocketServer */
    public BufferedSocketServer()
    {
        // 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");
            
            PrintWriter pw =
            new PrintWriter(fromClientSocket.getOutputStream(), true);
            
            BufferedReader br = new BufferedReader(
              new InputStreamReader(fromClientSocket.getInputStream()));
            
            
            while ((str = br.readLine()) != null)
            {
                System.out.println("The message from client is *** " +
                                                                  str);
                
                if (str.equals("bye"))
                {
                    pw.println("bye bye");
                    break;
                }
                else
                {
                    str = "Server returns " + str;
                    pw.println(str);
                }
                
            }
            pw.close();
            br.close();
            
            // Close Sockets
            fromClientSocket.close();
        } catch (Exception e)
        {
            System.out.println("Exception " + e);
        }
    }
    
    public static void main(String args[])
    {
        BufferedSocketServer bss = new BufferedSocketServer();
    }
    
    
}