1 29 38 39 package org.planetamessenger.io; 40 41 import java.io.*; 42 import java.net.*; 43 import org.planetamessenger.util.JKeyParser; 44 45 46 47 public class JIOStream { 48 49 50 public JIOStream() { 51 55 56 } 57 58 public boolean send( OutputStream outStream, java.lang.String strOutData ) { 59 67 68 if( outStream == null ) 69 return false; 70 71 try { 72 Writer outWriter = new OutputStreamWriter( outStream, "8859_1" ); 73 74 75 outWriter.write( strOutData ); 76 outWriter.flush(); 77 78 } catch( IOException e ) { 79 80 System.err.println( "JIOStream.send() - " + e ); 81 return false; 82 } 83 84 return true; 85 } 86 87 public java.lang.String recv( java.io.InputStream inStream ) { 88 94 95 if( inStream == null ) 96 return ""; 97 98 try { 99 int nChar; 100 java.lang.String strServerData = ""; 101 BufferedInputStream inBuffer = new BufferedInputStream( inStream ); 102 InputStreamReader inReader = new InputStreamReader( inBuffer, "8859_1" ); 103 104 105 while( ( nChar = inReader.read() ) != -1 ) { 106 strServerData += ( char ) nChar; 107 } 108 109 return strServerData; 110 } catch( IOException e ) { 111 System.err.println( "JIOStream.recv(1) - " + e ); 112 return ""; 113 } 114 } 115 116 public java.lang.String recv( java.io.InputStream inStream, int nLen ) { 117 125 126 if( inStream == null ) 127 return ""; 128 129 try { 130 int nRead; 131 char[] aBuffer = new char[nLen]; 132 BufferedInputStream inBuffer = new BufferedInputStream( inStream ); 133 InputStreamReader inReader = new InputStreamReader( inBuffer, "8859_1" ); 134 135 136 nRead = inReader.read( aBuffer, 0, nLen ); 137 138 if( nRead == nLen ) 139 return String.valueOf( aBuffer ); 140 else 141 return ""; 142 143 } catch( IOException e ) { 144 System.err.println( "JIOStream.recv(2) - " + e ); 145 return ""; 146 } 147 } 148 149 public boolean recv( java.io.InputStream inStream, java.util.HashMap <String , String > hash, boolean isSpaceSeparator ) { 150 160 161 if( ( inStream == null ) || ( hash == null ) ) 162 return false; 163 164 try { 165 BufferedInputStream inBuffer = new BufferedInputStream( inStream ); 166 InputStreamReader inReader = new InputStreamReader( inBuffer, "8859_1" ); 167 168 if( !JKeyParser.parseKeys( inReader, hash, isSpaceSeparator ) ) { 169 System.err.println( "JIOStream() - recv(3) - parser error" ); 170 return false; 171 } 172 173 } catch( IOException e ) { 174 System.err.println( "JIOStream.recv(3) - " + e ); 175 return false; 176 } 177 178 return true; 179 } 180 181 public boolean recv( java.io.InputStream inStream, java.util.HashMap <String , String > hash ) { 182 190 191 return recv( inStream, hash, true ); 192 } 193 } 194 195 | Popular Tags |