001
002 import java.io.IOException;
003
004 /**
005 * Application generates various transactions for accounting
006 * and passes them through a generated socket for processing.
007 * @author Heinz Kredel.
008 */
009
010 public class NetzBuchungGenerate {
011
012 private static int anzahl = 100;
013 private static ChannelFactory cf = null;
014 private static SocketChannel channel = null;
015 private final static String finis = "finis";
016
017 private static int kmax;
018 private static int umax = 300;
019
020 private static String hostname = "localhost";
021 private static int port = 30000;
022
023
024 public static void main(String[] args) throws InterruptedException {
025
026 final int kmax = 30;
027 final int bmax = 1000;
028
029 if ( args.length > 0 ) hostname = args[0];
030
031 cf = new ChannelFactory(port+1);
032
033 try { channel = cf.getChannel(hostname,port);
034 } catch (IOException e) { System.err.println(e); return; }
035
036
037 System.out.println("Starting ... ");
038 for ( int i = 0; i < anzahl; i++ ) {
039
040 int g = (int) (umax * Math.random());
041 int a = (int) (kmax * Math.random());
042 int b = (int) (kmax * Math.random());
043
044 System.out.println("Ueberweisung " + i + ":" +
045 " Konto a = " + a +
046 " Konto b = " + b +
047 " Betrag g = " + g );
048
049 Object u = (Object) new UeberweisungS(a,b,g);
050
051 try { channel.send( u ); }
052 catch (IOException e) {
053 System.err.println(e); return; }
054
055 }
056
057 try { channel.send( (Object) finis ); }
058 catch (IOException e) {
059 System.err.println(e); return; }
060 System.out.println("... finished " + anzahl + " records.");
061 System.exit(1);
062
063 }
064
065 }