byte[] buffer = new byte[1024];
int bytes;
InputStream in = null;
try {
in = mClientSocket.getInputStream();
while (true) {
if ((bytes = in.read(buffer)) > 0) {
byte[] buf_data = new byte[bytes];
for (int i = 0; i < bytes; i++) {
buf_data[i] = buffer[i];
int j = buffer[i];
j = buffer[i] & 0xff;
String str = Integer.toHexString(j);
if ("ff".equals(str)) {
Message msg = Message.obtain(null, MSG_UPDATE_LOG);
msg.obj = "台灯打开";
mHandler.sendMessage(msg);
} else if ("0".equals(str)) {//注意不能用00,因为0x00实际的值是0
Message msg = Message.obtain(null, MSG_UPDATE_LOG);
msg.obj = "台灯关闭";
mHandler.sendMessage(msg);
} else {
Message msg = Message.obtain(null, MSG_UPDATE_LOG);
msg.obj = "err...";
mHandler.sendMessage(msg);
}
}
}
}
} catch (IOException e) {
e.printStackTrace();
Message msg = Message.obtain(null, MSG_UPDATE_LOG);
msg.obj = "连接数据失败";
mHandler.sendMessage(msg);
} finally {
if (in != null)
try {
in.close();
} catch (IOException e) {
e.printStackTrace();
}
}
|