bufferediotestservice.java

移动Agent编程工具Naplet

package serviceImpl;

import java.io.*;
import java.util.*;
import naplet.serviceChannel.*;

public class BufferedIOTestService
    extends naplet.resource.PrivilegedService
{

  /**
   * Like PipedReader, ServiceReader pipe provides two ways to read
   * characters: read() for a single character and read( buf, offset,
   * length ) for up to <code>length</code> characters of data.
   *
   * Similarly, ServiceWriter pipe privides two ways to write characters:
   * write(char c) for a single character and
   * write(char buf[], int offset, int length) for a number of characters.
   *
   */

  public void run()
  {
    for ( ; ; )
    {
      System.out.println( "Buffered I/O Test Service>" );

      BufferedServiceInputStream in
          = new BufferedServiceInputStream( inStream );
      BufferedServiceOutputStream out
          = new BufferedServiceOutputStream( outStream );
      BufferedServiceReader reader
          = new BufferedServiceReader( inReader );
      BufferedServiceWriter writer
          = new BufferedServiceWriter( outWriter );

      try
      {
        int j = 0;
        while ( reader.read() != -1 )
        {
          j++;
        }

        System.out.println( "\nBufferedIOTestService reads " + j
                            + " characters from Naplet." );

        final int len = 10000000;

        int i = 0;
        for ( ; i < len; i++ )
        {
          outWriter.write( i );
        }

        System.out.println( "\nBufferedIOTestService writes "
                            + i + " characters to Naplet." );
        writer.close();
        out.close();
      }
      catch ( IOException ioe )
      {
        System.out.println( ioe.getMessage() );
      }
    }
  }
}