Android 接收服务器指令执行相应操作

儿童手表项目的Demo，需要实现功能：

家长点击网页的一个按钮，服务器通知手表应用端，手表应用完成GPS定位，然后将位置传递给服务器。

要接收服务器的消息，需要维系一个长连接，定时（每隔60s）发送心跳给服务器。

为了不影响手表的功耗，让手表休眠下去，不能使用一直acquire WakeLock的方式去执行心跳发送动作，使用闹钟机制。

Intent intentRepeat = new Intent(context, CoreService.class);
PendingIntent sender = PendingIntent.getService(context, 0,
intentRepeat, 0);
long triggerTime = SystemClock.elapsedRealtime() + 60 * 1000; // 第一次时间
long intervalTime = 60 * 1000; // ms FIXME：心跳 90s之内
AlarmManager am = (AlarmManager) context
.getSystemService(Context.ALARM_SERVICE);
/**
* AlarmManager.ELAPSED_REALTIME表示闹钟在手机睡眠状态下不可用，该状态下闹钟使用相对时间（
* 相对于系统启动开始），状态值为3；
*
* AlarmManager.ELAPSED_REALTIME_WAKEUP表示闹钟在睡眠状态下会唤醒系统并执行提示功能，
* 该状态下闹钟也使用相对时间，状态值为2；
*
* AlarmManager.RTC表示闹钟在睡眠状态下不可用，该状态下闹钟使用绝对时间，即当前系统时间，状态值为1；
*
* AlarmManager.RTC_WAKEUP表示闹钟在睡眠状态下会唤醒系统并执行提示功能，该状态下闹钟使用绝对时间，状态值为0；
*/
am.setRepeating(AlarmManager.ELAPSED_REALTIME_WAKEUP, triggerTime,
intervalTime, sender);

首次登录服务器的时候启动接收服务器信息线程ReadThread：

InetAddress address = InetAddress
.getByName(Constant.Server.NAME);
socket = new Socket(address, Constant.Server.PORT);
mSocket = new WeakReference<Socket>(socket);
mReadThread = new ReadThread(socket);
mReadThread.start();


接收并处理服务器信息线程ReadThread：
private WeakReference<Socket> mSocket;
private ReadThread mReadThread;

