bufferediotestservice.java~1~

移动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++ )
	       {
		  writer.write( i );
	       }

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