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 (24 years 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.
#	Content
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	// default UDP listening port.
14	int port = 4589;
15	final int packetSizeLimit = 8192;
16
17	// 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	// receive request
36	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	}
46	socket.close();
47	}
48	}