server/XMLReader/UDPReader.java

import java.io.*;
import java.net.*;
import java.util.*;

// This class contains the main method to be run by
// the filter children.  It harvests UDP traffic
//
//
public class UDPReader {

    public static void main(String[] args) throws IOException {

        // default UDP listening port.
        int port = 4589;
        final int packetSizeLimit = 8192;

        // Allow the user to choose their own port number.
        if (args.length == 1){
            try {
                port = new Integer(args[0]).intValue();
            }
            catch (Exception e){
                // If something went wrong, use the default again.
                port = 4589;
            }
        }

        DatagramSocket socket = new DatagramSocket(port);
        System.out.println("UDPReader ready and listening for UDP packets on port "+port);

        boolean running = true;
        while (running){
            try {
                byte[] buf = new byte[packetSizeLimit];
                // receive request
                DatagramPacket packet = new DatagramPacket(buf, buf.length);
                socket.receive(packet);
                UDPReaderThread thread = new UDPReaderThread(packet);
                thread.run();
            }
            catch (IOException e) {
                System.out.println("An exception occured in the UDPReader!");
                e.printStackTrace();
            }
        }
        socket.close();
    }
}
Revision:	1.2
Committed:	Fri Nov 17 12:16:39 2000 UTC (23 years, 5 months ago) by pjm2
Branch:	MAIN
Changes since 1.1:	+30 -11 lines
Log Message:	Changed a lot of parts of UDPReader, UDPReaderThread, XMLPacketMaker, XMLPacketParser and XMLSender so that they all work together. XMLSender is just a summy program to send UDP data to the UDPReader.
#	User	Rev	Content
1	pjm2	1.1	import java.io.*;
2			import java.net.*;
3			import java.util.*;
4
5			// This class contains the main method to be run by
6			// the filter children. It harvests UDP traffic
7			//
8			//
9			public class UDPReader {
10
11			public static void main(String[] args) throws IOException {
12
13	pjm2	1.2	// default UDP listening port.
14			int port = 4589;
15			final int packetSizeLimit = 8192;
16	pjm2	1.1
17	pjm2	1.2	// Allow the user to choose their own port number.
18			if (args.length == 1){
19			try {
20			port = new Integer(args[0]).intValue();
21			}
22			catch (Exception e){
23			// If something went wrong, use the default again.
24			port = 4589;
25			}
26			}
27
28			DatagramSocket socket = new DatagramSocket(port);
29			System.out.println("UDPReader ready and listening for UDP packets on port "+port);
30
31			boolean running = true;
32			while (running){
33			try {
34			byte[] buf = new byte[packetSizeLimit];
35	pjm2	1.1	// receive request
36	pjm2	1.2	DatagramPacket packet = new DatagramPacket(buf, buf.length);
37			socket.receive(packet);
38			UDPReaderThread thread = new UDPReaderThread(packet);
39			thread.run();
40			}
41			catch (IOException e) {
42			System.out.println("An exception occured in the UDPReader!");
43			e.printStackTrace();
44			}
45	pjm2	1.1	}
46			socket.close();
47			}
48			}