class ReadThread extends Thread {

private WeakReference<Socket> mWeakSocket;
private boolean isStart = true;

public ReadThread(Socket socket) {
mWeakSocket = new WeakReference<Socket>(socket);
}

public void release() {
isStart = false;
// releaseLastSocket(mWeakSocket);
}

@Override
public void run() {
super.run();
Socket socket = mWeakSocket.get();
if (null != socket) {
try {
InputStream inputStream = socket.getInputStream();
while (!socket.isClosed() && !socket.isInputShutdown()
&& isStart) {
byte[] byteOne = new byte[1];
inputStream.read(byteOne);
while (byteOne[0] != (byte) 0xA5) { // 帧头Head：A5
MyLog.v("[ReadThread] byteOne2:"
+ ConvertUtil.ByteToHexString(byteOne, 0,
byteOne.length));
inputStream.read(byteOne);
}
byte[] byteHead = new byte[1];
byteHead[0] = byteOne[0];
inputStream.read(byteOne); // byteOne[0]:消息长度Length
byte[] bytesDataFrame = new byte[byteOne[0] - 1];
inputStream.read(bytesDataFrame);
bytesDataFrame = ConvertUtil.concatAll(byteHead,
byteOne, bytesDataFrame);
MyLog.v("[ReadThread] DataFrameContent:"
+ ConvertUtil.ByteToHexString(bytesDataFrame,
0, bytesDataFrame.length));

byte byteDataFrameCommand = bytesDataFrame[5]; // 命令
if (byteDataFrameCommand == (byte) 0x81) { // 远程控制
// eg:A50A05000081 54983157 01
byte byteType = bytesDataFrame[10];
if (byteType == (byte) 0x01) { // 拍照
MyLog.v("[Server] RemoteControl Take Picture");
} else if (byteType == (byte) 0x02) { // 录音
MyLog.v("[Server] RemoteControl Record Sound");
}
} else if (byteDataFrameCommand == (byte) 0x82) { // 指令消息
// eg:A50A05000082 54983157 00 XX..XX
byte byteType = bytesDataFrame[10];
if (byteType == (byte) 0x00) { // 普通字符串

} else if (byteType == (byte) 0x01) { // url字符串
}
} else if (byteDataFrameCommand == (byte) 0x83) { // 查询：服务器请求查询设备上的参数
// eg:A50A05000083 54983157 04
byte byteType = bytesDataFrame[10];
if (byteType == (byte) 0x01) { // 固件版本
MyLog.v("[Server] Query Firmware Version");
} else if (byteType == (byte) 0x02) { // 服务器地址和端口
MyLog.v("[Server] Query Host & Port");
} else if (byteType == (byte) 0x03) { // 手机号信息
MyLog.v("[Server] Query PhoneNumber");
} else if (byteType == (byte) 0x04) { // GPS定位信息
MyLog.v("[Server] Query GPS Location");
MyApp.isNeedGps = true;
acquireWakeLock(160 * 1000);
gpsCount = 0;
new Thread(new GpsLocateThread()).start();
} else if (byteType == (byte) 0x05) { // 终端访问密码
MyLog.v("[Server] Query Password");
}
} else if (byteDataFrameCommand == (byte) 0x84) { // 修改：服务器请求修改设备上的参数

} else if (byteDataFrameCommand == (byte) 0x8F) { // 服务器应答
byte byteMessageCommand = bytesDataFrame[6];
if (byteMessageCommand == (byte) 0x01) { // 设备登录时，服务器应答
//eg:A50F8E00008F 01 01 24CA3257 24CA3257
byte byteResult = bytesDataFrame[7];
if (byteResult == (byte) 0x01) { // 登录成功
MyLog.v("[Server] Login Success");
ClickUtil.lastConnectTime = System
.currentTimeMillis();
} else if (byteResult == (byte) 0x02) { // 重定向
MyLog.v("[Server] Login Redirect");
} else { // 登录失败
MyLog.v("[Server] Login Fail,result:"
+ byteResult);
}
} else if (byteMessageCommand == (byte) 0x02) { // 设备登出时，服务器应答
// eg:A5079A00008F 02 01
byte byteResult = bytesDataFrame[7];
if (byteResult == (byte) 0x01) { // 登出成功
MyLog.v("[Server] Logout Success");
} else { // 登出失败
MyLog.v("[Server] Logout Fail,result:"
+ byteResult);
}
} else if (byteMessageCommand == (byte) 0x03) { // 设备发送位置数据，服务器应答
// eg:A5079A00008F 03 01
byte byteResult = bytesDataFrame[7];
if (byteResult == (byte) 0x01) { // 发送位置成功
MyLog.v("[Server] Send Location Success");
} else { // 发送位置失败
MyLog.v("[Server] Send Location Fail,result:"
+ byteResult);
}
} else if (byteMessageCommand == (byte) 0x04) { // 设备发送计步/心跳数据，服务器应答
if (bytesDataFrame.length == 8) { // 计步
// eg:A5079B00008F 04 01
byte byteResult = bytesDataFrame[7];
if (byteResult == (byte) 0x01) { // 发送计步成功
MyLog.v("[Server] Send Pedometer Success");
} else { // 发送计步失败
MyLog.v("[Server] Send Pedometer Fail,result:"
+ byteResult);
}
} else if (bytesDataFrame.length == 11) { // 心跳
// eg:A50A9900008F 04 00428931
byte[] bytesUtcTime = new byte[4];
for (int i = 0; i < 4; i++) {
bytesUtcTime[i] = bytesDataFrame[7 + i];
}
int utcTimeInt = ConvertUtil.bytesToInt2(
bytesUtcTime, 0);
MyLog.v("[Server] HeartBeat at:"
+ utcTimeInt);
ClickUtil.lastConnectTime = System
.currentTimeMillis();
}
} else if (byteMessageCommand == (byte) 0x05) { // 设备发送报警数据，服务器应答
byte byteResult = bytesDataFrame[7];
if (byteResult == (byte) 0x01) { // 发送报警成功
MyLog.v("[Server] Send Warning Success");
} else { // 发送报警失败
MyLog.v("[Server] Send Warning Fail,result:"
+ byteResult);
}
} else if (byteMessageCommand == (byte) 0x06) { // 设备发送通话/短信数据，服务器应答
byte byteResult = bytesDataFrame[7];
if (byteResult == (byte) 0x01) { // 发送通话/短信成功
MyLog.v("[Server] Send Phone&SMS Success");
} else { // 发送通话/短信失败
MyLog.v("[Server] Send Phone&SMS Fail,result:"
+ byteResult);
}
}
}
}
} catch (IOException e) {
e.printStackTrace();
MyLog.e("[ReadThread] IOException:" + e.toString());
// 重新登录
Message msgConnectServer = new Message();
msgConnectServer.what = 1;
taskHandler.sendMessage(msgConnectServer);
}
}
}
}