The Big Programming Thread - Page 474

public class TermoServer extends Thread {
	public static void main(String[] args) {
		TermoServer ts = new TermoServer();
		ts.run();
	}

	private final int PORT = 12345;
	private ObjectInputStream instream;
	private ServerSocket listener;
	private Socket clientSocket = null;
	private List<Double> temperatures = new ArrayList<Double>();
	private double averageTemperature;

	public void run() {

		try {
			getConnection();
			while (true) {
				temperatures.add(readTemperature());
				averageTemperature = calculateAverage(temperatures);
				System.out
						.println("Average temperature: " + averageTemperature);
			}
		} catch (Exception e) {
			System.out.println(e);
		}
	}

	private void getConnection() throws IOException {
		listener = new ServerSocket(PORT);
		clientSocket = listener.accept();
		instream = new ObjectInputStream(clientSocket.getInputStream());

	}
	private double readTemperature() throws IOException, ClassNotFoundException {
		//something
	}
	private double calculateAverage(List<Double> marks) {
		//something
	}

}

public class EventBus {
	private int[] ports = { 23456, 12345 };
	private String[] IPs = { "localhost", "localhost" };
	private String[][] topics = { { "TemperatureReading" },
			{ "TemperatureReading" } };
	private List<Node> nodes = new ArrayList<Node>();

	public static void main(String[] args) {
		EventBus eb = new EventBus();
		eb.start();
	}

	public void start() {
		try {
			addNodes();
			System.out.println("Nodes added");
			while (true) {
				Event e = getEvent();
				for (Node n : nodes) {
					if (n.isSubscribingTo(e.getTopic()))
						n.sendEvent(e);
				}
			}
		} catch (Exception e) {
			e.printStackTrace();
		}

	}

	private void addNodes() throws UnknownHostException, IOException {
		for (int i = 0; i < ports.length; i++) {
			nodes.add(new Node(topics[i], new Socket(IPs[i], ports[i])));
		}

	}

	private Event getEvent() throws IOException, ClassNotFoundException {
		// List<ObjectInputStream> instreams = getStreams();
		while (true) {
			for (Node n : nodes) {
				ObjectInputStream ois = new ObjectInputStream(n.getSocket()
						.getInputStream());
				System.out.println("test");
				if (ois.available() > 1) {
					System.out.println(" stream available");
					Object o = ois.readObject();
					if (o instanceof Event) {
						System.out.println("event found");
						return (Event) o;
					}
				}
			}
		}
	}