userinput.java

一个基于sensor的中间件

package Application;

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


public class UserInput extends Thread
{
	PrintWriter userOutput;
	Reader serverInput;
	int serial=0;

	public UserInput(Reader fromServer, final PrintWriter toUser)
	{
//		System.out.println(fromServer+"[]"+toUser);
		serverInput = fromServer;
		userOutput = toUser;
	}

	public UserInput(Reader fromServer, final PrintWriter toUser, int k)
	{
		serial = k;
		serverInput = fromServer;
		userOutput = toUser;
	}

	
	public void run(){
		Ircontrol rcontrol = new Ircontrol();
		Simulation simulation = new Simulation();
		char[] buffer = new char[1024];
		int chars_read;
		Vector rulecheckbuffer = new Vector();   //  rulecheck锟斤拷锟斤拷 锟斤拷锟斤拷锟斤拷; 锟斤拷锟阶撅拷 锟斤拷d锟斤拷.

		try{
			if(serial == 0){
				while((chars_read = serverInput.read(buffer)) != -1){
					String temps = new String(buffer,0,chars_read-2);
					StringTokenizer st1 = new StringTokenizer(temps, "锟斤拷");
					int i = 0;
					while(st1.hasMoreTokens()){
						rulecheckbuffer.addElement(st1.nextToken());
						i++;
					}
					/*
					for(int k=0; k<i; k++){
						System.out.println(rulecheckbuffer.elementAt(k));
					}
					*/
					if(rulecheckbuffer.elementAt(0).equals("order")){
						if(rulecheckbuffer.elementAt(1).equals("ircontrol")){ 
							System.out.println(rulecheckbuffer.elementAt(2));
//							rcontrol.Ircontrol((String)rulecheckbuffer.elementAt(2));

						}else if(rulecheckbuffer.elementAt(1).equals("simulation")){
							System.out.println("锟矫鼓凤拷锟教硷拷 "+(String)rulecheckbuffer.elementAt(2)+"锟斤拷 锟斤拷锟桔邓聪达拷.");
							simulation.Simulation((String)rulecheckbuffer.elementAt(2));
						}
					}else if(rulecheckbuffer.elementAt(0).equals("query")){
						System.out.println(rulecheckbuffer.elementAt(1));
					}else{
						userOutput.write(buffer, 0, chars_read);
						userOutput.flush();
					}
					rulecheckbuffer.removeAllElements();
				}
			}else{
			}
		}
		catch (IOException e){
			userOutput.println(e);
		}
		//锟斤拷锟斤拷锟斤拷锟