utility.java

一个用java写的即时聊天系统 C/S结构的

package mypkg;

import java.util.ArrayList;

public class Utility {
	
	//peer type
	public static final int CLIENT = 0;
	public static final int SERVER = 1;
	
	//peer status
	public static final int NULL = 0;	
	public static final int DISCONNECTED = 1;
	public static final int DISCONNECTING = 2;
	public static final int BEGIN_CONNECT = 3;
	public static final int CONNECTED = 4;	
	public static final int SENDING = 5;	
	public static final int RECVING = 6;
	
	// message type
	public static final int MSG = 0;
	public static final int QRY = 2;
	public static final int RPY = 3;

	// message content
	public static final String MSEG = "MSEG";
	public static final String FILE = "FILE";
	public static final String QERY = "QERY";
	public static final String REPY = "REPY";

	// RPY type
/*	public static final String CONE = "CONE";*/
	public static final String RECV = "RECEIVE";
	public static final String REFU = "REFUSE";

	public static Message parseMessage(String message) {
		System.out.println("Utility:" + message);
		String fields[] = message.split("\\|");
		String info[] = fields[1].split("\\*");
		ArrayList information = new ArrayList(3);
		information.clear();
		for(int i=0;i<info.length;i++){
			information.add(info[i]);
		}
		return new Message(fields[0],information);
	}

	public static String addHead(int type, String body) {
		StringBuffer message = new StringBuffer();
		switch (type) {
		case MSG:
			message.append(MSEG);
			message.append("|");
			message.append(body);
			return message.toString();
		case QRY:
			message.append(QERY);
			message.append("|");
			message.append(body);
			return message.toString();
		case RPY:
			message.append(REPY);
			message.append("|");
			message.append(body);
			return message.toString();
		default:
			return message.toString();
		}
	}
}