    View Javadoc
    1   package examples;
    2
    3   /* ====================================================================
    4    * The Apache Software License, Version 1.1
    5    *
    6    * Copyright (c) 2001 The Apache Software Foundation.  All rights
    7    * reserved.
    8    *
    9    * Redistribution and use in source and binary forms, with or without
    10   * modification, are permitted provided that the following conditions
    11   * are met:
    12   *
    13   * 1. Redistributions of source code must retain the above copyright
    14   *    notice, this list of conditions and the following disclaimer.
    15   *
    16   * 2. Redistributions in binary form must reproduce the above copyright
    17   *    notice, this list of conditions and the following disclaimer in
    18   *    the documentation and/or other materials provided with the
    19   *    distribution.
    20   *
    21   * 3. The end-user documentation included with the redistribution,
    22   *    if any, must include the following acknowledgment:
    23   *       "This product includes software developed by the
    24   *        Apache Software Foundation (http://www.apache.org/)."
    25   *    Alternately, this acknowledgment may appear in the software itself,
    26   *    if and wherever such third-party acknowledgments normally appear.
    27   *
    28   * 4. The names "Apache" and "Apache Software Foundation" and
    29   *    "Apache Commons" must not be used to endorse or promote products
    30   *    derived from this software without prior written permission. For
    31   *    written permission, please contact apache@apache.org.
    32   *
    33   * 5. Products derived from this software may not be called "Apache",
    34   *    nor may "Apache" appear in their name, without
    35   *    prior written permission of the Apache Software Foundation.
    36   *
    37   * THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED
    38   * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
    39   * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
    40   * DISCLAIMED.  IN NO EVENT SHALL THE APACHE SOFTWARE FOUNDATION OR
    41   * ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
    42   * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
    43   * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
    44   * USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
    45   * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
    46   * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT
    47   * OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
    48   * SUCH DAMAGE.
    49   * ====================================================================
    50   *
    51   * This software consists of voluntary contributions made by many
    52   * individuals on behalf of the Apache Software Foundation.  For more
    53   * information on the Apache Software Foundation, please see
    54   * <http://www.apache.org/>;.
    55   */
    56
    57  import java.io.IOException;
    58  import java.io.InputStream;
    59  import java.io.OutputStream;
    60  import org.apache.commons.net.io.Util;
    61
    62  /****
    63   * This is a utility class providing a reader/writer capability required
    64   * by the weatherTelnet, rexec, rshell, and rlogin example programs.
    65   * The only point of the class is to hold the static method readWrite
    66   * which spawns a reader thread and a writer thread.  The reader thread
    67   * reads from a local input source (presumably stdin) and writes the
    68   * data to a remote output destination.  The writer thread reads from
    69   * a remote input source and writes to a local output destination.
    70   * The threads terminate when the remote input source closes.
    71   * <p>
    72   ***/
    73
    74  public final class IOUtil
    75  {
    76
    77      public static final void readWrite(final InputStream remoteInput,
    78                                         final OutputStream remoteOutput,
    79                                         final InputStream localInput,
    80                                         final OutputStream localOutput)
    81      {
    82          Thread reader, writer;
    83
    84          reader = new Thread()
    85                   {
    86                       public void run()
    87                       {
    88                           int ch;
    89
    90                           try
    91                           {
    92                               while (!interrupted() && (ch = localInput.read()) != -1)
    93                               {
    94                                   remoteOutput.write(ch);
    95                                   remoteOutput.flush();
    96                               }
    97                           }
    98                           catch (IOException e)
    99                           {
    100                              //e.printStackTrace();
    101                          }
    102                      }
    103                  }
    104                  ;
    105
    106
    107         writer = new Thread()
    108                  {
    109                      public void run()
    110                      {
    111                          try
    112                          {
    113                              Util.copyStream(remoteInput, localOutput);
    114                          }
    115                          catch (IOException e)
    116                          {
    117                              e.printStackTrace();
    118                              System.exit(1);
    119                          }
    120                      }
    121                  };
    122
    123
    124         writer.setPriority(Thread.currentThread().getPriority() + 1);
    125
    126         writer.start();
    127         reader.setDaemon(true);
    128         reader.start();
    129
    130         try
    131         {
    132             writer.join();
    133             reader.interrupt();
    134         }
    135         catch (InterruptedException e)
    136         {
    137         }
    138     }
    139
    140 }
    141

This page was automatically generated by Maven