基于Android的tcp聊天工具

package com.myapp; import android.content.ContextWrapper; import android.content.Intent; import android.util.Log; import java.io.IOException; import java.io.UnsupportedEncodingException; import java.net.Socket; import java.net.SocketException; import java.net.UnknownHostException; import java.text.SimpleDateFormat; import java.util.Date; import java.util.HashMap; import java.util.LinkedHashMap; import java.util.Timer; import java.util.TimerTask; /*数据解析帮助类*/ class DataParserHelper extends Thread{ static final String TAG = "DataParserHelper"; /*解析命令*/ int getCmd(byte []data) { if(data.length < 4) { return ConstantData.ERROR; } byte[] tempArray = new byte[4]; System.arraycopy(data, 0, tempArray, 0, 4); int cmd = ByteAndInt.byteArray2Int(tempArray); return cmd; } /*解析类型*/ int getType(byte []data) { if(data.length - 4 < 4) { return ConstantData.ERROR; } byte[] tempArray = new byte[4]; System.arraycopy(data, 4, tempArray, 0, 4); int type = ByteAndInt.byteArray2Int(tempArray); return type; } /*解析整形返回结果*/ int getIntResult(byte []data) { if(data.length - 8 < 4) { return ConstantData.ERROR; } byte[] tempArray = new byte[4]; System.arraycopy(data, 8, tempArray, 0, 4); int result = ByteAndInt.byteArray2Int(tempArray); return result; } /*解析字串内容*/ String getContent(byte []data) { if(data.length - 8 < 4) { return null; } byte[] tempArray = new byte[4]; System.arraycopy(data, 8, tempArray, 0, 4); int len = ByteAndInt.byteArray2Int(tempArray); if(data.length - 12 < len) { return null; } tempArray = new byte[len]; System.arraycopy(data, 12, tempArray, 0, len); try { return new String(tempArray, 0, len, "UTF-8"); } catch (UnsupportedEncodingException e) { e.printStackTrace(); return null; } } /*解析用户名*/ String getUserName(String userInfo) { int userNameIndex = userInfo.indexOf("USER:"); int userNameEndIndex = userInfo.indexOf("$", userNameIndex + 5); if(userNameIndex == -1 || userNameEndIndex == -1) { return null; }else{ String userName = userInfo.subSequence(userNameIndex + 5, userNameEndIndex).toString(); return userName; } } /*解析密码*/ String getPwd(String userInfo) { int pwdIndex = userInfo.indexOf("PWD:"); int pwdEndIndex = userInfo.indexOf("$", pwdIndex + 4); if(pwdIndex == -1 || pwdEndIndex ==-1) { return null; }else{ String pwd = userInfo.subSequence(pwdIndex + 4, pwdEndIndex).toString(); return pwd; } } /*解析地址*/ String getAddr(String userInfo) { int pwdIndex = userInfo.indexOf("ADDR:"); int pwdEndIndex = userInfo.indexOf("$", pwdIndex + 5); if(pwdIndex == -1 || pwdEndIndex ==-1) { return null; }else{ String pwd = userInfo.subSequence(pwdIndex + 5, pwdEndIndex).toString(); return pwd; } } /*解析用户名*/ String getMsgContent(String conent) { int userNameEndIndex = conent.indexOf("$", 0); if(userNameEndIndex == -1) { return null; }else{ String msgContent = conent.subSequence(userNameEndIndex + 1, conent.length()).toString(); return msgContent; } } /*发送整形结果值*/ synchronized int sendData(Socket socket, int cmd, int type, int resultCode) { int errCode = -1; if(socket == null) { return errCode; } try { byte []buff = new byte[12]; System.arraycopy(ByteAndInt.int2ByteArray(cmd), 0, buff, 0, 4); System.arraycopy(ByteAndInt.int2ByteArray(type), 0, buff, 4, 4); System.arraycopy(ByteAndInt.int2ByteArray(resultCode), 0, buff, 8, 4); Log.v(TAG, "sendMsg resultCode: length="+buff.length); socket.getOutputStream().write(buff); errCode = 0; }catch (IOException e) { e.printStackTrace(); }finally { } return errCode; } /*发送字串形结果值*/ synchronized int sendData(Socket socket, int cmd, int type, String content) { int errCode = -1; if(socket == null) { return errCode; } try { byte[] tempContent = content.getBytes("UTF-8"); byte []buff = new byte[12 + tempContent.length]; System.arraycopy(ByteAndInt.int2ByteArray(cmd), 0, buff, 0, 4); System.arraycopy(ByteAndInt.int2ByteArray(type), 0, buff, 4, 4); System.arraycopy(ByteAndInt.int2ByteArray(tempContent.length), 0, buff, 8, 4); System.arraycopy(tempContent, 0, buff, 12, tempContent.length); Log.v(TAG, "sendMsg content destAddr:"+"empty"+" port:"+"empty"+" length="+buff.length); socket.getOutputStream().write(buff); errCode = 0; }catch (IOException e) { e.printStackTrace(); }finally { } return errCode; } int checkValidCmdOrType(byte []data, int cmdortype) { return ByteAndInt.compareBytesData(data, ByteAndInt.int2ByteArray(cmdortype), 4); } } /*数据解析*/ public class DataParser { static final String TAG = "DataParser"; DataParserHelper dataParserHelper; ContextWrapper mContextWrapper; HashMap<String, String> mOnlineList = new HashMap<String, String>(); HashMap<String, String> mPendingMessageList = new LinkedHashMap<String, String>(); String mMyOwnUserName = null; Socket mSocket = null; DataReceiverThread mRecvThread = null; boolean rspRecevied = false; int mCurrentState = ConstantData.STATE_IDLE; DataParser (ContextWrapper contextWrapper) { mContextWrapper = contextWrapper;//用于发出广播消息 dataParserHelper = new DataParserHelper(); } String getMyOwnUserName() { return mMyOwnUserName; } HashMap<String, String> getOnlineList() { return mOnlineList; } HashMap<String, String> getPendingMessageList() { return mPendingMessageList; } void addOnlineUserInfo(String userName, String addr) { mOnlineList.put(userName, addr); } void removeOnlineUserInfo(String userName) { mOnlineList.remove(userName); } void addPendingMessage(String userName, String msg) { String str = msg; if(mPendingMessageList.containsKey(userName)) { str = mPendingMessageList.get(userName) + str; } mPendingMessageList.put(userName, str); } void removePendingMessage(String userName) { mPendingMessageList.remove(userName); } void setCurrentState(int state) { mCurrentState = state; } int getCurrentState() { return mCurrentState; } voi