receiverthread.java

用swt作的一个类似飞鸽一样的局域网通信工具

package thread.receiver;

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;
import java.util.StringTokenizer;

import CreateFrame.CreateErrorFrame;

public class ReceiverThread extends Thread {

	public Socket socket = null;
	
	public DataInputStream inByte = null;

	public DataOutputStream outByte = null;

	public List cmdList = null;
	
	public ReceiverThread(Socket socket) {

		this.setDaemon(true);
		
		try {
			
			inByte = new DataInputStream(socket.getInputStream());

			outByte = new DataOutputStream(socket.getOutputStream());

		} catch (IOException e) {
			
			CreateErrorFrame thread = new CreateErrorFrame();
			thread.setMessage("Lose host connection");
			thread.start();
			
			e.printStackTrace();
		}
	}
	
	/*
	 *从字符串中以"|"作为分割符获取cmdList列表。
	 */
	public static List splitToken(String fs) {
		
		StringTokenizer pt = new StringTokenizer(fs, "|");
		
		List l = new ArrayList();
		
		while (pt.hasMoreTokens()) {
		
			l.add(pt.nextToken());
		}
		
		return l;
	}
	
	/*
	 * 从cmdList中根据Index的值判断是否与param相等。相等返回True，不相等返回False。
	 */
	public boolean equParam(int index, String param){
		
		if (((String) cmdList.get(index)).equals(param)) return true;
		
		else return false; 
	}
	
	/*
	 * 返回cmdList中Index项的值。
	 */
	public String getParam(int index){
		
		return ((String) cmdList.get(index));
	}
	
	/*
	 * 向网络流中写入UTF字符串。
	 */
	public void writeUTF(String Stream) throws IOException{
		
		outByte.writeUTF(Stream);
		
		System.out.println(Stream+"                    - "+this.getClass().getName());
	}
	
	/*
	 * 从网络流中读入UTF字符串。
	 */
	public String readUTF() throws IOException{
		
		String recString = inByte.readUTF();
		
		System.out.println(recString+"                    - "+this.getClass().getName());
		
		return (recString);
	}
	
	protected void free(){
		socket = null;
		inByte = null;
		outByte = null;
		cmdList = null;
	}
}