jremclientprotocol.java

一个基于J2ME技术的程序,使你可以远程控制装有服务端的PC.

/*
 * JRemCntl - Copyright (C) 2007 Filippo Di Vattimo <[e-mail]>
 * See COPYING
 */

package fildiv.jremcntl.client.core;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;

import fildiv.jremcntl.common.core.Config;
import fildiv.jremcntl.common.core.Context;
import fildiv.jremcntl.common.core.JRemCommandData;
import fildiv.jremcntl.common.core.JRemConfigData;
import fildiv.jremcntl.common.core.JRemContextData;
import fildiv.jremcntl.common.core.Logger;
import fildiv.jremcntl.common.proto.ByteReader;
import fildiv.jremcntl.common.proto.ByteWriter;
import fildiv.jremcntl.common.proto.JRemAbstractProtocol;
import fildiv.jremcntl.common.proto.JRemDataTransferException;
import fildiv.jremcntl.common.proto.JRemProtocolMessagesType;

public class JRemClientProtocol extends JRemAbstractProtocol {
	
	private Logger log;

	public JRemClientProtocol(InputStream in, OutputStream out, Logger log) {
		super(in, out);	
		this.log = log;
	}
	
	public void sendCommandID(int cmdID) throws JRemDataTransferException {

		ByteWriter bw = new ByteWriter();
		
		createMessage(bw, LENGHT_INT, 
				JRemProtocolMessagesType.MSG_TYPE_SEND_COMMAND_ID);
		bw.addInt(cmdID);
		
		sendMessage(bw.getBytes());
	}
	
	public Config retrieveConfig() throws JRemDataTransferException {
		
		Config conf = null;

		try {
			ByteReader br = readPacket(true);
								
			int command = br.getInt();
			if (command != JRemProtocolMessagesType.MSG_TYPE_SEND_CONFIG)
				throw new JRemDataTransferException(
						"Invalid command, expected MSG_TYPE_SEND_CONFIG");
		
			String name = br.getString();
			conf = new JRemConfigData(name, null);

			int contextCount = br.getInt();
			
			for (int index = 0; index < contextCount; ++index) {
				
				int id = br.getInt();
				String desc = br.getString();
				short defView = br.getShort();
				
				Context context = new JRemContextData( (JRemConfigData)
						conf, id, desc, defView, null);
				conf.appendContext(context);
				
				receiveContext(br, context);
			}
			
		} catch(IOException e) {
			throw new JRemDataTransferException(e);
		}
		
		return conf;
	}
	
	public ServerResponse retrieveServerResponse() throws IOException {
		
		ByteReader br = readPacket(false);
		if (br == null)
			return null;

		return new ServerResponse(br);
	}
	
	/*
	 * Implementation
	 */
	
	protected void receiveContext(ByteReader br, Context context) {

		int commandCount = br.getInt();

		for (int index = 0; index < commandCount; ++index) {
			receiveCommand(br, context);
		}
	}
	
	protected void receiveCommand(ByteReader br, Context context) {

		int id = br.getInt();
		String desc = br.getString();
		String key = br.getString();
		String question = br.getString();
		
		JRemCommandData command = 
			new JRemCommandData( (JRemContextData) 
					context, id, desc, null, key, question);
		
		context.appendCommand(command);
	}
}